文档章节

BaseDB MongoDb dao数据库操作类

hiyou
 hiyou
发布于 2014/08/30 15:27
字数 1124
阅读 23
收藏 0
package cn.ohalo.db.mongodb;

import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;
import java.util.ArrayList;
import java.util.List;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import com.alibaba.fastjson.util.TypeUtils;
import com.mongodb.BasicDBObject;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.WriteConcern;
import com.mongodb.WriteResult;

/**
 * 
 * @author halo
 * 
 */
public class BaseDb<T extends MongoBaseEntity> {

	public static Log logger = LogFactory.getLog(BaseDb.class);

	private DBCollection collection;

	private String collectionName;

	private Class<T> entityClass;

	public String getCollectionName() {
		return collectionName;
	}

	public void initDBCollection() {
		MongoConnection.initMongodb();
		MongoConnection.setWriteConcern(WriteConcern.SAFE);
	}

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

	public DBCollection getCollection() {
		return collection;
	}

	@SuppressWarnings("unchecked")
	public BaseDb() {
		initDBCollection();
		Type genericType = getClass().getGenericSuperclass();
		Type[] params = ((ParameterizedType) genericType)
				.getActualTypeArguments();
		entityClass = (Class<T>) params[0];
	}

	public T findOne() {
		return TypeUtils.castToJavaBean(collection.findOne().toMap(),
				entityClass);
	}

	/**
	 * 根据参数查询所有的文档信息
	 * 
	 * @param params
	 *            查询参数
	 * @return 返回文档集合
	 */
	public List<T> findAll(DBObject params) {
		return findAllAndSortAndLimit(params, null, null, null);
	}

	/**
	 * 根据参数查询所有的文档信息
	 * 
	 * @param params
	 *            查询参数
	 * @return 返回文档集合
	 */
	public List<T> findAll(T t) {
		return findAll(t == null ? null : t.toDBObject());
	}

	/**
	 * 查询所有的文档信息,并进行排序
	 * 
	 * @param params
	 *            查询参数
	 * @param sortparams
	 *            排序参数 1为正序排列 , -1为倒序排列
	 * @return 返回文档集合
	 */
	public List<T> findAllAndSort(DBObject params, DBObject sortparams) {
		return findAllAndSortAndLimit(params, sortparams, null, null);
	}

	/**
	 * 查询所有的文档信息,并进行排序
	 * 
	 * @param params
	 *            查询参数
	 * @param sortparams
	 *            排序参数 1为正序排列 , -1为倒序排列
	 * @return 返回文档集合
	 */
	public List<T> findAllAndSort(T t, DBObject sortparams) {
		return findAllAndSort(t == null ? null : t.toDBObject(), sortparams);
	}

	/**
	 * 查询符合条件的文档数量
	 * 
	 * @param params
	 *            查询参数
	 * @return
	 */
	public Long count(DBObject params) {
		return collection.count(params);
	}

	/**
	 * 查询符合条件的文档数量
	 * 
	 * @param params
	 *            查询参数
	 * @return
	 */
	public Long count(T t) {
		return count(t == null ? null : t.toDBObject());
	}

	/**
	 * 查询所有的文档记录信息,并且对这些信息进行排序和分页
	 * 
	 * @param params
	 *            查询参数
	 * @param sortparams
	 *            排序参数
	 * @param skip
	 *            从第几个位置开始
	 * @param limit
	 *            查询几条记录
	 * @return
	 */
	public List<T> findAllAndSortAndLimit(DBObject params, DBObject sortparams,
			Integer skip, Integer limit) {
		DBCursor cursor = null;
		if (params == null) {
			cursor = collection.find();
		} else {
			cursor = collection.find(params);
		}

		if (sortparams != null) {
			cursor = cursor.sort(sortparams);
		}

		if (skip != null) {
			cursor = cursor.skip(skip);
		}

		if (limit != null && limit > 0) {
			cursor = cursor.limit(limit);
		}

		List<T> list = new ArrayList<T>();
		while (cursor.hasNext()) {
			T t = TypeUtils.castToJavaBean(cursor.next().toMap(), entityClass);
			list.add(t);
		}
		return list;
	}

