您好,欢迎访问一九零五行业门户网

MongoDBJava连接

java 连接mongodb package mymaven;import java.net.unknownhostexception;import java.util.set;import com.mongodb.basicdbobject;import com.mongodb.db;import com.mongodb.dbcollection;import com.mongodb.dbcursor;import com.mongodb.dbobject;impor
java 连接mongodb
package mymaven;import java.net.unknownhostexception;import java.util.set;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.mongoexception;public class test { /** * @author ithomer.net * @datetime 2013-11-11 */ public static void main(string[] args) throws unknownhostexception, mongoexception { mongo mongo = new mongo(172.27.9.104, 27017); // 连接数据库 db db = mongo.getdb(mytestdb); // 数据库 set cols = db.getcollectionnames(); // 获取数据库中所有的集合(类似于获取关系数据库中的表) // 打印出数据库中的集合,这里应当为null for (string s : cols) { system.out.println(s); } dbcollection collection = db.getcollection(mytestcoll); // 创建一个集合 collection.drop(); // 删除集合,插入数据时自动重建 basicdbobject obj = new basicdbobject(); // 初始化一个基本db对象,插入数据库的就是db对象 obj.put(from, blog.ithomer.net); // 放入几个键值对 obj.put(to, forum.ithomer.net); obj.put(subject, ithomer.net); collection.insert(obj); // 插入对象 dbobject dbobj = collection.findone(); // 查看一条记录,findone()=find().limit(1); system.out.println(dbobj); // 打印出刚才插入的数据 // 插入10条{ranking:i}的数据 for (int i = 0; i < 10; i++) { collection.insert(new basicdbobject().append(ranking, i)); } system.out.println(count: + collection.getcount()); // 打印集合中的数据总数 dbcursor cursor = collection.find(); // 然后我们使用这个游标来遍历集合 while (cursor.hasnext()) { system.out.println(cursor.next()); } // 简单的条件查询,查询ranking为1的记录 basicdbobject query = new basicdbobject(); query.put(ranking, 1); cursor = collection.find(query); system.out.println(collection find({\ranking\:1}):); while (cursor.hasnext()) { system.out.println(cursor.next()); } // 复杂的条件查询,查询ranking大于等于5小于9的记录 query = new basicdbobject(); query.put(ranking, new basicdbobject($gte, 5).append($lt, 9)); cursor = collection.find(query); system.out.println(collection find({\ranking\:[5-9)}):); while (cursor.hasnext()) { system.out.println(cursor.next()); } // mongo.dropdatabase(mytestdb); // 最后删除我们的测试数据库 }}
运行结果:
mytestcollsystem.indexes{ _id : { $oid : 52c62ed8e4b0f4de3dd10107} , from : blog.ithomer.net , to : forum.ithomer.net , subject : ithomer.net}count: 11{ _id : { $oid : 52c62ed8e4b0f4de3dd10107} , from : blog.ithomer.net , to : forum.ithomer.net , subject : ithomer.net}{ _id : { $oid : 52c62ed8e4b0f4de3dd10108} , ranking : 0}{ _id : { $oid : 52c62ed8e4b0f4de3dd10109} , ranking : 1}{ _id : { $oid : 52c62ed8e4b0f4de3dd1010a} , ranking : 2}{ _id : { $oid : 52c62ed8e4b0f4de3dd1010b} , ranking : 3}{ _id : { $oid : 52c62ed8e4b0f4de3dd1010c} , ranking : 4}{ _id : { $oid : 52c62ed8e4b0f4de3dd1010d} , ranking : 5}{ _id : { $oid : 52c62ed8e4b0f4de3dd1010e} , ranking : 6}{ _id : { $oid : 52c62ed8e4b0f4de3dd1010f} , ranking : 7}{ _id : { $oid : 52c62ed8e4b0f4de3dd10110} , ranking : 8}{ _id : { $oid : 52c62ed8e4b0f4de3dd10111} , ranking : 9}collection find({ranking:1}):{ _id : { $oid : 52c62ed8e4b0f4de3dd10109} , ranking : 1}collection find({ranking:[5-9)}):{ _id : { $oid : 52c62ed8e4b0f4de3dd1010d} , ranking : 5}{ _id : { $oid : 52c62ed8e4b0f4de3dd1010e} , ranking : 6}{ _id : { $oid : 52c62ed8e4b0f4de3dd1010f} , ranking : 7}{ _id : { $oid : 52c62ed8e4b0f4de3dd10110} , ranking : 8}
源码下载(maven)
mongodb数组示例:
@suppresswarnings(unchecked) public static void loadmediatags(list mediaentitylist) { mediaentitylist.clear(); try { mongo mongo = new mongo(cosinecluster.gmongo_host, cosinecluster.gmongo_port); db db = mongo.getdb(cosinecluster.gmongo_db); dbcollection collection = db.getcollection(cosinecluster.gmongo_coll_media); dbcursor cursor = collection.find(); int index = 0; long starttime = system.currenttimemillis(); while(cursor.hasnext()){ basicdbobject obj = (basicdbobject) cursor.next(); long id = obj.getlong(_id); arraylist taglist = (arraylist) obj.get(tag); // tag arraylist keywordlist = (arraylist)obj.get(keyword); // keyword arraylist copyrightlist = (arraylist)obj.get(copyright); // copyright mediaentity mediaentity = new mediaentity(); mediaentity.setid(id); // tag for(int j=0; j
其它类似信息

推荐信息