github/SpringBlade
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bug fix

Browse Source
This commit is contained in:
zhuangqian 2017-02-27 21:37:07 +08:00
parent c21fdefb60
commit f7e9678f5f
2 changed files with 416 additions and 416 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

828
src/main/java/com/smallchill/core/plugins/dao/Db.java
View File

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

4
src/main/java/com/smallchill/core/plugins/dao/DbManager.java
View File

@ -215,7 +215,7 @@ public class DbManager {
* @param pkValue 主键值 * @param pkValue 主键值
* @return * @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)); return selectOneBy(tableName, "id = #{id}", CMap.init().set("id", pkValue));
} }
@ -226,7 +226,7 @@ public class DbManager {
* @param pkValue 主键值 * @param pkValue 主键值
* @return * @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)); return selectOneBy(tableName, pk + " = #{id}", CMap.init().set("id", pkValue));
} }