Java操作MongoDB

第一步：创建Maven项目，添加以下依赖

  junit
  junit
  4.12


  org.mongodb
  mongo-java-driver
  3.12.2

第二步：连接工具类

public class MongoDBUtil {
    public static MongoDatabase getConnection(String databaseName) {
        //连接到 mongodb 服务
        MongoClient mongoClient = new MongoClient("hcmaster", 27017);
        //连接到数据库
        MongoDatabase mongoDatabase = mongoClient.getDatabase(databaseName);
        //返回连接数据库对象
        return mongoDatabase;
    }
}

第三步：测试代码 测试框架

public class MongoDBTest {
    private String databaseName = "test";
    private String table = "emp";
}

插入文档

示例：插入一个文档

@Test
public void insert() throws UnknownHostException {
    MongoDatabase database = MongoDBUtil.getConnection(databaseName);
    Document document = new Document("empno", 1001)
            .append("ename", "zhangsan")
            .append("job", "salesman");

    MongoCollection collection = database.getCollection(table);
    collection.insertOne(document);
}

示例：插入多个文档

@Test
public void insertMany() throws UnknownHostException {
    MongoDatabase database = MongoDBUtil.getConnection(databaseName);
    List documentList = new ArrayList();
    for (int i = 0; i