org.tinygroup.tinydb.operator.impl

Class BeanDBSqlOperator<K>

java.lang.Object

org.tinygroup.tinydb.sql.impl.StatementTransformAdapter

org.tinygroup.tinydb.sql.impl.StatementTransformComposite

org.tinygroup.tinydb.operator.impl.DBSpringBaseOperator

org.tinygroup.tinydb.operator.impl.BeanDBSingleOperator<K>

org.tinygroup.tinydb.operator.impl.BeanDBBatchOperator<K>

org.tinygroup.tinydb.operator.impl.BeanDBSqlOperator<K>

All Implemented Interfaces:

DbBaseOperator, DbBatchOperator<K>, DbRelationOperator, DbSingleOperator<K>, DbSqlOperator<K>, TransactionOperator, StatementTransform

Direct Known Subclasses:

BeanDBSqlQueryOperator

public class BeanDBSqlOperator<K>
extends BeanDBBatchOperator<K>
implements DbSqlOperator<K>

Field Summary

Fields

Modifier and Type	Field and Description
protected BeanOperatorManager	manager

Fields inherited from class org.tinygroup.tinydb.operator.impl.DBSpringBaseOperator

jdbcTemplate

Fields inherited from class org.tinygroup.tinydb.sql.impl.StatementTransformAdapter

beanDbNameConverter, configuration, schema

Fields inherited from interface org.tinygroup.tinydb.operator.DbBaseOperator

DEFAULT_BEAN_TYPE

Constructor Summary

Constructors

Constructor and Description
BeanDBSqlOperator()
BeanDBSqlOperator(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, Configuration configuration)

Method Summary

Modifier and Type	Method and Description
int	account(Bean bean) 根据bean对象查询该bean对象的记录数
int	account(String sql, List<Object> parameters)
int	account(String sql, Map<String,Object> parameters)
int	account(String sql, Object... parameters)
protected org.springframework.jdbc.core.SqlParameterValue	createSqlParameter(Object value, ColumnConfiguration primaryColumn)
protected org.springframework.jdbc.core.SqlParameterValue[]	createSqlParameterValue(Bean bean)
protected org.springframework.jdbc.core.SqlParameterValue	createSqlParamter(Object value, ColumnConfiguration primaryColumn) Deprecated.
int	execute(String sql, List<Object> parameters)
int	execute(String sql, Map<String,Object> parameters) 执行带参数的sql语句
int	execute(String sql, Object... parameters) 执行带参数的sql语句
int	getAutoIncreaseKey() 如果是自增长类型的Key返回新增加的值
Bean[]	getBeans(Bean bean, int start, int limit) 分页查询bean
Bean[]	getBeans(String sql)
Bean[]	getBeans(String sql, List<Object> parameters)
Bean[]	getBeans(String sql, Map<String,Object> parameters)
Bean[]	getBeans(String sql, Object... parameters)
protected List<String>	getColumnNames(Bean bean) 获取操作的所有数据库字段名称
Bean[]	getCursorPageBeans(String sql, int start, int limit)
Bean[]	getCursorPageBeans(String sql, int start, int limit, List<Object> parameters)
Bean[]	getCursorPageBeans(String sql, int start, int limit, Map<String,Object> parameters)
Bean[]	getCursorPageBeans(String sql, int start, int limit, Object... parameters)
protected List<Integer>	getDataTypes(Bean bean) 获取操作的所有数据库字段类型
protected List<Integer>	getDataTypes(List<ColumnConfiguration> paramsKeys)
protected List<List<Object>>	getDeleteParams(Bean[] beans)
protected String	getDeleteSqlByKey(String beanType)
Bean[]	getDialectPageBeans(String sql, int start, int limit)
Bean[]	getDialectPageBeans(String sql, int start, int limit, List<Object> parameters)
Bean[]	getDialectPageBeans(String sql, int start, int limit, Map<String,Object> parameters)
Bean[]	getDialectPageBeans(String sql, int start, int limit, Object... parameters)
protected List<org.springframework.jdbc.core.SqlParameterValue[]>	getInsertParams(Bean[] beans)
BeanOperatorManager	getManager()
Bean[]	getPageBeans(String sql, int start, int limit)
Bean[]	getPageBeans(String sql, int start, int limit, List<Object> parameters)
Bean[]	getPageBeans(String sql, int start, int limit, Map<String,Object> parameters)
Bean[]	getPageBeans(String sql, int start, int limit, Object... parameters)
Pager	getPager(Bean bean, int start, int limit) 分页查询bean
Pager	getPager(String sql, int start, int limit)
Pager	getPager(String sql, int start, int limit, List<Object> parameters)
Pager	getPager(String sql, int start, int limit, Map<String,Object> parameters)
Pager	getPager(String sql, int start, int limit, Object... parameters)
protected List<Object>	getParam(Bean bean, List<ColumnConfiguration> paramsKeys)
protected List<List<Object>>	getParamList(Bean[] beans, List<ColumnConfiguration> paramsKeys)
protected List<Object>	getParams(Bean bean)
protected List<org.springframework.jdbc.core.SqlParameterValue[]>	getParams(Bean[] beans, org.springframework.jdbc.core.SqlParameterValue[] values)
protected String	getPrimaryFieldName(DbBaseOperator operator, String beanType)
protected String	getPrimaryKeyValue(DbBaseOperator operator, Bean bean) 获取主键值
protected String	getQuerySql(String beanType)
Relation	getRelation(String beanType) 获取关联操作对象
String	getSchema() 获取schame
Bean	getSingleValue(String sql)
Bean	getSingleValue(String sql, List<Object> parameters)
Bean	getSingleValue(String sql, Map<String,Object> parameters)
Bean	getSingleValue(String sql, Object... parameters)
protected org.springframework.jdbc.core.SqlParameterValue[]	getSqlParameterValue(Bean bean, List<String> conditionColumns)
protected org.springframework.jdbc.core.SqlParameterValue[]	getSqlParameterValues(Bean bean)
protected org.springframework.jdbc.core.SqlParameterValue[]	getSqlParamterValue(Bean bean, List<String> conditionColumns) Deprecated.
protected String	getTableNameWithSchame(String tableName)
void	setManager(BeanOperatorManager manager)

