Java访问MongoDB实用工具类

package com.dao.db.mongodb; import java.util.List; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import com.mongodb.BasicDBList; import com.mongodb.BasicDBObject; import com.mongodb.DB; import com.mongodb.DBCollection; import com.mongodb.DBCursor; import com.mongodb.DBObject; //import com.mongodb.MapReduceCommand; //import com.mongodb.MapReduceOutput; import com.mongodb.Mongo; import com.util.CommUtil; public class MongoDBManager { private Mongo mg = null; private DB db = null; private final static Map<String, MongoDBManager> instances = new ConcurrentHashMap<String, MongoDBManager>(); /** * 实例化 * * @return MongoDBManager对象 */ static { getInstance("db");// 初始化默认的MongoDB数据库 } public static MongoDBManager getInstance() { return getInstance("db");// 配置文件默认数据库前缀为db } public static MongoDBManager getInstance(String dbName) { MongoDBManager mm = instances.get(dbName); if (mm == null) { mm = getNewInstance(dbName); instances.put(dbName, mm); } return mm; } private static synchronized MongoDBManager getNewInstance(String dbName) { MongoDBManager mm = new MongoDBManager(); try { mm.mg = new Mongo(getProperty("mongodb.properties", dbName + ".host"), Integer.parseInt(getProperty( "mongodb.properties", dbName + ".port"))); mm.db = mm.mg.getDB(getProperty("mongodb.properties", dbName + ".dbname")); } catch (Exception e) { System.out.print("Can't connect " + dbName + " MongoDB!"); } return mm; } /** * 根据properties文件的key获取value * * @param filePath * properties文件路径 * @param key * 属性key * @return 属性value */ private static String getProperty(String filePath, String key) { Properties props = new Properties(); try { InputStream in = new BufferedInputStream(new FileInputStream(filePath)); props.load(in); String value = props.getProperty(key); return value; } catch (Exception e) { return null; } } /** * 获取集合（表） * * @param collection */ public DBCollection getCollection(String collection) { return this.db.getCollection(collection); } /** * ----------------------------------分割线------------------------------------ */ /** * 插入 * * @param collection * @param o * 插入 */ public void insert(String collection, DBObject o) { getCollection(collection).insert(o); } /** * 批量插入 * * @param collection * @param list * 插入的列表 */ public void insertBatch(String collection, List<DBObject> list) { if (list == null || list.isEmpty()) { return; } getCollection(collection).insert(list); } /** * 删除 * * @param collection * @param q * 查询条件 */ public void delete(String collection, DBObject q) { getCollection(collection).remove(q); } /** * 批量删除 * * @param collection * @param list * 删除条件列表 */ public void deleteBatch(String collection, List<DBObject> list) { if (list == null || list.isEmpty()) { return; } for (int i = 0; i < list.size(); i++) { getCollection(collection).remove(list.get(i)); } } /** * 计算集合总条数 * * @param collection */ public long getCount(String collection) { return getCollection(collection).find().count(); } /** * 计算满足条件条数 * * @param collection * @param q * 查询条件 */ public long getCount(String collection, DBObject q) { return getCollection(collection).getCount(q); } /** * 更新 * * @param collection * @param q * 查询条件 * @param setFields * 更新对象 */ public void update(String collection, DBObject q, DBObject setFields) { getCollection(collection).updateMulti(q, new BasicDBObject("$set", setFields)); } /** * 查找集合所有对象 * * @param collection */ public List<DBObject> findAll(String collection) { return getCollection(collection).find().toArray(); } /** * 按顺序查找集合所有对象 * * @param collection * 数据集 * @param orderBy * 排序 */ public List<DBObject> findAll(String collection, DBObject orderBy) { return getCollection(collection).find().sort(orderBy) .toArray(); } /** * 查找（返回一个对象） * * @param collection * @param q * 查询条件 */ public DBObject findOne(String collection, DBObject q) { return getCollection(collection).findOne(q); } /** * 查找（返回一个对象） * * @param collection * @param q * 查询条件 * @param fileds * 返回字段 */ public DBObject findOne(String collection, DBObject q, DBObject fileds) { return getCollection(collection).findOne(q, fileds); } /** * 查找返回特定字段（返回一个List<DBObject>） * * @param collection * @param q * 查询条件 * @param fileds * 返回字段 */ public List<DBObject> findLess(String collection, DBObject q, DBObject fileds) { DBCursor c = getCollection(collection).find(q, fileds); if (c != null) return c.toArray(); else return null; } /** * 查找返回特定字段（返回一个List<DBObject>） * * @param collection * @param q * 查询条件 * @param fileds * 返回字段 * @param orderBy * 排序 */ public List<DBObject> findLess(String collection, DBObject q, DBObject fileds, DBObject orderBy) { DBCursor c = getCollection(collection).find(q, fileds).sort(orderBy); if (c != null) return c.toArray(); else return null; } /** * 分页查找集合对象，返回特定字段 * * @param collection * @param q * 查询条件 * @param fileds * 返回字段 * @pageNo 第n页 * @perPageCount 每页记录数 */ public List<DBObject> findLess(String collection, DBObject q, DBObject fileds, int pageNo, int perPageCount) { return getCollection(collection).find(q, fileds) .skip((pageNo - 1) * perPageCount).limit(perPageCount) .toArray(); } /** * 按顺序分页查找集合对象，返回特定字段 * * @param collection * 集合 * @param q * 查询条件 * @param fileds * 返回字段 * @param orderBy * 排序 * @param pageNo * 第n页 * @param perPageCount * 每页记录数 */ public List<DBObject> findLess(String collection, DBObject q, DBObject fileds, DBObject orderBy, int pageNo, int perPageCount) { return getCollection(collection).find(q, fileds) .sort(orderBy).skip((pageNo - 1) * perPageCount) .limit(perPageCount).toArray(); } /** * 查找（返回一个List<DBObject>） * * @param collection * @param q * 查询条件 */ public List<DBObject> find(String collection, DBObject q) { DBCursor c = getCollection(collection).find(q); if (c != null) return c.toArray(); else return null; } /** * 按顺序查找（返回一个List<DBObject>） * * @param collection * @param q * 查询条件 * @param orderBy * 排序 */ public List<DBObject> find(String collection, DBObject q, DBObject orderBy) { DBCursor c = getCollection(collection).find(q).sort(orderBy); if (c != null) return c.toArray(); else return null; } /** * 分页查找集合对象 * *