不使用spring的情况下原生java代码两种方式操作mongodb数据库

2022-12-05 16:33:49

由于更改了mongodb3.0数据库的密码，导致这几天storm组对数据进行处理的时候，一直在报mongodb数据库连接不上的异常。

 

主要原因实际上是和mongodb本身无关的，因为他们改的是配置文件的密码，而实际上这个密码在代码中根本就没有使用，他们在代码中已经把用户验证信息写死。

 

在协助他们解决这个问题的时候，我看到他们代码中在和mongodb数据库交互时使用了已经不被建议使用的方法，于是便抽时间尝试了一下另一种被建议的方式实现各功能。

 

当然了，生产环境中用的是mongodb集群，验证时的写法和单机时会略有不同，我这里就只拿单机试验。

 

使用原生的Java代码操作mongodb数据库，就不需要和spring集成的那些jar包，只用到了mongodb-java-driver3.0.3.jar，代码如下，一些需要注意的地方也都写在注释中：

 

  1. package monAndMysql;
  2. import java.util.ArrayList;
  3. import java.util.Date;
  4. import java.util.List;
  5. import java.util.Set;
  6. import org.bson.BsonDocument;
  7. import org.bson.BsonString;
  8. import org.bson.Document;
  9. import org.bson.conversions.Bson;
  10. import com.mongodb.BasicDBObject;
  11. import com.mongodb.DB;
  12. import com.mongodb.DBCollection;
  13. import com.mongodb.DBCursor;
  14. import com.mongodb.DBObject;
  15. import com.mongodb.MongoClient;
  16. import com.mongodb.MongoCredential;
  17. import com.mongodb.ServerAddress;
  18. import com.mongodb.client.FindIterable;
  19. import com.mongodb.client.MongoCollection;
  20. import com.mongodb.client.MongoCursor;
  21. import com.mongodb.client.MongoDatabase;
  22. import com.mongodb.client.model.Filters;
  23. /**
  24. * mongodb和mysql性能测试
  25. *
  26. * @author tuzongxun123
  27. *
  28. */
  29. public class MonAndMysqlTest {
  30. public static void main(String[] args) {
  31. mongodbTest();
  32. }
  33. public static void mongodbTest() {
  34. ServerAddress sa = new ServerAddress("192.168.0.7", 27017);
  35. List<MongoCredential> mongoCredentialList = newArrayList<MongoCredential>();
  36. // java代码连接mongodb3.0数据库验证，userName,dbName,password
  37. mongoCredentialList.add(MongoCredential.createMongoCRCredential(
  38. "admin", "admin", "123456".toCharArray()));
  39. MongoClient client = new MongoClient(sa, mongoCredentialList);
  40. // 第一种方式
  41. // 第一种方式获取db，该方法已经不建议使用
  42. DB mongoDB = client.getDB("mongoTest1");
  43. DBCollection collection1 = mongoDB.getCollection("userTest1");
  44. // 这里的数据类型是dbobject
  45. DBObject document1 = new BasicDBObject();
  46. document1.put("name", "mongoTest1");
  47. document1.put("createTime", new Date().getTime());
  48. // 插入数据
  49. collection1.insert(document1);
  50. // 查询数据
  51. DBCursor cursor1 = collection1.find();
  52. System.out.println("第一种方式插入数据的结果：");
  53. while (cursor1.hasNext()) {
  54. DBObject object = cursor1.next();
  55. Set<String> keySet = object.keySet();
  56. for (String key : keySet) {
  57. System.out.println(key + ":" + object.get(key));
  58. }
  59. }
  60. // 更改数据
  61. DBObject query = new BasicDBObject();
  62. DBObject update = new BasicDBObject();
  63. query.put("name", "mongoTest1");
  64. update.put("$set", new BasicDBObject("name", "update1"));
  65. collection1.update(query, update);
  66. System.out
  67. .println("--------------------------------------------------------------------------------------");
  68. System.out.println("第一种方式修改数据的结果：");
  69. DBCursor cursor11 = collection1.find();
  70. while (cursor11.hasNext()) {
  71. DBObject object = cursor11.next();
  72. Set<String> keySet = object.keySet();
  73. for (String key : keySet) {
  74. System.out.println(key + ":" + object.get(key));
  75. }
  76. }
  77. // 删除数据
  78. DBObject query1 = new BasicDBObject();
  79. query1.put("name", "update1");
  80. collection1.remove(query1);
  81. System.out
  82. .println("--------------------------------------------------------------------------------------");
  83. System.out.println("第一种方式删除数据的结果：");
  84. DBCursor cursor12 = collection1.find();
  85. while (cursor12.hasNext()) {
  86. DBObject object = cursor12.next();
  87. Set<String> keySet = object.keySet();
  88. for (String key : keySet) {
  89. System.out.println(key + ":" + object.get(key));
  90. }
  91. }
  92. // 第二种方式
  93. System.out
  94. .println("****************************************************************************");
  95. // 第二种方式获取db及插入数据和查询操作。推荐方式
  96. MongoDatabase database = client.getDatabase("mongoTest2");
  97. // 注意这里的数据类型是document
  98. Document document2 = new Document();
  99. document2.put("name", "mongoTest2");
  100. document2.put("createTime", new Date().getTime());
  101. MongoCollection collection2 = database.getCollection("userTest2");
  102. // 插入数据
  103. collection2.insertOne(document2);
  104. // 查询数据，注意这里直接查询出的结果不是游标，还需要转换
  105. FindIterable<Document> findIterable = collection2.find();
  106. MongoCursor<Document> cursor2 = findIterable.iterator();
  107. System.out.println("第二种方式插入数据的结果：");
  108. while (cursor2.hasNext()) {
  109. Document document = cursor2.next();
  110. Set<String> keySet = document.keySet();
  111. for (String key : keySet) {
  112. System.out.println(key + ":" + document.get(key));
  113. }
  114. }
  115. // 更改数据
  116. Bson filter = Filters.eq("name", "mongoTest2");
  117. BsonDocument update2 = new BsonDocument();
  118. update2.put("$set", new BsonDocument("name", new BsonString("update2")));
  119. collection2.updateOne(filter, update2);
  120. System.out
  121. .println("--------------------------------------------------------------------------------------");
  122. MongoCursor<Document> cursor21 = findIterable.iterator();
  123. System.out.println("第二种方式更改数据的结果：");
  124. while (cursor21.hasNext()) {
  125. Document document = cursor21.next();
  126. Set<String> keySet = document.keySet();
  127. for (String key : keySet) {
  128. System.out.println(key + ":" + document.get(key));
  129. }
  130. }
  131. // 删除数据
  132. Bson filter2 = Filters.eq("name", "update2");
  133. collection2.deleteOne(filter2);
  134. System.out
  135. .println("--------------------------------------------------------------------------------------");
  136. MongoCursor<Document> cursor22 = findIterable.iterator();
  137. System.out.println("第二种方式删除数据的结果：");
  138. while (cursor22.hasNext()) {
  139. Document document = cursor22.next();
  140. Set<String> keySet = document.keySet();
  141. for (String key : keySet) {
  142. System.out.println(key + ":" + document.get(key));
  143. }
  144. }
  145. // 关闭数据库连接
  146. client.close();
  147. }
  148. }

执行main方法后，控制台打印结果如下图所示，证明操作都是没有问题的：

不使用spring的情况下原生java代码两种方式操作mongodb数据库

上一篇：Javascript 回调函数理解---二娃子买肾机6


下一篇：ligerGrid 取得选中行的数据