Java操作MongoDB实例


终于跑通了自己的第一个Java操作MongoDB的例子,不知为何每次启动机子,MongoDB总会被lock住需要删除lock文件才能启动,难道跟自己的Windows 7系统有关系?费解费解!
  1. package mongodb;  
  2.   
  3. import java.net.UnknownHostException;  
  4. import com.mongodb.BasicDBObject;  
  5. import com.mongodb.DB;  
  6. import com.mongodb.DBCollection;  
  7. import com.mongodb.DBCursor;  
  8. import com.mongodb.Mongo;  
  9. import com.mongodb.MongoException;  
  10.   
  11. /** 
  12.  * Java + MongoDB Hello world Example 
  13.  *  
  14.  */  
  15. public class MongoDb {  
  16.     public static void main(String[] args) {  
  17.         try {  
  18.             // 实例化Mongo对象,连接27017端口   
  19.             Mongo mongo = new Mongo("localhost"27017);  
  20.             // 连接名为xiaodb的数据库,假如数据库不存在的话,mongodb会自动建立   
  21.             DB db = mongo.getDB("xiaodb");  
  22.             // Get collection from MongoDB, database named "xiao"   
  23.             // 从Mongodb中获得名为users的数据集合,如果该数据集合不存在,Mongodb会为其新建立   
  24.             DBCollection collection = db.getCollection("users");  
  25.             // 使用BasicDBObject对象创建一个mongodb的document,并给予赋值。   
  26.             BasicDBObject document = new BasicDBObject();  
  27.             document.put("id"1001);  
  28.             document.put("msg""hello world mongoDB in Java");  
  29.             // 将新建立的document保存到collection中去   
  30.             collection.insert(document);  
  31.             // 创建要查询的document   
  32.             BasicDBObject searchQuery = new BasicDBObject();  
  33.             searchQuery.put("id"1002);  
  34.             // 使用collection的find方法查找document   
  35.             DBCursor cursor = collection.find(searchQuery);  
  36.             // 循环输出结果   
  37.             while (cursor.hasNext()) {  
  38.                 System.out.println(cursor.next());  
  39.             }  
  40.             System.out.println("Done");  
  41.         } catch (UnknownHostException e) {  
  42.             e.printStackTrace();  
  43.         } catch (MongoException e) {  
  44.             e.printStackTrace();  
  45.         }  
  46.     }  
  47. }  

相关内容