package mongoDB; import java.net.UnknownHostException; import java.util.ArrayList; import java.util.List; 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; /** * java * mongodb的數據插入、讀取、更新、刪除 */ public class test{ private static Mongo m = null; private static DB db = null; //數據集合名稱 private static final String COLLECTION_NAME = "mcpang"; /* * 測試java處理mongodb的增、刪、改、查操作 */ public static void main(String[] args) { //獲取數據庫連接 startMongoDBConn(); //保存數據 createColData(); //讀取數據 readColData(); //更新數據 updateColData(); //讀取數據 readColData(); //刪除數據 deleteColData(); //讀取數據 readColData(); //刪除數據集 db.getCollection(COLLECTION_NAME).drop(); //關閉數據庫連接 stopMondoDBConn(); } /** * 數據插入 * 測試數據: * 【name:小李、age:30、address:北京】 * 【name:小張、age:25、address:天津】 * @return */ private static void createColData(){ DBCollection dbCol = db.getCollection(COLLECTION_NAME); System.out.println("向數據集中插入數據開始:"); List<DBObject> dbList = new ArrayList<DBObject>(); BasicDBObject doc1 = new BasicDBObject(); doc1.put("name", "小李"); doc1.put("age", 30); doc1.put("address", "北京"); dbList.add(doc1); BasicDBObject doc2 = new BasicDBObject(); doc2.put("name", "小張"); doc2.put("age", 25); doc2.put("address", "天津"); dbList.add(doc2); dbCol.insert(dbList); System.out.println("向數據集中插入數據完成!"); System.out.println("------------------------------"); } /** * 數據讀取 */ private static void readColData(){ DBCollection dbCol = db.getCollection(COLLECTION_NAME); DBCursor ret = dbCol.find(); System.out.println("從數據集中讀取數據:"); while(ret.hasNext()){ BasicDBObject bdbObj = (BasicDBObject) ret.next(); if(bdbObj != null){ System.out.println("name:"+bdbObj.getString("name")); System.out.println("age:"+bdbObj.getInt("age")); System.out.println("address:"+bdbObj.getString("address")); } } } /** * 數據更新 * update(q, o, upsert, multi) * update(q, o, upsert, multi, concern) * update(arg0, arg1, arg2, arg3, arg4, arg5) * updateMulti(q, o) */ private static void updateColData(){ System.out.println("------------------------------"); DBCollection dbCol = db.getCollection(COLLECTION_NAME); DBCursor ret = dbCol.find(); BasicDBObject doc = new BasicDBObject(); BasicDBObject res = new BasicDBObject(); res.put("age", 40); System.out.println("將數據集中的所有文檔的age修改成40!"); doc.put("$set", res); dbCol.update(new BasicDBObject(),doc,false,true); System.out.println("更新數據完成!"); System.out.println("------------------------------"); } /** * 數據刪除 */ private static void deleteColData(){ System.out.println("------------------------------"); DBCollection dbCol = db.getCollection(COLLECTION_NAME); System.out.println("刪除【小李】!"); BasicDBObject doc = new BasicDBObject(); doc.put("name", "小李"); dbCol.remove(doc); System.out.println("------------------------------"); } /** * 關閉mongodb數據庫連接 */ private static void stopMondoDBConn(){ if (null != m) { if (null != db) { // 結束Mongo數據庫的事務請求 try { db.requestDone(); } catch(Exception e) { e.printStackTrace(); } } try { m.close(); } catch(Exception e) { e.printStackTrace(); } m = null; db = null; } } /** * 獲取mongodb數據庫連接 */ private static void startMongoDBConn(){ try { //Mongo(p1, p2):p1=>IP地址 p2=>端口 m = new Mongo("127.0.0.1", 27017); //根據mongodb數據庫的名稱獲取mongodb對象 db = m.getDB("yyl"); //校驗用戶密碼是否正確 if (!db.authenticate("yyl", "yyl123".toCharArray())){ System.out.println("連接MongoDB數據庫,校驗失敗!"); }else{ System.out.println("連接MongoDB數據庫,校驗成功!"); } } catch (UnknownHostException e) { e.printStackTrace(); } catch (MongoException e) { e.printStackTrace(); } } }
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索:z360901061

微信掃一掃加我為好友
QQ號聯系: 360901061
您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。
【本文對您有幫助就好】元
