5.0、Java操作MongoDB数据库

2018-01-26 19:26:45

总字数 579

预计阅读时间 2 分钟

(一) 连接MongoDB

一个MongoClient的实例代表一个客户端连接
从中可以获取到需要使用的数据库MongoDatabase对象

MongoClient client = new MongoClient("localhost",27017);
MongoDatabase db = client.getDatabase("demo");

// 使用完毕后, 需要关闭客户端连接
client.close();

MongoClient是线程安全的，可以在多程程环境中共享同一个MongoClient。通常来说，一个应用程序中，只需要生成一个全局的MongoClient实例

(二) 认证

上述方式是在数据库没有添加用户认证的情况下实现的连接
认证信息用MongoCredential对象表示

ServerAddress address = new ServerAddress("localhost", 27017);
// 参数分别是 用户名 所在数据库 密码(char数组形式)
MongoCredential credential = MongoCredential.createCredential("sookie", "demo", "123456".toCharArray());

// 由于构造函数接受一个List对象, 所以需要进行一次包装
MongoClient client = new MongoClient(address, Arrays.asList(credential));

client.close();

(三) 获取一个集合

1
2
3

MongoDatabase db = client.getDatabase("demo");
//获取指定名称的集合
MongoCollection<Document> collection = db.getCollection("test");

在集合对象上就可以直接进行增删改查的操作

(四) 数据对象

或者也可以称为文档 , 本身是一个JSON
使用Document对象来表示
任何需要JSON的地方都通用这个对象( 包括数据的查询结果 )

(五) 插入与删除

Document中的静态方法parse可以将JSON字符串转化为Document对象 , 用于插入方法的参数

1
2
3

Person person = new Person("Sookie",18);
Document doc = Document.parse(JSON.toJSONString(person));
collection.insertOne(doc);

insert相关的方法也可以接受Map对象等作为参数 , 具体的参考源码

删除使用deleteOne和deleteMany方法
前者表示删除符合条件的一条数据 , 后者表示删除符合条件的多条数据

1 2	Bson filter = new BasicDBObject("age",18); collection.deleteMany(filter);

Bson是一个接口 , BasicDBObject是这个接口的一个实现类 , 可以作为查询条件

(六) 查询

// 执行查询操作, 方法名称与终端所用的指令类似
FindIterable<Document> result = collection.find();
for (Document doc : result) {
  System.out.println(doc);
}

find函数也有Bson作为参数的重载形式 , 查询条件的创建方式同上面的删除操作
包含$操作符的查询条件同样可以使用BasicDBObject创建