org.tinygroup.tinydb.operator.impl

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

All Implemented Interfaces:

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

Direct Known Subclasses:

BeanDBSqlOperator

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

Method Summary

Modifier and Type	Method and Description
int[]	batchDelete(Bean[] beans)
void	batchDelete(Bean[] beans, int batchSize)
int[]	batchDelete(Collection<Bean> beans)
void	batchDelete(Collection<Bean> beans, int batchSize)
Bean[]	batchInsert(Bean[] beans)
Bean[]	batchInsert(Bean[] beans, int batchSize) 可以分批次进行批处理操作
Bean[]	batchInsert(Collection<Bean> beans)
Bean[]	batchInsert(Collection<Bean> beans, int batchSize)
int[]	batchUpdate(Bean[] beans)
void	batchUpdate(Bean[] beans, int batchSize)
int[]	batchUpdate(Collection<Bean> beans)
void	batchUpdate(Collection<Bean> beans, int batchSize)
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[]	deleteBean(Bean[] beans)
int[]	deleteById(Collection<K> beanIds, String beanType)
int[]	deleteById(K[] beanIds, String beanType)
int[]	executeBatch(List<String> sqls) 批量执行sql语句
int[]	executeBatchByList(String sql, List<List<Object>> parameters)
int[]	executeBatchByList(String sql, List<List<Object>> parameters, int[] columnTypes)
int[]	executeBatchByMap(String sql, List<Map<String,Object>> parameters)
int	getAutoIncreaseKey() 如果是自增长类型的Key返回新增加的值
Bean[]	getBeans(Bean bean)
Bean[]	getBeansById(Collection<K> beanIds, String beanType)
Bean[]	getBeansById(K[] beanIds, String beanType)
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.
protected String	getTableNameWithSchame(String tableName)
Bean[]	insertBean(Bean[] beans) 处理的bean类型可以不一样，非批处理实现方式
void	setManager(BeanOperatorManager manager)
int[]	updateBean(Bean[] beans)

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

BeanDBBatchOperator

public BeanDBBatchOperator()

BeanDBBatchOperator

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

Method Detail

getBeans

public Bean[] getBeans(Bean bean)
                throws TinyDbException

Specified by:

getBeans in interface DbBatchOperator<K>

Throws:

TinyDbException

batchInsert

public Bean[] batchInsert(Bean[] beans)
                   throws TinyDbException

Specified by:

batchInsert in interface DbBatchOperator<K>

Throws:

TinyDbException

batchUpdate

public int[] batchUpdate(Bean[] beans)
                  throws TinyDbException

Specified by:

batchUpdate in interface DbBatchOperator<K>

Throws:

TinyDbException

batchDelete

public int[] batchDelete(Bean[] beans)
                  throws TinyDbException

Specified by:

batchDelete in interface DbBatchOperator<K>

Throws:

TinyDbException

deleteById

public int[] deleteById(K[] beanIds,
                        String beanType)
                 throws TinyDbException

Specified by:

deleteById in interface DbBatchOperator<K>

Throws:

TinyDbException

getBeansById

public Bean[] getBeansById(K[] beanIds,
                           String beanType)
                    throws TinyDbException

Specified by:

getBeansById in interface DbBatchOperator<K>

Throws:

TinyDbException

batchInsert

public Bean[] batchInsert(Collection<Bean> beans)
                   throws TinyDbException

Specified by:

batchInsert in interface DbBatchOperator<K>

Throws:

TinyDbException

batchInsert

public Bean[] batchInsert(Collection<Bean> beans,
                          int batchSize)
                   throws TinyDbException

Specified by:

batchInsert in interface DbBatchOperator<K>

Throws:

TinyDbException

batchUpdate

public int[] batchUpdate(Collection<Bean> beans)
                  throws TinyDbException

Specified by:

batchUpdate in interface DbBatchOperator<K>

Throws:

TinyDbException

batchUpdate

public void batchUpdate(Collection<Bean> beans,
                        int batchSize)
                 throws TinyDbException

Specified by:

batchUpdate in interface DbBatchOperator<K>

Throws:

TinyDbException

batchDelete

public int[] batchDelete(Collection<Bean> beans)
                  throws TinyDbException

Specified by:

batchDelete in interface DbBatchOperator<K>

Throws:

TinyDbException

batchDelete

public void batchDelete(Collection<Bean> beans,
                        int batchSize)
                 throws TinyDbException

Specified by:

batchDelete in interface DbBatchOperator<K>

Throws:

TinyDbException

deleteById

public int[] deleteById(Collection<K> beanIds,
                        String beanType)
                 throws TinyDbException

Specified by:

deleteById in interface DbBatchOperator<K>

Throws:

TinyDbException

getBeansById

public Bean[] getBeansById(Collection<K> beanIds,
                           String beanType)
                    throws TinyDbException

Specified by:

getBeansById in interface DbBatchOperator<K>

Throws:

TinyDbException

batchInsert

public Bean[] batchInsert(Bean[] beans,
                          int batchSize)
                   throws TinyDbException

Description copied from interface: DbBatchOperator

可以分批次进行批处理操作

Specified by:

batchInsert in interface DbBatchOperator<K>

Parameters:

beans - 批处理的所有记录

batchSize - 一次批处理最大数量

Returns:

Throws:

TinyDbException

batchUpdate

public void batchUpdate(Bean[] beans,
                        int batchSize)
                 throws TinyDbException

Specified by:

batchUpdate in interface DbBatchOperator<K>

Throws:

TinyDbException

batchDelete

public void batchDelete(Bean[] beans,
                        int batchSize)
                 throws TinyDbException

Specified by:

batchDelete in interface DbBatchOperator<K>

Throws:

TinyDbException

insertBean

public Bean[] insertBean(Bean[] beans)
                  throws TinyDbException

Description copied from interface: DbBatchOperator

处理的bean类型可以不一样，非批处理实现方式

Specified by:

insertBean in interface DbBatchOperator<K>

Returns:

Throws:

TinyDbException

updateBean

public int[] updateBean(Bean[] beans)
                 throws TinyDbException

Specified by:

updateBean in interface DbBatchOperator<K>

Throws:

TinyDbException

deleteBean

public int[] deleteBean(Bean[] beans)
                 throws TinyDbException

Specified by:

deleteBean in interface DbBatchOperator<K>

Throws:

TinyDbException

executeBatch

public int[] executeBatch(List<String> sqls)
                   throws TinyDbException

Description copied from interface: DbBatchOperator

批量执行sql语句

Specified by:

executeBatch in interface DbBatchOperator<K>

Returns:

Throws:

TinyDbException

executeBatchByList

public int[] executeBatchByList(String sql,
                                List<List<Object>> parameters)
                         throws TinyDbException

Specified by:

executeBatchByList in interface DbBatchOperator<K>

Throws:

TinyDbException

executeBatchByList

public int[] executeBatchByList(String sql,
                                List<List<Object>> parameters,
                                int[] columnTypes)
                         throws TinyDbException

Specified by:

executeBatchByList in interface DbBatchOperator<K>

Throws:

TinyDbException

executeBatchByMap

public int[] executeBatchByMap(String sql,
                               List<Map<String,Object>> parameters)
                        throws TinyDbException

Specified by:

executeBatchByMap in interface DbBatchOperator<K>

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