您好,登录后才能下订单哦!
这篇文章给大家介绍使用java怎么连接mongoDB并进行增删改查操作,内容非常详细,感兴趣的小伙伴们可以参考借鉴,希望对大家能有所帮助。
在java中使用mongoDB之前,首先需要拥有java连接mongoDB的第三方驱动包(jar包)
<dependencies> <dependency> <groupId>org.mongodb</groupId> <artifactId>mongo-java-driver</artifactId> <version>3.0.4</version> </dependency> </dependencies>
mongoDB jar包
将mongoDB JDBC驱动加入到项目之后,就可以对mongoDB进行操作了。
//连接到 mongodb 服务 MongoClient mongoClient = new MongoClient("localhost", 27017);
这里的 "localhost" 表示连接的服务器地址,27017 为端口号。可以省略 端口号 不写,系统将默认端口号为 27017。如:
//连接到 mongodb 服务,默认端口号为27017 MongoClient mongoClient = new MongoClient("localhost");
也可以将 服务器地址 和 端口号 都省略,系统默认服务器地址为 "localhost",端口号为 27017。如:
//连接到 mongodb 服务,默认连接到localhost服务器,端口号为27017 MongoClient mongoClient = new MongoClient();
List<ServerAddress> adds = new ArrayList<>(); //ServerAddress()两个参数分别为 服务器地址 和 端口 ServerAddress serverAddress = new ServerAddress("localhost", 27017); adds.add(serverAddress); List<MongoCredential> credentials = new ArrayList<>(); //MongoCredential.createScramSha1Credential()三个参数分别为 用户名 数据库名称 密码 MongoCredential mongoCredential = MongoCredential.createScramSha1Credential("username", "databaseName", "password".toCharArray()); credentials.add(mongoCredential); //通过连接认证获取MongoDB连接 MongoClient mongoClient = new MongoClient(adds, credentials);
ServerAddress()
两个参数 "localhost" , 27017 分别为 服务器地址 和 端口。
MongoCredential.createScramSha1Credential()
三个参数 "username", "databaseName", "password".toCharArray() 分别为 用户名 数据库名称 密码。
//连接到数据库 MongoDatabase mongoDatabase = mongoClient.getDatabase("test");
这里的 "test" 表示数据库名,若指定的数据库不存在,mongoDB将会在你第一次插入文档时创建数据库。
由于所有连接数据库操作都需要执行这两步操作,我们可以将这两步操作封装成工具类。
import com.mongodb.MongoClient; import com.mongodb.client.MongoDatabase; //mongodb 连接数据库工具类 public class MongoDBUtil { //不通过认证获取连接数据库对象 public static MongoDatabase getConnect(){ //连接到 mongodb 服务 MongoClient mongoClient = new MongoClient("localhost", 27017); //连接到数据库 MongoDatabase mongoDatabase = mongoClient.getDatabase("test"); //返回连接数据库对象 return mongoDatabase; } //需要密码认证方式连接 public static MongoDatabase getConnect2(){ List<ServerAddress> adds = new ArrayList<>(); //ServerAddress()两个参数分别为 服务器地址 和 端口 ServerAddress serverAddress = new ServerAddress("localhost", 27017); adds.add(serverAddress); List<MongoCredential> credentials = new ArrayList<>(); //MongoCredential.createScramSha1Credential()三个参数分别为 用户名 数据库名称 密码 MongoCredential mongoCredential = MongoCredential.createScramSha1Credential("username", "databaseName", "password".toCharArray()); credentials.add(mongoCredential); //通过连接认证获取MongoDB连接 MongoClient mongoClient = new MongoClient(adds, credentials); //连接到数据库 MongoDatabase mongoDatabase = mongoClient.getDatabase("test"); //返回连接数据库对象 return mongoDatabase; } }
mongoDB中的数据都是通过文档(对应于关系型数据库表中的一行)保存的,而文档又保存在集合(对应于关系型数据库的表)中。
要对数据进行CRUD操作首先要获取到操作的集合。
//获取集合 MongoCollection<Document> collection = MongoDBUtil.getConnect().getCollection("user");
这里的 "user" 表示集合的名字,如果指定的集合不存在,mongoDB将会在你第一次插入文档时创建集合。
要插入文档首先需要创建文档对象
//创建文档 Document document = new Document("name","张三") .append("sex", "男") .append("age", 18);
插入一个文档,使用 MongoCollection 对象的 insertOne()
方法,该方法接收一个 Document 对象作为要插入的数据
//插入一个文档 @Test public void insertOneTest(){ //获取数据库连接对象 MongoDatabase mongoDatabase = MongoDBUtil.getConnect(); //获取集合 MongoCollection<Document> collection = mongoDatabase.getCollection("user"); //要插入的数据 Document document = new Document("name","张三") .append("sex", "男") .append("age", 18); //插入一个文档 collection.insertOne(document); }
插入多个文档,使用 MongoCollection 对象的 insertMany()
方法,该方法接收一个 数据类型为 Document 的 List 对象作为要插入的数据
//插入多个文档 @Test public void insertManyTest(){ //获取数据库连接对象 MongoDatabase mongoDatabase = MongoDBUtil.getConnect(); //获取集合 MongoCollection<Document> collection = mongoDatabase.getCollection("user"); //要插入的数据 List<Document> list = new ArrayList<>(); for(int i = 1; i <= 3; i++) { Document document = new Document("name", "张三") .append("sex", "男") .append("age", 18); list.add(document); } //插入多个文档 collection.insertMany(list); }
删除与筛选器匹配的单个文档,使用 MongoCollection 对象的 deleteOne()
方法,该方法接收一个数据类型为 Bson 的的对象作为过滤器筛选出需要删除的文档。然后删除第一个。为了便于创建过滤器对象,JDBC驱动程序提供了 Filters 类。
//删除与筛选器匹配的单个文档 @Test public void deleteOneTest(){ //获取数据库连接对象 MongoDatabase mongoDatabase = MongoDBUtil.getConnect(); //获取集合 MongoCollection<Document> collection = mongoDatabase.getCollection("user"); //申明删除条件 Bson filter = Filters.eq("age",18); //删除与筛选器匹配的单个文档 collection.deleteOne(filter); }
删除与筛选器匹配的所有文档,使用 MongoCollection 对象的 deleteMany()
方法,该方法接收一个数据类型为 Bson 的的对象作为过滤器筛选出需要删除的文档。然后删除所有筛选出的文档。
//删除与筛选器匹配的所有文档 @Test public void deleteManyTest(){ //获取数据库连接对象 MongoDatabase mongoDatabase = MongoDBUtil.getConnect(); //获取集合 MongoCollection<Document> collection = mongoDatabase.getCollection("user"); //申明删除条件 Bson filter = Filters.eq("age",18); //删除与筛选器匹配的所有文档 collection.deleteMany(filter); }
修改单个文档,使用 MongoCollection 对象的 updateOne()
方法,该方法接收两个参数,第一个数据类型为 Bson 的过滤器筛选出需要修改的文档,第二个参数数据类型为 Bson 指定如何修改筛选出的文档。然后修改过滤器筛选出的第一个文档。
//修改单个文档 @Test public void updateOneTest(){ //获取数据库连接对象 MongoDatabase mongoDatabase = MongoDBUtil.getConnect(); //获取集合 MongoCollection<Document> collection = mongoDatabase.getCollection("user"); //修改过滤器 Bson filter = Filters.eq("name", "张三"); //指定修改的更新文档 Document document = new Document("$set", new Document("age", 100)); //修改单个文档 collection.updateOne(filter, document); }
修改多个文档,使用 MongoCollection 对象的 updateMany()
方法,该方法接收两个参数,第一个数据类型为 Bson 的过滤器筛选出需要修改的文档,第二个参数数据类型为 Bson 指定如何修改筛选出的文档。然后修改过滤器筛选出的所有文档。
//修改多个文档 @Test public void updateManyTest(){ //获取数据库连接对象 MongoDatabase mongoDatabase = MongoDBUtil.getConnect(); //获取集合 MongoCollection<Document> collection = mongoDatabase.getCollection("user"); //修改过滤器 Bson filter = Filters.eq("name", "张三"); //指定修改的更新文档 Document document = new Document("$set", new Document("age", 100)); //修改多个文档 collection.updateMany(filter, document); }
使用 MongoCollection 对象的 find()
方法,该方法有多个重载方法,可以使用不带参数的 find()
方法查询集合中的所有文档,也可以通过传递一个 Bson 类型的 过滤器查询符合条件的文档。这几个重载方法均返回一个 FindIterable 类型的对象,可通过该对象遍历出查询到的所有文档。
查找集合中的所有文档
//查找集合中的所有文档 @Test public void findTest(){ //获取数据库连接对象 MongoDatabase mongoDatabase = MongoDBUtil.getConnect(); //获取集合 MongoCollection<Document> collection = mongoDatabase.getCollection("user"); //查找集合中的所有文档 FindIterable findIterable = collection.find(); MongoCursor cursor = findIterable.iterator(); while (cursor.hasNext()) { System.out.println(cursor.next()); } }
指定查询过滤器查询
//指定查询过滤器查询 @Test public void FilterfindTest(){ //获取数据库连接对象 MongoDatabase mongoDatabase = MongoDBUtil.getConnect(); //获取集合 MongoCollection<Document> collection = mongoDatabase.getCollection("user"); //指定查询过滤器 Bson filter = Filters.eq("name", "张三"); //指定查询过滤器查询 FindIterable findIterable = collection.find(filter); MongoCursor cursor = findIterable.iterator(); while (cursor.hasNext()) { System.out.println(cursor.next()); } }
可通过 first()
方法取出查询到的第一个文档
//取出查询到的第一个文档 @Test public void findTest(){ //获取数据库连接对象 MongoDatabase mongoDatabase = MongoDBUtil.getConnect(); //获取集合 MongoCollection<Document> collection = mongoDatabase.getCollection("user"); //查找集合中的所有文档 FindIterable findIterable = collection.find(); //取出查询到的第一个文档 Document document = (Document) findIterable.first(); //打印输出 System.out.println(document); }
Java的特点有哪些 1.Java语言作为静态面向对象编程语言的代表,实现了面向对象理论,允许程序员以优雅的思维方式进行复杂的编程。 2.Java具有简单性、面向对象、分布式、安全性、平台独立与可移植性、动态性等特点。 3.使用Java可以编写桌面应用程序、Web应用程序、分布式系统和嵌入式系统应用程序等。
关于使用java怎么连接mongoDB并进行增删改查操作就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。