	/**
	 * 查询所有的文档记录信息,并且对这些信息进行排序和分页
	 * 
	 * @param params
	 *            查询参数
	 * @param sortparams
	 *            排序参数
	 * @param skip
	 *            从第几个位置开始
	 * @param limit
	 *            查询几条记录
	 * @return
	 */
	public List<T> findAllAndSortAndLimit(T t, DBObject sortparams,
			Integer skip, Integer limit) {
		return findAllAndSortAndLimit(t == null ? null : t.toDBObject(),
				sortparams, skip, limit);
	}

	/**
	 * 查询多条文档
	 * 
	 * @param objs
	 *            文档集合
	 * @return 返回插入的文档成功或者是失败 ,true 为成功, false 为失败
	 */
	public boolean insert(List<DBObject> objs) {
		boolean flag = false;
		try {
			WriteResult result = collection.insert(objs);
			if (result.getN() > 0) {
				flag = true;
			}
		} catch (Exception e) {
			logger.error("插入数据库出现异常,数据库名称:" + this.getCollectionName()
					+ ",插入参数:" + objs == null ? "null" : objs.toString(), e);
		}
		return flag;
	}

	/**
	 * 插入单条文档
	 * 
	 * @param obj
	 *            单个文档
	 * @return 返回插入的文档成功或者是失败 ,true 为成功, false 为失败
	 */
	public boolean insert(DBObject obj) {
		boolean flag = false;
		try {
			WriteResult result = collection.insert(obj);
			if (result.getN() > 0) {
				flag = true;
			}
		} catch (Exception e) {
			logger.error("插入数据库出现异常,数据库名称:" + this.getCollectionName()
					+ ",插入参数:" + obj == null ? "null" : obj.toString(), e);
		}
		return flag;
	}

	/**
	 * 插入更新数据库
	 * 
	 * @param obj
	 * @return
	 */
	public boolean saveOrUpdate(DBObject obj) {
		boolean flag = false;
		try {
			WriteResult result = collection.save(obj);
			if (result.getN() > 0) {
				flag = true;
			}
		} catch (Exception e) {
			logger.error("插入数据库或者是更新数据库出现异常,数据库名称:" + this.getCollectionName()
					+ ",插入参数:" + obj == null ? "null" : obj.toString(), e);
		}
		return flag;
	}

	/**
	 * 插入更新数据库
	 * 
	 * @param obj
	 * @return
	 */
	public boolean saveOrUpdate(T t) {
		return saveOrUpdate(t == null ? null : t.toDBObject());
	}

	/**
	 * 插入单条文档
	 * 
	 * @param obj
	 *            单个文档
	 * @return 返回插入的文档成功或者是失败 ,true 为成功, false 为失败
	 */
	public boolean insert(T t) {
		return insert(t == null ? null : t.toDBObject());
	}

	/**
	 * 更新文档信息
	 * 
	 * @param queryParams
	 *            查询参数
	 * @param obj
	 *            更新文档
	 * @return 返回插入的文档成功或者是失败 ,true 为成功, false 为失败
	 */
	public boolean update(DBObject queryParams, DBObject obj) {
		boolean flag = false;
		try {
			WriteResult result = collection.update(queryParams,
					new BasicDBObject().append("$set", obj), true, true);
			if (result.getN() > 0) {
				flag = true;
			}
		} catch (Exception e) {
			logger.error(
					"更新数据库出现异常,数据库名称:" + this.getCollectionName() + ",更新参数:"
							+ obj == null ? "null" : obj.toString() + ",查询参数:"
							+ queryParams == null ? "null" : queryParams
							.toString(), e);
		}
		return flag;
	}

	/**
	 * 更新文档信息
	 * 
	 * @param queryParams
	 *            查询参数
	 * @param obj
	 *            更新文档
	 * @return 返回插入的文档成功或者是失败 ,true 为成功, false 为失败
	 */
	public boolean update(DBObject queryParams, T t) {
		return update(queryParams, t == null ? null : t.toDBObject());
	}

	/**
	 * 删除数据库的文档信息
	 * 
	 * @param obj
	 * @return
	 */
	public boolean remove(DBObject obj) {
		boolean flag = false;
		try {
			WriteResult result = collection.remove(obj);
			if (result.getN() > 0) {
				flag = true;
			}
		} catch (Exception e) {
			logger.error("删除数据出现异常,数据库名称:" + this.getCollectionName()
					+ ",删除参数:" + obj == null ? "null" : obj.toString(), e);
		}
		return flag;
	}

	/**
	 * 删除数据库的文档信息
	 * 
	 * @param obj
	 * @return
	 */
	public boolean remove(T t) {
		return remove(t == null ? null : t.toDBObject());
	}

	/**
	 * 删除这个collection所有文档信息
	 */
	public void removeAll() {
		collection.drop();
	}
}


© 著作权归作者所有

hiyou

hiyou

粉丝 4
博文 57
码字总数 15203
作品 0
闵行
程序员
私信 提问
崛起于Springboot2.0.X之Mongodb多数据源处理(35)

多数据源:4个mongodb库! 目录结构图: 1、添加pom依赖 <dependency> </dependency><dependency> </dependency> <dependency> </dependency><dependency> </dependency> 2、application.pro......

木九天
2018/08/16
0
0
Spring Boot (八)MyBatis + Docker + MongoDB 4.x

一、MongoDB简介 1.1 MongoDB介绍 MongoDB是一个强大、灵活,且易于扩展的通用型数据库。MongoDB是C++编写的文档型数据库,有着丰富的关系型数据库的功能,并在4.0之后添加了事务支持。 随着...

王磊的博客
2018/10/08
0
0
MongoDB在spring中xml传统配置

背景 旧项目中依然在使用springmvc的xml传统配置,最近需要使用MongoDB,需要在spring引入MongoDB的连接配置。 解决 配置mongodb数据库 配置mongodb数据工厂 配置mongodb的Template 配置mon...

亚林瓜子
2018/06/12
0
0
在ASP.NET Core 2.0上操作MongoDB就是能这么的简便酷爽(自动完成分库分表)

NoSQL是泛指非关系型的数据库,现今在我们的项目中也多有使用,其独特的优点为我们的项目架构带来了不少亮点,而我们这里的主角(MongoDB)则是NoSQL数据库家族中的一种。事实上,NoSQL数据库...

Andre-Hub
2018/09/27
0
0
使用MongoDB的支持Linq 驱动NoRM

MongoDB的驱动有好几个,分布式文件存储的数据库开源项目MongoDB里使用的是github.com/samus/mongodb-csharp,monogodb-csharp不是强类型,使用起来不方便。转向使用支持强类型访问MongoDB的...

鉴客
2011/06/24
876
1

没有更多内容

加载失败,请刷新页面

加载更多

分布式架构 实现分布式锁的常见方式

一、我们为什么需要分布式锁? 在单机时代,虽然不需要分布式锁,但也面临过类似的问题,只不过在单机的情况下,如果有多个线程要同时访问某个共享资源的时候,我们可以采用线程间加锁的机制...

太猪-YJ
42分钟前
3
0
GitLab Docker 安装记录

安装环境 环境Centos7.4 64 1.拉取镜像文件 docker pull gitlab/gitlab-ce:latest 2.docker 安装 git.zddts.com 为访问域名或换成可以访问的IP docker run -d --hostname git.***.com -p ......

侠者圣
今天
0
0
部署kubernates dashboard

参考官方文档: https://github.com/kubernetes/dashboard 直接部署官方默认的dashboard: kubectl apply -f https://raw.githubusercontent.com/kubernetes/dashboard/v1.10.1/src/deploy/r......

猫海豚
今天
0
0
Docker中Redis的安装

一、下载镜像 docker pull redis 二、创建外挂目录及配置 mkdir /opt/docker/redismkdir /opt/docker/redis/confmkdir /opt/docker/redis/data 三、安装 docker run -d --name compose_r......

闊苡訆涐囍醣
今天
0
0
JNI内存泄露处理方法汇总

在c++中new的对象,如果不返回java,必须用release掉,否则内存泄露。包括NewStringUTF,NewObject。如果返回java不必release,java会自己回收。   jstring jstr = env->NewStringUTF((*p)....

shzwork
今天
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部