Methods inherited from class org.tinygroup.tinydb.operator.impl.BeanDBBatchOperator

batchDelete, batchDelete, batchDelete, batchDelete, batchInsert, batchInsert, batchInsert, batchInsert, batchUpdate, batchUpdate, batchUpdate, batchUpdate, deleteBean, deleteById, deleteById, executeBatch, executeBatchByList, executeBatchByList, executeBatchByMap, getBeans, getBeansById, getBeansById, insertBean, updateBean

Methods inherited from class org.tinygroup.tinydb.operator.impl.BeanDBSingleOperator

beanNotExist, checkMoreToOne, checkOneToMore, createRelationBean, createRelationBeans, delete, deleteById, deleteTopBean, getBean, getRelationBeans, insert, insertTopBean, processRelation, relationProcess, update, update, updateTopBean

Methods inherited from class org.tinygroup.tinydb.operator.impl.DBSpringBaseOperator

account, beginTransaction, checkNullParamList, commitTransaction, deleteNullParamList, execute, executeBatchBySqlParamterValues, executeBatchOperator, executeBatchOperator, executeByArray, executeByList, executeByMap, executeBySqlParameterValue, executeBySqlParameterValues, findBeans, findBeans, findBeansByList, findBeansByListForCursorPage, findBeansByListForDialectPage, findBeansByListForPage, findBeansByMap, findBeansByMapForCursorPage, findBeansByMapForDialectPage, findBeansByMapForPage, findBeansForCursorPage, findBeansForDialectPage, findBeansForPage, getBeanDbNameConverter, getDialect, getParamArray, getTransactionDefinition, getTransactionManager, getUniqueCode, operatorDebugLog, operatorDebugLogNoParam, operatorErrorLog, operatorErrorLogNoParam, queryForInt, queryForIntByList, queryForIntByMap, queryObject, queryObjectByMap, rollbackTransaction, setBeanDbNameConverter, setDialect, setJdbcTemplate, setTransactionDefinition, setTransactionManager

Methods inherited from class org.tinygroup.tinydb.sql.impl.StatementTransformComposite

setConfiguration, setSchema, toDelete, toInsert, toSelect, toUpdate

