JdbcQueryJDBC封装包
JdbcQuery是一个对JDBC操作进行封装，使得在JAVA中执行复杂的SQL语句和存储过程变得像hibernate一样的简单,并能方便的将结果集以List、Map、Array的形式返回。
1. 调用存储过程示例:
String strSql = "{call callcenter_pack.Get_TaskCaseCount(:P_UserID,:P_ErrorInfo,:P_OutData)}";
JdbcQuery query = JdbcUtils.createNativeQuery(super.getConnection(), strSql);
query.setParameter("P_UserID", 5);
query.setOutParameter("P_ErrorInfo", OracleTypes.VARCHAR);
query.setOutParameter("P_OutData", OracleTypes.CURSOR);
query.excuteProcedure();
//params: P_UserID、 P_ErrorInfo、 P_OutData.
//P_ErrorInfo 是一个输出参数, 用于返回存储过程中的错误信息
//P_OutData 是一个游标
//可以方便的获取一个List类型的结果
String strError = query.getString("P_ErrorInfo");
List<TaskBarCounter> dataList = query.getResultList("P_OutData",TaskBarCounter.class);
query.closeCallableStatement();
2. 调用SQL语句示例:
public Result findCollect(final QueryMap qMap) {
final StringBuilder sb = new StringBuilder();
StringBuilder sbWhere = new StringBuilder();
// 汇总查询所需的列
sb.append("select c.store_id, s.name,SUM(c.total_recharge) as total_recharge,");
sb.append("SUM(c.total_payment) as total_payment,");
sb.append("SUM(c.total_reversal) as total_reversal ");
// 查询条件
sbWhere.append(" from collect c inner join store s on c.store_id = s.id ");
sbWhere.append(" where c.created >= :start ");
sbWhere.append(" and c.created <= :end ");
sbWhere.append(" and s.parent_id = :parentId ");
sbWhere.append(" and s.name like :storeName");
sbWhere.append(" GROUP BY c.store_id,s.name ");
// 查询数量
final String countSQL = "select count(c.id)" + sbWhere.toString();
// 分页
sb.append(sbWhere).append("limit :pageStart,:pageSize");
// QueryMap 是一个功能强大的HashMap, 提供了各种类型的转换,
// 例如: String 转 Integer、String 赚 Date 等等.
qMap.convertsInt("pageIndex", "pageSize");
// 计算分页参数: limit :pageStart,:pageSize
qMap.setProperty("pageStart", qMap.getPageIndex()*qMap.getPageSize());
// 设置参数parentId 例如SQL: and s.parent_id = :parentId
qMap.setProperty("parentId", 5);
// getLikeValue可以格式化为 Like形式，例如: test => '%test%'
qMap.setProperty("storeName", qMap.getLikeValue("storeName"));
final Result result = new Result();
// 获取hibernate数据源连接,基类中获取，通过super.getSession().connection
// 设置方法的参数：数据库连接，SQL语句，参数
JdbcQuery query = JdbcUtils.createNativeQuery(super.getSession().connection, countSQL, qMap);
// 获取数量
int count = query.getCount();
// 设置方法的参数：数据库连接，SQL语句，参数
JdbcQuery querys = JdbcUtils.createNativeQuery(super.getSession().connection, sb.toString(), qMap);
// 获取结果
List list = querys.getResultList();
// 将结果存入result中返回
result.setTotal(count);
result.setData(list);
Log.i("result", result);
return result;
}
//===========================================================================================
//============= Hibernate4.x 获取数据库连接方式 begin ============================================
super.getCurrentSession().doWork(new Work() {
public void execute(Connection connection) {
// 获取hibernate数据源连接：
// 设置方法的参数：数据库连接，SQL语句，参数
JdbcQuery query = JdbcUtils.createNativeQuery(connection, countSQL, qMap);
// 获取数量
int count = query.getCount();
//设置方法的参数：数据库连接，SQL语句，参数
JdbcQuery querys = JdbcUtils.createNativeQuery(connection, sb.toString(), qMap);
// 获取结果
List list = querys.getResultList();
// 将结果存入result中返回
result.setTotal(count);
result.setData(list);
Log.i("result", result);
}
});
//============= Hibernate4.x 获取数据库连接方式 end ============================================
return result;
}评论