com.hecloud.runtime.database.core

类 BasicDao

java.lang.Object

com.hecloud.runtime.database.core.BasicDao

所有已实现的接口:

org.springframework.beans.factory.InitializingBean

@Repository
public class BasicDao
extends Object
implements org.springframework.beans.factory.InitializingBean

ORM映射基础类

作者:

LoveinBJ

构造器概要

构造器

构造器和说明
BasicDao()

方法概要

限定符和类型	方法和说明
void	afterPropertiesSet()
boolean	baseDelete(Object bean) 根据bean的pk来删除bean
List<Map<String,Object>>	baseQueryForList(Class<?> clazz, Conditions conditions, Map<String,Object> paramMap) 自动分页/不分页查询返回list
boolean	baseSaveEntity(Object bean) 保存新增的实体对象
boolean	batchInsert(List<?> beans) 批量插入数据
boolean	batchInsert(List<?> beans, Integer batchSize) 指定批量大小的批量插入数据
boolean	batchUpdate(List<?> objects, Integer batchSize) 批量更新数据
boolean	batchUpdate(List<?> objects, String[] fields, Integer batchSize) 批量更新指定属性的实体类
Long	countQuery(String sql) 条数查询
Long	countQuery(String sql, Map<String,Object> param) 条数查询
boolean	deleteWithColumn(Object bean, String[] fields) 根据bean的部分字段的条件来删除bean
void	execute(String sql) 指定无参sql语句
Long	listCount(Class<?> cs, Conditions conditions, Map<String,Object> params) 获取查询记录条数
Object	loadEntity(Class<?> clazz, Serializable pk) 根据单一主键获取实体对象，必须为单一主键，无主键或者复合主键将会抛出异常
Object	queryForEntity(Class<?> clazz, Condition condition, Map<String,Object> paramMap) 查询满足条件的单条记录的实体对象，如果超过1条则抛出异常，没查询到则返回null
List<Map<String,Object>>	queryForList(String sql) 返回原始数据的列表查询
List<Object>	queryForList(String sql, Class<?> clazz) 返回实体对象列表的查询
List<Map<String,Object>>	queryForList(String sql, Map<String,Object> paramMap) 获取原生的数据列表
List<Object>	queryForList(String sql, Map<String,Object> paramMap, Class<?> clazz) 列表查询
Object	saveEntity(Object bean) 保存实体类，返回主键
int	update(String sql, Map<String,Object> paramMap) 执行带参sql语句
boolean	updateEntity(Object bean) 根据主键保存修改的实体对象
boolean	updateFields(Object bean, String[] fields) 根据bean的部分字段的条件来更新bean的信息

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

BasicDao

public BasicDao()

方法详细资料

loadEntity

public Object loadEntity(Class<?> clazz,
                         Serializable pk)
                  throws DatabaseException

根据单一主键获取实体对象，必须为单一主键，无主键或者复合主键将会抛出异常

参数:

clazz - 实体类 实体类

pk - 主键值

返回:

实体对象

抛出:

DatabaseException - 运行异常

saveEntity

public Object saveEntity(Object bean)
                  throws DatabaseException

保存实体类，返回主键

参数:

bean - 实体类对象

返回:

带有实体类的对象

抛出:

DatabaseException - 运行异常

execute

public void execute(String sql)
             throws DatabaseException

指定无参sql语句

参数:

sql - SQL语句 sql语句

抛出:

DatabaseException - 运行异常

update

public int update(String sql,
                  Map<String,Object> paramMap)
           throws DatabaseException

执行带参sql语句

参数:

sql - SQL语句

paramMap - 参数

返回:

生效行数

抛出:

DatabaseException - 运行异常

queryForList

public List<Map<String,Object>> queryForList(String sql)
                                      throws DatabaseException

返回原始数据的列表查询

参数:

sql - SQL语句 SQL语句

返回:

结果数组

抛出:

DatabaseException - 运行异常

queryForList

public List<Object> queryForList(String sql,
                                 Class<?> clazz)
                          throws DatabaseException

返回实体对象列表的查询

参数:

sql - SQL语句

clazz - 实体类

返回:

结果数组

抛出:

DatabaseException - 运行异常

queryForList

public List<Map<String,Object>> queryForList(String sql,
                                             Map<String,Object> paramMap)
                                      throws DatabaseException

获取原生的数据列表

参数:

sql - SQL语句

paramMap - 查询参数

返回:

结果数组

抛出:

