最近NoSQL(或者NoRelation)很火，咱不想Out了，所以也來湊湊熱鬧。

概念、優點之類的東西就不在這里重復啰嗦了，
直接動手玩一下。

MongoDB(包括Java驅動)的官方文檔寫得不夠認真，
連個最普通的CRUD例子都沒有，
看過網站上那篇“Java - Saving Objects Using DBObject”文章的人肯定被氣暈了。。。

安裝:
1)下載MongoDB數據庫(這里使用Windows 32 bit版)

http://downloads.mongodb.org/win32/mongodb-win32-i386-1.2.4.zip

然后解壓到一個目錄(這里是D:MongoDB)，
并且在D:MongoDB目錄中建個”datadb”目錄用來存放數據文件。
(注意:很多文檔中說”C:datadb”目錄是缺省目錄，實際上是不起作用的)

2)下載MongoDB數據庫的Java驅動程序

http://github.com/downloads/mongodb/mongo-java-driver/mongo-1.3.jar
然后把mongo-1.3.jar放到D:MongoDB目錄

完成上面兩步就算完成安裝任務了，夠簡單吧。

啟動MongoDB數據庫服務器:

D:>cd D:MongoDB
D:MongoDB>binmongod –dbpath datadb
能看到下面這張圖就算是成功了:

下面是一個CRUD例子，雖然簡單，不過也算是覆蓋了大多數核心內容了，
一邊看代碼一邊看注釋吧，挺簡單的。

Java代碼

import java.util.*;

