课程表

MongoDB 基础教程

MongoDB 高级教程

工具箱
速查手册

MongoDB Java

当前位置:免费教程 » 数据库/运维 » MongoDB

环境配置

在 Java 程序中如果要使用 MongoDB,你需要确保已经安装了 Java 环境及 MongoDB JDBC 驱动。

本章节实例时候 Mongo 3.x 以上版本。

你可以参考本站的Java教程来安装Java程序。现在让我们来检测你是否安装了 MongoDB JDBC 驱动。


连接数据库

连接数据库,你需要指定数据库名称,如果指定的数据库不存在,mongo会自动创建数据库。

连接数据库的Java代码如下:

  1. import com.mongodb.MongoClient;
  2. import com.mongodb.client.MongoDatabase;
  3.  
  4. public class MongoDBJDBC{
  5. public static void main( String args[] ){
  6. try{
  7. // 连接到 mongodb 服务
  8. MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
  9. // 连接到数据库
  10. MongoDatabase mongoDatabase = mongoClient.getDatabase("mycol");
  11. System.out.println("Connect to database successfully");
  12. }catch(Exception e){
  13. System.err.println( e.getClass().getName() + ": " + e.getMessage() );
  14. }
  15. }
  16. }

现在,让我们来编译运行程序并连接到数据库 mycol。

你可以根据你的实际环境改变 MongoDB JDBC 驱动的路径。

本实例将 MongoDB JDBC 启动包 mongo-java-driver-3.2.2.jar 放在本地目录下:

  1. $ javac -cp .:mongo-java-driver-3.2.2.jar MongoDBJDBC.java
  2. $ java -cp .:mongo-java-driver-3.2.2.jar MongoDBJDBC
  3. Connect to database successfully
  4. Authentication: true

本实例中 Mongo 数据库无需用户名密码验证。如果你的 Mongo 需要验证用户名及密码,可以使用以下代码:

  1. import java.util.ArrayList;
  2. import java.util.List;
  3. import com.mongodb.MongoClient;
  4. import com.mongodb.MongoCredential;
  5. import com.mongodb.ServerAddress;
  6. import com.mongodb.client.MongoDatabase;
  7. public class MongoDBJDBC {
  8. public static void main(String[] args){
  9. try {
  10. //连接到MongoDB服务 如果是远程连接可以替换“localhost”为服务器所在IP地址
  11. //ServerAddress()两个参数分别为 服务器地址 和 端口
  12. ServerAddress serverAddress = new ServerAddress("localhost",27017);
  13. List<ServerAddress> addrs = new ArrayList<ServerAddress>();
  14. addrs.add(serverAddress);
  15. //MongoCredential.createScramSha1Credential()三个参数分别为 用户名 数据库名称 密码
  16. MongoCredential credential = MongoCredential.createScramSha1Credential("username", "databaseName", "password".toCharArray());
  17. List<MongoCredential> credentials = new ArrayList<MongoCredential>();
  18. credentials.add(credential);
  19. //通过连接认证获取MongoDB连接
  20. MongoClient mongoClient = new MongoClient(addrs,credentials);
  21. //连接到数据库
  22. MongoDatabase mongoDatabase = mongoClient.getDatabase("databaseName");
  23. System.out.println("Connect to database successfully");
  24. } catch (Exception e) {
  25. System.err.println( e.getClass().getName() + ": " + e.getMessage() );
  26. }
  27. }
  28. }

创建集合

我们可以使用 com.mongodb.client.MongoDatabase 类中的createCollection()来创建集合

代码片段如下:

  1. import com.mongodb.MongoClient;
  2. import com.mongodb.client.MongoDatabase;
  3.  
  4. public class MongoDBJDBC{
  5. public static void main( String args[] ){
  6. try{
  7. // 连接到 mongodb 服务
  8. MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
  9. // 连接到数据库
  10. MongoDatabase mongoDatabase = mongoClient.getDatabase("mycol");
  11. System.out.println("Connect to database successfully");
  12. mongoDatabase.createCollection("test");
  13. System.out.println("集合创建成功");
  14. }catch(Exception e){
  15. System.err.println( e.getClass().getName() + ": " + e.getMessage() );
  16. }
  17. }
  18. }

编译运行以上程序,输出结果如下:

  1. Connect to database successfully
  2. 集合创建成功

获取集合