Methods inherited from class org.tinygroup.tinydb.sql.impl.StatementTransformAdapter

checkBeanPropertyNull, getConditionParams, getConditionSql, getDeleteSql, getFullTableName, getInsertSql, getTableName, getUpdateSql

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.tinygroup.tinydb.operator.DbBaseOperator

getBeanDbNameConverter, getDialect, getUniqueCode, setBeanDbNameConverter, setConfiguration, setDialect, setJdbcTemplate, setSchema

Field Detail

manager

protected BeanOperatorManager manager

Constructor Detail

BeanDBSqlOperator

public BeanDBSqlOperator()

BeanDBSqlOperator

public BeanDBSqlOperator(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate,
                         Configuration configuration)

Method Detail

getBeans

public Bean[] getBeans(String sql)
                throws TinyDbException

Specified by:

getBeans in interface DbSqlOperator<K>

Throws:

TinyDbException

getBeans

public Bean[] getBeans(String sql,
                       Map<String,Object> parameters)
                throws TinyDbException

Specified by:

getBeans in interface DbSqlOperator<K>

Throws:

TinyDbException

getPageBeans

public Bean[] getPageBeans(String sql,
                           int start,
                           int limit,
                           Map<String,Object> parameters)
                    throws TinyDbException

Specified by:

getPageBeans in interface DbSqlOperator<K>

Throws:

TinyDbException

getBeans

public Bean[] getBeans(String sql,
                       Object... parameters)
                throws TinyDbException

Specified by:

getBeans in interface DbSqlOperator<K>

Throws:

TinyDbException

getBeans

public Bean[] getBeans(String sql,
                       List<Object> parameters)
                throws TinyDbException

Specified by:

getBeans in interface DbSqlOperator<K>

Throws:

TinyDbException

getPageBeans

public Bean[] getPageBeans(String sql,
                           int start,
                           int limit,
                           Object... parameters)
                    throws TinyDbException

Specified by:

getPageBeans in interface DbSqlOperator<K>

Throws:

TinyDbException

getCursorPageBeans

public Bean[] getCursorPageBeans(String sql,
                                 int start,
                                 int limit)
                          throws TinyDbException

Specified by:

getCursorPageBeans in interface DbSqlOperator<K>

Throws:

TinyDbException

getCursorPageBeans

public Bean[] getCursorPageBeans(String sql,
                                 int start,
                                 int limit,
                                 Map<String,Object> parameters)
                          throws TinyDbException

Specified by:

getCursorPageBeans in interface DbSqlOperator<K>

Throws:

TinyDbException

getCursorPageBeans

public Bean[] getCursorPageBeans(String sql,
                                 int start,
                                 int limit,
                                 List<Object> parameters)
                          throws TinyDbException

Specified by:

getCursorPageBeans in interface DbSqlOperator<K>

Throws:

TinyDbException

getCursorPageBeans

public Bean[] getCursorPageBeans(String sql,
                                 int start,
                                 int limit,
                                 Object... parameters)
                          throws TinyDbException

Specified by:

getCursorPageBeans in interface DbSqlOperator<K>

Throws:

TinyDbException

getPageBeans

public Bean[] getPageBeans(String sql,
                           int start,
                           int limit)
                    throws TinyDbException

Specified by:

getPageBeans in interface DbSqlOperator<K>

Throws:

TinyDbException

getDialectPageBeans

public Bean[] getDialectPageBeans(String sql,
                                  int start,
                                  int limit)
                           throws TinyDbException

Specified by:

getDialectPageBeans in interface DbSqlOperator<K>

Throws:

TinyDbException

getDialectPageBeans

public Bean[] getDialectPageBeans(String sql,
                                  int start,
                                  int limit,
                                  Object... parameters)
                           throws TinyDbException

Specified by:

getDialectPageBeans in interface DbSqlOperator<K>

Throws:

TinyDbException

getPageBeans

public Bean[] getPageBeans(String sql,
                           int start,
                           int limit,
                           List<Object> parameters)
                    throws TinyDbException

Specified by:

getPageBeans in interface DbSqlOperator<K>

Throws:

TinyDbException

getDialectPageBeans

