使用java怎么连接mongoDB并进行增删改查操作

  介绍

这篇文章给大家介绍使用java怎么连接mongoDB并进行增删改查操作,内容非常详细,感兴趣的小伙伴们可以参考借鉴,希望对大家能有所帮助。

1,安装mongoDB JDBC驱动程序

在java中使用mongoDB之前,首先需要拥有java连接mongoDB的第三方驱动包(jar包)

1) maven项目可通过在砰的一声。xml中添加依赖

& lt; dependencies>   & lt;才能dependency>   ,,& lt; groupId> org.mongodb   ,,& lt; artifactId> mongo-java-driver   ,,& lt; version> 3.0.4   & lt;才能/dependency>   & lt;/dependencies>

2)非maven项目jar包下载地址:

,,mongoDB jar包

2,连接数据库

将mongoDB JDBC驱动加入到项目之后,就可以对mongoDB进行操作了。

1)不通过认证连接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 ();

2)通过认证连接mongoDB服务

List, adds =, new  ArrayList<在();//ServerAddress()两个参数分别为,服务器地址,和,端口   ServerAddress  ServerAddress =, new  ServerAddress (“localhost",, 27017);   adds.add (serverAddress);   List

<代码> ServerAddress() 两个参数“localhost"27017分别为服务器地址和端口。

<代码> MongoCredential.createScramSha1Credential() 三个参数“username"“databaseName",“password" .toCharArray()分别为用户名数据库名称密码。

3)连接到数据库

//连接到数据库   MongoDatabase  MongoDatabase =, mongoClient.getDatabase (“test");

这里的“test"表示数据库名,若指定的数据库不存在,mongoDB将会在你第一次插入文档时创建数据库。

4)封装成工具类

由于所有连接数据库操作都需要执行这两步操作,我们可以将这两步操作封装成工具类。

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, adds =, new  ArrayList<在();   ,,,//ServerAddress()两个参数分别为,服务器地址,和,端口   ,,,ServerAddress  ServerAddress =, new  ServerAddress (“localhost",, 27017);   ,,,adds.add (serverAddress);   ,,,List, credentials =, new  ArrayList<在();   ,,,//MongoCredential.createScramSha1Credential()三个参数分别为,用户名,数据库名称,密码   ,,,MongoCredential  MongoCredential =, MongoCredential.createScramSha1Credential (“username",,“databaseName",,“password" .toCharArray ());   ,,,credentials.add (mongoCredential);   ,,,//通过连接认证获取MongoDB连接   ,,,MongoClient  MongoClient =, new  MongoClient(补充道,,凭证);   ,,,//连接到数据库   ,,,MongoDatabase  MongoDatabase =, mongoClient.getDatabase (“test");   ,,,//返回连接数据库对象   ,,,return  mongoDatabase;   ,,}   }

使用java怎么连接mongoDB并进行增删改查操作