MongoDB API实现增删改查

一，代码实现

import com.mongodb.DBCollection;
import com.mongodb.MongoClient;
import java.net.UnknownHostException;


public class MongDBUtile {
    /**
     * MongoClient是线程安全的
     * Mongo是非线程安全的
     * 目前mongodb API中已经建议用MongoClient替代Mongo
     */
    private MongoClient mongoClient = null;


    /**
     *   指定数据库的指定集合
     * @param dbName
     * @param collectionName
     * @return
     */
    public DBCollection getDBCollection(String dbName, String collectionName) {
        return mongoClient.getDB(dbName).getCollection(collectionName);
    }

    /**
     * 单例模式获取MongoClient
     */
    private static MongDBUtile getInstance = null;

    public static MongDBUtile getInstance(String host, int port){
        getInstance = new MongDBUtile(host,port);
        return getInstance;
    }

    private MongDBUtile(String host, int port){
        if(mongoClient == null){
            synchronized (MongDBUtile.class) {
                if (mongoClient == null) {
                    initConn(host, port);
                }
            }
        }
    }

    /**
     * 初始化MongoClient
     * @param host
     * @param port
     */
    private void initConn(String host, int port) {
        try {
            mongoClient = new MongoClient(host,port);
        } catch (UnknownHostException e) {
            e.printStackTrace();
        }
    }

}

1.1 插入

/**
     * 新增 一条记录
     * @param dbCollection
     */
    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);
    }

    /**
     * 批量新增记录:可以使用各种数据类型
     * @param dbCollection
     */
    public static void addList(DBCollection dbCollection){
        List<DBObject> listdbo= new ArrayList<>();
        DBObject dbObject = new BasicDBObject();
        dbObject.put("name", "老王");
        // 可以直接保存List类型
        List<String> list = new ArrayList<>();
        list.add("老王1");
        list.add("老王2");
        dbObject.put("remark", list);
        listdbo.add(dbObject);

        dbObject = new BasicDBObject();
        // 可以直接保存map
        Map<String,List<String>> map = new HashMap<>();
        List<String> hobbys = new ArrayList<>();
        hobbys.add("吃饭");
        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);
    }

    /**
     * json转对象后执行新增
     * @param dbCollection
     */
    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);
    }

方法调用以及运行结果

//连接mongoDB,并打开数据库
DBCollection dbCollection = MongDBUtile.getInstance(HOST,PORT).getDBCollection(DB_NAME, DBCOLLECTION_NAME);

addOne(dbCollection);
addList(dbCollection);
addByJson(dbCollection);

 

1.2 查询

/**
     * 条件查询：name 为 张三
     * @param dbCollection
     */
    public static void queryOne(DBCollection dbCollection){
        DBObject result = dbCollection.findOne(new BasicDBObject("name","张三"));
        System.out.println(result);
    }

    /**
     * 分页查询:跳过前2条后的3条数据
     * @param dbCollection
     */
    public static void queryPage(DBCollection dbCollection){
        DBCursor cursor = dbCollection.find().skip(2).limit(3);
        //遍历输出结果
        while (cursor.hasNext()) {
            System.out.println(cursor.next());
        }
    }
    /**
     * 范围查询：第3条 到 第5条 之间的记录
     * @param dbCollection
     * 大于 - $gt
     * 小于 - $lt
     * 大于等于 - $gte
     * 小于等于 - $lte
     */
    public static void queryRange(DBCollection dbCollection) {
        DBObject range = new BasicDBObject();
        range.put("$gte", 28);
        range.put("$lte", 32);

        DBObject dbObject = new BasicDBObject();
        dbObject.put("age", range);
        DBCursor cursor = dbCollection.find(dbObject);
        while (cursor.hasNext()) {
            System.out.println(cursor.next());
        }
    }

    /**'
     *查询出全部的 记录
     * @param dbCollection
     */
    public static void queryList(DBCollection dbCollection) {
        DBCursor cursor = dbCollection.find();
        while(cursor.hasNext()){
            System.out.println(cursor.next());
        }
    }

方法调用以及运行结果

  //连接mongoDB,并打开数据库
        DBCollection dbCollection = MongDBUtile.getInstance(HOST,PORT).getDBCollection(DB_NAME, DBCOLLECTION_NAME);
        System.out.println("条件查询：name 为 张三");
        queryOne(dbCollection);
        System.out.println("跳过前2条后的3条数据");
        queryPage(dbCollection);
        System.out.println("age在50到52之间的记录");
        queryRange(dbCollection);
        System.out.println("查询出全部的记录");
        queryList(dbCollection);


