MongoDB常用操作

使用API时，先引入maven依赖

<dependency>
    <groupId>org.mongodb</groupId>
    <artifactId>mongo-java-driver</artifactId>
    <version>3.11.1</version>
</dependency>

创建连接

//mongoClient连接
protected static MongoClient mongoClient;
 public synchronized static MongodbClient getInstance(String mongodbUrl) {
        if (null == mongoClient) {
            mongoClient = MongoClients.create(mongodbUrl);
            if(null != mongoClient){
                log.info("mongoClient init success!");
            }
            else{
                log.info("mongoClient init failed!");
            }
        }
        return mongodbClient;
    }　

在生产环境中常用properties文件存放String mongodbUrl：

    private MongoClient mongoClient = new MongoClient(PropertityUtils.getValue("mongoaddr"),Integer.valueOf(PropertityUtils.getValue("mongoport")));
    

直接通过mongodb的host和port来创建client：

MongoClient mongoClient = MongoClients.create("mongodb://host1:27017");
//client连接到一个 Replica Set：
MongoClient mongoClient = MongoClients.create("mongodb://host1:27017,host2:27017,host3:27017");
3 MongoClient mongoClient = MongoClients.create("mongodb://host1:27017,host2:27017,host3:27017/?replicaSet=myReplicaSet");

关闭连接：

public void close() {
    if(null!=mongoClient){
        mongoClient.close();
        mongoClient=null;
    }
}

//创建Collection

 public void createCollection(String dataBaseName,String collectionName){
        getDatabase(dataBaseName).createCollection(collectionName);
    }
//查询dataBaseName
public MongoDatabase getDatabase(String dataBaseName){ return mongoClient.getDatabase(dataBaseName); }
//查询Collection

public List<String> listCollectionNames(String dataBaseName){
 List<String> stringList = new ArrayList<String>(); 
mongoClient.getDatabase(dataBaseName).listCollectionNames().forEach((Consumer<? super String>) t->{ stringList.add(t); });
 return stringList; } 

public MongoCollection<Document> getCollectionByName(String dataBaseName, String collectionName)
　　{ return getDatabase(dataBaseName).getCollection(collectionName); }
 

 

关于MongoDB 的查询操作

 2 

//通过id（objectid）精确查询
public FindIterable<Document>  findMongoDbDocById(String dataBaseName, String collectionName, String id){
    BasicDBObject searchDoc = new BasicDBObject().append("_id", id);
   return getCollectionByName(dataBaseName,collectionName).find(searchDoc);
}
//通过id（objectid）模糊查询
public FindIterable<Document>  findMongoDbDocByIdRegex(String dataBaseName, String collectionName, String id){
    BasicDBObject searchDoc = new BasicDBObject().append("_id", new BasicDBObject("$regex",id));
    return getCollectionByName(dataBaseName,collectionName).find(searchDoc);
}
//通过开始id和结束id 查询（根据objectId范围查询）
public FindIterable<Document>  findMongoDbDocById(String dataBaseName, String collectionName, String startId,String endId){
    BasicDBObject searchDoc = new BasicDBObject().append("_id", new BasicDBObject("$gte", startId).append("$lte", endId));
    return getCollectionByName(dataBaseName,collectionName).find(searchDoc);
}
public FindIterable<Document> findMongoDbDoc(String dataBaseName, String collectionName,BasicDBObject basicDBObject){
    return getCollectionByName(dataBaseName,collectionName).find(basicDBObject);
}
//限制查询返回的条数
public FindIterable<Document> findMongoDbDoc(String dataBaseName, String collectionName,BasicDBObject basicDBObject,Integer limitNum){
    return findMongoDbDoc(dataBaseName,collectionName,basicDBObject).limit(limitNum) ;
}
public FindIterable<Document>  findMongoDbDocById(String dataBaseName, String collectionName, String startId,String endId,Integer limitNum){
    return findMongoDbDocById(dataBaseName,collectionName,startId,endId).limit(limitNum);
}
 
/**
 * 降序查询（排序）
 * @param dataBaseName
 * @param collectionName
 * @param startId
 * @param endId
 * @param sortField  排序字段
 * @return
 */
public FindIterable<Document>  findMongoDbDocByIdDescSort(String dataBaseName, String collectionName, String startId,String endId,String sortField){
  return findMongoDbDocById(dataBaseName,collectionName,startId,endId).sort(new Document().append(sortField, -1));
}
public FindIterable<Document>  findMongoDbDocByIdDescSort(String dataBaseName, String collectionName, String startId,String endId,String sortField,Integer limitNum){
    return findMongoDbDocByIdDescSort(dataBaseName,collectionName,startId,endId,sortField).limit(limitNum);
}
 
/**
 * 降序查询（排序）
 * @param dataBaseName
 * @param collectionName
 * @param startId
 * @param endId
 * @param sortField  排序字段
 * @return
 */
public FindIterable<Document>  findMongoDbDocByIdAscSort(String dataBaseName, String collectionName, String startId,String endId,String sortField){
    return findMongoDbDocById(dataBaseName,collectionName,startId,endId).sort(new Document().append(sortField, 1));
}
public FindIterable<Document>  findMongoDbDocByIdAscSort(String dataBaseName, String collectionName, String startId,String endId,String sortField,Integer limitNum){
    return findMongoDbDocByIdAscSort(dataBaseName,collectionName,startId,endId,sortField).limit(limitNum);
}

数据的插入

public void insertDoc(String dataBaseName, String collectionName, Document document){
     getCollectionByName(dataBaseName,collectionName).insertOne(document);
 }
 //插入多条记录
 public void insertDoc(String dataBaseName, String collectionName,List<? extends Document> listData){
     getCollectionByName(dataBaseName,collectionName).insertMany(listData);
 }

数据的更新

//更新单条
public void updateDoc(String dataBaseName, String collectionName, Bson var1, Bson var2){
    getCollectionByName(dataBaseName,collectionName).updateOne(var1,var2);
}
public void updateDoc(String dataBaseName, String collectionName, Bson var1, List<? extends Bson> list){
    getCollectionByName(dataBaseName,collectionName).updateOne(var1,list);
}
//批量更新
public void updateDocs(String dataBaseName, String collectionName, Bson var1, Bson var2){
    getCollectionByName(dataBaseName,collectionName).updateMany(var1,var2);
}
public void updateDocs(String dataBaseName, String collectionName, Bson var1, List<? extends Bson> list){
    getCollectionByName(dataBaseName,collectionName).updateMany(var1,list);
}

数据的删除

//单条删除 
  public DeleteResult deleteDoc(String dataBaseName, String collectionName, Bson var1){
        return getCollectionByName(dataBaseName,collectionName).deleteOne(var1);
    }
//批量删除 
    public DeleteResult deleteDocs(String dataBaseName, String collectionName,Bson var1){
       return getCollectionByName(dataBaseName,collectionName).deleteMany(var1);
    }

数据的跟新

//单条删除 
  public DeleteResult deleteDoc(String dataBaseName, String collectionName, Bson var1){
        return getCollectionByName(dataBaseName,collectionName).deleteOne(var1);
    }
//批量删除 
    public DeleteResult deleteDocs(String dataBaseName, String collectionName,Bson var1){
       return getCollectionByName(dataBaseName,collectionName).deleteMany(var1);
    }

数据的替换

//存在就替换，不存在的话就插入
public UpdateResult replaceDoc(String dataBaseName, String collectionName, Bson var1, Document var2){
     return getCollectionByName(dataBaseName,collectionName).replaceOne(var1,var2);
 }

关于MongoDB 的bulkWrite操作　（批量写入）

public BulkWriteResult bulkWrite(String dataBaseName, String collectionName, List<? extends WriteModel<? extends Document>> listData){
   return getCollectionByName(dataBaseName,collectionName).bulkWrite(listData);
}