Skip to content

M
midjourney-proxy
Commit 8f2b65ad by zhangyang
Options

feat:[none] 调用sessionTemplate统一改成方法形式以便子类自定义

parent 34ab6f0e
Showing with 353 additions and 349 deletions
pcloud-common-core/src/main/java/com/pcloud/common/core/dao/BaseDaoImpl.java
package com.pcloud.common.core.dao;
import java.sql.Connection;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import com.pcloud.common.utils.string.StringUtil;
import org.apache.ibatis.jdbc.SqlRunner;
import org.apache.ibatis.session.RowBounds;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionTemplate;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import com.alibaba.druid.pool.DruidDataSource;
import com.pcloud.common.core.mybatis.interceptor.ExecutorInterceptor;
import com.pcloud.common.entity.BaseEntity;
import com.pcloud.common.exceptions.BizException;
import com.pcloud.common.page.PageBean;
import com.pcloud.common.page.PageBeanNew;
import com.pcloud.common.page.PageParam;
/**
* @描述：数据访问层基础支撑类. @作者：DiSeng.H
* @创建时间：2016年3月11日,下午4:03:36 @版本：1.0
*/
public abstract class BaseDaoImpl<T extends BaseEntity> implements BaseDao<T> {
protected static final Logger logger = LoggerFactory.getLogger(BaseDaoImpl.class);
public static final String SQL_INSERT = "insert";
public static final String SQL_BATCH_INSERT = "batchInsert";
public static final String SQL_UPDATE = "update";
public static final String SQL_GET_BY_ID = "getById";
public static final String SQL_DELETE_BY_ID = "deleteById";
public static final String SQL_LIST_PAGE = "listPage";
public static final String SQL_LIST_BY = "listBy";
public static final String SQL_COUNT_BY_PAGE_PARAM = "countByPageParam"; // 根据当前分页参数进行统计
/**
* 注入SqlSessionTemplate实例(要求Spring中进行SqlSessionTemplate的配置).<br/>
* 可以调用sessionTemplate完成数据库操作.
*/
@Autowired
protected SqlSessionTemplate sqlSessionTemplate;
@Autowired
protected SqlSessionFactory sqlSessionFactory;
@Autowired
private DruidDataSource druidDataSource;
public SqlSessionTemplate getSessionTemplate() {
return sqlSessionTemplate;
}
public SqlSession getSqlSession() {
return sqlSessionTemplate;
}
public long insert(T t) {
if (t == null)
throw new RuntimeException("T is null");
int result = sqlSessionTemplate.insert(getStatement(SQL_INSERT), t);
if (result <= 0)
throw BizException.DB_INSERT_RESULT_0;
if (t != null && t.getId() != null && result > 0)
return t.getId();
return result;
}
public long insert(List<T> list) {
if (list == null || list.size() <= 0)
return 0;
int result = sqlSessionTemplate.insert(getStatement(SQL_BATCH_INSERT), list);
if (result <= 0)
throw BizException.DB_INSERT_RESULT_0;
return result;
}
public long update(T t) {
if (t == null)
throw new RuntimeException("T is null");
int result = sqlSessionTemplate.update(getStatement(SQL_UPDATE), t);
if (result <= 0)
throw BizException.DB_UPDATE_RESULT_0;
return result;
}
public long update(T t, String sqlId) {
if (t == null)
throw new RuntimeException("T is null");
int result = 0;
try {
result = sqlSessionTemplate.update(getStatement(sqlId), t);
} catch (Exception e) {
logger.error("update fail[" + sqlId + "]:" + e.getMessage(), e);
throw BizException.DB_DML_FAIL;
}
if (result <= 0)
throw BizException.DB_UPDATE_RESULT_0;
return result;
}
public long update(T t, String sqlId, String errorMessage) {
if (t == null)
throw new RuntimeException("T is null");
int result = 0;
try {
result = sqlSessionTemplate.update(getStatement(sqlId), t);
} catch (Exception e) {
logger.error("update fail[" + sqlId + "]:" + e.getMessage(), e);
throw BizException.DB_DML_FAIL;
}
if (result <= 0) {
if (StringUtil.isEmpty(errorMessage))
throw BizException.DB_UPDATE_RESULT_0;
else
throw new BizException(10000, errorMessage);
}
return result;
}
public long update(List<T> list) {
if (list == null || list.size() <= 0)
return 0;
int result = 0;
for (int i = 0; i < list.size(); i++) {
this.update(list.get(i));
result += 1;
}
if (result <= 0)
throw BizException.DB_UPDATE_RESULT_0;
return result;
}
public T getById(long id) {
return sqlSessionTemplate.selectOne(getStatement(SQL_GET_BY_ID), id);
}
public long deleteById(long id) {
return (long) sqlSessionTemplate.delete(getStatement(SQL_DELETE_BY_ID), id);
}
public PageBean listPage(PageParam pageParam, Map<String, Object> paramMap, String sqlId) {
if (paramMap == null)
paramMap = new HashMap<String, Object>();
// 获取分页数据集 , 注切勿换成 sessionTemplate 对象
List<Object> list = getSqlSession().selectList(getStatement(sqlId), paramMap,
new RowBounds(pageParam.getPageNum() * pageParam.getNumPerPage(), pageParam.getNumPerPage()));
// 统计总记录数
Object countObject = (Object) getSqlSession().selectOne(getStatement(sqlId),
new ExecutorInterceptor.CountParameter(paramMap));
Long count = Long.valueOf(countObject.toString());
return new PageBean(pageParam.getPageNum(), pageParam.getNumPerPage(), count.intValue(), list);
}
public <C> PageBeanNew<C> listPageNew(PageParam pageParam, Map<String, Object> paramMap, String sqlId) {
if (paramMap == null)
paramMap = new HashMap<String, Object>();
// 获取分页数据集 , 注切勿换成 sessionTemplate 对象
List<C> list = getSqlSession().selectList(getStatement(sqlId), paramMap,
new RowBounds(pageParam.getPageNum() * pageParam.getNumPerPage(), pageParam.getNumPerPage()));
// 统计总记录数
Integer count = getSqlSession().selectOne(getStatement(sqlId),
new ExecutorInterceptor.CountParameter(paramMap));
return new PageBeanNew<C>(pageParam.getPageNum(), pageParam.getNumPerPage(), count, list);
}
public PageBean listPage(PageParam pageParam, Map<String, Object> paramMap, String sqlId, String countSqlId) {
if (paramMap == null)
paramMap = new HashMap<String, Object>();
// 获取分页数据集 , 注切勿换成 sessionTemplate 对象
List<Object> list = getSqlSession().selectList(getStatement(sqlId), paramMap,
new RowBounds(pageParam.getPageNum() * pageParam.getNumPerPage(), pageParam.getNumPerPage()));
// 统计总记录数
Object countObject = getSqlSession().selectOne(getStatement(countSqlId), paramMap);
Long count = Long.valueOf(countObject.toString());
return new PageBean(pageParam.getPageNum(), pageParam.getNumPerPage(), count.intValue(), list);
}
public <C> PageBeanNew<C> listPageNew(PageParam pageParam, Map<String, Object> paramMap, String sqlId,
String countSqlId) {
if (paramMap == null)
paramMap = new HashMap<String, Object>();
// 获取分页数据集 , 注切勿换成 sessionTemplate 对象
List<C> list = getSqlSession().selectList(getStatement(sqlId), paramMap,
new RowBounds(pageParam.getPageNum() * pageParam.getNumPerPage(), pageParam.getNumPerPage()));
// 统计总记录数
Object countObject = getSqlSession().selectOne(getStatement(countSqlId), paramMap);
Long count = Long.valueOf(countObject.toString());
return new PageBeanNew<C>(pageParam.getPageNum(), pageParam.getNumPerPage(), count.intValue(), list);
}
public PageBean listSimplePage(PageParam pageParam, Map<String, Object> paramMap, String sqlId) {
if (paramMap == null)
paramMap = new HashMap<String, Object>();
// 获取分页数据集 , 注切勿换成 sessionTemplate 对象
List<Object> list = getSqlSession().selectList(getStatement(sqlId), paramMap,
new RowBounds(pageParam.getPageNum() * pageParam.getNumPerPage(), pageParam.getNumPerPage() + 1));
return new PageBean(pageParam.getPageNum(), pageParam.getNumPerPage(), list);
}
public PageBean listPage(PageParam pageParam, Map<String, Object> paramMap) {
if (paramMap == null)
paramMap = new HashMap<String, Object>();
// 获取分页数据集 , 注切勿换成 sessionTemplate 对象
List<Object> list = getSqlSession().selectList(getStatement(SQL_LIST_PAGE), paramMap,
new RowBounds(pageParam.getPageNum() * pageParam.getNumPerPage(), pageParam.getNumPerPage()));
// 统计总记录数
Object countObject = (Object) getSqlSession().selectOne(getStatement(SQL_LIST_PAGE),
new ExecutorInterceptor.CountParameter(paramMap));
Long count = Long.valueOf(countObject.toString());
// 是否统计当前分页条件下的数据：1:是，其他为否
Object isCount = paramMap.get("isCount");
if (isCount != null && "1".equals(isCount.toString())) {
Map<String, Object> countResultMap = sqlSessionTemplate.selectOne(getStatement(SQL_COUNT_BY_PAGE_PARAM),
paramMap);
return new PageBean(pageParam.getPageNum(), pageParam.getNumPerPage(), count.intValue(), list,
countResultMap);
} else {
return new PageBean(pageParam.getPageNum(), pageParam.getNumPerPage(), count.intValue(), list);
}
}
@SuppressWarnings({"rawtypes", "unchecked"})
public List<T> listBy(Map<String, Object> paramMap) {
return (List) this.listBy(paramMap, SQL_LIST_BY);
}
public List<Object> listBy(Map<String, Object> paramMap, String sqlId) {
if (paramMap == null)
paramMap = new HashMap<String, Object>();
return sqlSessionTemplate.selectList(getStatement(sqlId), paramMap);
}
@SuppressWarnings("unchecked")
public T getBy(Map<String, Object> paramMap) {
return (T) this.getBy(paramMap, SQL_LIST_BY);
}
public Object getBy(Map<String, Object> paramMap, String sqlId) {
if (paramMap == null || paramMap.isEmpty())
return null;
return this.getSqlSession().selectOne(getStatement(sqlId), paramMap);
}
public String getStatement(String sqlId) {
String name = this.getClass().getName();
StringBuffer sb = new StringBuffer().append(name).append(".").append(sqlId);
return sb.toString();
}
/**
* 根据序列名称,获取序列值
*/
public String getSeqNextValue(String seqName) {
boolean isClosedConn = false;
// 获取当前线程的连接
Connection connection = this.sqlSessionTemplate.getConnection();
// 获取Mybatis的SQLRunner类
SqlRunner sqlRunner = null;
try {
// 要执行的SQL
String sql = "";
// 数据库驱动类
String driverClass = druidDataSource.getDriver().getClass().getName();
// 不同的数据库,拼接SQL语句
if (driverClass.equals("com.ibm.db2.jcc.DB2Driver")) {
sql = " VALUES " + seqName.toUpperCase() + ".NEXTVAL";
}
if (driverClass.equals("oracle.jdbc.OracleDriver")) {
sql = "SELECT " + seqName.toUpperCase() + ".NEXTVAL FROM DUAL";
}
if (driverClass.equals("com.mysql.jdbc.Driver")) {
sql = "SELECT FUN_SEQ('" + seqName.toUpperCase() + "')";
}
// 如果状态为关闭,则需要从新打开一个连接
if (connection.isClosed()) {
connection = sqlSessionFactory.openSession().getConnection();
isClosedConn = true;
}
sqlRunner = new SqlRunner(connection);
Object[] args = {};
// 执行SQL语句
Map<String, Object> params = sqlRunner.selectOne(sql, args);
for (Object o : params.values()) {
return o.toString();
}
return null;
} catch (Exception e) {
throw BizException.DB_GET_SEQ_NEXT_VALUE_ERROR.newInstance("获取序列出现错误!序列名称:{%s}", seqName);
} finally {
if (isClosedConn) {
sqlRunner.closeConnection();
}
}
}
}
package com.pcloud.common.core.dao;
import java.sql.Connection;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import com.pcloud.common.utils.string.StringUtil;
import org.apache.ibatis.jdbc.SqlRunner;
import org.apache.ibatis.session.RowBounds;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionTemplate;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import com.alibaba.druid.pool.DruidDataSource;
import com.pcloud.common.core.mybatis.interceptor.ExecutorInterceptor;
import com.pcloud.common.entity.BaseEntity;
import com.pcloud.common.exceptions.BizException;
import com.pcloud.common.page.PageBean;
import com.pcloud.common.page.PageBeanNew;
import com.pcloud.common.page.PageParam;
/**
* @描述：数据访问层基础支撑类. @作者：DiSeng.H
* @创建时间：2016年3月11日,下午4:03:36 @版本：1.0
*/
public abstract class BaseDaoImpl<T extends BaseEntity> implements BaseDao<T> {
protected static final Logger logger = LoggerFactory.getLogger(BaseDaoImpl.class);
public static final String SQL_INSERT = "insert";
public static final String SQL_BATCH_INSERT = "batchInsert";
public static final String SQL_UPDATE = "update";
public static final String SQL_GET_BY_ID = "getById";
public static final String SQL_DELETE_BY_ID = "deleteById";
public static final String SQL_LIST_PAGE = "listPage";
public static final String SQL_LIST_BY = "listBy";
public static final String SQL_COUNT_BY_PAGE_PARAM = "countByPageParam"; // 根据当前分页参数进行统计
/**
* 注入SqlSessionTemplate实例(要求Spring中进行SqlSessionTemplate的配置).<br/>
* 可以调用sessionTemplate完成数据库操作.
*/
@Autowired
protected SqlSessionTemplate sqlSessionTemplate;
@Autowired
protected SqlSessionFactory sqlSessionFactory;
@Autowired
private DruidDataSource druidDataSource;
public SqlSessionTemplate getSessionTemplate() {
return sqlSessionTemplate;
}
public SqlSessionFactory getSqlSessionFactory() {
return sqlSessionFactory;
}
public SqlSession getSqlSession() {
return sqlSessionTemplate;
}
public long insert(T t) {
if (t == null)
throw new RuntimeException("T is null");
int result = getSessionTemplate().insert(getStatement(SQL_INSERT), t);
if (result <= 0)
throw BizException.DB_INSERT_RESULT_0;
if (t != null && t.getId() != null && result > 0)
return t.getId();
return result;
}
public long insert(List<T> list) {
if (list == null || list.size() <= 0)
return 0;
int result = getSessionTemplate().insert(getStatement(SQL_BATCH_INSERT), list);
if (result <= 0)
throw BizException.DB_INSERT_RESULT_0;
return result;
}
public long update(T t) {
if (t == null)
throw new RuntimeException("T is null");
int result = getSessionTemplate().update(getStatement(SQL_UPDATE), t);
if (result <= 0)
throw BizException.DB_UPDATE_RESULT_0;
return result;
}
public long update(T t, String sqlId) {
if (t == null)
throw new RuntimeException("T is null");
int result = 0;
try {
result = getSessionTemplate().update(getStatement(sqlId), t);
} catch (Exception e) {
logger.error("update fail[" + sqlId + "]:" + e.getMessage(), e);
throw BizException.DB_DML_FAIL;
}
if (result <= 0)
throw BizException.DB_UPDATE_RESULT_0;
return result;
}
public long update(T t, String sqlId, String errorMessage) {
if (t == null)
throw new RuntimeException("T is null");
int result = 0;
try {
result = getSessionTemplate().update(getStatement(sqlId), t);
} catch (Exception e) {
logger.error("update fail[" + sqlId + "]:" + e.getMessage(), e);
throw BizException.DB_DML_FAIL;
}
if (result <= 0) {
if (StringUtil.isEmpty(errorMessage))
throw BizException.DB_UPDATE_RESULT_0;
else
throw new BizException(10000, errorMessage);
}
return result;
}
public long update(List<T> list) {
if (list == null || list.size() <= 0)
return 0;
int result = 0;
for (int i = 0; i < list.size(); i++) {
this.update(list.get(i));
result += 1;
}
if (result <= 0)
throw BizException.DB_UPDATE_RESULT_0;
return result;
}
public T getById(long id) {
return getSessionTemplate().selectOne(getStatement(SQL_GET_BY_ID), id);
}
public long deleteById(long id) {
return (long) getSessionTemplate().delete(getStatement(SQL_DELETE_BY_ID), id);
}
public PageBean listPage(PageParam pageParam, Map<String, Object> paramMap, String sqlId) {
if (paramMap == null)
paramMap = new HashMap<String, Object>();
// 获取分页数据集 , 注切勿换成 sessionTemplate 对象
List<Object> list = getSqlSession().selectList(getStatement(sqlId), paramMap,
new RowBounds(pageParam.getPageNum() * pageParam.getNumPerPage(), pageParam.getNumPerPage()));
// 统计总记录数
Object countObject = (Object) getSqlSession().selectOne(getStatement(sqlId),
new ExecutorInterceptor.CountParameter(paramMap));
Long count = Long.valueOf(countObject.toString());
return new PageBean(pageParam.getPageNum(), pageParam.getNumPerPage(), count.intValue(), list);
}
public <C> PageBeanNew<C> listPageNew(PageParam pageParam, Map<String, Object> paramMap, String sqlId) {
if (paramMap == null)
paramMap = new HashMap<String, Object>();
// 获取分页数据集 , 注切勿换成 sessionTemplate 对象
List<C> list = getSqlSession().selectList(getStatement(sqlId), paramMap,
new RowBounds(pageParam.getPageNum() * pageParam.getNumPerPage(), pageParam.getNumPerPage()));
// 统计总记录数
Integer count = getSqlSession().selectOne(getStatement(sqlId),
new ExecutorInterceptor.CountParameter(paramMap));
return new PageBeanNew<C>(pageParam.getPageNum(), pageParam.getNumPerPage(), count, list);
}
public PageBean listPage(PageParam pageParam, Map<String, Object> paramMap, String sqlId, String countSqlId) {
if (paramMap == null)
paramMap = new HashMap<String, Object>();
// 获取分页数据集 , 注切勿换成 sessionTemplate 对象
List<Object> list = getSqlSession().selectList(getStatement(sqlId), paramMap,
new RowBounds(pageParam.getPageNum() * pageParam.getNumPerPage(), pageParam.getNumPerPage()));
// 统计总记录数
Object countObject = getSqlSession().selectOne(getStatement(countSqlId), paramMap);
Long count = Long.valueOf(countObject.toString());
return new PageBean(pageParam.getPageNum(), pageParam.getNumPerPage(), count.intValue(), list);
}
public <C> PageBeanNew<C> listPageNew(PageParam pageParam, Map<String, Object> paramMap, String sqlId,
String countSqlId) {
if (paramMap == null)
paramMap = new HashMap<String, Object>();
// 获取分页数据集 , 注切勿换成 sessionTemplate 对象
List<C> list = getSqlSession().selectList(getStatement(sqlId), paramMap,
new RowBounds(pageParam.getPageNum() * pageParam.getNumPerPage(), pageParam.getNumPerPage()));
// 统计总记录数
Object countObject = getSqlSession().selectOne(getStatement(countSqlId), paramMap);
Long count = Long.valueOf(countObject.toString());
return new PageBeanNew<C>(pageParam.getPageNum(), pageParam.getNumPerPage(), count.intValue(), list);
}
public PageBean listSimplePage(PageParam pageParam, Map<String, Object> paramMap, String sqlId) {
if (paramMap == null)
paramMap = new HashMap<String, Object>();
// 获取分页数据集 , 注切勿换成 sessionTemplate 对象
List<Object> list = getSqlSession().selectList(getStatement(sqlId), paramMap,
new RowBounds(pageParam.getPageNum() * pageParam.getNumPerPage(), pageParam.getNumPerPage() + 1));
return new PageBean(pageParam.getPageNum(), pageParam.getNumPerPage(), list);
}
public PageBean listPage(PageParam pageParam, Map<String, Object> paramMap) {
if (paramMap == null)
paramMap = new HashMap<String, Object>();
// 获取分页数据集 , 注切勿换成 sessionTemplate 对象
List<Object> list = getSqlSession().selectList(getStatement(SQL_LIST_PAGE), paramMap,
new RowBounds(pageParam.getPageNum() * pageParam.getNumPerPage(), pageParam.getNumPerPage()));
// 统计总记录数
Object countObject = (Object) getSqlSession().selectOne(getStatement(SQL_LIST_PAGE),
new ExecutorInterceptor.CountParameter(paramMap));
Long count = Long.valueOf(countObject.toString());
// 是否统计当前分页条件下的数据：1:是，其他为否
Object isCount = paramMap.get("isCount");
if (isCount != null && "1".equals(isCount.toString())) {
Map<String, Object> countResultMap = getSessionTemplate().selectOne(getStatement(SQL_COUNT_BY_PAGE_PARAM),
paramMap);
return new PageBean(pageParam.getPageNum(), pageParam.getNumPerPage(), count.intValue(), list,
countResultMap);
} else {
return new PageBean(pageParam.getPageNum(), pageParam.getNumPerPage(), count.intValue(), list);
}
}
@SuppressWarnings({"rawtypes", "unchecked"})
public List<T> listBy(Map<String, Object> paramMap) {
return (List) this.listBy(paramMap, SQL_LIST_BY);
}
public List<Object> listBy(Map<String, Object> paramMap, String sqlId) {
if (paramMap == null)
paramMap = new HashMap<String, Object>();
return getSessionTemplate().selectList(getStatement(sqlId), paramMap);
}
@SuppressWarnings("unchecked")
public T getBy(Map<String, Object> paramMap) {
return (T) this.getBy(paramMap, SQL_LIST_BY);
}
public Object getBy(Map<String, Object> paramMap, String sqlId) {
if (paramMap == null || paramMap.isEmpty())
return null;
return this.getSqlSession().selectOne(getStatement(sqlId), paramMap);
}
public String getStatement(String sqlId) {
String name = this.getClass().getName();
StringBuffer sb = new StringBuffer().append(name).append(".").append(sqlId);
return sb.toString();
}
/**
* 根据序列名称,获取序列值
*/
public String getSeqNextValue(String seqName) {
boolean isClosedConn = false;
// 获取当前线程的连接
Connection connection = this.getSessionTemplate().getConnection();
// 获取Mybatis的SQLRunner类
SqlRunner sqlRunner = null;
try {
// 要执行的SQL
String sql = "";
// 数据库驱动类
String driverClass = druidDataSource.getDriver().getClass().getName();
// 不同的数据库,拼接SQL语句
if (driverClass.equals("com.ibm.db2.jcc.DB2Driver")) {
sql = " VALUES " + seqName.toUpperCase() + ".NEXTVAL";
}
if (driverClass.equals("oracle.jdbc.OracleDriver")) {
sql = "SELECT " + seqName.toUpperCase() + ".NEXTVAL FROM DUAL";
}
if (driverClass.equals("com.mysql.jdbc.Driver")) {
sql = "SELECT FUN_SEQ('" + seqName.toUpperCase() + "')";
}
// 如果状态为关闭,则需要从新打开一个连接
if (connection.isClosed()) {
connection = getSqlSessionFactory().openSession().getConnection();
isClosedConn = true;
}
sqlRunner = new SqlRunner(connection);
Object[] args = {};
// 执行SQL语句
Map<String, Object> params = sqlRunner.selectOne(sql, args);
for (Object o : params.values()) {
return o.toString();
}
return null;
} catch (Exception e) {
throw BizException.DB_GET_SEQ_NEXT_VALUE_ERROR.newInstance("获取序列出现错误!序列名称:{%s}", seqName);
} finally {
if (isClosedConn) {
sqlRunner.closeConnection();
}
}
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment