MongoDB操作:insert()
            时间:2015-03-13 00:19:31  
            收藏:0  
            阅读:1945
        
        
        - @Override
 - public boolean inSert(String dbName, String collectionName, String[] keys,
 - Object[] values) {
 - DB db = null;
 - DBCollection dbCollection = null;
 - WriteResult result = null;
 - String resultString = null;
 - if(keys!=null && values!=null){
 - //keys与values都不是空的时候才可以执行插入操作
 - if(keys.length != values.length){
 - //keys与values是一一对应的关系,数目必须相等
 - return false;
 - }else{
 - db = mongoClient.getDB(dbName);
 - //获取数据库实例
 - dbCollection = db.getCollection(collectionName);
 - //获取数据库中指定的collection集合
 - BasicDBObject insertObj = new BasicDBObject();
 - //MongoDB中的基本对象,它是对DBObject的实现,继承自BasicBSONObject
 - /*
 - 
*public class BasicDBObject extends BasicBSONObject implements DBObject*/
 - for(int i=0; i<keys.length; i++){
 - //构建添加条件
 - insertObj.put(keys[i], values[i]);
 - //输入k-v对
 - }
 - try {
 - result = dbCollection.insert(insertObj);
 - //将对象插入到文档Collection中
 - resultString = result.getError();
 - //将写操作结果WriteResult传递给resultString,以方便显示
 - } catch (Exception e) {
 - // TODO: handle exception
 - e.printStackTrace();
 - }finally{
 - if(null != db){
 - //如果数据库不为空,则表示已经插入数据(数据库原来初始化为null)
 - db.requestDone();
 - //请求结束后关闭db(即停止继续执行“request”操作)
 - }
 - }
 - return (resultString != null) ? false : true;
 - }
 - }
 - return false;
 - }
 
            评论(0)