IBatis常用操作封装
package cn.skyclass.ibatis;
import java.util.ArrayList;
import java.util.List;
import org.apache.commons.beanutils.BeanUtils;
import cn.skyclass.io.AppLogger;
import cn.skyclass.net.OperationResult;
import com.ibatis.sqlmap.client.SqlMapClient;
import com.ibatis.sqlmap.client.event.RowHandler;
/**
?* 对 ibatis 操作数据库的常用方法进行包装
?*
?* @author fl
?*
?*/
public class IBatisDao implements IDao {
??? protected SqlMapClient sqlMap;
??? protected AppLogger logger = AppLogger.getInstance();
??? /**
??? ?* 使用默认的 SqlMapClient ，通过 cn.skyclass.ibatis.SqlConfig 类的
??? ?* getSqlMapInstance() 方法获取
??? ?*
??? ?*/
??? public IBatisDao() {
??? ??? this.sqlMap = SqlConfig.getSqlMapInstance();
??? }
??? /**
??? ?* 使用给定的 SqlMapClient
??? ?*
??? ?* @param sqlMap
??? ?*??????????? dao 将使用此 SqlMapClient 访问数据库
??? ?*/
??? public IBatisDao(SqlMapClient sqlMap) {
??? ??? this.sqlMap = sqlMap;
??? }
??? public SqlMapClient getSqlMap() {
??? ??? return this.sqlMap;
??? }
??? public List getList(String sqlId, Object param) {
??? ??? try {
??? ??? ??? try {
??? ??? ??? ??? sqlMap.startTransaction();
??? ??? ??? ??? List list = sqlMap.queryForList(sqlId, param);
??? ??? ??? ??? sqlMap.commitTransaction();
??? ??? ??? ??? return list;
??? ??? ??? } catch (Exception e) {
??? ??? ??? ??? logger.exception(e);
??? ??? ??? } finally {
??? ??? ??? ??? sqlMap.endTransaction();
??? ??? ??? }
??? ??? } catch (Exception e) {
??? ??? ??? logger.exception(e);
??? ??? }
??? ??? return new ArrayList();
??? }
??? public List getList(String sqlId, Object param, int pageSize, int pageNo) {
??? ??? int skip = (pageNo - 1) * pageSize;
??? ??? int max = pageSize;
??? ??? return getListLimit(sqlId, param, skip, max);
??? }
??? public List getListLimit(String sqlId, Object param, int skip, int max) {
??? ??? try {
??? ??? ??? try {
??? ??? ??? ??? sqlMap.startTransaction();
??? ??? ??? ??? List list = sqlMap.queryForList(sqlId, param, skip, max);
??? ??? ??? ??? sqlMap.commitTransaction();
??? ??? ??? ??? return list;
??? ??? ??? } catch (Exception e) {
??? ??? ??? ??? logger.exception(e);
??? ??? ??? } finally {
??? ??? ??? ??? sqlMap.endTransaction();
??? ??? ??? }
??? ??? } catch (Exception e) {
??? ??? ??? logger.exception(e);
??? ??? }
??? ??? return new ArrayList();
??? }
??? public void queryWithRowHandler(String sqlId, Object param,
??? ??? ??? RowHandler handler) {
??? ??? try {
??? ??? ??? try {
??? ??? ??? ??? sqlMap.startTransaction();
??? ??? ??? ??? sqlMap.queryWithRowHandler(sqlId, param, handler);
??? ??? ??? ??? sqlMap.commitTransaction();
??? ??? ??? } catch (Exception e) {
??? ??? ??? ??? logger.exception(e);
??? ??? ??? } finally {
??? ??? ??? ??? sqlMap.endTransaction();
??? ??? ??? }
??? ??? } catch (Exception e) {
??? ??? ??? logger.exception(e);
??? ??? }
??? }
??? public Object getObject(String sqlId, Object param) {
??? ??? try {
??? ??? ??? try {
??? ??? ??? ??? sqlMap.startTransaction();
??? ??? ??? ??? Object obj = sqlMap.queryForObject(sqlId, param);
??? ??? ??? ??? sqlMap.commitTransaction();
??? ??? ??? ??? return obj;
??? ??? ??? } catch (Exception e) {
??? ??? ??? ??? logger.exception(e);
??? ??? ??? } finally {
??? ??? ??? ??? sqlMap.endTransaction();
??? ??? ??? }
??? ??? } catch (Exception e) {
??? ??? ??? logger.exception(e);
??? ??? }
??? ??? return null;
??? }
??? public Object getFirstObject(String sqlId, Object param) {
??? ??? try {
??? ??? ??? try {
??? ??? ??? ??? sqlMap.startTransaction();
??? ??? ??? ??? List list = sqlMap.queryForList(sqlId, param);
??? ??? ??? ??? sqlMap.commitTransaction();
??? ??? ??? ??? if (list != null && list.size() > 0) {
??? ??? ??? ??? ??? return list.get(0);
??? ??? ??? ??? } else {
??? ??? ??? ??? ??? return null;
??? ??? ??? ??? }
??? ??? ??? } catch (Exception e) {
??? ??? ??? ??? logger.exception(e);
??? ??? ??? } finally {
??? ??? ??? ??? sqlMap.endTransaction();
??? ??? ??? }
??? ??? } catch (Exception e) {
??? ??? ??? logger.exception(e);
??? ??? }
??? ??? return null;
??? }
??? public OperationResult executeInsert(String sqlId, Object param) {
??? ??? OperationResult result = new OperationResult(true, "");
??? ??? try {
??? ??? ??? try {
??? ??? ??? ??? sqlMap.startTransaction();
??? ??? ??? ??? Object newId = sqlMap.insert(sqlId, param);
??? ??? ??? ??? result.setStrId(String.valueOf(newId));
??? ??? ??? ??? if (newId instanceof Integer) {
??? ??? ??? ??? ??? result.setId((Integer) newId);
??? ??? ??? ??? }
??? ??? ??? ??? if (newId instanceof Long) {
??? ??? ??? ??? ??? result.setLongId((Long) newId);
??? ??? ??? ??? }
??? ??? ??? ??? result.setSuccessful(true);
??? ??? ??? ??? sqlMap.commitTransaction();
??? ??? ??? } catch (Exception e) {
??? ??? ??? ??? result.setSuccessful(false);
??? ??? ??? ??? result.setMsg(e.getMessage());
??? ??? ??? ??? logger.exception(e);
??? ??? ??? } finally {
??? ??? ??? ??? sqlMap.endTransaction();
??? ??? ??? }
??? ??? } catch (Exception e) {
??? ??? ??? result.setSuccessful(false);
??? ??? ??? result.setMsg(e.getMessage());
??? ??? ??? logger.exception(e);
??? ??? }
??? ??? return result;
??? }
??? public OperationResult executeInsertBatch(String sqlId, List list) {
??? ??? OperationResult result = new OperationResult(true, "");
??? ??? try {
??? ??? ??? try {
??? ??? ??? ??? sqlMap.startTransaction();
??? ??? ??? ??? sqlMap.startBatch();
??? ??? ??? ??? for (Object object : list) {
??? ??? ??? ??? ??? sqlMap.insert(sqlId, object);
??? ??? ??? ??? }
??? ??? ??? ??? int row = sqlMap.executeBatch();
??? ??? ??? ??? result.setIntValue(row);
??? ??? ??? ??? result.setSuccessful(true);
??? ??? ??? ??? sqlMap.commitTransaction();
??? ??? ??? } catch (Exception e) {
??? ??? ??? ??? result.setSuccessful(false);
??? ??? ??? ??? result.setMsg(e.getMessage());
??? ??? ??? ??? logger.exception(e);
??? ??? ??? } finally {
??? ??? ??? ??? sqlMap.endTransaction();
??? ??? ??? }
??? ??? } catch (Exception e) {
??? ??? ??? result.setSuccessful(false);
??? ??? ??? result.setMsg(e.getMessage());
??? ??? ??? logger.exception(e);
??? ??? }
??? ??? return result;
??? }
??? public OperationResult executeUpdate(String sqlId, Object param) {
??? ??? OperationResult result = new OperationResult(true, "");
??? ??? try {
??? ??? ??? try {
??? ??? ??? ??? sqlMap.startTransaction();
??? ??? ??? ??? int row = sqlMap.update(sqlId, param);
??? ??? ??? ??? result.setIntValue(row);
??? ??? ??? ??? result.setSuccessful(true);
??? ??? ??? ??? sqlMap.commitTransaction();
??? ??? ??? } catch (Exception e) {
??? ??? ??? ??? result.setSuccessful(false);
??? ??? ??? ??? result.setMsg(e.getMessage());
??? ??? ??? ??? logger.exception(e);
??? ??? ??? } finally {
??? ??? ??? ??? sqlMap.endTransaction();
??? ??? ??? }
??? ??? } catch (Exception e) {
??? ??? ??? result.setSuccessful(false);
??? ??? ??? result.setMsg(e.getMessage());
??? ??? ??? logger.exception(e);
??? ??? }
??? ??? return result;
??? }
??? public OperationResult executeUpdateBatch(String sqlId, List list) {
??? ??? OperationResult result = new OperationResult(true, "");
??? ??? try {
??? ??? ??? try {
??? ??? ??? ??? sqlMap.startTransaction();
??? ??? ??? ??? sqlMap.startBatch();
??? ??? ??? ??? for (Object object : list) {
??? ??? ??? ??? ??? sqlMap.update(sqlId, object);
??? ??? ??? ??? }
??? ??? ??? ??? int row = sqlMap.executeBatch();
??? ??? ??? ??? result.setIntValue(row);
??? ??? ??? ??? result.setSuccessful(true);
??? ??? ??? ??? sqlMap.commitTransaction();
??? ??? ??? } catch (Exception e) {
??? ??? ??? ??? result.setSuccessful(false);
??? ??? ??? ??? result.setMsg(e.getMessage());
??? ??? ??? ??? logger.exception(e);
??? ??? ??? } finally {
??? ??? ??? ??? sqlMap.endTransaction();
??? ??? ??? }
??? ??? } catch (Exception e) {
??? ??? ??? result.setSuccessful(false);
??? ??? ??? result.setMsg(e.getMessage());
??? ??? ??? logger.exception(e);
??? ??? }
??? ??? return result;
??? }
??? public OperationResult executeDelete(String sqlId, Object param) {
??? ??? OperationResult result = new OperationResult(true, "");
??? ??? try {
??? ??? ??? try {
??? ??? ??? ??? sqlMap.startTransaction();
??? ??? ??? ??? int row = sqlMap.delete(sqlId, param);
??? ??? ??? ??? result.setIntValue(row);
??? ??? ??? ??? result.setSuccessful(true);
??? ??? ??? ??? sqlMap.commitTransaction();
??? ??? ??? } catch (Exception e) {
??? ??? ??? ??? result.setSuccessful(false);
??? ??? ??? ??? result.setMsg(e.getMessage());
??? ??? ??? ??? logger.exception(e);
??? ??? ??? } finally {
??? ??? ??? ??? sqlMap.endTransaction();
??? ??? ??? }
??? ??? } catch (Exception e) {
??? ??? ??? result.setSuccessful(false);
??? ??? ??? result.setMsg(e.getMessage());
??? ??? ??? logger.exception(e);
??? ??? }
??? ??? return result;
??? }
??? public OperationResult executeDeleteBatch(String sqlId, List list) {
??? ??? OperationResult result = new OperationResult(true, "");
??? ??? try {
??? ??? ??? try {
??? ??? ??? ??? sqlMap.startTransaction();
??? ??? ??? ??? sqlMap.startBatch();
??? ??? ??? ??? for (Object object : list) {
??? ??? ??? ??? ??? sqlMap.delete(sqlId, object);
??? ??? ??? ??? }
??? ??? ??? ??? int row = sqlMap.executeBatch();
??? ??? ??? ??? result.setIntValue(row);
??? ??? ??? ??? result.setSuccessful(true);
??? ??? ??? ??? sqlMap.commitTransaction();
??? ??? ??? } catch (Exception e) {
??? ??? ??? ??? result.setSuccessful(false);
??? ??? ??? ??? result.setMsg(e.getMessage());
??? ??? ??? ??? logger.exception(e);
??? ??? ??? } finally {
??? ??? ??? ??? sqlMap.endTransaction();
??? ??? ??? }
??? ??? } catch (Exception e) {
??? ??? ??? result.setSuccessful(false);
??? ??? ??? result.setMsg(e.getMessage());
??? ??? ??? logger.exception(e);
??? ??? }
??? ??? return result;
??? }
??? public Integer getCount(String sqlId, Object param) {
??? ??? Integer count = 0;
??? ??? try {
??? ??? ??? count = (Integer) sqlMap.queryForObject(sqlId, param);
??? ??? } catch (Exception e) {
??? ??? ??? logger.exception(e);
??? ??? }
??? ??? return count;
??? }
??? /**
??? ?* 拷贝对象
??? ?*
??? ?* @param source
??? ?* @return
??? ?*/
??? protected Object cloneObject(Object source) {
??? ??? if (source != null) {
??? ??? ??? try {
??? ??? ??? ??? Object result = source.getClass().newInstance();
??? ??? ??? ??? BeanUtils.copyProperties(result, source);
??? ??? ??? ??? return result;
??? ??? ??? } catch (Exception e) {
??? ??? ??? ??? logger.exception(e);
??? ??? ??? }
??? ??? }
??? ??? return null;
??? }
}
