mongodb-java-driver基本用法详解数据库

import com.google.gson.Gson; 
import com.mongodb.BasicDBObject; 
import com.mongodb.DB; 
import com.mongodb.DBCollection; 
import com.mongodb.DBCursor; 
import com.mongodb.DBObject; 
import com.mongodb.Mongo; 
import com.mongodb.util.JSON; 
import java.net.UnknownHostException; 
import java.util.Calendar; 
import java.util.Date; 
import java.util.HashMap; 
import java.util.HashSet; 
import java.util.Map; 
import java.util.Set; 
import org.junit.Test; 
public class TestMongoDriver { 
@Test 
public void testCRUD() throws UnknownHostException { 
// 连接到mongodb 
Mongo mongo = new Mongo("localhost", 27017); 
// 打开数据库test 
DB db = mongo.getDB("test"); 
// 遍历所有集合的名字 
Set<String> colls = db.getCollectionNames(); 
for (String s : colls) { 
System.out.println(s); 
// 先删除所有Collection(类似于关系数据库中的"表") 
if (!s.equals("system.indexes")) { 
db.getCollection(s).drop(); 
} 
} 
// 取得集合emp(若：emp不存在，mongodb将自动创建该集合) 
DBCollection coll = db.getCollection("emp"); 
// delete all 
DBCursor dbCursor = coll.find(); 
for (DBObject dbObject : dbCursor) { 
coll.remove(dbObject); 
} 
// create 
BasicDBObject doc = new BasicDBObject("name", "杨俊明").append("sex", "男") 
.append("address", 
new BasicDBObject("postcode", "201202").append( 
"street", "田林路888号").append("city", "上海")); 
coll.insert(doc); 
// retrieve 
BasicDBObject docFind = new BasicDBObject("name", "杨俊明"); 
DBObject findResult = coll.findOne(docFind); 
System.out.println(findResult); 
// update 
doc.put("sex", "MALE");// 把sex属性从"男"，改成"MALE" 
        coll.update(docFind, doc); 
findResult = coll.findOne(docFind); 
System.out.println(findResult); 
coll.dropIndexes();// 先删除所有索引 
// create index 
coll.createIndex(new BasicDBObject("name", 1)); // 1代表升序 
// 复杂对象 
UserData userData = new UserData("jimmy", "123456"); 
Set<String> pets = new HashSet<String>(); 
pets.add("cat"); 
pets.add("dog"); 
Map<String, String> favoriteMovies = new HashMap<String, String>(); 
favoriteMovies.put("dragons", "Dragons II"); 
favoriteMovies.put("avator", "Avator I"); 
userData.setFavoriteMovies(favoriteMovies); 
userData.setPets(pets); 
userData.setBirthday(getDate(1990, 5, 1)); 
BasicDBObject objUser = new BasicDBObject("key", "jimmy").append( 
"value", toDBObject(userData)); 
coll.insert(objUser); 
System.out.println(coll.findOne(objUser)); 
} 
/** 
* 将普通Object对象转换成mongodb的DBObject对象 
*  
* @param obj 
* @return 
*/ 
private DBObject toDBObject(Object obj) { 
Gson gson = new Gson(); 
String json = gson.toJson(obj); 
return (DBObject) JSON.parse(json); 
} 
/** 
* 获取指定日期 
*  
* @param year 
* @param month 
* @param day 
* @return 
*/ 
private Date getDate(int year, int month, int day) { 
Calendar calendar = Calendar.getInstance(); 
calendar.clear(); 
calendar.set(year, month - 1, day); 
return calendar.getTime(); 
} 
}

import java.io.Serializable; 
import java.util.Date; 
import java.util.Map; 
import java.util.Set; 
public class UserData implements Serializable { 
private static final long serialVersionUID = -4770493237851400594L; 
private String userName; 
private String password; 
private Set<String> pets; 
private Map<String, String> favoriteMovies; 
private Date birthday; 
public UserData() { 
} 
public UserData(String userName, String passWord) { 
this.userName = userName; 
this.password = passWord; 
} 
public String getUserName() { 
return userName; 
} 
public void setUserName(String userName) { 
this.userName = userName; 
} 
public String getPassword() { 
return password; 
} 
public void setPassword(String password) { 
this.password = password; 
} 
public Set<String> getPets() { 
return pets; 
} 
public void setPets(Set<String> pets) { 
this.pets = pets; 
} 
public Map<String, String> getFavoriteMovies() { 
return favoriteMovies; 
} 
public void setFavoriteMovies(Map<String, String> favoriteMovies) { 
this.favoriteMovies = favoriteMovies; 
} 
public Date getBirthday() { 
return birthday; 
} 
public void setBirthday(Date birthday) { 
this.birthday = birthday; 
} 
}

emp 
system.indexes 
{ "_id" : { "$oid" : "53d34795744ec171e7f6980a"} , "name" : "杨俊明" , "sex" : "男" , "address" : { "postcode" : "201202" , "street" : "田林路888号" , "city" : "上海"}} 
{ "_id" : { "$oid" : "53d34795744ec171e7f6980a"} , "name" : "杨俊明" , "sex" : "MALE" , "address" : { "postcode" : "201202" , "street" : "田林路888号" , "city" : "上海"}} 
{ "_id" : { "$oid" : "53d34796744ec171e7f6980b"} , "key" : "jimmy" , "value" : { "userName" : "jimmy" , "password" : "123456" , "pets" : [ "cat" , "dog"] , "favoriteMovies" : { "dragons" : "Dragons II" , "avator" : "Avator I"} , "birthday" : "May 1, 1990 12:00:00 AM"}}