代码
封装类:
package mongodbtest;
import com.mongodb.MongoClient;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
import java.util.ArrayList;
import java.util.List;
/**
* 使用java连接mongodb并且进行更新文档的测试代码
* 要求：
* 对连接步骤进行方法的封装：
* 1、连接数据库方法
* 2、创建集合方法
* 3、获取到集合方法
* 4、插入文档方法
* 5、查看文档方法
* 6、更新文档方法
* @since JDK 1.8
* @date 2021/6/30
* @author Lucifer
*/
public class MongoDB {
/*定义连接需要用到的属性*/
private static String MONGO_HOST = "localhost";
private static Integer MONGO_PORT = 27017;
private static final String MONGO_DB_NAME = "practice";
private static final String GATHER_NAME = "practiceDemo";
/**
* 属性设置方法
* @return
*/
public static String getMongoHost() {
return MONGO_HOST;
}
public static Integer getMongoPort() {
return MONGO_PORT;
}
public static void setMongoHost(String mongoHost) {
MONGO_HOST = mongoHost;
}
public static void setMongoPort(Integer mongoPort) {
MONGO_PORT = mongoPort;
}
/**
* 连接数据库方法
* @Test
*/
public static MongoDatabase connect(String mongo_host, Integer mongo_port){
//连接到mongodb服务--->使用Mongo客户端类创建连接对象
MongoClient mongoClient = new MongoClient(mongo_host,mongo_port);
//连接到数据库--->使用mongo数据库类调用mongodb服务对象通过方法获取
MongoDatabase mongoDatabase = mongoClient.getDatabase(MONGO_DB_NAME);
System.out.println("Connect to database successfully!!!");
//返回mongodatabase对象
return mongoDatabase;
}
/**
* 创建集合方法
* @Create
* @return
*/
public static String create(){
// //连接到mongodb服务--->创建类对象，操作类方法获取数据库信息
// MongoDB mdb = new MongoDB();
//
// //连接数据库