t user = BasicDBObjectUtils.castModel2DBObject(new User("345567", "jack", 22, "beijin"));
users.insert(user);
// 用BasicDBObjectBuilder构建一个DBObject对象
user = BasicDBObjectBuilder.start("id", 1546555).append("name", "jojo").add("address", "gz").append("email", "hoojo_@126.com").get();
users.insert(user);
} catch (Exception e) {
e.printStackTrace();
}
System.out.println("游标查询所有users集合数据");
DBCursor cur = users.find();
while (cur.hasNext()) {
System.out.println(cur.next());
}
System.out.println("查询游标相关内容");
System.out.println(cur.count());
System.out.println(cur.getCursorId());
System.out.println(cur.getOptions());
System.out.println(cur.getQuery());
System.out.println(cur.getSizes().listIterator());
System.out.println(cur.itcount());
//System.out.println(cur.length());
System.out.println(cur.size());
System.out.println(cur.numGetMores());
System.out.println(cur.curr());
//System.out.println(cur.toArray().get(0));
System.out.println("显示游标查询到的所有内容：" + JSON.serialize(cur));
}
}
工具类，将带有getter、setter方法的
Java类序列化成DBObject对象
package com.hoo.util;
import java.lang.reflect.Method;
import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
/**
* function: 将Entity/Model转换成DBObject
* @author hoojo
* @createDate 2011-5-30下午01:53:08
* @file BasicDBObjectUtil.java
* @package com.hoo.util
* @project MongoDB
* @blog http://blog.csdn.net/IBM_hoojo
* @email hoojo_@126.com
* @version 1.0
*/
publicclass BasicDBObjectUtils {
public static DBObject castModel2DBObject(T entity) throws Exception {
Method[] method = entity.getClass().getMethods();
DBObject dbObject = new BasicDBObject();
for (Method m : method) {
//System.out.println(m.getName());
if (m.getName().startsWith("get")) {
String name = m.getName().replace("get", "");
for (Method m2 : method) {
if (m2.getName().equals("set" + name)) {
name = name.substring(0, 1).toLowerCase() + name.substring(1);
Object returnVal = m.invoke(entity, new Object[] {});
if (returnVal != null) {
//System.out.println(name + " : " + m.invoke(shipping, new Object[] {}));
dbObject.put(name, returnVal);
}
}
}
}
}
System.out.println("dbObject: " + dbObject);
return dbObject;
}
}
2、 完成索引操作，首先建立一个MongoDB4IndexTest.java，基本测试代码如下：
package com.hoo.test;
import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.List;
import org.bson.types.ObjectId;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import com.mongodb.BasicDBObject;
import com.mongodb.Bytes;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObje |