MongoDB（二）-- Java API 實現增刪改查

一、下載jar包

　　http://central.maven.org/maven2/org/mongodb/mongo-java-driver/

二、代碼實現

package com.xbq.mongodb;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.bson.types.ObjectId;
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.util.JSON;

/** 
 * @ClassName: MongoDBTest
 * @Description: TODO MongoDB 增刪改查 操作，包含批量操作
 * @author xbq
 * @version 1.0
 * @date 2017-4-5 上午11:50:06
 */
public class MongoDBTest {

    private static final String HOST = "192.168.242.129";
    private static final int PORT = 27017;
    private static final String DB_NAME = "testDB";
    private static Mongo mongo;
    private static DB db;
    
    static {
        // 連接到MongoDB
        mongo = new Mongo(HOST, PORT);
        // 打開數據庫 testDB
        db = mongo.getDB(DB_NAME);
    }
    
    public static void main(String[] args) {
        // 獲取集合 xbqTable，若該集合不存在，mongoDB將自動創建該集合
        DBCollection dbCollection = db.getCollection("testTable");
        
        // 查詢該數據庫所有的集合名
        for(String name : mongo.getDatabaseNames()){
            System.out.println(name);
        }
        
//        addOne(dbCollection);
//        addList(dbCollection);
//        addByJson(dbCollection);
        
//        deleteOne(dbCollection);
//        deleteByIn(dbCollection);
//        deleteAll(dbCollection);
        
//        updateOne(dbCollection);
//        updateMulti(dbCollection);
        
//        queryOne(dbCollection);
//        queryPage(dbCollection);
//        queryRange(dbCollection);
        queryList(dbCollection);
        
    }
    
    
    // ====================================查詢開始==============================================
    /**
     * @Title: queryOne
     * @Description: TODO 查詢 name為 張三的 一條記錄
     * @param dbCollection
     * @return: void
     */
    public static void queryOne(DBCollection dbCollection){
        DBObject documents = new BasicDBObject("name","張三");
        DBObject result = dbCollection.findOne(documents);
        System.out.println(result);
    }
    
    /**
     * @Title: queryPage
     * @Description: TODO 分頁查詢  ， 查詢 跳過前2條 后的 3條 數據
     * @param dbCollection
     * @return: void
     */
    public static void queryPage(DBCollection dbCollection){
        DBCursor cursor = dbCollection.find().skip(2).limit(3);
        while (cursor.hasNext()) {
            System.out.println(cursor.next());
        }
    }
    
    /**
     * @Title: queryRange
     * @Description: TODO 范圍查詢，查詢 第3條 到 第5條 之間的記錄
     * @param dbCollection
     * @return: void
     */
    public static void queryRange(DBCollection dbCollection) {
        DBObject range = new BasicDBObject();
        range.put("$gte", 50);
        range.put("$lte", 52);
        
        DBObject dbObject = new BasicDBObject();
        dbObject.put("age", range);
        DBCursor cursor = dbCollection.find(dbObject);
        while (cursor.hasNext()) {
            System.out.println(cursor.next());
        }
    }
    
    /**'
     * @Title: queryList
     * @Description: TODO 查詢出全部的 記錄
     * @param dbCollection
     * @return: void
     */
    public static void queryList(DBCollection dbCollection) {
        DBCursor cursor = dbCollection.find();
        DBObject dbObject = null;
        while(cursor.hasNext()){
            dbObject = cursor.next();
            System.out.println(dbObject);
        }
    }
    
    // ====================================增加開始==============================================
    /**
     * @Title: addOne
     * @Description: TODO 新增 一條記錄
     * @param dbCollection
     * @return: void
     */
    public static void addOne(DBCollection dbCollection){
        DBObject documents = new BasicDBObject("name","張三").append("age", 45).append("sex", "男").append("address", 
                new BasicDBObject("postCode", 100000).append("street", "深南大道888號").append("city", "深圳"));
        dbCollection.insert(documents);
    }
    
    /**
     * @Title: addList 
     * @Description: TODO 批量新增 記錄    , 增加的記錄 中 可以使用各種數據類型
     * @param dbCollection
     * @return: void
     */
    public static void addList(DBCollection dbCollection){
        List<DBObject> listdbo= new ArrayList<DBObject>();
        DBObject dbObject = new BasicDBObject();
        dbObject.put("name", "老王");
        // 可以直接保存List類型
        List<String> list = new ArrayList<String>();
        list.add("非隔壁老王");
        dbObject.put("remark", list);
        listdbo.add(dbObject);
        
        dbObject = new BasicDBObject();
        // 可以直接保存map
        Map<String,List<String>> map = new HashMap<String,List<String>>();
        List<String> hobbys = new ArrayList<String>();
        hobbys.add("看花");
        hobbys.add("采花");
        map.put("愛好", hobbys);
        dbObject.put("hobby", map);
        listdbo.add(dbObject);
        
        dbObject = new BasicDBObject();
        dbObject.put("name", "老張");
        dbObject.put("age", 52);
        dbObject.put("job", "看守老王");
        dbObject.put("remark", new BasicDBObject("address", "廣東省深圳市").append("street", "深南大道888號"));
        listdbo.add(dbObject);
        
        dbCollection.insert(listdbo);
    }
    
    /**
     * @Title: addByJson
     * @Description: TODO json轉對象后 ，執行新增
     * @param dbCollection
     * @return: void
     */
    public static void addByJson(DBCollection dbCollection){
        String json = "{ \"name\" : \"王五\" , \"age\" : 66 , \"job\" : \"看守老王\" , \"remark\" : { \"address\" : \"廣東省深圳市\" , \"street\" : \"深南大道888號\"}}";
        DBObject dbObject = (DBObject) JSON.parse(json);
        dbCollection.insert(dbObject);
    }
    
    // ====================================修改開始==============================================
    /**
     * @Title: update
     * @Description: TODO 修改指定記錄
     * @param dbCollection
     * @return: void
     */
    public static void updateOne(DBCollection dbCollection) {
        // 先根據id查詢將 這條 記錄查詢出來
        DBObject qryResult = dbCollection.findOne(new ObjectId("58e4a11c6c166304f0635958"));
        // 修改指定的值
        qryResult.put("age", 55);
        
        DBObject olddbObject = new BasicDBObject();
        olddbObject.put("_id", new ObjectId("58e4a11c6c166304f0635958"));
        dbCollection.update(olddbObject, qryResult);
    }
    
    /**
     * @Title: updateMulti
     * @Description: TODO 修改 多條記錄
     * @param dbCollection
     * @return: void
     */
    public static void updateMulti(DBCollection dbCollection) {
        DBObject newdbObject = new BasicDBObject();
        newdbObject.put("name", "張三");
        newdbObject.put("address", "廣東深圳");
        newdbObject.put("remark", "張三是一個NB的Coder");
        
        DBObject olddbObject = new BasicDBObject();
        olddbObject.put("name", "張三");
        // 需要加上這個
        DBObject upsertValue = new BasicDBObject("$set", newdbObject);  
        // 后面的兩個參數：1.若所更新的數據沒有，則插入 ; 2、同時更新多個符合條件的文檔(collection) 
        dbCollection.update(olddbObject, upsertValue, true, true);
    }
    
    // ====================================刪除開始==============================================
    /**
     * @Title: deleteFirst
     * @Description: TODO 刪除第一個
     * @param 
     * @return: void
     */
    public static void deleteFirst(DBCollection dbCollection){
        DBObject dbObject = dbCollection.findOne();
        dbCollection.remove(dbObject);
    }
    
    /**
     * @Title: deleteOne
     * @Description: TODO 刪除指定的一條記錄
     * @param dbCollection
     * @return: void
     */
    public static void deleteOne(DBCollection dbCollection){
        DBObject dbObject = new BasicDBObject();
        dbObject.put("_id", new ObjectId("58e49c2d6c166309e0d50484"));
        dbCollection.remove(dbObject);
    }
    
    /**
     * @Title: deleteByIn
     * @Description: TODO 刪除多條記錄      例如：select * from tb where name in('12','34')
     * @param dbCollection
     * @return: void
     */
    public static void deleteByIn(DBCollection dbCollection) {
        List<String> list = new ArrayList<String>();
        list.add("老張");
        list.add("老王");
        list.add("張三");
        DBObject dbObject = new BasicDBObject("$in", list);
        
        DBObject delObject = new BasicDBObject();
        delObject.put("name", dbObject);
        dbCollection.remove(delObject);
    }
    
    /**
     * @Title: deleteAll
     * @Description: TODO 刪除全部的記錄
     * @param dbCollection
     * @return: void
     */
    public static void deleteAll(DBCollection dbCollection){
        DBCursor cursor = dbCollection.find();
        while(cursor.hasNext()){
            dbCollection.remove(cursor.next());
        }
    }
}

三、源碼下載

　　點我下載