MongoDB的安装与CRUD(JAVA)

http://blogread.cn/it/article/4348?f=wb (MongoDB)

安装:
1)下载MongoDB数据库(这里使用Windows 32 bit版)

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

然后解压到一个目录(这里是D:\\MongoDB)，
并且在D:\\MongoDB目录中建个\"data\\db\"目录用来存放数据文件。
(注意:很多文档中说\"C:\\data\\db\"目录是缺省目录，实际上是不起作用的)

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>bin\\mongod --dbpath data\\db
能看到下面这张图就算是成功了:



下面是一个CRUD例子，虽然简单，不过也算是覆盖了大多数核心内容了，
一边看代码一边看注释吧，挺简单的。

import java.util.*;
import com.mongodb.*; //com.mongodb包类似于java.sql，大多数与数据库相关的类都在这里

public class MongoTest {
public static void out(Object o) {
System.err.println(o);
}
public static void out() {
System.err.println();
}

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());

//查看所有的数据库名
for(String dbName : mongo.getDatabaseNames()) {
out(\"dbName = \"+dbName);
}

//DB类用来表示一个数据库，如果数据库不存在则创建一个
DB db = mongo.getDB( \"test\" );

//查看所有的Collection名
for(String collectionName : db.getCollectionNames()) {
out(\"collectionName = \"+collectionName);
}

out();

//DBCollection类用来存放对象，类似数据库表的概念
DBCollection coll = db.getCollection(\"testCollection\");

//插入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());

coll.insert(user);
}

findAll(coll); //查找出coll中的所有对象并打印输出

//查找出第一条记录，在内部会自动转换成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); //还原最初的对象类型

out();

user.setAge(100);
coll.save(user); //保存更新
findAll(coll); //确认第一条记录的\"Age\"是否变成100了?

coll.remove(user); //删除第一条记录

findAll(coll);

//查找年纪大于等于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));

DBCursor cur = coll.find(query);
while(cur.hasNext()) {
out(cur.next());
}

out();

//跳过前面3条记录，然后显示总共5条记录
cur = coll.find().skip(3).limit(5);
while(cur.hasNext()) {
out(cur.next());
}

coll.drop(); //删除coll这个DBCollection
}

public static void findAll(DBCollection coll) {
DBCursor cur = coll.find();
while(cur.hasNext()) {
out(cur.next());
}
out();
}

//插入DBCollection中的java对象必需实现DBObject接口，
//ReflectionDBObject实现了DBObject接口，在内部是采用反射来完成的
public static class User extends ReflectionDBObject {
private String name;
private int age;
private Date date;

public void setName(String name) {
this.name = name;
}

public String getName() {
return name;
}

public void setAge(int age) {
this.age = age;
}

public int getAge() {
return age;
}

public void setDate(Date date) {
this.date = date;
}

public Date getDate() {
return date;
}
}

//如果不想用反射的方式，又不想手工实现DBObject接口的方法，
//可以直接继承BasicDBObject，但是需要做额外的工作，
//就像下面这样:
public static class UserNoReflection extends BasicDBObject {
private String name;
private int age;
private Date date;

public void setName(String name) {
this.name = name;

super.put(\"name\", name);
}

public String getName() {
return name;
}

public void setAge(int age) {
this.age = age;

super.put(\"age\", age);
}

public int getAge() {
return age;
}

public void setDate(Date date) {
this.date = date;

super.put(\"date\", date);
}

public Date getDate() {
return date;
}

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;

return super.put(key, v);
}
}
}

把MongoTest.java文件放到D:\\MongoDB目录

编译:
javac -cp D:\\MongoDB\\mongo-1.3.jar D:\\MongoDB\\MongoTest.java

运行:
java -cp D:\\MongoDB\\mongo-1.3.jar;D:\\MongoDB MongoTest

Douyu也支持MongoDB了，比上面的代码还简洁

//对应上面的User类(或UserNoReflection类)，
//在Douyu中如下所示，不需要任何setter和getter代码

import douyu.mvc.Model;

@Model
public class User {
private String name;
private int age;
private Date date;
}

然后在conf/server.java中配置一个MongoDB的数据源(跟普通的关系型数据库类似)

最后是Controller

import java.util.Date;
import douyu.mvc.Controller;
import douyu.mvc.ModelManager;

@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());

modelManager.insert(user);

user.setAge(20);
modelManager.save(user);

modelManager.delete(user);
//....
}
}