`

java操作MongoDB工具类分享

MongoDBjava 
阅读更多

最近做了个用MongoDB存储的项目，由于MongoDB对开发人员不开放，由DBA统一管理。因此，自己抽时间写了个MongoDB的查询机。便于查询项目中的数据，方便维护和分析问题。总结了一些java操作MongoDB的方法。本文没有使用spring-data来操作MongoDB。而是直接使用MongoDB for java的原始API。现在介绍一下工具类。

1.准备工作

MongoDB的安装，不多做介绍。

MongoDB的java驱动

 

      <dependency>
            <groupId>org.mongodb</groupId>
            <artifactId>mongo-java-driver</artifactId>
            <version>2.11.3</version>
        </dependency>

 测试的集合：

2.封装实体介绍

 

  • MongoDBCursor——MongoDB条件查询封装实体（支持limit，skip，sort）
  • MongoDBEntity——MongoDB集合封装实体
  • MongoDBUpdate——MongoDB更新封装实体

MongoDBCursor

 

import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;

import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.Map;

/**
 * MongoDB条件查询封装实体（支持limit，skip，sort）
 *
 * @author: alex
 * @time: 14-1-21 下午5:00
 * @version: 1.0
 */
public class MongoDBCursor extends MongoDBEntity {

    /**
     * skip属性
     */
    private int skip;

    /**
     * limit属性
     */
    private int limit = 100;

    /**
     * 排序属性
     */
    private Map<String, Object> sort = new LinkedHashMap<String, Object>();

    /**
     * 自定义查询字段属性
     */
    private Map<String, Object> customFieldMap = new HashMap<String, Object>();

    public int getSkip() {
        return skip;
    }

    public void setSkip(int skip) {
        this.skip = skip;
    }

    public int getLimit() {
        return limit;
    }

    public void setLimit(int limit) {
        this.limit = limit;
    }

    public Map<String, Object> getSort() {
        return sort;
    }

    public void setSort(Map<String, Object> sort) {
        this.sort = sort;
    }

    public DBObject getSortObject() {
        if (this.sort == null) {
            return null;
        }
        DBObject dbo = new BasicDBObject();
        for (String k : sort.keySet()) {
            dbo.put(k, Integer.valueOf(sort.get(k).toString()));
        }
        return dbo;
    }

    public Map<String, Object> getCustomFieldMap() {
        return customFieldMap;
    }

    public void setCustomFieldMap(Map<String, Object> customFieldMap) {
        this.customFieldMap = customFieldMap;
    }
}

 MongoDBEntity

 

 

import com.mongodb.DB;

import java.util.Map;

/**
 * MongoDB集合封装实体
 *
 * @author: alex
 * @time: 14-1-20 下午2:57
 * @version: 1.0
 */
public class MongoDBEntity {

    /**
     * mongo数据库
     */
    private DB db;

    /**
     * 集合名字
     */
    private String collectionName;

    /**
     * 字段封装Map
     */
    private Map<String,Object> fieldMap;

    public DB getDb() {
        return db;
    }

    public void setDb(DB db) {
        this.db = db;
    }

    public String getCollectionName() {
        return collectionName;
    }

    public void setCollectionName(String collectionName) {
        this.collectionName = collectionName;
    }

    public Map<String, Object> getFieldMap() {
        return fieldMap;
    }

    public void setFieldMap(Map<String, Object> fieldMap) {
        this.fieldMap = fieldMap;
    }
}

 MongoDBUpdate 

 

 

import java.util.Map;

/**
 * MongoDB更新封装实体
 *
 * @author: alex
 * @time: 14-1-21 下午5:00
 * @version: 1.0
 */
public class MongoDBUpdate extends MongoDBEntity {

    /**
     * where查询Map
     */
    private Map<String, Object> whereMap;

    /**
     * value查询Map
     */
    private Map<String, Object> valueMap;

    public Map<String, Object> getWhereMap() {
        return whereMap;
    }

    public void setWhereMap(Map<String, Object> whereMap) {
        this.whereMap = whereMap;
    }

    public Map<String, Object> getValueMap() {
        return valueMap;
    }

    public void setValueMap(Map<String, Object> valueMap) {
        this.valueMap = valueMap;
    }
}

 

3.MongoDB操作类

  • MongoDBCommonUtil——MongoDB集合操作工作类
  • MongoDBUtil——MongoDBCRUD操作封装工具类

MongoDBCommonUtil

 

import com.mongodb.*;
import org.bson.types.BasicBSONList;
import org.bson.types.ObjectId;

import java.util.*;

/**
 * MongoDBCRUD操作封装工具类
 *
 * @author: alex
 * @time: 14-1-21 下午3:16
 * @version: 1.0
 */
public class MongoDBUtil {

    /**
     * 按主键查询单个实体
     *
     * @param id            主键
     * @param mongoDBCursor 查询实体
     * @return DBObject
     */
    public static DBObject findById(MongoDBCursor mongoDBCursor, String id) {
        Map<String, Object> map = new HashMap<String, Object>();
        map.put("_id", new ObjectId(id));
        mongoDBCursor.setFieldMap(map);
        return findOne(mongoDBCursor);
    }

    /**
     * 按条件查询单个
     *
     * @param mongoDBCursor 查询实体
     * @return DBObject
     */
    public static DBObject findOne(MongoDBCursor mongoDBCursor) {
        DBObject dbObject = getMapped(mongoDBCursor.getFieldMap());
        return MongoDBCommonUtil.getCollection(mongoDBCursor).findOne(dbObject);
    }

    /**
     * 查询全部
     *
     * @param mongoDBCursor 查询实体
     */
    public static List<DBObject> findAll(MongoDBCursor mongoDBCursor) {
        mongoDBCursor.setFieldMap(new HashMap<String, Object>());
        return find(mongoDBCursor);
    }


    /**
     * 按条件查询
     * 支持skip，limit,sort
     *
     * @param mongoDBCursor 查询实体
     */
    public static List<DBObject> find(MongoDBCursor mongoDBCursor) {
        DBObject dbObject = getMapped(mongoDBCursor.getFieldMap());
        BasicDBObjectBuilder customField = null;
        //自定义查询字段
        if(mongoDBCursor.getCustomFieldMap() != null && mongoDBCursor.getCustomFieldMap().size() > 0) {
            customField = new BasicDBObjectBuilder();
            for(Map.Entry<String, Object> field : mongoDBCursor.getCustomFieldMap().entrySet()) {
                customField.add(field.getKey(),field.getValue());
            }
        }
        return find(mongoDBCursor, dbObject, customField);
    }

    /**
     * 查询（私有方法,检查是否含有skip，limit，sort）
     *
     * @param dbObject      查询条件
     * @param mongoDBCursor 查询实体
     */
    private static List<DBObject> find(final MongoDBCursor mongoDBCursor, DBObject dbObject,BasicDBObjectBuilder customField) {
        MongoDBCursorPreparer cursorPreparer = mongoDBCursor == null ? null : new MongoDBCursorPreparer() {
            public DBCursor prepare(DBCursor dbCursor) {
                if (mongoDBCursor == null) {
                    return dbCursor;
                }
                if (mongoDBCursor.getLimit() <= 0 && mongoDBCursor.getSkip() <= 0 && mongoDBCursor.getSortObject() == null) {
                    return dbCursor;
                }
                DBCursor cursorToUse = dbCursor;
                if (mongoDBCursor.getSkip() > 0) {
                    cursorToUse = cursorToUse.skip(mongoDBCursor.getSkip());
                }
                if (mongoDBCursor.getLimit() > 0) {
                    cursorToUse = cursorToUse.limit(mongoDBCursor.getLimit());
                }
                if (mongoDBCursor.getSortObject() != null) {
                    cursorToUse = cursorToUse.sort(mongoDBCursor.getSortObject());
                }
                return cursorToUse;
            }
        };
        return find(mongoDBCursor, dbObject, cursorPreparer,customField);
    }

    /**
     * 查询（私有方法，真正的查询操作）
     *
     * @param query       查询条件
     * @param mongoDBCursor  查询实体
     * @param cursorPreparer 查询转换接口
     */
    private static List<DBObject> find(MongoDBCursor mongoDBCursor, DBObject query, MongoDBCursorPreparer cursorPreparer,BasicDBObjectBuilder customField) {
        DBCursor dbCursor = null;
        if(customField == null) {
            dbCursor = MongoDBCommonUtil.getCollection(mongoDBCursor).find(query);
        } else {
            dbCursor = MongoDBCommonUtil.getCollection(mongoDBCursor).find(query,customField.get());
        }
        if (cursorPreparer != null) {
            dbCursor = cursorPreparer.prepare(dbCursor);
        }
        return dbCursor.toArray();
    }

    /**
     * Count查询
     *
     * @param mongoDBCursor 查询实体
     * @return 总数
     */
    public static long count(MongoDBCursor mongoDBCursor) {
        DBObject dbObject = getMapped(mongoDBCursor.getFieldMap());
        return MongoDBCommonUtil.getCollection(mongoDBCursor).count(dbObject);

    }

    /**
     * 把参数Map转换DBObject
     *
     * @param map 查询条件
     * @return DBObject
     */
    private static DBObject getMapped(Map<String, Object> map) {
        DBObject dbObject = new BasicDBObject();
        Iterator<Map.Entry<String, Object>> iterable = map.entrySet().iterator();
        while (iterable.hasNext()) {
            Map.Entry<String, Object> entry = iterable.next();
            Object value = entry.getValue();
            String key = entry.getKey();
            if (key.startsWith("$") && value instanceof Map) {
                BasicBSONList basicBSONList = new BasicBSONList();
                Map<String, Object> conditionsMap = ((Map) value);
//                Set<String> keys = conditionsMap.keySet();
                for (String k : conditionsMap.keySet()) {
                    Object conditionsValue = conditionsMap.get(k);
                    if (conditionsValue instanceof Collection) {
                        conditionsValue = convertArray(conditionsValue);
                    }
                    DBObject dbObject2 = new BasicDBObject(k, conditionsValue);
                    basicBSONList.add(dbObject2);
                }
                value = basicBSONList;
            } else if (value instanceof Collection) {
                value = convertArray(value);
            } else if (!key.startsWith("$") && value instanceof Map) {
                value = getMapped(((Map) value));
            }
            dbObject.put(key, value);
        }
        return dbObject;
    }

    /**
     * 转换成Object[]
     *
     * @param value 待转换实体
     * @return Object[]
     */
    private static Object[] convertArray(Object value) {
        Object[] values = ((Collection) value).toArray();
        return values;
    }

    /**
     * 添加操作
     *
     * @param mongoDBEntity 实体
     */
    public static void add(MongoDBEntity mongoDBEntity) {
        DBObject dbObject = new BasicDBObject(mongoDBEntity.getFieldMap());
        MongoDBCommonUtil.getCollection(mongoDBEntity).insert(dbObject);
    }

    /**
     * 批量处理添加操作
     *
     * @param list          批量字段数据
     * @param mongoDBEntity 实体
     */
    public static void add(MongoDBEntity mongoDBEntity, List<Map<String, Object>> list) {
        for (Map<String, Object> map : list) {
            mongoDBEntity.setFieldMap(map);
            add(mongoDBEntity);
        }
    }

    /**
     * 删除操作
     *
     * @param mongoDBEntity 实体
     */
    public static void delete(MongoDBEntity mongoDBEntity) {
        DBObject dbObject = new BasicDBObject(mongoDBEntity.getFieldMap());
        MongoDBCommonUtil.getCollection(mongoDBEntity).remove(dbObject);
    }

    /**
     * 删除操作,根据主键
     *
     * @param id            主键
     * @param mongoDBEntity 实体
     */
    public static void delete(MongoDBEntity mongoDBEntity, String id) {
        Map<String, Object> map = new HashMap<String, Object>();
        map.put("_id", new ObjectId(id));
        mongoDBEntity.setFieldMap(map);
        delete(mongoDBEntity);
    }

    /**
     * 删除全部
     *
     * @param mongoDBEntity 实体
     */
    public static void deleteAll(MongoDBEntity mongoDBEntity) {
        MongoDBCommonUtil.getCollection(mongoDBEntity).drop();
    }

    /**
     * 修改操作
     * 会用一个新文档替换现有文档,文档key结构会发生改变
     * 比如原文档{"_id":"123","name":"zhangsan","age":12}当根据_id修改age
     * value为{"age":12}新建的文档name值会没有,结构发生了改变
     *
     * @param mongoDBUpdate 更新实体
     */
    public static void update(MongoDBUpdate mongoDBUpdate) {
        executeUpdate(mongoDBUpdate, new UpdateCallback() {
            public DBObject doCallback(DBObject valueDBObject) {
                return valueDBObject;
            }
        });
    }

    /**
     * 修改操作,使用$set修改器
     * 用来指定一个键值,如果键不存在,则自动创建,会更新原来文档, 不会生成新的, 结构不会发生改变
     *
     * @param mongoDBUpdate 更新实体
     */
    public static void updateSet(MongoDBUpdate mongoDBUpdate) {
        executeUpdate(mongoDBUpdate, new UpdateCallback() {
            public DBObject doCallback(DBObject valueDBObject) {
                return new BasicDBObject("$set", valueDBObject);
            }
        });
    }

    /**
     * 修改操作,使用$inc修改器
     * 修改器键的值必须为数字
     * 如果键存在增加或减少键的值, 如果不存在创建键
     *
     * @param mongoDBUpdate 更新实体
     */
    public static void updateInc(MongoDBUpdate mongoDBUpdate) {
        executeUpdate(mongoDBUpdate, new UpdateCallback() {
            public DBObject doCallback(DBObject valueDBObject) {
                return new BasicDBObject("$inc", valueDBObject);
            }
        });
    }

    /**
     * 修改(私有方法)
     *
     * @param mongoDBUpdate  更新实体
     * @param updateCallback 更新回调
     */
    private static void executeUpdate(MongoDBUpdate mongoDBUpdate, UpdateCallback updateCallback) {
        DBObject whereDBObject = new BasicDBObject(mongoDBUpdate.getWhereMap());
        DBObject valueDBObject = new BasicDBObject(mongoDBUpdate.getValueMap());
        valueDBObject = updateCallback.doCallback(valueDBObject);
        MongoDBCommonUtil.getCollection(mongoDBUpdate).update(whereDBObject, valueDBObject);
    }


    public static void main(String[] args) {
        try {
            //获取操作DB
            DB db = MongoDBCommonUtil.getDB("192.168.227.170", 20011,"lagd","lagd_rw","lagd_pwd");
            MongoDBCursor mongoDBCursor = new MongoDBCursor();
            mongoDBCursor.setDb(db);     //赋值DB
            mongoDBCursor.setCollectionName("lagd_data_dictionary");   //赋值集合名
            //封装查询条件
            Map<String, Object> fieldMap = new HashMap<String, Object>();
            fieldMap.put("type","dataSource");
            mongoDBCursor.setFieldMap(fieldMap);
            //赋值skip
            mongoDBCursor.setSkip(1);
            //赋值limit
            mongoDBCursor.setLimit(1);
            //封装Sort
            Map<String, Object> sortMap = new LinkedHashMap<String, Object>();
            sortMap.put("key",1);
            mongoDBCursor.setSort(sortMap);
            //查询
            List<DBObject> result = MongoDBUtil.find(mongoDBCursor);
            for(DBObject dbObject : result){
                for(String key : dbObject.keySet()){
                    System.out.println("key=" + key + ";  value=" + dbObject.get(key));
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

 MongoDBUtil

 

 

import com.mongodb.*;
import org.bson.types.BasicBSONList;
import org.bson.types.ObjectId;

import java.util.*;

/**
 * MongoDBCRUD操作封装工具类
 *
 * @author: alex
 * @time: 14-1-21 下午3:16
 * @version: 1.0
 */
public class MongoDBUtil {

    /**
     * 按主键查询单个实体
     *
     * @param id            主键
     * @param mongoDBCursor 查询实体
     * @return DBObject
     */
    public static DBObject findById(MongoDBCursor mongoDBCursor, String id) {
        Map<String, Object> map = new HashMap<String, Object>();
        map.put("_id", new ObjectId(id));
        mongoDBCursor.setFieldMap(map);
        return findOne(mongoDBCursor);
    }

    /**
     * 按条件查询单个
     *
     * @param mongoDBCursor 查询实体
     * @return DBObject
     */
    public static DBObject findOne(MongoDBCursor mongoDBCursor) {
        DBObject dbObject = getMapped(mongoDBCursor.getFieldMap());
        return MongoDBCommonUtil.getCollection(mongoDBCursor).findOne(dbObject);
    }

    /**
     * 查询全部
     *
     * @param mongoDBCursor 查询实体
     */
    public static List<DBObject> findAll(MongoDBCursor mongoDBCursor) {
        mongoDBCursor.setFieldMap(new HashMap<String, Object>());
        return find(mongoDBCursor);
    }


    /**
     * 按条件查询
     * 支持skip，limit,sort
     *
     * @param mongoDBCursor 查询实体
     */
    public static List<DBObject> find(MongoDBCursor mongoDBCursor) {
        DBObject dbObject = getMapped(mongoDBCursor.getFieldMap());
        BasicDBObjectBuilder customField = null;
        //自定义查询字段
        if(mongoDBCursor.getCustomFieldMap() != null && mongoDBCursor.getCustomFieldMap().size() > 0) {
            customField = new BasicDBObjectBuilder();
            for(Map.Entry<String, Object> field : mongoDBCursor.getCustomFieldMap().entrySet()) {
                customField.add(field.getKey(),field.getValue());
            }
        }
        return find(mongoDBCursor, dbObject, customField);
    }

    /**
     * 查询（私有方法,检查是否含有skip，limit，sort）
     *
     * @param dbObject      查询条件
     * @param mongoDBCursor 查询实体
     */
    private static List<DBObject> find(final MongoDBCursor mongoDBCursor, DBObject dbObject,BasicDBObjectBuilder customField) {
        MongoDBCursorPreparer cursorPreparer = mongoDBCursor == null ? null : new MongoDBCursorPreparer() {
            public DBCursor prepare(DBCursor dbCursor) {
                if (mongoDBCursor == null) {
                    return dbCursor;
                }
                if (mongoDBCursor.getLimit() <= 0 && mongoDBCursor.getSkip() <= 0 && mongoDBCursor.getSortObject() == null) {
                    return dbCursor;
                }
                DBCursor cursorToUse = dbCursor;
                if (mongoDBCursor.getSkip() > 0) {
                    cursorToUse = cursorToUse.skip(mongoDBCursor.getSkip());
                }
                if (mongoDBCursor.getLimit() > 0) {
                    cursorToUse = cursorToUse.limit(mongoDBCursor.getLimit());
                }
                if (mongoDBCursor.getSortObject() != null) {
                    cursorToUse = cursorToUse.sort(mongoDBCursor.getSortObject());
                }
                return cursorToUse;
            }
        };
        return find(mongoDBCursor, dbObject, cursorPreparer,customField);
    }

    /**
     * 查询（私有方法，真正的查询操作）
     *
     * @param query       查询条件
     * @param mongoDBCursor  查询实体
     * @param cursorPreparer 查询转换接口
     */
    private static List<DBObject> find(MongoDBCursor mongoDBCursor, DBObject query, MongoDBCursorPreparer cursorPreparer,BasicDBObjectBuilder customField) {
        DBCursor dbCursor = null;
        if(customField == null) {
            dbCursor = MongoDBCommonUtil.getCollection(mongoDBCursor).find(query);
        } else {
            dbCursor = MongoDBCommonUtil.getCollection(mongoDBCursor).find(query,customField.get());
        }
        if (cursorPreparer != null) {
            dbCursor = cursorPreparer.prepare(dbCursor);
        }
        return dbCursor.toArray();
    }

    /**
     * Count查询
     *
     * @param mongoDBCursor 查询实体
     * @return 总数
     */
    public static long count(MongoDBCursor mongoDBCursor) {
        DBObject dbObject = getMapped(mongoDBCursor.getFieldMap());
        return MongoDBCommonUtil.getCollection(mongoDBCursor).count(dbObject);

    }

    /**
     * 把参数Map转换DBObject
     *
     * @param map 查询条件
     * @return DBObject
     */
    private static DBObject getMapped(Map<String, Object> map) {
        DBObject dbObject = new BasicDBObject();
        Iterator<Map.Entry<String, Object>> iterable = map.entrySet().iterator();
        while (iterable.hasNext()) {
            Map.Entry<String, Object> entry = iterable.next();
            Object value = entry.getValue();
            String key = entry.getKey();
            if (key.startsWith("$") && value instanceof Map) {
                BasicBSONList basicBSONList = new BasicBSONList();
                Map<String, Object> conditionsMap = ((Map) value);
//                Set<String> keys = conditionsMap.keySet();
                for (String k : conditionsMap.keySet()) {
                    Object conditionsValue = conditionsMap.get(k);
                    if (conditionsValue instanceof Collection) {
                        conditionsValue = convertArray(conditionsValue);
                    }
                    DBObject dbObject2 = new BasicDBObject(k, conditionsValue);
                    basicBSONList.add(dbObject2);
                }
                value = basicBSONList;
            } else if (value instanceof Collection) {
                value = convertArray(value);
            } else if (!key.startsWith("$") && value instanceof Map) {
                value = getMapped(((Map) value));
            }
            dbObject.put(key, value);
        }
        return dbObject;
    }

    /**
     * 转换成Object[]
     *
     * @param value 待转换实体
     * @return Object[]
     */
    private static Object[] convertArray(Object value) {
        Object[] values = ((Collection) value).toArray();
        return values;
    }

    /**
     * 添加操作
     *
     * @param mongoDBEntity 实体
     */
    public static void add(MongoDBEntity mongoDBEntity) {
        DBObject dbObject = new BasicDBObject(mongoDBEntity.getFieldMap());
        MongoDBCommonUtil.getCollection(mongoDBEntity).insert(dbObject);
    }

    /**
     * 批量处理添加操作
     *
     * @param list          批量字段数据
     * @param mongoDBEntity 实体
     */
    public static void add(MongoDBEntity mongoDBEntity, List<Map<String, Object>> list) {
        for (Map<String, Object> map : list) {
            mongoDBEntity.setFieldMap(map);
            add(mongoDBEntity);
        }
    }

    /**
     * 删除操作
     *
     * @param mongoDBEntity 实体
     */
    public static void delete(MongoDBEntity mongoDBEntity) {
        DBObject dbObject = new BasicDBObject(mongoDBEntity.getFieldMap());
        MongoDBCommonUtil.getCollection(mongoDBEntity).remove(dbObject);
    }

    /**
     * 删除操作,根据主键
     *
     * @param id            主键
     * @param mongoDBEntity 实体
     */
    public static void delete(MongoDBEntity mongoDBEntity, String id) {
        Map<String, Object> map = new HashMap<String, Object>();
        map.put("_id", new ObjectId(id));
        mongoDBEntity.setFieldMap(map);
        delete(mongoDBEntity);
    }

    /**
     * 删除全部
     *
     * @param mongoDBEntity 实体
     */
    public static void deleteAll(MongoDBEntity mongoDBEntity) {
        MongoDBCommonUtil.getCollection(mongoDBEntity).drop();
    }

    /**
     * 修改操作
     * 会用一个新文档替换现有文档,文档key结构会发生改变
     * 比如原文档{"_id":"123","name":"zhangsan","age":12}当根据_id修改age
     * value为{"age":12}新建的文档name值会没有,结构发生了改变
     *
     * @param mongoDBUpdate 更新实体
     */
    public static void update(MongoDBUpdate mongoDBUpdate) {
        executeUpdate(mongoDBUpdate, new UpdateCallback() {
            public DBObject doCallback(DBObject valueDBObject) {
                return valueDBObject;
            }
        });
    }

    /**
     * 修改操作,使用$set修改器
     * 用来指定一个键值,如果键不存在,则自动创建,会更新原来文档, 不会生成新的, 结构不会发生改变
     *
     * @param mongoDBUpdate 更新实体
     */
    public static void updateSet(MongoDBUpdate mongoDBUpdate) {
        executeUpdate(mongoDBUpdate, new UpdateCallback() {
            public DBObject doCallback(DBObject valueDBObject) {
                return new BasicDBObject("$set", valueDBObject);
            }
        });
    }

    /**
     * 修改操作,使用$inc修改器
     * 修改器键的值必须为数字
     * 如果键存在增加或减少键的值, 如果不存在创建键
     *
     * @param mongoDBUpdate 更新实体
     */
    public static void updateInc(MongoDBUpdate mongoDBUpdate) {
        executeUpdate(mongoDBUpdate, new UpdateCallback() {
            public DBObject doCallback(DBObject valueDBObject) {
                return new BasicDBObject("$inc", valueDBObject);
            }
        });
    }

    /**
     * 修改(私有方法)
     *
     * @param mongoDBUpdate  更新实体
     * @param updateCallback 更新回调
     */
    private static void executeUpdate(MongoDBUpdate mongoDBUpdate, UpdateCallback updateCallback) {
        DBObject whereDBObject = new BasicDBObject(mongoDBUpdate.getWhereMap());
        DBObject valueDBObject = new BasicDBObject(mongoDBUpdate.getValueMap());
        valueDBObject = updateCallback.doCallback(valueDBObject);
        MongoDBCommonUtil.getCollection(mongoDBUpdate).update(whereDBObject, valueDBObject);
    }


    public static void main(String[] args) {
        try {
            //获取操作DB
            DB db = MongoDBCommonUtil.getDB("192.168.227.170", 20011,"lagd","lagd_rw","lagd_pwd");
            MongoDBCursor mongoDBCursor = new MongoDBCursor();
            mongoDBCursor.setDb(db);     //赋值DB
            mongoDBCursor.setCollectionName("lagd_data_dictionary");   //赋值集合名
            //封装查询条件
            Map<String, Object> fieldMap = new HashMap<String, Object>();
            fieldMap.put("type","dataSource");
            mongoDBCursor.setFieldMap(fieldMap);
            //赋值skip
            mongoDBCursor.setSkip(1);
            //赋值limit
            mongoDBCursor.setLimit(1);
            //封装Sort
            Map<String, Object> sortMap = new LinkedHashMap<String, Object>();
            sortMap.put("key",1);
            mongoDBCursor.setSort(sortMap);
            //自定义查询字段
            Map<String, Object> customFieldMap =  new LinkedHashMap<String, Object>();
            customFieldMap.put("type","1");
            customFieldMap.put("key","1");
            customFieldMap.put("value","1");
            mongoDBCursor.setCustomFieldMap(customFieldMap);
            //查询
            List<DBObject> result = MongoDBUtil.find(mongoDBCursor);
            for(DBObject dbObject : result){
                for(String key : dbObject.keySet()){
                    System.out.println("键：" + key + ";  值：" + dbObject.get(key));
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

 MongoDBCursorPreparer

import com.mongodb.DBCursor;

/**
 * 查询转换接口定义
 *
 * @author: alex
 * @time: 14-1-21 下午4:55
 * @version: 1.0
 */
public interface MongoDBCursorPreparer {

    DBCursor prepare(DBCursor cursor);
}

 UpdateCallback

import com.mongodb.DBObject;

/**
 * MongoDB更新操作接口定义
 *
 * @author: alex
 * @time: 14-1-21 下午5:25
 * @version: 1.0
 */
interface UpdateCallback {

    DBObject doCallback(DBObject valueDBObject);
}

 

  • 大小: 5.3 KB
分享到：
| Schema学习
评论
1 楼 MrwenQ 2014-07-14  
哥们，你这少个MongoDBCommonUtil类吧 怎么两个MongoDBUtil类呢？
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    java操作mongodb的工具类

    java操作mongodb的工具类,增删查改方法

    java 连接 MongoDB 工具类示例

    一款没有sql语句的数据库，感觉不错，就去看看，大量使用json保存数据的文档性数据，真的在bs开发不错的选择

    JAVA单例MongoDB工具类

    经常对MongoDB进行一些常用操作，为了方便起见将这些常用操作合并到一个工具类中，方便自己开发使用。 　没用Spring Data、Morphia等框架是为了减少学习、维护成本，另外自己直接JDBC方式的话可以更方便的控制操作...

    Java访问MongoDB实用工具类

    Java访问MongoDB的实用工具类，包括增、删、改、查、distinct、group、mapreduce等，具备常用的MongoDB操作，可以简化基于MongoDB的Java程序开发。

    mongodb java Driver

    mongodb java Driver,具体使用请看我的博客：http://blog.csdn.net/lablenet

    java中mongodb使用环境详细配置

    java中mongodb使用环境详细配置，主要是在Windows上（WinXP）安装、运行、安装Windows服务的笔记，以作备忘。

    java代码操作MongoDB

    运用mongo.jar开发JAVA代码操作数据库，内含一个基础的Test类，以及经过封装的工具类

    Mongodb底层java驱动框架工具类使用

    使用MongoDB需要对文档结构进行合理的设计，以满足某些特定需求。比如随机选取文档，使用skip跳过随机个文档就没有在文档中加个随机键， 然后使用某个随机数对文档进行查询高效，随机键还能添加索引，效率更高。合理...

    java操作geoserver的工具类GeoServer，配合geoserver-manager包使用

    java操作geoserver的工具类，包含mongodb和sqlserver创建数据存储的对象, 封装好了图层的shp发布，数据库空间表发布,图层列表查询，删除，发布样式，设置图层默认样式，发布带样式的空间表，删除样式，查询图层中心...

    java针对mongo操作的封装，完全面向对象，无需修改，可直接使用

    完全面向对象的mongo封装，maven工程源码，可直接install导出jar包引用，支持基本的增删改查和分页等，使用反射对javaBean实体进行映射，所有方法参数只需要传javaBean就行了，支持带密码连接,即拿即用，无需修改。

    Mongodb网页管理工具，基于Spring Boot2.0实现

    源于线上环境部署mongodb时屏蔽了外网访问mongodb,所以使用不了mongochef这样方便的远程连接工具，便Mongodb提供的java api实现的的网页版管理。 未设置登录权限相关模块，低耦合性 方便嵌入到现有的项目。

    Java单例模式下的MongoDB数据库操作工具类

    主要介绍了Java单例模式下的MongoDB数据库操作工具类,结合实例形式分析了java基于单例模式下操作MongoDB数据库相关连接、查询、插入、删除等操作封装技巧,需要的朋友可以参考下

    JAVA工具类

    MongodbUtils - 操作mongodb的工具类 email EmailUtils - 邮件工具类，支持发送带附件的邮件 encryption AesUtils - 实现AES加密解密 Base64Utils - 实现Base64加密解密 Md5Utils - 获取字符串或文件的md5 ...

    java的MongoUtil

    java操作mongodb的util工具类，其中主要包括了增删改查

    mongodb工具类

    Mongo DB 是目前在IT行业非常流行的一种非关系型数据库(NoSql),其灵活的数据存储方式备受当前IT...Mongo DB最大的优势在于所有的数据持久操作都无需开发人员手动编写SQL语句,直接调用方法就可以轻松的实现CRUD操作。

    spring-data-mongodb-1.7.0

    包括spring-data-mongodb-1.7.0.jar、spring-data-commons-1.10.0.RELEASE.jar、spring-data-commons-core-1.4.1.RELEASE.jar、mongo-java-driver-3.0.1.jar 对应支持的mongoDB版本为3.0.3，自己整理好的方便大家...

    spring-data-mongodb增强工具包，简化 CRUD 操作，提供类mybatis plus的数据库操作体验

    spring-data-mongodb增强工具包，简化 CRUD 操作，提供类mybatis plus的数据库操作。传统关系型数据库及围绕它们构建的orm在项目开发中有很多难用的痛点，而mongodb这种文档性数据库的出现，完美的解决了sql数据库在...

    springboot整合mongodb

    mongodb版本号3.2,需手动开启http服务，启动时使用命令 ./mongod --httpinterface 新增 修改 删除 查询 排序 分页 可查看： https://blog.csdn.net/m0_37132783/article/details/96992439

    mongoDB java demo

    mongoDB java demo,博客地址：http://blog.csdn.net/qq5132834/article/details/53045418

    mongoTemplate工具类Dao层方法封装.zip

    该资源内容主要包含：两个版本常用mongoTemplate操作数据库集合语句的整理

Magicbox
Global site tag (gtag.js) - Google Analytics