From f7e9678f5f6f6bd9ed41387abf17965f6e9f23e6 Mon Sep 17 00:00:00 2001 From: zhuangqian Date: Mon, 27 Feb 2017 21:37:07 +0800 Subject: [PATCH] bug fix --- .../com/smallchill/core/plugins/dao/Db.java | 828 +++++++++--------- .../core/plugins/dao/DbManager.java | 4 +- 2 files changed, 416 insertions(+), 416 deletions(-) diff --git a/src/main/java/com/smallchill/core/plugins/dao/Db.java b/src/main/java/com/smallchill/core/plugins/dao/Db.java index 94ec073a..3d4c14d3 100644 --- a/src/main/java/com/smallchill/core/plugins/dao/Db.java +++ b/src/main/java/com/smallchill/core/plugins/dao/Db.java @@ -1,414 +1,414 @@ -/** - * Copyright (c) 2015-2017, Chill Zhuang 庄骞 (smallchill@163.com). - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.smallchill.core.plugins.dao; - -import java.util.List; -import java.util.Map; - -import org.beetl.sql.core.OnConnection; -import org.beetl.sql.core.SQLReady; - -import com.smallchill.core.aop.AopContext; -import com.smallchill.core.meta.IQuery; -import com.smallchill.core.toolbox.CMap; -import com.smallchill.core.toolbox.grid.BladePage; - -/** - * beetlsql Dao工具 - */ -public class Db { - - private static DbManager dbManager = null; - - public static DbManager init(String name) { - return DbManager.init(name); - } - - private Db() {} - - private static DbManager getDbManager() { - if (null == dbManager) { - synchronized (Db.class) { - dbManager = DbManager.init(); - } - } - return dbManager; - } - - /************ ↓↓↓ ******** 通用 ********* ↓↓↓ ****************/ - - /** - * 直接执行sql语句，sql语句已经是准备好的，采用preparedstatment执行 - * @param clazz - * @param p - * @return 返回查询结果 - */ - public static List execute(SQLReady p, Class clazz){ - return getDbManager().execute(p, clazz); - } - - /** 直接执行sql语句，sql语句已经是准备好的，采用preparedstatment执行 - * @param p - * @return 返回更新条数 - */ - public static int executeUpdate(SQLReady p){ - return getDbManager().executeUpdate(p); - } - - /** - * 存储过程调用 - * @param call - * @return T - */ - public static T executeCall(OnConnection call) { - return getDbManager().executeCall(call); - } - - /** - * 根据sql新增数据 - * @param sqlTemplate sql语句 - * @param paras 实体类或map - * @return - */ - public static int insert(String sqlTemplate, Object paras){ - return getDbManager().insert(sqlTemplate, paras); - } - - /** - * 根据sql修改数据 - * @param sqlTemplate sql语句 - * @param paras 实体类或map - * @return - */ - public static int update(String sqlTemplate, Object paras){ - return getDbManager().update(sqlTemplate, paras); - } - - /** - * 根据sql删除数据 - * @param sqlTemplate sql语句 - * @param paras 实体类或map - * @return - */ - public static int delete(String sqlTemplate, Object paras){ - return getDbManager().delete(sqlTemplate, paras); - } - - /** - * 获取一条数据 - * @param sqlTemplate sql语句 - * @return - */ - @SuppressWarnings("rawtypes") - public static Map selectOne(String sqlTemplate){ - return getDbManager().selectOne(sqlTemplate); - } - - /** - * 获取一条数据 - * @param sqlTemplate sql语句 - * @param paras 实体类或map - * @return - */ - @SuppressWarnings("rawtypes") - public static Map selectOne(String sqlTemplate, Object paras){ - return getDbManager().selectOne(sqlTemplate, paras); - } - - /** - * 获取一条数据 - * @param sqlTemplate sql语句 - * @return - */ - @SuppressWarnings("rawtypes") - public static List selectList(String sqlTemplate){ - return getDbManager().selectList(sqlTemplate); - } - - /** - * 获取多条数据 - * @param sqlTemplate sql语句 - * @param paras 实体类或map - * @return - */ - @SuppressWarnings("rawtypes") - public static List selectList(String sqlTemplate, Object paras){ - return getDbManager().selectList(sqlTemplate, paras); - } - - /** - * 获取多条数据 - * @param sqlTemplate sql语句 - * @param paras 实体类或map - * @param topNum 排序 - * @return - */ - @SuppressWarnings("rawtypes") - public static List selectTop(String sqlTemplate, Object paras, Integer topNum){ - return getDbManager().selectTop(sqlTemplate, paras, topNum); - } - - /** - * 根据表名、主键获取一条数据 - * @param tableName 表名 - * @param pkValue 主键值 - * @return - */ - @SuppressWarnings("rawtypes") - public static Map findById(String tableName, String pkValue) { - return getDbManager().findById(tableName, pkValue); - } - - /** - * 根据表名、主键名、主键值获取一条数据 - * @param tableName 表名 - * @param pk 主键名 - * @param pkValue 主键值 - * @return - */ - @SuppressWarnings("rawtypes") - public static Map findById(String tableName, String pk, String pkValue) { - return getDbManager().findById(tableName, pk, pkValue); - } - - /** - * 获取Integer - * @param sqlTemplate sql语句 - * @param paras 实体类或map - * @return - */ - public static Integer queryInt(String sqlTemplate, Object paras){ - return getDbManager().queryInt(sqlTemplate, paras); - } - - /** - * 获取Integer集合 - * @param sqlTemplate sql语句 - * @param paras 实体类或map - * @return - */ - public static List queryListInt(String sqlTemplate, Object paras){ - return getDbManager().queryListInt(sqlTemplate, paras); - } - - /** - * 获取字符串 - * @param sqlTemplate sql语句 - * @param paras 实体类或map - * @return - */ - public static String queryStr(String sqlTemplate, Object paras){ - return getDbManager().queryStr(sqlTemplate, paras); - } - - /** - * 获取字符串集合 - * @param sqlTemplate sql语句 - * @param paras 实体类或map - * @return - */ - public static List queryListStr(String sqlTemplate, Object paras){ - return getDbManager().queryListStr(sqlTemplate, paras); - } - - /** 查询aop返回单条数据 - * @param sqlTemplate - * @param paras - * @param ac - * @param intercept - * @return - */ - @SuppressWarnings("rawtypes") - public static Map selectOne(String sqlTemplate, Map param, AopContext ac, IQuery intercept) { - return getDbManager().selectOne(sqlTemplate, param, ac, intercept); - } - - /**查询aop返回多条数据 - * @param sqlTemplate - * @param paras - * @param ac - * @param intercept - * @return - */ - @SuppressWarnings("rawtypes") - public static List selectList(String sqlTemplate, Map param, AopContext ac, IQuery intercept) { - return getDbManager().selectList(sqlTemplate, param, ac, intercept); - } - - /** - * 根据缓存找一条数据 - * @param cacheName - * @param key - * @param sqlTemplate - * @param paras - * @return Map - */ - @SuppressWarnings("rawtypes") - public static Map selectOneByCache(String cacheName, String key, String sqlTemplate, Object paras){ - return getDbManager().selectOneByCache(cacheName, key, sqlTemplate, paras); - } - - /** - * 根据缓存找多条数据 - * @param cacheName - * @param key - * @param sqlTemplate - * @param paras - * @return List - */ - @SuppressWarnings("rawtypes") - public static List selectListByCache(String cacheName, String key, String sqlTemplate, Object paras){ - return getDbManager().selectListByCache(cacheName, key, sqlTemplate, paras); - } - - /************ ↑↑↑ ******** 通用 ********* ↑↑↑ ****************/ - - /** - * 新增一条数据 - * @param tableName 表名 - * @param pk 主键名 - * @param paras 参数 - * @return - */ - public static int save(String tableName, String pk, CMap paras) { - return getDbManager().save(tableName, pk, paras); - } - - /** - * 修改一条数据 - * @param tableName 表名 - * @param pk 主键名 - * @param paras 参数 - * @return - */ - public static int update(String tableName, String pk, CMap paras) { - return getDbManager().update(tableName, pk, paras); - } - - /** - * 根据表名、字段名、值删除数据 - * @param table 表名 - * @param col 字段名 - * @param ids 字段值集合(1,2,3) - * @return - */ - public static int deleteByIds(String table, String col, String ids) { - return getDbManager().deleteByIds(table, col, ids); - } - - /** - * 根据表名、字段名、值删除数据 - * @param table 表名 - * @param col 字段名 - * @param ids 字段值集合(1,2,3) - * @return - */ - public static int deleteByStrIds(String table, String col, String ids) { - return getDbManager().deleteByStrIds(table, col, ids); - } - - - /** - * 获取list - * @param model 实体类 - * @param pageNum 页号 - * @param pageSize 数量 - * @return - */ - public static List getList(Object model, int pageNum, int pageSize) { - return getDbManager().getList(model, pageNum, pageSize); - } - - - /** - * 获取list - * @param sqlTemplate sql语句 - * @param clazz 返回类型 - * @param paras 参数 - * @param pageNum 页号 - * @param pageSize 数量 - * @return - */ - public static List getList(String sqlTemplate, Class clazz, Object paras, int pageNum, int pageSize) { - return getDbManager().getList(sqlTemplate, clazz, paras, pageNum, pageSize); - } - - /** - * 分页 - * @param sqlTemplate sql语句 - * @param paras 参数 - * @param pageNum 页号 - * @param pageSize 数量 - * @return - */ - @SuppressWarnings("rawtypes") - public static BladePage paginate(String sqlTemplate, Object paras, int pageNum, int pageSize){ - return getDbManager().paginate(sqlTemplate, paras, pageNum, pageSize); - } - - /** - * 分页 - * @param sqlTemplate sql语句 - * @param clazz 返回类型 - * @param paras 参数 - * @param pageNum 页号 - * @param pageSize 数量 - * @return - */ - public static BladePage paginate(String sqlTemplate, Class clazz, Object paras, int pageNum, int pageSize){ - return getDbManager().paginate(sqlTemplate, clazz, paras, pageNum, pageSize); - } - - /** - * 分页 - * @param sqlTemplate sql语句 - * @param sqlCount count语句 - * @param clazz 返回类型 - * @param paras 参数 - * @param pageNum 页号 - * @param pageSize 数量 - * @return - */ - @SuppressWarnings("rawtypes") - public static BladePage paginate(String sqlTemplate, String sqlCount, Object paras, int pageNum, int pageSize){ - return getDbManager().paginate(sqlTemplate, sqlCount, paras, pageNum, pageSize); - } - - /** - * 分页 - * @param sqlTemplate sql语句 - * @param sqlCount count语句 - * @param clazz 返回类型 - * @param paras 参数 - * @param pageNum 页号 - * @param pageSize 数量 - * @return - */ - public static BladePage paginate(String sqlTemplate, String sqlCount, Class clazz, Object paras, int pageNum, int pageSize){ - return getDbManager().paginate(sqlTemplate, sqlCount, clazz, paras, pageNum, pageSize); - } - - /** - * 是否存在 - * - * @param sqlTemplate - * @param paras - * @return - */ - public static boolean isExist(String sqlTemplate, Object paras) { - return getDbManager().isExist(sqlTemplate, paras); - } -} +/** + * Copyright (c) 2015-2017, Chill Zhuang 庄骞 (smallchill@163.com). + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package com.smallchill.core.plugins.dao; + +import java.util.List; +import java.util.Map; + +import org.beetl.sql.core.OnConnection; +import org.beetl.sql.core.SQLReady; + +import com.smallchill.core.aop.AopContext; +import com.smallchill.core.meta.IQuery; +import com.smallchill.core.toolbox.CMap; +import com.smallchill.core.toolbox.grid.BladePage; + +/** + * beetlsql Dao工具 + */ +public class Db { + + private static DbManager dbManager = null; + + public static DbManager init(String name) { + return DbManager.init(name); + } + + private Db() {} + + private static DbManager getDbManager() { + if (null == dbManager) { + synchronized (Db.class) { + dbManager = DbManager.init(); + } + } + return dbManager; + } + + /************ ↓↓↓ ******** 通用 ********* ↓↓↓ ****************/ + + /** + * 直接执行sql语句，sql语句已经是准备好的，采用preparedstatment执行 + * @param clazz + * @param p + * @return 返回查询结果 + */ + public static List execute(SQLReady p, Class clazz){ + return getDbManager().execute(p, clazz); + } + + /** 直接执行sql语句，sql语句已经是准备好的，采用preparedstatment执行 + * @param p + * @return 返回更新条数 + */ + public static int executeUpdate(SQLReady p){ + return getDbManager().executeUpdate(p); + } + + /** + * 存储过程调用 + * @param call + * @return T + */ + public static T executeCall(OnConnection call) { + return getDbManager().executeCall(call); + } + + /** + * 根据sql新增数据 + * @param sqlTemplate sql语句 + * @param paras 实体类或map + * @return + */ + public static int insert(String sqlTemplate, Object paras){ + return getDbManager().insert(sqlTemplate, paras); + } + + /** + * 根据sql修改数据 + * @param sqlTemplate sql语句 + * @param paras 实体类或map + * @return + */ + public static int update(String sqlTemplate, Object paras){ + return getDbManager().update(sqlTemplate, paras); + } + + /** + * 根据sql删除数据 + * @param sqlTemplate sql语句 + * @param paras 实体类或map + * @return + */ + public static int delete(String sqlTemplate, Object paras){ + return getDbManager().delete(sqlTemplate, paras); + } + + /** + * 获取一条数据 + * @param sqlTemplate sql语句 + * @return + */ + @SuppressWarnings("rawtypes") + public static Map selectOne(String sqlTemplate){ + return getDbManager().selectOne(sqlTemplate); + } + + /** + * 获取一条数据 + * @param sqlTemplate sql语句 + * @param paras 实体类或map + * @return + */ + @SuppressWarnings("rawtypes") + public static Map selectOne(String sqlTemplate, Object paras){ + return getDbManager().selectOne(sqlTemplate, paras); + } + + /** + * 获取一条数据 + * @param sqlTemplate sql语句 + * @return + */ + @SuppressWarnings("rawtypes") + public static List selectList(String sqlTemplate){ + return getDbManager().selectList(sqlTemplate); + } + + /** + * 获取多条数据 + * @param sqlTemplate sql语句 + * @param paras 实体类或map + * @return + */ + @SuppressWarnings("rawtypes") + public static List selectList(String sqlTemplate, Object paras){ + return getDbManager().selectList(sqlTemplate, paras); + } + + /** + * 获取多条数据 + * @param sqlTemplate sql语句 + * @param paras 实体类或map + * @param topNum 排序 + * @return + */ + @SuppressWarnings("rawtypes") + public static List selectTop(String sqlTemplate, Object paras, Integer topNum){ + return getDbManager().selectTop(sqlTemplate, paras, topNum); + } + + /** + * 根据表名、主键获取一条数据 + * @param tableName 表名 + * @param pkValue 主键值 + * @return + */ + @SuppressWarnings("rawtypes") + public static Map findById(String tableName, Object pkValue) { + return getDbManager().findById(tableName, pkValue); + } + + /** + * 根据表名、主键名、主键值获取一条数据 + * @param tableName 表名 + * @param pk 主键名 + * @param pkValue 主键值 + * @return + */ + @SuppressWarnings("rawtypes") + public static Map findById(String tableName, String pk, Object pkValue) { + return getDbManager().findById(tableName, pk, pkValue); + } + + /** + * 获取Integer + * @param sqlTemplate sql语句 + * @param paras 实体类或map + * @return + */ + public static Integer queryInt(String sqlTemplate, Object paras){ + return getDbManager().queryInt(sqlTemplate, paras); + } + + /** + * 获取Integer集合 + * @param sqlTemplate sql语句 + * @param paras 实体类或map + * @return + */ + public static List queryListInt(String sqlTemplate, Object paras){ + return getDbManager().queryListInt(sqlTemplate, paras); + } + + /** + * 获取字符串 + * @param sqlTemplate sql语句 + * @param paras 实体类或map + * @return + */ + public static String queryStr(String sqlTemplate, Object paras){ + return getDbManager().queryStr(sqlTemplate, paras); + } + + /** + * 获取字符串集合 + * @param sqlTemplate sql语句 + * @param paras 实体类或map + * @return + */ + public static List queryListStr(String sqlTemplate, Object paras){ + return getDbManager().queryListStr(sqlTemplate, paras); + } + + /** 查询aop返回单条数据 + * @param sqlTemplate + * @param paras + * @param ac + * @param intercept + * @return + */ + @SuppressWarnings("rawtypes") + public static Map selectOne(String sqlTemplate, Map param, AopContext ac, IQuery intercept) { + return getDbManager().selectOne(sqlTemplate, param, ac, intercept); + } + + /**查询aop返回多条数据 + * @param sqlTemplate + * @param paras + * @param ac + * @param intercept + * @return + */ + @SuppressWarnings("rawtypes") + public static List selectList(String sqlTemplate, Map param, AopContext ac, IQuery intercept) { + return getDbManager().selectList(sqlTemplate, param, ac, intercept); + } + + /** + * 根据缓存找一条数据 + * @param cacheName + * @param key + * @param sqlTemplate + * @param paras + * @return Map + */ + @SuppressWarnings("rawtypes") + public static Map selectOneByCache(String cacheName, String key, String sqlTemplate, Object paras){ + return getDbManager().selectOneByCache(cacheName, key, sqlTemplate, paras); + } + + /** + * 根据缓存找多条数据 + * @param cacheName + * @param key + * @param sqlTemplate + * @param paras + * @return List + */ + @SuppressWarnings("rawtypes") + public static List selectListByCache(String cacheName, String key, String sqlTemplate, Object paras){ + return getDbManager().selectListByCache(cacheName, key, sqlTemplate, paras); + } + + /************ ↑↑↑ ******** 通用 ********* ↑↑↑ ****************/ + + /** + * 新增一条数据 + * @param tableName 表名 + * @param pk 主键名 + * @param paras 参数 + * @return + */ + public static int save(String tableName, String pk, CMap paras) { + return getDbManager().save(tableName, pk, paras); + } + + /** + * 修改一条数据 + * @param tableName 表名 + * @param pk 主键名 + * @param paras 参数 + * @return + */ + public static int update(String tableName, String pk, CMap paras) { + return getDbManager().update(tableName, pk, paras); + } + + /** + * 根据表名、字段名、值删除数据 + * @param table 表名 + * @param col 字段名 + * @param ids 字段值集合(1,2,3) + * @return + */ + public static int deleteByIds(String table, String col, String ids) { + return getDbManager().deleteByIds(table, col, ids); + } + + /** + * 根据表名、字段名、值删除数据 + * @param table 表名 + * @param col 字段名 + * @param ids 字段值集合(1,2,3) + * @return + */ + public static int deleteByStrIds(String table, String col, String ids) { + return getDbManager().deleteByStrIds(table, col, ids); + } + + + /** + * 获取list + * @param model 实体类 + * @param pageNum 页号 + * @param pageSize 数量 + * @return + */ + public static List getList(Object model, int pageNum, int pageSize) { + return getDbManager().getList(model, pageNum, pageSize); + } + + + /** + * 获取list + * @param sqlTemplate sql语句 + * @param clazz 返回类型 + * @param paras 参数 + * @param pageNum 页号 + * @param pageSize 数量 + * @return + */ + public static List getList(String sqlTemplate, Class clazz, Object paras, int pageNum, int pageSize) { + return getDbManager().getList(sqlTemplate, clazz, paras, pageNum, pageSize); + } + + /** + * 分页 + * @param sqlTemplate sql语句 + * @param paras 参数 + * @param pageNum 页号 + * @param pageSize 数量 + * @return + */ + @SuppressWarnings("rawtypes") + public static BladePage paginate(String sqlTemplate, Object paras, int pageNum, int pageSize){ + return getDbManager().paginate(sqlTemplate, paras, pageNum, pageSize); + } + + /** + * 分页 + * @param sqlTemplate sql语句 + * @param clazz 返回类型 + * @param paras 参数 + * @param pageNum 页号 + * @param pageSize 数量 + * @return + */ + public static BladePage paginate(String sqlTemplate, Class clazz, Object paras, int pageNum, int pageSize){ + return getDbManager().paginate(sqlTemplate, clazz, paras, pageNum, pageSize); + } + + /** + * 分页 + * @param sqlTemplate sql语句 + * @param sqlCount count语句 + * @param clazz 返回类型 + * @param paras 参数 + * @param pageNum 页号 + * @param pageSize 数量 + * @return + */ + @SuppressWarnings("rawtypes") + public static BladePage paginate(String sqlTemplate, String sqlCount, Object paras, int pageNum, int pageSize){ + return getDbManager().paginate(sqlTemplate, sqlCount, paras, pageNum, pageSize); + } + + /** + * 分页 + * @param sqlTemplate sql语句 + * @param sqlCount count语句 + * @param clazz 返回类型 + * @param paras 参数 + * @param pageNum 页号 + * @param pageSize 数量 + * @return + */ + public static BladePage paginate(String sqlTemplate, String sqlCount, Class clazz, Object paras, int pageNum, int pageSize){ + return getDbManager().paginate(sqlTemplate, sqlCount, clazz, paras, pageNum, pageSize); + } + + /** + * 是否存在 + * + * @param sqlTemplate + * @param paras + * @return + */ + public static boolean isExist(String sqlTemplate, Object paras) { + return getDbManager().isExist(sqlTemplate, paras); + } +} diff --git a/src/main/java/com/smallchill/core/plugins/dao/DbManager.java b/src/main/java/com/smallchill/core/plugins/dao/DbManager.java index 6b5dbabc..e3a09e57 100644 --- a/src/main/java/com/smallchill/core/plugins/dao/DbManager.java +++ b/src/main/java/com/smallchill/core/plugins/dao/DbManager.java @@ -215,7 +215,7 @@ public class DbManager { * @param pkValue 主键值 * @return */ - public Map findById(String tableName, String pkValue) { + public Map findById(String tableName, Object pkValue) { return selectOneBy(tableName, "id = #{id}", CMap.init().set("id", pkValue)); } @@ -226,7 +226,7 @@ public class DbManager { * @param pkValue 主键值 * @return */ - public Map findById(String tableName, String pk, String pkValue) { + public Map findById(String tableName, String pk, Object pkValue) { return selectOneBy(tableName, pk + " = #{id}", CMap.init().set("id", pkValue)); }