DatabaseException - 运行异常

queryForList

public List<Object> queryForList(String sql,
                                 Map<String,Object> paramMap,
                                 Class<?> clazz)
                          throws DatabaseException

列表查询

参数:

sql - SQL语句

paramMap - 查询参数

clazz - 实体类

返回:

结果数组

抛出:

DatabaseException - 运行异常

baseSaveEntity

public boolean baseSaveEntity(Object bean)
                       throws DatabaseException

保存新增的实体对象

参数:

bean - 实体对象

返回:

是否成功

抛出:

DatabaseException - 运行异常

batchInsert

public boolean batchInsert(List<?> beans)
                    throws DatabaseException

批量插入数据

参数:

beans - 批量插入实体

返回:

是否成功

抛出:

DatabaseException - 运行异常

batchInsert

public boolean batchInsert(List<?> beans,
                           Integer batchSize)
                    throws DatabaseException

指定批量大小的批量插入数据

参数:

beans - 批量数据

batchSize - 批量大小

返回:

是否成功

抛出:

DatabaseException - 运行异常

updateEntity

public boolean updateEntity(Object bean)
                     throws DatabaseException

根据主键保存修改的实体对象

参数:

bean - 实体对象

返回:

是否成功

抛出:

DatabaseException - 运行异常

updateFields

public boolean updateFields(Object bean,
                            String[] fields)
                     throws DatabaseException

根据bean的部分字段的条件来更新bean的信息

参数:

bean - 需要修改的实体类对象

fields - 需要更新的属性值

返回:

是否更新成功

抛出:

DatabaseException - 运行异常

batchUpdate

public boolean batchUpdate(List<?> objects,
                           Integer batchSize)
                    throws DatabaseException

批量更新数据

参数:

objects - 待更新数据

batchSize - 批量规模

返回:

是否成功

抛出:

DatabaseException - 运行异常

batchUpdate

public boolean batchUpdate(List<?> objects,
                           String[] fields,
                           Integer batchSize)
                    throws DatabaseException

批量更新指定属性的实体类

参数:

objects - 实体数组

fields - 待更新字段

batchSize - 批量规模

返回:

是否成功

抛出:

DatabaseException - 运行异常

baseDelete

public boolean baseDelete(Object bean)
                   throws DatabaseException

根据bean的pk来删除bean

参数:

bean - 待删除对象

返回:

是否删除成功

抛出:

DatabaseException - 运行异常

deleteWithColumn

public boolean deleteWithColumn(Object bean,
                                String[] fields)
                         throws DatabaseException

根据bean的部分字段的条件来删除bean

参数:

bean - 待删除对象

fields - 判断条件

返回:

是否删除成功

抛出:

DatabaseException - 运行异常

countQuery

public Long countQuery(String sql,
                       Map<String,Object> param)
                throws DatabaseException

条数查询

参数:

sql - SQL语句

param - 查询参数

返回:

满足条件的行数

抛出:

DatabaseException - 运行异常

countQuery

public Long countQuery(String sql)
                throws DatabaseException

条数查询

参数:

sql - SQL语句

返回:

满足条数

抛出:

DatabaseException - 运行异常

listCount

public Long listCount(Class<?> cs,
                      Conditions conditions,
                      Map<String,Object> params)
               throws DatabaseException

获取查询记录条数

参数:

cs - 对象类

conditions - 条件定义

params - 查询参数

返回:

满足条数

抛出:

DatabaseException - 运行异常

baseQueryForList

public List<Map<String,Object>> baseQueryForList(Class<?> clazz,
                                                 Conditions conditions,
                                                 Map<String,Object> paramMap)
                                          throws DatabaseException

自动分页/不分页查询返回list

参数:

clazz - 查询对象

conditions - 条件定义

paramMap - 查询参数

返回:

满足对象列表

抛出:

DatabaseException - 运行异常

queryForEntity

public Object queryForEntity(Class<?> clazz,
                             Condition condition,
                             Map<String,Object> paramMap)
                      throws DatabaseException

查询满足条件的单条记录的实体对象，如果超过1条则抛出异常，没查询到则返回null

参数:

clazz - 查询对象

condition - 条件定义

paramMap - 查询参数

返回:

满足对象

抛出:

DatabaseException - 运行异常

afterPropertiesSet

public void afterPropertiesSet()
                        throws DatabaseException

指定者:

afterPropertiesSet 在接口中 org.springframework.beans.factory.InitializingBean

抛出:

DatabaseException