2019独角兽企业重金招聘Python工程师标准>>> 
- @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;
- }
