一、MongoDB简介
MongoDB是一个基于分布式文件存储的开源数据库。它的数据存储方式是以BSON(一种二进制的JSON格式)为中心的,可以存储对象和数组数据类型。MongoDB是一个面向文档的数据库,而非关系型数据库,在使用上有着比较大的不同。
二、Java连接MongoDB
Java可以通过maven依赖的方式引用MongoDB官方提供的Java Driver。
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongodb-driver</artifactId>
<version>3.12.7</version>
</dependency>
然后在Java代码中使用MongoClient连接MongoDB服务器。以下为示例代码:
import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.client.MongoDatabase;
public class MongoConnectivity {
public static void main( String args[] ) {
try {
// 连接到MongoDB
MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017");
MongoClient client = new MongoClient(uri);
// 获取数据库
MongoDatabase database = client.getDatabase("mydb");
// 打印数据库名称
System.out.println("MongoDB database name: " + database.getName());
// 关闭连接
client.close();
} catch (Exception e) {
System.err.println(e.getClass().getName() + ": " + e.getMessage());
}
}
}
上述代码连接了本地MongoDB服务器,并指定了要使用的数据库。然后获取该数据库对象,并打印出数据库的名称。最后,关闭MongoClient连接。
三、MongoDB操作
1. 插入数据
使用MongoDB的Java Driver通过以下代码来向指定的集合中插入一条数据:
import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
public class InsertData {
public static void main( String args[] ) {
try {
// 连接到MongoDB
MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017");
MongoClient client = new MongoClient(uri);
// 获取数据库
MongoDatabase database = client.getDatabase("mydb");
// 获取集合
MongoCollection
collection = database.getCollection("mycollection");
// 插入数据
Document doc = new Document("name", "MongoDB")
.append("type", "database")
.append("count", 1);
collection.insertOne(doc);
// 关闭连接
client.close();
} catch (Exception e) {
System.err.println(e.getClass().getName() + ": " + e.getMessage());
}
}
}
2. 查询数据
查询MongoDB中的数据可以使用以下代码段:
import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Filters;
public class QueryData {
public static void main( String args[] ) {
try {
// 连接到MongoDB
MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017");
MongoClient client = new MongoClient(uri);
// 获取数据库
MongoDatabase database = client.getDatabase("mydb");
// 获取集合
MongoCollection
collection = database.getCollection("mycollection");
// 查询数据
FindIterable
cursor = collection.find(Filters.eq("name", "MongoDB"));
for (Document doc : cursor) {
System.out.println(doc.toJson());
}
// 关闭连接
client.close();
} catch (Exception e) {
System.err.println(e.getClass().getName() + ": " + e.getMessage());
}
}
}
3. 更新数据
使用以下代码段可以更新符合条件的数据:
import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Filters;
import com.mongodb.client.model.Updates;
public class UpdateData {
public static void main( String args[] ) {
try {
// 连接到MongoDB
MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017");
MongoClient client = new MongoClient(uri);
// 获取数据库
MongoDatabase database = client.getDatabase("mydb");
// 获取集合
MongoCollection
collection = database.getCollection("mycollection");
// 更新数据
collection.updateMany(Filters.eq("name", "MongoDB"), Updates.set("count", 2));
// 关闭连接
client.close();
} catch (Exception e) {
System.err.println(e.getClass().getName() + ": " + e.getMessage());
}
}
}
4. 删除数据
使用以下代码段可以删除符合条件的数据:
import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.model.Filters;
public class DeleteData {
public static void main( String args[] ) {
try {
// 连接到MongoDB
MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017");
MongoClient client = new MongoClient(uri);
// 获取数据库
MongoDatabase database = client.getDatabase("mydb");
// 获取集合
MongoCollection
collection = database.getCollection("mycollection");
// 删除数据
collection.deleteMany(Filters.eq("name", "MongoDB"));
// 关闭连接
client.close();
} catch (Exception e) {
System.err.println(e.getClass().getName() + ": " + e.getMessage());
}
}
}
四、小结
本文介绍了Java连接MongoDB的基本方法,以及如何进行增删改查操作。MongoDB是一个非常灵活的数据库,可以根据应用情况选择不同的存储方式和查询方式,能够更好地满足应用的需求。