Java操作MongoDB-xyz

xiahe999

　　java驱动程序是Mongodb中的驱动程序之一，也是比较成熟的Mongodb驱动程序之一，下面介绍了使用java连接、操作Mongodb。
　　一、安装java驱动程序
　　Mongodb的java驱动程序是一个jar包，可以在：https://github.com/mongodb/mongo-java-driver/downloads 下载，下载的jar导入到eclipse的项目中即可。
　　二、java操作Mongodb
　　java操作Mongodb常用的几个类：
　　Mongo：连接服务器，执行一些数据库操作的选项，如新建立一个数据库等
　　DB：对应一个数据库，可以用来建立集合等操作
　　DBCollection：对应一个集合（类似表），可能是我们用得最多的，可以添加删除记录等
　　DBObject接口和BasicDBObject对象：表示一个具体的记录，BasicDBObject实现了DBObject，是key-value的数据结构，用起来和HashMap是基本一致的。
　　DBCursor：用来遍历取得的数据，实现了Iterable和Iterator
private static void mongodbOperating(){ try { //有多种构造方法，选择一种（IP、port） Mongo m = new Mongo( &quot;192.168.21.111&quot; , 27017 ); //选择数据库，如果没有这个数据库的话，会自动建立 DB  db = m.getDB( &quot;mydb&quot; );  //建立一个集合，和数据库一样，如果没有，会自动建立 DBCollection collection = db.getCollection(&quot;myCollectionTest&quot;);  BasicDBObject doc = new BasicDBObject();         doc.put(&quot;name&quot;, &quot;MongoDB&quot;);         doc.put(&quot;type&quot;, &quot;database&quot;);         doc.put(&quot;count&quot;, 1);          BasicDBObject info = new BasicDBObject();         info.put(&quot;x&quot;, 203);         info.put(&quot;y&quot;, 102);         doc.put(&quot;info&quot;, info);          //插入一条数据,数据如下         // {         //   &quot;name&quot; : &quot;MongoDB&quot;,         //   &quot;type&quot; : &quot;database&quot;,         //   &quot;count&quot; : 1,         //   &quot;info&quot; : {         //               x : 203,         //               y : 102         //             }         //}             // 可以循环插入多条数据         collection.insert(doc);         //查找第一条数据,显示如下，_id是系统自动帮加上的，全局唯一         //{ &quot;_id&quot; : &quot;49902cde5162504500b45c2c&quot; , &quot;name&quot; : &quot;MongoDB&quot; , &quot;type&quot; : &quot;database&quot; , &quot;count&quot; : 1 , &quot;info&quot; : { &quot;x&quot; : 203 , &quot;y&quot; : 102}}         DBObject myDoc = collection.findOne();         System.out.println(myDoc);                  //插入多条数据         for (int i=0; i < 100; i++) {         collection.insert(new BasicDBObject().append(&quot;i&quot;, i));         }                   //获取文档条数         System.out.println(collection.getCount());                  //使用Cursor 获取所有文档         DBCursor cursor = collection.find();         try {             while(cursor.hasNext()) {                 System.out.println(cursor.next());             }         } finally {             cursor.close();         }                  //查找操作，获取单条记录         //{ &quot;_id&quot; : &quot;49903677516250c1008d624e&quot; , &quot;i&quot; : 71 }         BasicDBObject query = new BasicDBObject();         query.put(&quot;i&quot;, 71);         cursor = collection.find(query);         try {             while(cursor.hasNext()) {                 System.out.println(cursor.next());             }         } finally {             cursor.close();         }              //查找 i>50的项         query = new BasicDBObject();         query.put(&quot;i&quot;, new BasicDBObject(&quot;$gt&quot;, 50));  // e.g. find all where i > 50         cursor = collection.find(query);         try {             while(cursor.hasNext()) {                 System.out.println(cursor.next());             }         } finally {             cursor.close();         }           //查找 20