mongo数据库动态添加procedure(存储过程)

作者:static菜园  发布日期:2011-10-12 11:14:03

         mongo DB 同样支持存储过程,和别的一些数据库的不同的是 mongo 的 procedure 是以 javascript 形式存储在内部一个叫 system.js 的 collection 里的。可以使用 mongo 的 JDBC 驱动中的 API 对 procedure 进行动态的添加。

下面为代码demo:

              Mongo mongo = new Mongo( "10.232.31.46" ,27015);

       DB db = mongo.getDB( "dbName" );

       if ( "username" != null ) {

           boolean auth = db.authenticate( "username" ,

                  "password" == null ? new char [0] : "password" .toCharArray());

           if (!auth) {

              throw new MongoException( "authenticate failed!" );

           }

       }

       

       // 获取存储 procedure 的 collection

       DBCollection coll = db.getCollection( "system.js" );     

       BasicDBObject dbObject = new BasicDBObject();

      

       dbObject.put( "_id" , "addNumbers" );

       //procedure 的具体内容不能使用 string 类型存入,需要使用 driver 中定义的 code 类型

       dbObject.put( "value" , new Code( "function(x, y){ return x + y; }" ));

      

       // 将存储过程动态的添加到该集合中

       coll.save(dbObject);

 

 

       添加进去即可在进行查询等的时候调用 procedure 。如输入 {"$where":"addNumbers(a,1)==4"}

      也可使用 db 的 eval() 方法直接测试调用 procedure 。如 db.eval("function(x, y){ return x + y; }", 3,4);

      另:

        我觉得也 可以使用 DB 中的 command() 方法,可以直接执行命令行里的命令,感觉也可以通过这种方法添加 procedure 。

            上面是最近做项目需要用到自定义动态添加mongoDB的procedure,感觉可能还有许多错误的地方,以后深入了解了过后再校正。

Tag标签: mongo   数据库   procedure  
  • 专题推荐

About IT165 - 广告服务 - 隐私声明 - 版权申明 - 免责条款 - 网站地图 - 网友投稿 - 联系方式
本站内容来自于互联网,仅供用于网络技术学习,学习中请遵循相关法律法规