我们可以使用com.mongodb.client.MongoDatabase类的 getCollection() 方法来获取一个集合

代码片段如下:

  1. import org.bson.Document;
  2. import com.mongodb.MongoClient;
  3. import com.mongodb.client.MongoCollection;
  4. import com.mongodb.client.MongoDatabase;
  5.  
  6. public class MongoDBJDBC{
  7. public static void main( String args[] ){
  8. try{
  9. // 连接到 mongodb 服务
  10. MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
  11. // 连接到数据库
  12. MongoDatabase mongoDatabase = mongoClient.getDatabase("mycol");
  13. System.out.println("Connect to database successfully");
  14. MongoCollection<Document> collection = mongoDatabase.getCollection("test");
  15. System.out.println("集合 test 选择成功");
  16. }catch(Exception e){
  17. System.err.println( e.getClass().getName() + ": " + e.getMessage() );
  18. }
  19. }
  20. }

编译运行以上程序,输出结果如下:

  1. Connect to database successfully
  2. 集合 test 选择成功

插入文档

我们可以使用com.mongodb.client.MongoCollection类的 insertMany() 方法来插入一个文档

代码片段如下:

  1. import java.util.ArrayList;
  2. import java.util.List;
  3. import org.bson.Document;
  4.  
  5. import com.mongodb.MongoClient;
  6. import com.mongodb.client.MongoCollection;
  7. import com.mongodb.client.MongoDatabase;
  8.  
  9. public class MongoDBJDBC{
  10. public static void main( String args[] ){
  11. try{
  12. // 连接到 mongodb 服务
  13. MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
  14. // 连接到数据库
  15. MongoDatabase mongoDatabase = mongoClient.getDatabase("mycol");
  16. System.out.println("Connect to database successfully");
  17. MongoCollection<Document> collection = mongoDatabase.getCollection("test");
  18. System.out.println("集合 test 选择成功");
  19. //插入文档
  20. /**
  21. * 1. 创建文档 org.bson.Document 参数为key-value的格式
  22. * 2. 创建文档集合List<Document>
  23. * 3. 将文档集合插入数据库集合中 mongoCollection.insertMany(List<Document>) 插入单个文档可以用 mongoCollection.insertOne(Document)
  24. * */
  25. Document document = new Document("title", "MongoDB").
  26. append("description", "database").
  27. append("likes", 100).
  28. append("by", "Fly");
  29. List<Document> documents = new ArrayList<Document>();
  30. documents.add(document);
  31. collection.insertMany(documents);
  32. System.out.println("文档插入成功");
  33. }catch(Exception e){
  34. System.err.println( e.getClass().getName() + ": " + e.getMessage() );
  35. }
  36. }
  37. }
  38.  

编译运行以上程序,输出结果如下:

  1. Connect to database successfully
  2. 集合 test 选择成功
  3. 文档插入成功

检索所有文档

我们可以使用 com.mongodb.client.MongoCollection 类中的 find() 方法来获取集合中的所有文档。

此方法返回一个游标,所以你需要遍历这个游标。

代码片段如下:

  1. import org.bson.Document;
  2. import com.mongodb.MongoClient;
  3. import com.mongodb.client.FindIterable;
  4. import com.mongodb.client.MongoCollection;
  5. import com.mongodb.client.MongoCursor;
  6. import com.mongodb.client.MongoDatabase;
  7.  
  8. public class MongoDBJDBC{
  9. public static void main( String args[] ){
  10. try{
  11. // 连接到 mongodb 服务
  12. MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
  13. // 连接到数据库
  14. MongoDatabase mongoDatabase = mongoClient.getDatabase("mycol");
  15. System.out.println("Connect to database successfully");
  16. MongoCollection<Document> collection = mongoDatabase.getCollection("test");
  17. System.out.println("集合 test 选择成功");
  18. //检索所有文档
  19. /**
  20. * 1. 获取迭代器FindIterable<Document>
  21. * 2. 获取游标MongoCursor<Document>
  22. * 3. 通过游标遍历检索出的文档集合
  23. * */
  24. FindIterable<Document> findIterable = collection.find();
  25. MongoCursor<Document> mongoCursor = findIterable.iterator();
  26. while(mongoCursor.hasNext()){
  27. System.out.println(mongoCursor.next());
  28. }
  29. }catch(Exception e){
  30. System.err.println( e.getClass().getName() + ": " + e.getMessage() );
  31. }
  32. }
  33. }

