亚洲免费在线-亚洲免费在线播放-亚洲免费在线观看-亚洲免费在线观看视频-亚洲免费在线看-亚洲免费在线视频

mongodb實現簡單的增刪改查

系統 1795 0
      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();  

        }  

    }  

}








  



mongodb實現簡單的增刪改查


更多文章、技術交流、商務合作、聯系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯系: 360901061

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

【本文對您有幫助就好】

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長會非常 感謝您的哦!??!

發表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 色综合视频在线 | 久久久久蜜桃 | 亚洲色四在线视频观看 | 欧美又黄又嫩大片a级 | 亚洲精品在线观看视频 | 色综合久久久久久中文网 | 一区精品视频 | 亚洲欧美成人永久第一网站 | 免费观看欧美精品成人毛片能看的 | 国产成人精品三区 | 亚洲在线观看一区 | 特级毛片aaa免费版 特级毛片a级毛免费播放 | 成人免费动作大片黄在线 | 2021精品综合久久久久 | 日日碰碰 | 毛色毛片免费看 | 国产成人在线视频 | 亚洲国产精品综合久久网络 | 日韩亚洲视频 | a免费网站| 久久精品亚洲综合一品 | 香蕉大黄香蕉在线观看 | 久草视频在线播放 | 特级毛片网站 | 久久精品国产这里是免费 | 日本亚洲欧洲免费无码 | 国产精品天天干 | 国产精品手机视频 | 女孕学护士一级毛片 | 国产高清a毛片在线看 | 日韩香蕉网 | 干干干操操操 | 亚洲国产精品久久久天堂 | 九九在线精品视频播放 | chinese456老人gay| 久久精品国产日本波多麻结衣 | 九九综合九九综合 | 亚洲国产成人久久综合一区 | 欧美成人性色生活片天天看 | 久久这里精品 | 日韩欧美高清在线 |