public Bean[] getDialectPageBeans(String sql,
                                  int start,
                                  int limit,
                                  List<Object> parameters)
                           throws TinyDbException

Specified by:

getDialectPageBeans in interface DbSqlOperator<K>

Throws:

TinyDbException

getDialectPageBeans

public Bean[] getDialectPageBeans(String sql,
                                  int start,
                                  int limit,
                                  Map<String,Object> parameters)
                           throws TinyDbException

Specified by:

getDialectPageBeans in interface DbSqlOperator<K>

Throws:

TinyDbException

getSingleValue

public Bean getSingleValue(String sql)
                    throws TinyDbException

Specified by:

getSingleValue in interface DbSqlOperator<K>

Throws:

TinyDbException

getSingleValue

public Bean getSingleValue(String sql,
                           Map<String,Object> parameters)
                    throws TinyDbException

Specified by:

getSingleValue in interface DbSqlOperator<K>

Throws:

TinyDbException

getSingleValue

public Bean getSingleValue(String sql,
                           Object... parameters)
                    throws TinyDbException

Specified by:

getSingleValue in interface DbSqlOperator<K>

Throws:

TinyDbException

getSingleValue

public Bean getSingleValue(String sql,
                           List<Object> parameters)
                    throws TinyDbException

Specified by:

getSingleValue in interface DbSqlOperator<K>

Throws:

TinyDbException

execute

public int execute(String sql,
                   Map<String,Object> parameters)
            throws TinyDbException

Description copied from interface: DbSqlOperator

执行带参数的sql语句

Specified by:

execute in interface DbSqlOperator<K>

Returns:

Throws:

TinyDbException

execute

public int execute(String sql,
                   Object... parameters)
            throws TinyDbException

Description copied from interface: DbSqlOperator

执行带参数的sql语句

Specified by:

execute in interface DbSqlOperator<K>

Returns:

Throws:

TinyDbException

execute

public int execute(String sql,
                   List<Object> parameters)
            throws TinyDbException

Specified by:

execute in interface DbSqlOperator<K>

Throws:

TinyDbException

account

public int account(String sql,
                   Object... parameters)
            throws TinyDbException

Specified by:

account in interface DbSqlOperator<K>

Throws:

TinyDbException

account

public int account(String sql,
                   List<Object> parameters)
            throws TinyDbException

Specified by:

account in interface DbSqlOperator<K>

Throws:

TinyDbException

account

public int account(String sql,
                   Map<String,Object> parameters)
            throws TinyDbException

Specified by:

account in interface DbSqlOperator<K>

Throws:

TinyDbException

getPager

public Pager getPager(String sql,
                      int start,
                      int limit)
               throws TinyDbException

Specified by:

getPager in interface DbSqlOperator<K>

Throws:

TinyDbException

getPager

public Pager getPager(String sql,
                      int start,
                      int limit,
                      Object... parameters)
               throws TinyDbException

Specified by:

getPager in interface DbSqlOperator<K>

Throws:

TinyDbException

getPager

public Pager getPager(String sql,
                      int start,
                      int limit,
                      List<Object> parameters)
               throws TinyDbException

Specified by:

getPager in interface DbSqlOperator<K>

Throws:

TinyDbException

getPager

public Pager getPager(String sql,
                      int start,
                      int limit,
                      Map<String,Object> parameters)
               throws TinyDbException

Specified by:

getPager in interface DbSqlOperator<K>

Throws:

TinyDbException

getBeans

public Bean[] getBeans(Bean bean,
                       int start,
                       int limit)
                throws TinyDbException

Description copied from interface: DbSqlOperator

分页查询bean

Specified by:

getBeans in interface DbSqlOperator<K>

Returns:

Throws:

TinyDbException

getPager

public Pager getPager(Bean bean,
                      int start,
                      int limit)
               throws TinyDbException

Description copied from interface: DbSqlOperator

分页查询bean

Specified by:

getPager in interface DbSqlOperator<K>

Returns:

Throws:

TinyDbException

account

public int account(Bean bean)
            throws TinyDbException

Description copied from interface: DbSqlOperator

根据bean对象查询该bean对象的记录数

Specified by:

account in interface DbSqlOperator<K>

Returns:

Throws:

