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

jialiguo

           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("authenticatefailed!");

           }

       }

       

       //获取存储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，感觉可能还有许多错误的地方，以后深入了解了过后再校正。