*******************************运行结果*******************************

条件查询：name 为 张三
{ "_id" : { "$oid" : "5a50b3d6e6fbe9e658745f04"} , "name" : "张三" , "age" : 45 , "sex" : "男" , "address" : { "postCode" : 100000 , "street" : "深南大道888号" , "city" : "深圳"}}
跳过前2条后的3条数据
{ "_id" : { "$oid" : "5a50b41ae6fb51a28bf2b2d5"} , "hobby" : { "爱好" : [ "吃饭" , "睡觉" , "吃鸡"]}}
{ "_id" : { "$oid" : "5a50b41ae6fb51a28bf2b2d6"} , "name" : "老张" , "age" : 52 , "job" : "快递员" , "remark" : { "address" : "广东省深圳市" , "street" : "深南大道888号"}}
age在50到52之间的记录
{ "_id" : { "$oid" : "5a50b41ae6fb51a28bf2b2d6"} , "name" : "老张" , "age" : 52 , "job" : "快递员" , "remark" : { "address" : "广东省深圳市" , "street" : "深南大道888号"}}
查询出全部的记录
{ "_id" : { "$oid" : "5a50b3d6e6fbe9e658745f04"} , "name" : "张三" , "age" : 45 , "sex" : "男" , "address" : { "postCode" : 100000 , "street" : "深南大道888号" , "city" : "深圳"}}
{ "_id" : { "$oid" : "5a50b41ae6fb51a28bf2b2d4"} , "name" : "老王" , "remark" : [ "老王1" , "老王2"]}
{ "_id" : { "$oid" : "5a50b41ae6fb51a28bf2b2d5"} , "hobby" : { "爱好" : [ "吃饭" , "睡觉" , "吃鸡"]}}
{ "_id" : { "$oid" : "5a50b41ae6fb51a28bf2b2d6"} , "name" : "老张" , "age" : 52 , "job" : "快递员" , "remark" : { "address" : "广东省深圳市" , "street" : "深南大道888号"}}

 1.3 更新

 /**
     * 修改指定记录
     * @param dbCollection
     */
    public static void updateOne(DBCollection dbCollection) {
        // 先根据id查询将这条记录查询出来
        DBObject qryResult = dbCollection.findOne(new ObjectId("5a50b768e6fbda046406b255"));
        // 修改指定的值
        qryResult.put("age", 55);

        DBObject oldDBObject = new BasicDBObject();
        oldDBObject.put("_id", new ObjectId("5a50b768e6fbda046406b255"));
        dbCollection.update(oldDBObject, qryResult);
    }

    /**
     * 修改多条记录
     * @param dbCollection
     */
    public static void updateMulti(DBCollection dbCollection) {
        DBObject newDBObject = new BasicDBObject();
        newDBObject.put("name", "张三");
        newDBObject.put("address", "广东深圳");
        newDBObject.put("remark", "张三是一个man");

        DBObject oldDBObject = new BasicDBObject();
        oldDBObject.put("name", "张三");
        // 需要加上这个
        DBObject upsertValue = new BasicDBObject("$set", newDBObject);
        // 后面的两个参数：1.若所更新的数据没有，则插入 ; 2、同时更新多个符合条件的文档(collection)
        dbCollection.update(oldDBObject, upsertValue, true, true);
    }

方法调用以及运行结果

1.4 删除

    /**
     *删除第一个
     * @param dbCollection
     */
    public static void deleteFirst(DBCollection dbCollection){
        DBObject dbObject = dbCollection.findOne();
        dbCollection.remove(dbObject);
    }

    /**
     * 删除指定的一条记录
     * @param dbCollection
     */
    public static void deleteOne(DBCollection dbCollection){
        DBObject dbObject = new BasicDBObject();
        dbObject.put("_id", new ObjectId("5a50b41ae6fb51a28bf2b2d4"));
        dbCollection.remove(dbObject);
    }

    /**
     * 删除多条记录
     * 例如：select * from tb where name in('12','34')
     * @param dbCollection25      */
    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);
    }

    /**
     * 删除全部的记录
     * @param dbCollection
     */
    public static void deleteAll(DBCollection dbCollection){
        DBCursor cursor = dbCollection.find();
        while(cursor.hasNext()){
            dbCollection.remove(cursor.next());
        }
    }