编译运行以上程序,输出结果如下:

  1. Connect to database successfully
  2. 集合 test 选择成功
  3. Document{{_id=56e65fb1fd57a86304fe2692, title=MongoDB, description=database, likes=100, by=Fly}}

更新文档

你可以使用 com.mongodb.client.MongoCollection 类中的 updateMany() 方法来更新集合中的文档。

代码片段如下:

  1. import org.bson.Document;
  2. import com.mongodb.MongoClient;
  3. import com.mongodb.client.FindIterable;
  4. import com.mongodb.client.MongoCollection;
  5. import com.mongodb.client.MongoCursor;
  6. import com.mongodb.client.MongoDatabase;
  7. import com.mongodb.client.model.Filters;
  8.  
  9. public class MongoDBJDBC{
  10. public static void main( String args[] ){
  11. try{
  12. // 连接到 mongodb 服务
  13. MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
  14. // 连接到数据库
  15. MongoDatabase mongoDatabase = mongoClient.getDatabase("mycol");
  16. System.out.println("Connect to database successfully");
  17. MongoCollection<Document> collection = mongoDatabase.getCollection("test");
  18. System.out.println("集合 test 选择成功");
  19. //更新文档 将文档中likes=100的文档修改为likes=200
  20. collection.updateMany(Filters.eq("likes", 100), new Document("$set",new Document("likes",200)));
  21. //检索查看结果
  22. FindIterable<Document> findIterable = collection.find();
  23. MongoCursor<Document> mongoCursor = findIterable.iterator();
  24. while(mongoCursor.hasNext()){
  25. System.out.println(mongoCursor.next());
  26. }
  27. }catch(Exception e){
  28. System.err.println( e.getClass().getName() + ": " + e.getMessage() );
  29. }
  30. }
  31. }

编译运行以上程序,输出结果如下:

  1. Connect to database successfully
  2. 集合 test 选择成功
  3. Document{{_id=56e65fb1fd57a86304fe2692, title=MongoDB, description=database, likes=200, by=Fly}}

删除第一个文档

要删除集合中的第一个文档,首先你需要使用com.mongodb.DBCollection类中的 findOne()方法来获取第一个文档,然后使用remove 方法删除。

代码片段如下:

  1. import org.bson.Document;
  2. import com.mongodb.MongoClient;
  3. import com.mongodb.client.FindIterable;
  4. import com.mongodb.client.MongoCollection;
  5. import com.mongodb.client.MongoCursor;
  6. import com.mongodb.client.MongoDatabase;
  7. import com.mongodb.client.model.Filters;
  8.  
  9. public class MongoDBJDBC{
  10. public static void main( String args[] ){
  11. try{
  12. // 连接到 mongodb 服务
  13. MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
  14.  
  15. // 连接到数据库
  16. MongoDatabase mongoDatabase = mongoClient.getDatabase("mycol");
  17. System.out.println("Connect to database successfully");
  18.  
  19. MongoCollection<Document> collection = mongoDatabase.getCollection("test");
  20. System.out.println("集合 test 选择成功");
  21.  
  22. //删除符合条件的第一个文档
  23. collection.deleteOne(Filters.eq("likes", 200));
  24. //删除所有符合条件的文档
  25. collection.deleteMany (Filters.eq("likes", 200));
  26. //检索查看结果
  27. FindIterable<Document> findIterable = collection.find();
  28. MongoCursor<Document> mongoCursor = findIterable.iterator();
  29. while(mongoCursor.hasNext()){
  30. System.out.println(mongoCursor.next());
  31. }
  32. }catch(Exception e){
  33. System.err.println( e.getClass().getName() + ": " + e.getMessage() );
  34. }
  35. }
  36. }

编译运行以上程序,输出结果如下:

  1. Connect to database successfully
  2. 集合 test 选择成功

更多操作可以参考:http://mongodb.github.io/mongo-java-driver/3.0/driver/getting-started/quick-tour/

参考文档:http://blog.csdn.net/ererfei/article/details/50857103

转载本站内容时,请务必注明来自W3xue,违者必究。
 友情链接:直通硅谷  点职佳  北美留学生论坛

本站QQ群:前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

W3xue 的所有内容仅供测试,对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接(目前9元/月)请联系QQ:27243702 沸活量
皖ICP备17017327号-2 皖公网安备34020702000426号