mongodb初探-小试牛刀
mongodb初探-小试牛刀1、启动数据库服务
2、下载mongodb的Java驱动，并构建到java工程中，下载地址：https://github.com/mongodb/mongo-java-driver/downloads
3、编写如下代码
Java代码1.package com.ljq.dao;
2.
3.import java.util.Date;
4.import java.util.HashMap;
5.import java.util.List;
6.import java.util.Map;
7.import java.util.Set;
8.import java.util.UUID;
9.
10.import com.mongodb.BasicDBObject;
11.import com.mongodb.DB;
12.import com.mongodb.DBCollection;
13.import com.mongodb.DBObject;
14.import com.mongodb.Mongo;
15./**
16. * Mongodb connect & insert & query simple example
17. * @author jiaqianli.cn@gmail.com
18. */
19.public class DbTest {
20. public static void main(String[] args) throws Exception{
21. /*
22. The Mongo object instance actually represents a pool of connections to the database;
23. you will only need one object of class Mongo even with multiple threads.
24. */
25. // Mongo mongo = new Mongo();
26. Mongo mongo = new Mongo("127.0.0.1");
27.
28. List<String> list = mongo.getDatabaseNames();
29. // 打印数据库名字
30. int index = 0;
31. for (String db : list) {
32. System.out.println("数据库"+(++index)+"："+db);
33. }
34. System.out.println("=============================");
35.
36. DB db = mongo.getDB( "mydb1" );
37. Set<String> colls = db.getCollectionNames();
38. // 打印mydb1中的链接
39. index = 0;
40. for (String s : colls) {
41. System.out.println("连接"+(++index)+"："+s);
42. }
43. System.out.println("=============================");
44.
45. // 获取某个链接
46. DBCollection collection = db.getCollection("mydb1");
47.
48. Map<String, Object> data = new HashMap<String, Object>();
49. data.put("_id", UUID.randomUUID());
50. data.put("name", "lijiaqian2011");
51. data.put("email", "jiaqianli.cn@gmail.com");
52. data.put("address", "BeiJing China");
53. data.put("company", "BeiJing Boeh Technology");
54. data.put("salary", 6000f);
55. data.put("addtime", new Date());
56.
57. BasicDBObject doc = new BasicDBObject();
58. doc.putAll(data);
59.
60. // 插入数据
61. collection.insert(doc);
62.
63. BasicDBObject query = new BasicDBObject();
64. query.put("name", "lijiaqian2011");
65.
66. // 查询数据
67. DBObject mydoc = collection.findOne(query);
68.
69. System.out.println("email:"+mydoc.get("email"));
70. }
71.}
package com.ljq.dao;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.UUID;
import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBObject;
import com.mongodb.Mongo;
/**
* Mongodb connect & insert & query simple example
* @author jiaqianli.cn@gmail.com
*/
public class DbTest {
public static void main(String[] args) throws Exception{
/*
The Mongo object instance actually represents a pool of connections to the database;
you will only need one object of class Mongo even with multiple threads.
*/
// Mongo mongo = new Mongo();
Mongo mongo = new Mongo("127.0.0.1");
List<String> list = mongo.getDatabaseNames();
// 打印数据库名字
int index = 0;
for (String db : list) {
System.out.println("数据库"+(++index)+"："+db);
}
System.out.println("=============================");
DB db = mongo.getDB( "mydb1" );
Set<String> colls = db.getCollectionNames();
// 打印mydb1中的链接
index = 0;
for (String s : colls) {
System.out.println("连接"+(++index)+"："+s);
}
System.out.println("=============================");
// 获取某个链接
DBCollection collection = db.getCollection("mydb1");
Map<String, Object> data = new HashMap<String, Object>();
data.put("_id", UUID.randomUUID());
data.put("name", "lijiaqian2011");
data.put("email", "jiaqianli.cn@gmail.com");
data.put("address", "BeiJing China");
data.put("company", "BeiJing Boeh Technology");
data.put("salary", 6000f);
data.put("addtime", new Date());
BasicDBObject doc = new BasicDBObject();
doc.putAll(data);
// 插入数据
collection.insert(doc);
BasicDBObject query = new BasicDBObject();
query.put("name", "lijiaqian2011");
// 查询数据
DBObject mydoc = collection.findOne(query);
System.out.println("email:"+mydoc.get("email"));
}
}4、执行结果如下图：
页:
[1]