mongodb初探-小试牛刀

凝望长空

mongodb初探-小试牛刀

1、启动数据库服务
2、下载mongodb的Java驱动，并构建到java工程中，下载地址：https://github.com/mongodb/mongo-java-driver/downloads
3、编写如下代码

Java代码

1. 1.package com.ljq.dao;   
   
2. 2.  
   
3. 3.import java.util.Date;   
   
4. 4.import java.util.HashMap;   
   
5. 5.import java.util.List;   
   
6. 6.import java.util.Map;   
   
7. 7.import java.util.Set;   
   
8. 8.import java.util.UUID;   
   
9. 9.  
   
10. 10.import com.mongodb.BasicDBObject;   
    
11. 11.import com.mongodb.DB;   
    
12. 12.import com.mongodb.DBCollection;   
    
13. 13.import com.mongodb.DBObject;   
    
14. 14.import com.mongodb.Mongo;   
    
15. 15./**  
    
16. 16. * Mongodb connect & insert & query simple example  
    
17. 17. * @author jiaqianli.cn@gmail.com  
    
18. 18. */  
    
19. 19.public class DbTest {   
    
20. 20.    public static void main(String[] args) throws Exception{   
    
21. 21.        /*  
    
22. 22.          The Mongo object instance actually represents a pool of connections to the database;  
    
23. 23.          you will only need one object of class Mongo even with multiple threads.  
    
24. 24.         */  
    
25. 25.        // Mongo mongo = new Mongo();   
    
26. 26.        Mongo mongo = new Mongo("127.0.0.1");   
    
27. 27.           
    
28. 28.        List<String> list = mongo.getDatabaseNames();   
    
29. 29.        // 打印数据库名字   
    
30. 30.        int index = 0;   
    
31. 31.        for (String db : list) {   
    
32. 32.            System.out.println("数据库"+(++index)+"："+db);   
    
33. 33.        }   
    
34. 34.        System.out.println("=============================");   
    
35. 35.           
    
36. 36.        DB db = mongo.getDB( "mydb1" );   
    
37. 37.        Set<String> colls = db.getCollectionNames();   
    
38. 38.        // 打印mydb1中的链接   
    
39. 39.        index = 0;   
    
40. 40.        for (String s : colls) {   
    
41. 41.            System.out.println("连接"+(++index)+"："+s);   
    
42. 42.        }   
    
43. 43.        System.out.println("=============================");   
    
44. 44.           
    
45. 45.        // 获取某个链接   
    
46. 46.        DBCollection collection = db.getCollection("mydb1");   
    
47. 47.           
    
48. 48.        Map<String, Object> data = new HashMap<String, Object>();   
    
49. 49.        data.put("_id", UUID.randomUUID());   
    
50. 50.        data.put("name", "lijiaqian2011");   
    
51. 51.        data.put("email", "jiaqianli.cn@gmail.com");   
    
52. 52.        data.put("address", "BeiJing China");   
    
53. 53.        data.put("company", "BeiJing Boeh Technology");   
    
54. 54.        data.put("salary", 6000f);   
    
55. 55.        data.put("addtime", new Date());   
    
56. 56.           
    
57. 57.        BasicDBObject doc = new BasicDBObject();   
    
58. 58.        doc.putAll(data);   
    
59. 59.           
    
60. 60.        // 插入数据   
    
61. 61.        collection.insert(doc);   
    
62. 62.           
    
63. 63.        BasicDBObject query = new BasicDBObject();   
    
64. 64.        query.put("name", "lijiaqian2011");   
    
65. 65.           
    
66. 66.        // 查询数据   
    
67. 67.        DBObject mydoc = collection.findOne(query);   
    
68. 68.           
    
69. 69.        System.out.println("email:"+mydoc.get("email"));   
    
70. 70.    }   
    
71. 71.}  
    
72. package com.ljq.dao;
    
73. 
    
74. import java.util.Date;
    
75. import java.util.HashMap;
    
76. import java.util.List;
    
77. import java.util.Map;
    
78. import java.util.Set;
    
79. import java.util.UUID;
    
80. 
    
81. import com.mongodb.BasicDBObject;
    
82. import com.mongodb.DB;
    
83. import com.mongodb.DBCollection;
    
84. import com.mongodb.DBObject;
    
85. import com.mongodb.Mongo;
    
86. /**
    
87. * Mongodb connect & insert & query simple example
    
88. * @author jiaqianli.cn@gmail.com
    
89. */
    
90. public class DbTest {
    
91.         public static void main(String[] args) throws Exception{
    
92.                 /*
    
93.                   The Mongo object instance actually represents a pool of connections to the database;
    
94.                   you will only need one object of class Mongo even with multiple threads.
    
95.                  */
    
96.                 // Mongo mongo = new Mongo();
    
97.                 Mongo mongo = new Mongo("127.0.0.1");
    
98.                
    
99.                 List<String> list = mongo.getDatabaseNames();
    
100.                 // 打印数据库名字
     
101.                 int index = 0;
     
102.                 for (String db : list) {
     
103.                         System.out.println("数据库"+(++index)+"："+db);
     
104.                 }
     
105.                 System.out.println("=============================");
     
106.                
     
107.                 DB db = mongo.getDB( "mydb1" );
     
108.                 Set<String> colls = db.getCollectionNames();
     
109.                 // 打印mydb1中的链接
     
110.                 index = 0;
     
111.                 for (String s : colls) {
     
112.                     System.out.println("连接"+(++index)+"："+s);
     
113.                 }
     
114.                 System.out.println("=============================");
     
115.                
     
116.                 // 获取某个链接
     
117.                 DBCollection collection = db.getCollection("mydb1");
     
118.                
     
119.                 Map<String, Object> data = new HashMap<String, Object>();
     
120.                 data.put("_id", UUID.randomUUID());
     
121.                 data.put("name", "lijiaqian2011");
     
122.                 data.put("email", "jiaqianli.cn@gmail.com");
     
123.                 data.put("address", "BeiJing China");
     
124.                 data.put("company", "BeiJing Boeh Technology");
     
125.                 data.put("salary", 6000f);
     
126.                 data.put("addtime", new Date());
     
127.                
     
128.                 BasicDBObject doc = new BasicDBObject();
     
129.                 doc.putAll(data);
     
130.                
     
131.                 // 插入数据
     
132.                 collection.insert(doc);
     
133.                
     
134.                 BasicDBObject query = new BasicDBObject();
     
135.                 query.put("name", "lijiaqian2011");
     
136.                
     
137.                 // 查询数据
     
138.                 DBObject mydoc = collection.findOne(query);
     
139.                
     
140.                 System.out.println("email:"+mydoc.get("email"));
     
141.         }
     
142. }

复制代码

4、执行结果如下图：