TinyDbException

getAutoIncreaseKey

public int getAutoIncreaseKey()
                       throws TinyDbException

Description copied from interface: DbBaseOperator

如果是自增长类型的Key返回新增加的值

Specified by:

getAutoIncreaseKey in interface DbBaseOperator

Returns:

Throws:

TinyDbException

getDeleteSqlByKey

protected String getDeleteSqlByKey(String beanType)
                            throws TinyDbException

Throws:

TinyDbException

getColumnNames

protected List<String> getColumnNames(Bean bean)

获取操作的所有数据库字段名称

Overrides:

getColumnNames in class StatementTransformAdapter

Parameters:

bean -

Returns:

getDataTypes

protected List<Integer> getDataTypes(Bean bean)

获取操作的所有数据库字段类型

Parameters:

bean -

Returns:

getSqlParameterValues

protected org.springframework.jdbc.core.SqlParameterValue[] getSqlParameterValues(Bean bean)

getDataTypes

protected List<Integer> getDataTypes(List<ColumnConfiguration> paramsKeys)

createSqlParamter

@Deprecated
protected org.springframework.jdbc.core.SqlParameterValue createSqlParamter(Object value,
                                                                                        ColumnConfiguration primaryColumn)

Deprecated.

createSqlParameter

protected org.springframework.jdbc.core.SqlParameterValue createSqlParameter(Object value,
                                                                             ColumnConfiguration primaryColumn)

getSqlParamterValue

@Deprecated
protected org.springframework.jdbc.core.SqlParameterValue[] getSqlParamterValue(Bean bean,
                                                                                            List<String> conditionColumns)
                                                                                     throws TinyDbException

Deprecated.

Throws:

TinyDbException

getSqlParameterValue

protected org.springframework.jdbc.core.SqlParameterValue[] getSqlParameterValue(Bean bean,
                                                                                 List<String> conditionColumns)
                                                                          throws TinyDbException

Throws:

TinyDbException

getParamList

protected List<List<Object>> getParamList(Bean[] beans,
                                          List<ColumnConfiguration> paramsKeys)

getParam

protected List<Object> getParam(Bean bean,
                                List<ColumnConfiguration> paramsKeys)

createSqlParameterValue

protected org.springframework.jdbc.core.SqlParameterValue[] createSqlParameterValue(Bean bean)
                                                                             throws TinyDbException

Throws:

TinyDbException

getInsertParams

protected List<org.springframework.jdbc.core.SqlParameterValue[]> getInsertParams(Bean[] beans)
                                                                           throws TinyDbException

Throws:

TinyDbException

getParams

protected List<org.springframework.jdbc.core.SqlParameterValue[]> getParams(Bean[] beans,
                                                                            org.springframework.jdbc.core.SqlParameterValue[] values)

getDeleteParams

protected List<List<Object>> getDeleteParams(Bean[] beans)

getParams

protected List<Object> getParams(Bean bean)

getQuerySql

protected String getQuerySql(String beanType)
                      throws TinyDbException

Throws:

TinyDbException

getTableNameWithSchame

protected String getTableNameWithSchame(String tableName)

Overrides:

getTableNameWithSchame in class StatementTransformAdapter

getSchema

public String getSchema()

Description copied from interface: DbBaseOperator

获取schame

Specified by:

getSchema in interface DbBaseOperator

Overrides:

getSchema in class StatementTransformAdapter

getManager

public BeanOperatorManager getManager()

Specified by:

getManager in interface DbBaseOperator

setManager

public void setManager(BeanOperatorManager manager)

Specified by:

setManager in interface DbBaseOperator

getRelation

public Relation getRelation(String beanType)

Description copied from interface: DbRelationOperator

获取关联操作对象

Specified by:

getRelation in interface DbRelationOperator

Returns:

getPrimaryFieldName

protected String getPrimaryFieldName(DbBaseOperator operator,
                                     String beanType)
                              throws TinyDbException

Throws:

TinyDbException

getPrimaryKeyValue

protected String getPrimaryKeyValue(DbBaseOperator operator,
                                    Bean bean)
                             throws TinyDbException

获取主键值

Parameters:

operator -

bean -

Returns:

Throws:

TinyDbException