2013年，写的CRUD太简单了，今天在原来的基础上，稍微完善了下，用了更多语法，比如排序sort、in语句等。
参考了《Mongodb权威指南-第1版-高清》，等下上传到CSDN下载频道，免积分下载。
代码写得够清晰了，不再过多解释。
package mongodb;
import java.net.UnknownHostException;
import java.util.Date;
import com.mongodb.BasicDBList;
import com.mongodb.BasicDBObject;
import com.mongodb.CommandResult;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.Mongo;
import com.mongodb.WriteResult;
/**
* MongoDB-CRUD Demo。
*
*
*/
public class MongoDBDemo {
// /////////////数据库地址常量/////////////////////
/**
* 数据库地址
*/
public static final String DEFAULT_HOST = "localhost";// localhost
/**
* 端口号
*/
public static final int DEFAULT_PORT = 27017;
// //////////////数据库名称和集合常量/////////////////
/**
* 数据库名称
*/
public static final String DB_BLOG = "blog";
/**
* 集合名称
*/
public static final String DB_BLOG_COLLECTION = "article";
// /////////////文章Article的属性名称常量/////////////////////
/**
* 标题
*/
public static final String TITLE = "title";
/**
* 内容
*/
public static final String CONTENT = "content";
/**
* 作者
*/
public static final String AUTHOR = "author";
/**
* 日期
*/
public static final String DATE = "date";
public static final String ID = "id";
public static void main(String[] args) throws UnknownHostException {
Mongo mogo = new Mongo(DEFAULT_HOST, DEFAULT_PORT);
// 获得数据库
DB blogDb = mogo.getDB(DB_BLOG);
DBCollection articleCollection = blogDb
.getCollection(DB_BLOG_COLLECTION);
buildThreeArticles(articleCollection);
// 查找并打印作者为"FansUnion"的文章
BasicDBObject searchArticleByAuthor = new BasicDBObject();
searchArticleByAuthor.append(AUTHOR, "FansUnion");
demoFindByField(articleCollection, searchArticleByAuthor);
demoFindAndSort(articleCollection, searchArticleByAuthor);
BasicDBObject searchArticleById = new BasicDBObject();
searchArticleById.append(ID, 3L);
demoFindById(articleCollection, searchArticleById);
demoFindSpecialField(articleCollection, searchArticleById);
demoFindWithIn(articleCollection);
demoUpdateWithTwoWay(articleCollection, searchArticleByAuthor);
demoRemove(articleCollection);
// 集合中的文档数量
long count = articleCollection.count();
println("删除了刚刚新建的3条记录，剩余count=" + count);
// 关闭连接
mogo.close();
}
//删除数据
private static void demoRemove(DBCollection articleCollection) {
// 删除
BasicDBObject removeCondition = new BasicDBObject();
removeCondition.append(AUTHOR, "FansUnion");
articleCollection.remove(removeCondition);
BasicDBObject removeCondition2 = new BasicDBObject();
removeCondition.append(TITLE, "HelloWorld");
// 删除，并查看是否有报错
WriteResult writeResult = articleCollection.remove(removeCondition2);
CommandResult commandResult = writeResult.getLastError();
println("查看error信息，发现err字段为空" + commandResult.toString());
BasicDBObject removeAll = new BasicDBObject();
articleCollection.remove(removeAll);
}
//2种方式更新对象
private static void demoUpdateWithTwoWay(DBCollection articleCollection,
BasicDBObject searchArticleByAuthor) {
// 把标题为"HelloWorld"的文章的作者，修改为“小雷”
println("把标题为HelloWorld的文章的作者，修改为小雷,只修改AUTHOR1个字段");
// 查询条件：标题为"HelloWorld"
BasicDBObject updateCondition = new BasicDBObject();
searchArticleByAuthor.append(TITLE, "HelloWorld");
BasicDBObject newHelloWorldArticle = new BasicDBObject();
newHelloWorldArticle.append(AUTHOR, "小雷");
// 第1种方式-修改，只修改指定的字段("$set","$inc"都是修改器)
// update Article set author="小雷" where title='HelloWorld'
DBObject updateSetValue = new BasicDBObject("$set",
newHelloWorldArticle);
articleCollection.update(updateCondition, updateSetValue);
// 打印第1次修改过的"HelloWorld"文章
DBObject helloWordlArticle2 = articleCollection
.findOne(updateCondition);
print(helloWordlArticle2);
// 第2种方式-修改
// update Article set author="小雷",title=null,content=null,date=null
// where title='HelloWorld'
println("把标题为HelloWorld的文章的作者，修改为小雷,修改了所有的字段");
articleCollection.update(updateCondition, newHelloWorldArticle);
DBObject helloWordlArticle = articleCollection.findOne(updateCondition);
// 打印第2次修改过的"HelloWorld"文章
print(helloWordlArticle);
}
//Mongodb中的in语句
private static void demoFindWithIn(DBCollection articleCollection) {
// IN查询
println("查找并打印ID为1和2的文章");
// List list = Arrays.asList(1,2);
// Long[] array= new Long[]{1L,2L};
BasicDBList values = new BasicDBList();
values.add(1);
values.add(2);
DBObject inQuery = new BasicDBObject("$in", values);
DBObject con = new BasicDBObject();
con.put(ID, inQuery);
DBCursor cursorIdArray = articleCollection.find(con);
println("个数：" + cursorIdArray.count());
while (cursorIdArray.hasNext()) {
print(cursorIdArray.next());
}
}
//查询特定的字段
private static void demoFindSpecialField(DBCollection articleCollection,
BasicDBObject searchArticleById) {
println("查找并打印ID为3的文章2，只查询TITLE字段");
BasicDBObject b = new BasicDBObject();
b.append(TITLE, 1);
DBCursor cursor3 = articleCollection.find(searchArticleById, b);
println("个数：" + cursor3.count());
while (cursor3.hasNext()) {
print(cursor3.next());
}
// cursor3.close();//在没有这行代码的情况下，同样的程序，出现了1次，个数为4，仔细看，发现他们的内置ID不一样
// 可能是上一次执行的删除，还没有完成？
//这个地方是一个疑问，但是复现不了
}
//根据ID查找对象
private static BasicDBObject demoFindById(DBCollection articleCollection,
BasicDBObject searchArticleById) {
// 查找并打印ID为3的文章
println("查找并打印ID为3的文章");
DBCursor cursor2 = articleCollection.find(searchArticleById);
println("个数：" + cursor2.count());
while (cursor2.hasNext()) {
print(cursor2.next());
}
cursor2.close();
return searchArticleById;
}
//查找对象,并排序
private static void demoFindAndSort(DBCollection articleCollection,
BasicDBObject searchArticleByAuthor) {
// 查找并打印作者为"FansUnion"的文章,按照ID降序排列
println("查找并打印作者为FansUnion的文章，降序排列，查询出来的ID一次为3,2,1");
BasicDBObject orderByIdDesc = new BasicDBObject();
orderByIdDesc.append(ID, -1);
DBCursor cursorIdDesc = articleCollection.find(searchArticleByAuthor)
.sort(orderByIdDesc);
while (cursorIdDesc.hasNext()) {
print(cursorIdDesc.next());
}
}
//根据字段查找对象
private static void demoFindByField(DBCollection articleCollection,
BasicDBObject searchArticleByAuthor) {
println("查找并打印作者为FansUnion的文章，查询出来的ID一次为1，2，3");
DBCursor cursor = articleCollection.find(searchArticleByAuthor);
while (cursor.hasNext()) {
print(cursor.next());
}
cursor.close();// 网上和书中的的例子，没有关闭游标，官方JDK文档“kills the current cursor on
// the server.”
}
// 构造3个文章,插入的ID顺序是1，2，3
private static void buildThreeArticles(DBCollection articleCollection) {
BasicDBObject article = buildArticle("做好社会主义的接班人", "好好学习，天天向上",
"FansUnion", new Date(), 1L);
BasicDBObject article2 = buildArticle("做好资本主义的掘墓人", "拼命干活，时时向上",
"FansUnion", new Date(), 2L);
BasicDBObject article3 = buildArticle("HelloWorld",
"I am a MongoDb demo.", "FansUnion", new Date(), 3L);
// 增加若干文章
articleCollection.insert(article);
articleCollection.insert(article2);
articleCollection.insert(article3);
println("插入文章的个数：" + articleCollection.count());
}
// 打印对象
private static void print(DBObject article) {
// println("-----------------------");
println("内置ID：" + article.get("_id"));
println("标题：" + article.get(TITLE));
println("内容：" + article.get(CONTENT));
println("作者：" + article.get(AUTHOR));
println("日期：" + article.get(DATE));
println("ID：" + article.get(ID));
println("-----------------------");
}
private static void println(Object object) {
System.out.println(object);
}
/**
* 构造1个文章对象
*
* @param title
* 标题
* @param content
* 内容
* @param author
* 作者
* @param date
* 日期
* @return 文章对象
*/
private static BasicDBObject buildArticle(String title, String content,
String author, Date date, Long id) {
BasicDBObject article = new BasicDBObject();
article.append(TITLE, title);
article.append(CONTENT, content);
article.append(AUTHOR, author);
article.append(DATE, date);
article.append(ID, id);
return article;
}
}代码执行结果
插入文章的个数：3
查找并打印作者为FansUnion的文章，查询出来的ID一次为1，2，3
内置ID：561baace3aea5b925fddc83c
标题：做好社会主义的接班人
内容：好好学习，天天向上
作者：FansUnion
日期：Mon Oct 12 20:42:54 CST 2015
ID：1
-----------------------
内置ID：561baace3aea5b925fddc83d
标题：做好资本主义的掘墓人
内容：拼命干活，时时向上
作者：FansUnion
日期：Mon Oct 12 20:42:54 CST 2015
ID：2
-----------------------
内置ID：561baace3aea5b925fddc83e
标题：HelloWorld
内容：I am a MongoDb demo.
作者：FansUnion
日期：Mon Oct 12 20:42:54 CST 2015
ID：3
-----------------------
查找并打印作者为FansUnion的文章，降序排列，查询出来的ID一次为3,2,1
内置ID：561baace3aea5b925fddc83e
标题：HelloWorld
内容：I am a MongoDb demo.
作者：FansUnion
日期：Mon Oct 12 20:42:54 CST 2015
ID：3
-----------------------
内置ID：561baace3aea5b925fddc83d
标题：做好资本主义的掘墓人
内容：拼命干活，时时向上
作者：FansUnion
日期：Mon Oct 12 20:42:54 CST 2015
ID：2
-----------------------
内置ID：561baace3aea5b925fddc83c
标题：做好社会主义的接班人
内容：好好学习，天天向上
作者：FansUnion
日期：Mon Oct 12 20:42:54 CST 2015
ID：1
-----------------------
查找并打印ID为3的文章
个数：1
内置ID：561baace3aea5b925fddc83e
标题：HelloWorld
内容：I am a MongoDb demo.
作者：FansUnion
日期：Mon Oct 12 20:42:54 CST 2015
ID：3
-----------------------
查找并打印ID为3的文章2，只查询TITLE字段
个数：1
内置ID：561baace3aea5b925fddc83e
标题：HelloWorld
内容：null
作者：null
日期：null
ID：null
-----------------------
查找并打印ID为1和2的文章
个数：2
内置ID：561baace3aea5b925fddc83c
标题：做好社会主义的接班人
内容：好好学习，天天向上
作者：FansUnion
日期：Mon Oct 12 20:42:54 CST 2015
ID：1
-----------------------
内置ID：561baace3aea5b925fddc83d
标题：做好资本主义的掘墓人
内容：拼命干活，时时向上
作者：FansUnion
日期：Mon Oct 12 20:42:54 CST 2015
ID：2
-----------------------
把标题为HelloWorld的文章的作者，修改为小雷,只修改AUTHOR1个字段
内置ID：561baace3aea5b925fddc83c
标题：做好社会主义的接班人
内容：好好学习，天天向上
作者：小雷
日期：Mon Oct 12 20:42:54 CST 2015
ID：1
-----------------------
把标题为HelloWorld的文章的作者，修改为小雷,修改了所有的字段
内置ID：561baace3aea5b925fddc83c
标题：null
内容：null
作者：小雷
日期：null
ID：null
-----------------------
查看error信息，发现err字段为空{ "serverUsed" : "localhost/127.0.0.1:27017" , "n" : 1 , "connectionId" : 1 , "err" : null , "ok" : 1.0}
删除了刚刚新建的3条记录，剩余count=0