Java操作MongoDB實例 |
發布時間: 2012/8/30 17:34:57 |
終于跑通了自己的第一個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.} 本文出自:億恩科技【www.laynepeng.cn】 |