Mongodb JAVA API

阅读量：6957 次

发布时间：2019-06-27

本文共 5164 字，大约阅读时间需要 17 分钟。

连接mongodb

1.连接一个mongodb

MongoClient mongoClient = new MongoClient( "localhost" , 27017 );

2.连接mongodb集群 MongoClient mongoClient =

new MongoClient( Arrays.asList(new ServerAddress("localhost", 27017), new ServerAddress("localhost", 27018), new ServerAddress("localhost", 27019)));

MongoClientURI connectionString =

new MongoClientURI("mongodb://localhost:27017,localhost:27018,localhost:27019");

获取数据库

MongoDatabase database = mongoClient.getDatabase("mydb");

获取数据库列表

client.listDatabaseNames().forEach(new Block<String>() {

@Override

public void apply(final String s) {

System.out.println(s);

}

});

获取集合

MongoCollection<Document> collection = database.getCollection("test");

插入文档

要使用Java驱动程序创建文档，请使用该类。您也可以使用此类创建嵌入式文档。

Document doc = new Document("name", "MongoDB") .append("type", "database") .append("count", 1) .append("info", new Document("x", 203).append("y", 102));

collection.insertOne(doc);

添加多个文档

要添加多个文档，可以使用该insertMany()方法。

List<Document> list = new ArrayList<>();

for(int i=0;i<50;i++){

list.add(new Document().append("i:", i));

}

collection.insertMany(list);

对集合计数

col.count();

查询集合

使用该方法查询集合。

在集合中找到第一个文档

要获取集合中的第一个文档，请调用操作方法。collection.find().first()返回第一个文档或null而不是一个游标。这对于只应该匹配单个文档的查询或者仅对第一个文档感兴趣才有用。

以下示例打印集合中找到的第一个文档。

Document first = collection.find().first();

System.out.println(first.toJson());

查找集合中的所有文档

要检索集合中的所有文档，我们将使用该 find()方法。该find()方法返回一个FindIterable为链接或控制查找操作提供流畅界面的实例。使用该 iterator()方法来获取与查询和迭代匹配的文档集合的迭代器。以下代码检索集合中的所有文档并将其打印出来（101个文档）：

FindIterable<Document> find = collection.find();

MongoCursor<Document> iterator = find.iterator();

while(iterator.hasNext()){

System.out.println(iterator.next().toJson());

}

获取具有查询过滤器的单个文档

我们可以创建一个过滤器来传递给find（）方法来获取我们集合中的一个文档子集。例如，如果我们想要找到“i”字段的值为71的文档，我们将执行以下操作：

importstatic com.mongodb.client.model.Filters.*; myDoc = collection.find(eq("i", 71)).first(); System.out.println(myDoc.toJson());

注意

使用，并为建立查询的简单明了的方式帮手。

获取一组查询文档

我们可以使用查询从我们的集合中获取一组文档。例如，查询i>50的所有文档，"i" > 50，我们可以写：

Block<Document> printBlock = new Block<Document>() { @Overridepublic void apply(final Document document) {

System.out.println(document.toJson()); } }; collection.find(gt("i", 50)).forEach(printBlock);

请注意，我们使用对每个文档应用块的forEach方法，FindIterable并将所有文档打印在其中i > 50。

我们也可以得到一个范围，说50 < i <= 100：

collection.find(and(gt("i", 50), lte("i", 100))).forEach(printBlock);

排序文件

我们也可以使用帮助器对文档进行排序。我们通过调用一个sort()方法来添加一个查找查询FindIterable。下面我们使用帮助器对我们的文档进行排序：

MongoCursor<Document> iterator = collection.find(exists("i:")).sort(new BasicDBObject("i:",-1)).iterator(); //当"i:"存在的时候，才会进行排序，不存在时，不输出

while(iterator.hasNext()){

System.out.println(iterator.next().toJson());

}

投影领域

有时我们不需要文档中包含的所有数据，帮助程序可以帮助构建查找操作的投影参数。下面我们将对该集合进行排序，排除该_id字段并输出第一个匹配的文档：

Document first = collection.find().projection(new BasicDBObject("_id",0)).first(); //表示_id字段不需要如果是1表示只要_id字段

System.out.println(first.toJson());

更新文档

MongoDB支持许多。

要最多更新一个文档（如果不匹配过滤器，可以为0），请使用该方法来指定过滤器和更新文档。在这里，我们更新符合过滤器的第一个文档iequals 10，并将其值设置i为110：

collection.updateOne(eq("i", 10), new Document("$set", new Document("i", 110)));

	将字段的值增加指定的数量。
	将字段的值乘以指定的数量。
	重命名一个字段。
	如果更新导致文档的插入，则设置字段的值。对修改现有文档的更新操作没有影响。
	设置文档中字段的值。
	从文档中删除指定的字段。
	只有指定的值小于现有的字段值，才更新该字段。
	如果指定的值大于现有字段值，则仅更新该字段。
	将字段的值设置为当前日期，作为日期或时间戳。

要更新与过滤器匹配的所有文档，请使用该方法。在这里，我们增加的值i由100其中i小于100。

UpdateResult updateResult = collection.updateMany(lt("i", 100), new Document("$inc", new Document("i", 100))); System.out.println(updateResult.getModifiedCount());//更新方法返回一个提供有关操作的信息，包括更新修改的文档数。

删除文件

最多只能删除一个文档（如果没有匹配过滤器，可以为0）使用以下方法：

collection.deleteOne(eq("i", 110));或collection.deleteOne(new Document("i",110));

要删除与过滤器匹配的所有文档，请使用该方法。
这里我们删除i大于或等于的所有文档100：

DeleteResult deleteResult = collection.deleteMany(gte("i", 100)); System.out.println(deleteResult.getDeletedCount());//delete方法返回一个，提供有关操作的信息，包括删除的文档数量。