原文链接 http://docs.mongodb.org/ecosystem/tutorial/getting-started-with-java-driver/ 介绍 本文的目的是让你对如何使用mongodb的java-driver驱动有一个简单的了解,当你阅读完本文你就可以参考其他文章以了解更多信息。 下载java-driver驱动 你可以在
原文链接http://docs.mongodb.org/ecosystem/tutorial/getting-started-with-java-driver/介绍本文的目的是让你对如何使用mongodb的java-driver驱动有一个简单的了解,当你阅读完本文你就可以参考其他文章以了解更多信息。
下载java-driver驱动你可以在这里下载需要的驱动。
添加java-driver驱动将下载的mongo-java-driver-2.12.3.jar 拷贝到你的lib目录下。获取数据库对象mongoclient mongoclient = new mongoclient( localhost , 5000 ); // 5000 为实例端口号,默认启动端口号为27017
db db = mongoclient.getdb(mydb); // 必须要先创建数据库
获取集合名称set colls = db.getcollectionnames();
for (string s : colls) {
system.out.println(s);
}获取集合对象dbcollection coll = db.getcollection(blog);获取集合文档数system.out.println(coll.getcount());
插入一个文档basicdbobject doc = new basicdbobject(name, mongodb)
.append(type, database)
.append(count, 1)
.append(info, new basicdbobject(x, 203).append(y, 102));
coll.insert(doc);插入多个文档for (int i=0; i coll.insert(new basicdbobject(i, i));
}使用游标查询满足条件的文档basicdbobject query = new basicdbobject(i, 71);
dbcursor cursor = coll.find(query);
try {
while(cursor.hasnext()) {
system.out.println(cursor.next());
}
} finally {
cursor.close();
}
bulkwriteoperation builder = coll.initializeorderedbulkoperation();
builder.insert(new basicdbobject(_id, 1));
builder.insert(new basicdbobject(_id, 2));
builder.insert(new basicdbobject(_id, 3));更新已存在的文档builder.find(new basicdbobject(_id, 1)).updateone(new basicdbobject($set, new basicdbobject(x, 2)));删除已存在的文档builder.find(new basicdbobject(_id, 2)).removeone();
builder.find(new basicdbobject(_id, 3)).replaceone(new basicdbobject(_id, 3).append(x, 4));
bulkwriteresult result = builder.execute();