import com.mongodb.*; //com.mongodb包類似于java.sql，大多數與數據庫相關的類都在這里
3.4. public class MongoTest {

public static void out(Object o) {

System.err.println(o);

}

public static void out() {

System.err.println();

}
11.12. public static void main(String[] args) throws Exception {

//Mongo是與java.sql.Connection同等級別的概念，

//默認是鏈接到127.0.0.1:27017/test，

//見getConnectPoint()的輸出結果，其中27017是端口號，test是數據庫名

Mongo mongo = new Mongo();

out(“mongo.getConnectPoint() = “+mongo.getConnectPoint());
18.19. //查看所有的數據庫名

for(String dbName : mongo.getDatabaseNames()) {

out(“dbName = “+dbName);

}
23.24. //DB類用來表示一個數據庫，如果數據庫不存在則創建一個

DB db = mongo.getDB( “test” );
26.27. //查看所有的Collection名

for(String collectionName : db.getCollectionNames()) {

out(“collectionName = “+collectionName);

}
31.32. out();
33.34. //DBCollection類用來存放對象，類似數據庫表的概念

DBCollection coll = db.getCollection(“testCollection”);
36.37. //插入10個User對象到coll

//插入DBCollection中的對象必需實現DBObject接口(見User類的注釋)

for(int i=1; i<=10; i++) {

User user = new User();

user.setName(“user “+(10+i));

user.setAge(10+i);

user.setDate(new Date());
44.45. coll.insert(user);

}
47.48. findAll(coll); //查找出coll中的所有對象并打印輸出
49.50. //查找出第一條記錄，在內部會自動轉換成User類型

coll.setObjectClass(User.class);

User user = (User)coll.findOne();

out(“user.name=”+user.getName());

out(“user.age=”+user.getAge());

out(“user.getDate()=”+user.getDate());

coll.setObjectClass(BasicDBObject.class); //還原最初的對象類型
57.58. out();
59.60. user.setAge(100);

coll.save(user); //保存更新

findAll(coll); //確認第一條記錄的”Age”是否變成100了?
63.64. coll.remove(user); //刪除第一條記錄
65.66. findAll(coll);
67.68. //查找年紀大于等于15小于等于18的記錄(15<=age<=18)

//(查詢條件的組合方式很啰嗦，這方面就沒sql方便)

BasicDBObject query = new BasicDBObject();

//注意這里的”Age”第一個字母要大寫，如果把User類替換成UserNoReflection類就用小寫，

//這是因為ReflectionDBObject類的內部實現在截取setter和getter方法的”set”和”get”前綴后

//沒有進行大小寫轉換，比如”setAge”得到的key值就是”Age”

query.put(“Age”, new BasicDBObject(“$gte”, 15).append(“$lte”, 18));
75.76.77. DBCursor cur = coll.find(query);

while(cur.hasNext()) {

out(cur.next());

}
81.82. out();
83.84. //跳過前面3條記錄，然后顯示總共5條記錄

cur = coll.find().skip(3).limit(5);

while(cur.hasNext()) {

out(cur.next());

}
89.90. coll.drop(); //刪除coll這個DBCollection

}
92.93. public static void findAll(DBCollection coll) {

DBCursor cur = coll.find();

while(cur.hasNext()) {

out(cur.next());

}

out();

}
100.101. //插入DBCollection中的java對象必需實現DBObject接口，

//ReflectionDBObject實現了DBObject接口，在內部是采用反射來完成的

public static class User extends ReflectionDBObject {

private String name;

private int age;

private Date date;
107.108. public void setName(String name) {

this.name = name;

}
111.112. public String getName() {

return name;

}
115.116. public void setAge(int age) {

this.age = age;

}
119.120. public int getAge() {

return age;

}
123.124. public void setDate(Date date) {

this.date = date;

}
127.128. public Date getDate() {

return date;

}

}
132.133. //如果不想用反射的方式，又不想手工實現DBObject接口的方法，

//可以直接繼承BasicDBObject，但是需要做額外的工作，

//就像下面這樣:

public static class UserNoReflection extends BasicDBObject {

private String name;

private int age;

private Date date;
140.141. public void setName(String name) {

this.name = name;
143.144. super.put(“name”, name);

}
146.147. public String getName() {

return name;

}
150.151. public void setAge(int age) {

this.age = age;
153.154. super.put(“age”, age);

}
156.157. public int getAge() {

return age;

}
160.161. public void setDate(Date date) {

this.date = date;
163.164. super.put(“date”, date);

}
166.167. public Date getDate() {

return date;

}
170.171. public Object put(String key, Object v) {

if(key.equals(“name”)) name = (String)v;

else if(key.equals(“age”)) age = (Integer)v;

else if(key.equals(“date”)) date = (Date)v;
175.176. return super.put(key, v);

}

}

}
把MongoTest.java文件放到D:MongoDB目錄

編譯:
javac -cp D:MongoDBmongo-1.3.jar D:MongoDBMongoTest.java

運行:
java -cp D:MongoDBmongo-1.3.jar;D:MongoDB MongoTest

Douyu也支持MongoDB了，比上面的代碼還簡潔

Java代碼

//對應上面的User類(或UserNoReflection類)，

//在Douyu中如下所示，不需要任何setter和getter代碼
3.4. import douyu.mvc.Model;
5.6. @Model

public class User {

private String name;

private int age;

private Date date;

}
然后在conf/server.java中配置一個MongoDB的數據源(跟普通的關系型數據庫類似)

最后是Controller

Java代碼

import java.util.Date;

import douyu.mvc.Controller;

import douyu.mvc.ModelManager;
4.5. @Controller

public class MongoTest {

public void index(ModelManager modelManager) {

User user = new User();

//下面三個setter方法雖然沒有在User類中聲明，

//但是編譯器在編譯User類時發現User類帶有@Model，就會自動生成setter、getter方法

user.setName(“user 10”);

user.setAge(10);

user.setDate(new Date());
14.15. modelManager.insert(user);
16.17. user.setAge(20);

modelManager.save(user);
19.20. modelManager.delete(user);

//….

}

}

本文來源于"阿里中間件團隊播客",原文發表時間"?2011-07-06??"

總結

以上是生活随笔為你收集整理的也来玩玩MongoDB的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。