通過 Java 操作 MongoDB

jopen 14年前發布 | 99K 次閱讀 MongoDB NoSQL數據庫 NOSQL

mongodb的java驅動已經提供比較全的操作，分為三塊：

1.普通用戶操作

2.管理員操作

3.oplog操作

具體可以添加一個eclipse testng插件，再在工程中導入testng.jar包即可看到。

本文主要說明各個使用點和注意事項。

 

1.連接一個復制集（replica sets）mongod：

復制集是mongo解決穩定性的一個方案，也是可以實現讀寫分離的一種實現，這里介紹復制集的java連接方式。

    static Mongo m;

    static {
        List<ServerAddress> addresslist = new ArrayList<ServerAddress>();
        try {
            addresslist.add(new ServerAddress("127.0.0.1:10240"));
            addresslist.add(new ServerAddress("127.0.0.1:11240"));
            addresslist.add(new ServerAddress("127.0.0.1:12240"));
        } catch (UnknownHostException e) {
            System.err.println("address check error.");
            System.exit(-1);
        }

        MongoOptions options = new MongoOptions();
        options.autoConnectRetry = true;
        options.connectionsPerHost = 20;
        options.connectTimeout = 6000;
        options.maxAutoConnectRetryTime = 12000;
        options.maxWaitTime = 12000;
        options.socketKeepAlive = true;
        options.socketTimeout = 2000;

        try {
            m = new Mongo(addresslist, options);
        } catch (MongoException e) {
            System.err.println("mongo create error.");
            System.exit(-1);
        }
    }
注：一般例子采用的連接方式是直接連一個mongod服務，但是作為單臺的生產環境顯然安全性不足，因此采用復制集方式，連接也區別于一般，是使用 
        public Mongo( List<ServerAddress> replicaSetSeeds , MongoOptions options ) throws MongoException
方法。

MongoOptions根據自己的需求設置，參數說明已經很多了，不細講。

注意mongo實例使用單例模式。

 

2.獲取db：

DB db = m.getDB("test");
注：取到名為test的db進行操作；若該db不存在，該操作會創建對應的db。

 

3.獲取集合：

DBCollection col = db.getCollection("offer");
注：取名字為offer的集合；類似于db的表。

 

以上三個操作是建立連接，接下去才是db中常用的操作。

 

4.查詢：

        DBCursor cursor = col.find();
        while(cursor.hasNext()) {
            System.out.println(cursor.next());
            i++;
        }
注：全集合查詢，輸出每條記錄，正常情況不會作類似操作，記住兩個東西，find()和cursor 
        BasicDBObject query = new BasicDBObject();
        query = new BasicDBObject();
        query.put("i", new BasicDBObject("$gt", 20).append("$lte", 30));  // i.e.   20 < i <= 30
        <pre name="code" class="java">        DBCursor cur = coll.find(query);
        while(cur.hasNext()) {
            System.out.println(cur.next());
        }
注：查詢指定條件的offer信息。 
DBObject tmpdoc = col.findOne(doc);
注：查詢單條記錄；在很明確一條記錄有且只有一條時，findOne()比較方便，免得游標移動麻煩。


5.更新：

DBObject tmpdoc = col.findOne(doc);
tmpdoc.put("i", (Integer)tmpdoc.get("i")+1);
System.out.println("update obj: " + col.findOne(tmpdoc));
注：更新一條記錄，先整個讀出再更新部分信息再寫入， 切記不要讀出一部分更新回去。

 

6.插入：
int i=1000;
BasicDBObject doc = new BasicDBObject();
doc.put("i", i+1);
col.insert(doc);
System.out.println("insert obj: " + col.findOne(doc));
注：插入一條記錄｛i:1001｝,_id自動生成。

 

7.刪除：

BasicDBObject doc = new BasicDBObject();
doc.put("i", i+1);

col.remove(doc);
System.out.println("insert obj: " + col.findOne(doc));
注：刪除一條記錄。

 本文由用戶 jopen 自行上傳分享，僅供網友學習交流。所有權歸原作者，若您的權利被侵害，請聯系管理員。
 轉載本站原創文章，請注明出處，并保留原始鏈接、圖片水印。
 本站是一個以用戶分享為主的開源技術平臺，歡迎各類分享！