MongoDB操作：insert()

2024-09-05 16:14:27

@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;
}

最新文章

热门文章