org.tinygroup.tinydb.operator.impl

Class GenericDbOperator<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>

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

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

All Implemented Interfaces:

DbBaseOperator, DbBatchOperator<K>, DbMonitorOperator, DBOperator<K>, DbRelationOperator, DbSingleOperator<K>, DbSqlOperator<K>, DbSqlQueryOperator<K>, SqlRowSetOperator, TransactionOperator, StatementTransform

Direct Known Subclasses:

BeanStringOperator

public class GenericDbOperator<K>
extends BeanDBSqlQueryOperator<K>
implements DBOperator<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
GenericDbOperator()
GenericDbOperator(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate, Configuration configuration)

Method Summary

Modifier and Type	Method and Description
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	getAutoIncreaseKey() 如果是自增长类型的Key返回新增加的值
protected List<String>	getColumnNames(Bean bean) 获取操作的所有数据库字段名称
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)
protected List<org.springframework.jdbc.core.SqlParameterValue[]>	getInsertParams(Bean[] beans)
BeanOperatorManager	getManager()
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
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.
org.springframework.jdbc.support.rowset.SqlRowSet	getSqlRowSet(String sql)
org.springframework.jdbc.support.rowset.SqlRowSet	getSqlRowSet(String sql, List<Object> parameters)
org.springframework.jdbc.support.rowset.SqlRowSet	getSqlRowSet(String sql, Map<String,Object> parameters)
org.springframework.jdbc.support.rowset.SqlRowSet	getSqlRowSet(String sql, Object... parameters)
protected String	getTableNameWithSchame(String tableName)
Collection<ConnectionTrace>	queryAllActiveConnection() 获取当前正在使用的连接信息
void	setManager(BeanOperatorManager manager)

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

generateOrderSqlClause, generateQuerySqlClause, generateSelectSqlClause, generateSqlClause, generateSqlClause, getBeans, getBeans, getBeans, getBeans, getBeans, getBeans, getSingleValue, getSingleValue, getSingleValue

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

account, account, account, account, execute, execute, execute, getBeans, getBeans, getBeans, getBeans, getBeans, getCursorPageBeans, getCursorPageBeans, getCursorPageBeans, getCursorPageBeans, getDialectPageBeans, getDialectPageBeans, getDialectPageBeans, getDialectPageBeans, getPageBeans, getPageBeans, getPageBeans, getPageBeans, getPager, getPager, getPager, getPager, getPager, getSingleValue, getSingleValue, getSingleValue, getSingleValue

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

getAutoIncreaseKey, getBeanDbNameConverter, getDialect, getManager, getSchema, getUniqueCode, setBeanDbNameConverter, setConfiguration, setDialect, setJdbcTemplate, setManager, setSchema

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

getRelation

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

delete, deleteById, getBean, insert, update, update

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

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 interface org.tinygroup.tinydb.operator.DbSqlOperator

account, account, account, account, execute, execute, execute, getBeans, getBeans, getBeans, getBeans, getBeans, getCursorPageBeans, getCursorPageBeans, getCursorPageBeans, getCursorPageBeans, getDialectPageBeans, getDialectPageBeans, getDialectPageBeans, getDialectPageBeans, getPageBeans, getPageBeans, getPageBeans, getPageBeans, getPager, getPager, getPager, getPager, getPager, getSingleValue, getSingleValue, getSingleValue, getSingleValue

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

getBeans, getBeans, getBeans, getBeans, getBeans, getBeans, getSingleValue, getSingleValue, getSingleValue

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

beginTransaction, commitTransaction, execute, rollbackTransaction, setTransactionDefinition, setTransactionManager

Field Detail

manager

protected BeanOperatorManager manager

Constructor Detail

GenericDbOperator

public GenericDbOperator()

GenericDbOperator

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

Method Detail

getSqlRowSet

public org.springframework.jdbc.support.rowset.SqlRowSet getSqlRowSet(String sql)
                                                               throws TinyDbException

Specified by:

getSqlRowSet in interface SqlRowSetOperator

Throws:

TinyDbException

getSqlRowSet

public org.springframework.jdbc.support.rowset.SqlRowSet getSqlRowSet(String sql,
                                                                      Object... parameters)
                                                               throws TinyDbException

Specified by:

getSqlRowSet in interface SqlRowSetOperator

Throws:

TinyDbException

getSqlRowSet

public org.springframework.jdbc.support.rowset.SqlRowSet getSqlRowSet(String sql,
                                                                      List<Object> parameters)
                                                               throws TinyDbException

Specified by:

getSqlRowSet in interface SqlRowSetOperator

Throws:

TinyDbException

getSqlRowSet

public org.springframework.jdbc.support.rowset.SqlRowSet getSqlRowSet(String sql,
                                                                      Map<String,Object> parameters)
                                                               throws TinyDbException

Specified by:

getSqlRowSet in interface SqlRowSetOperator

Throws:

TinyDbException

queryAllActiveConnection

public Collection<ConnectionTrace> queryAllActiveConnection()

Description copied from interface: DbMonitorOperator

获取当前正在使用的连接信息

Specified by:

queryAllActiveConnection in interface DbMonitorOperator

Returns:

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