org.tinygroup.tinydb.operator.impl

Class DBSpringBaseOperator

java.lang.Object

org.tinygroup.tinydb.sql.impl.StatementTransformAdapter

org.tinygroup.tinydb.sql.impl.StatementTransformComposite

org.tinygroup.tinydb.operator.impl.DBSpringBaseOperator

All Implemented Interfaces:

TransactionOperator, StatementTransform

Direct Known Subclasses:

BeanDBSingleOperator

public class DBSpringBaseOperator
extends StatementTransformComposite
implements TransactionOperator

Field Summary

Fields

Modifier and Type	Field and Description
protected org.springframework.jdbc.core.JdbcTemplate	jdbcTemplate

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

beanDbNameConverter, configuration, schema

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
int	account(String sql)
void	beginTransaction() 开始事务
protected Object[]	checkNullParamList(List<Object> parameters)
void	commitTransaction() 提交事务
protected Object[]	deleteNullParamList(List<Object> parameters)
Object	execute(TransactionCallBack callback) 以事务方式执行回调处理
protected int[]	executeBatchBySqlParamterValues(String sql, List<org.springframework.jdbc.core.SqlParameterValue[]> parameters) 根据参数中sql语句进行批处理操作
protected int[]	executeBatchOperator(String[] sqls)
protected int[]	executeBatchOperator(String sql, List<List<Object>> parameters, int[] columnTypes) 根据参数中sql语句进行批处理操作
int	executeByArray(String sql, Object... parameters)
int	executeByList(String sql, List<Object> parameters, List<Integer> dataTypes)
int	executeByMap(String sql, Map<String,Object> parameters, List<Integer> dataTypes)
int	executeBySqlParameterValue(String sql, org.springframework.jdbc.core.SqlParameterValue value)
int	executeBySqlParameterValues(String sql, org.springframework.jdbc.core.SqlParameterValue[] values)
List<Bean>	findBeans(String sql, String beanType, String schema)
List<Bean>	findBeans(String sql, String beanType, String schema, Object... parameters)
List<Bean>	findBeansByList(String sql, String beanType, String schema, List<Object> parameters)
protected List<Bean>	findBeansByListForCursorPage(String sql, String beanType, String schema, int start, int limit, List<Object> parameters)
protected List<Bean>	findBeansByListForDialectPage(String sql, String beanType, String schema, int start, int limit, List<Object> parameters)
List<Bean>	findBeansByListForPage(String sql, String beanType, String schema, int start, int limit, List<Object> parameters)
List<Bean>	findBeansByMap(String sql, String beanType, String schema, Map<String,Object> parameters, List<Integer> dataTypes)
protected List<Bean>	findBeansByMapForCursorPage(String sql, String beanType, String schema, int start, int limit, Map<String,Object> parameters, List<Integer> dataTypes)
protected List<Bean>	findBeansByMapForDialectPage(String sql, String beanType, String schema, int start, int limit, Map<String,Object> parameters, List<Integer> dataTypes)
List<Bean>	findBeansByMapForPage(String sql, String beanType, String schema, int start, int limit, Map<String,Object> parameters, List<Integer> dataTypes)
protected List<Bean>	findBeansForCursorPage(String sql, String beanType, String schema, int start, int limit)
protected List<Bean>	findBeansForDialectPage(String sql, String beanType, String schema, int start, int limit)
List<Bean>	findBeansForPage(String sql, String beanType, String schema, int start, int limit)
BeanDbNameConverter	getBeanDbNameConverter()
Dialect	getDialect()
protected List<Object>	getParamArray(String sql, Map<String,Object> parameters, StringBuffer buf)
org.springframework.transaction.TransactionDefinition	getTransactionDefinition()
org.springframework.transaction.PlatformTransactionManager	getTransactionManager()
UUID	getUniqueCode()
protected void	operatorDebugLog(String sql, Object... parameters)
protected void	operatorDebugLogNoParam(String sql)
protected void	operatorErrorLog(String sql, org.springframework.dao.DataAccessException exception, Object... parameters)
protected void	operatorErrorLogNoParam(String sql, org.springframework.dao.DataAccessException e)
int	queryForInt(String sql, Object... parameters)
int	queryForIntByList(String sql, List<Object> parameters)
int	queryForIntByMap(String sql, Map<String,Object> parameters)
Object	queryObject(String sql, String beanType, String schema, Object... parameters)
Object	queryObjectByMap(String sql, String beanType, String schema, Map<String,Object> parameters, List<Integer> dataTypes)
void	rollbackTransaction() 回滚事务
void	setBeanDbNameConverter(BeanDbNameConverter beanDbNameConverter)
void	setDialect(Dialect dialect)
void	setJdbcTemplate(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate)
void	setTransactionDefinition(org.springframework.transaction.TransactionDefinition transactionDefinition) 设置事务定义，默认为PROPAGATION_REQUIRED,ISOLATION_DEFAULT
void	setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) 设置事务管理对象

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, getColumnNames, getConditionParams, getConditionSql, getDeleteSql, getFullTableName, getInsertSql, getSchema, getTableName, getTableNameWithSchame, getUpdateSql

Methods inherited from class java.lang.Object

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

Field Detail

jdbcTemplate

protected org.springframework.jdbc.core.JdbcTemplate jdbcTemplate

Constructor Detail

DBSpringBaseOperator

public DBSpringBaseOperator()

DBSpringBaseOperator

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

Method Detail

getUniqueCode

public UUID getUniqueCode()

getBeanDbNameConverter

public BeanDbNameConverter getBeanDbNameConverter()

setBeanDbNameConverter

public void setBeanDbNameConverter(BeanDbNameConverter beanDbNameConverter)

getDialect

public Dialect getDialect()

setDialect

public void setDialect(Dialect dialect)

setJdbcTemplate

public void setJdbcTemplate(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate)

account

public int account(String sql)
            throws TinyDbException

Throws:

TinyDbException

executeByList

public int executeByList(String sql,
                         List<Object> parameters,
                         List<Integer> dataTypes)
                  throws TinyDbException

Throws:

TinyDbException

executeBySqlParameterValues

public int executeBySqlParameterValues(String sql,
                                       org.springframework.jdbc.core.SqlParameterValue[] values)
                                throws TinyDbException

Throws:

TinyDbException

executeBySqlParameterValue

public int executeBySqlParameterValue(String sql,
                                      org.springframework.jdbc.core.SqlParameterValue value)
                               throws TinyDbException

Throws:

TinyDbException

executeBatchOperator

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

根据参数中sql语句进行批处理操作

Parameters:

sql -

parameters -

dataTypes - key代表未赋参数值的sql语句 value代表sql语句中的参数列表信息

Throws:

TinyDbException

executeBatchOperator

protected int[] executeBatchOperator(String[] sqls)
                              throws TinyDbException

Throws:

TinyDbException

executeBatchBySqlParamterValues

protected int[] executeBatchBySqlParamterValues(String sql,
                                                List<org.springframework.jdbc.core.SqlParameterValue[]> parameters)
                                         throws TinyDbException

根据参数中sql语句进行批处理操作

Parameters:

sql -

parameters - key代表未赋参数值的sql语句 value代表sql语句中的参数列表信息

Throws:

TinyDbException

findBeansForPage

public List<Bean> findBeansForPage(String sql,
                                   String beanType,
                                   String schema,
                                   int start,
                                   int limit)
                            throws TinyDbException

Throws:

TinyDbException

findBeansForCursorPage

protected List<Bean> findBeansForCursorPage(String sql,
                                            String beanType,
                                            String schema,
                                            int start,
                                            int limit)
                                     throws TinyDbException

Throws:

TinyDbException

findBeansForDialectPage

protected List<Bean> findBeansForDialectPage(String sql,
                                             String beanType,
                                             String schema,
                                             int start,
                                             int limit)
                                      throws TinyDbException

Throws:

TinyDbException

findBeansByListForPage

public List<Bean> findBeansByListForPage(String sql,
                                         String beanType,
                                         String schema,
                                         int start,
                                         int limit,
                                         List<Object> parameters)
                                  throws TinyDbException

Throws:

TinyDbException

findBeansByListForDialectPage

protected List<Bean> findBeansByListForDialectPage(String sql,
                                                   String beanType,
                                                   String schema,
                                                   int start,
                                                   int limit,
                                                   List<Object> parameters)
                                            throws TinyDbException

Throws:

TinyDbException

findBeansByListForCursorPage

protected List<Bean> findBeansByListForCursorPage(String sql,
                                                  String beanType,
                                                  String schema,
                                                  int start,
                                                  int limit,
                                                  List<Object> parameters)
                                           throws TinyDbException

Throws:

TinyDbException

findBeansByMapForPage

public List<Bean> findBeansByMapForPage(String sql,
                                        String beanType,
                                        String schema,
                                        int start,
                                        int limit,
                                        Map<String,Object> parameters,
                                        List<Integer> dataTypes)
                                 throws TinyDbException

Throws:

TinyDbException

findBeansByMapForDialectPage

protected List<Bean> findBeansByMapForDialectPage(String sql,
                                                  String beanType,
                                                  String schema,
                                                  int start,
                                                  int limit,
                                                  Map<String,Object> parameters,
                                                  List<Integer> dataTypes)
                                           throws TinyDbException

Throws:

TinyDbException

findBeansByMapForCursorPage

protected List<Bean> findBeansByMapForCursorPage(String sql,
                                                 String beanType,
                                                 String schema,
                                                 int start,
                                                 int limit,
                                                 Map<String,Object> parameters,
                                                 List<Integer> dataTypes)
                                          throws TinyDbException

Throws:

TinyDbException

findBeans

public List<Bean> findBeans(String sql,
                            String beanType,
                            String schema)
                     throws TinyDbException

Throws:

TinyDbException

findBeans

public List<Bean> findBeans(String sql,
                            String beanType,
                            String schema,
                            Object... parameters)
                     throws TinyDbException

Throws:

TinyDbException

findBeansByList

public List<Bean> findBeansByList(String sql,
                                  String beanType,
                                  String schema,
                                  List<Object> parameters)
                           throws TinyDbException

Throws:

TinyDbException

queryObject

public Object queryObject(String sql,
                          String beanType,
                          String schema,
                          Object... parameters)
                   throws TinyDbException

Throws:

TinyDbException

findBeansByMap

public List<Bean> findBeansByMap(String sql,
                                 String beanType,
                                 String schema,
                                 Map<String,Object> parameters,
                                 List<Integer> dataTypes)
                          throws TinyDbException

Throws:

TinyDbException

queryObjectByMap

public Object queryObjectByMap(String sql,
                               String beanType,
                               String schema,
                               Map<String,Object> parameters,
                               List<Integer> dataTypes)
                        throws TinyDbException

Throws:

TinyDbException

executeByMap

public int executeByMap(String sql,
                        Map<String,Object> parameters,
                        List<Integer> dataTypes)
                 throws TinyDbException

Throws:

TinyDbException

executeByArray

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

Throws:

TinyDbException

queryForInt

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

Throws:

TinyDbException

queryForIntByList

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

Throws:

TinyDbException

queryForIntByMap

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

Throws:

TinyDbException

getParamArray

protected List<Object> getParamArray(String sql,
                                     Map<String,Object> parameters,
                                     StringBuffer buf)

beginTransaction

public void beginTransaction()

Description copied from interface: TransactionOperator

开始事务

Specified by:

beginTransaction in interface TransactionOperator

commitTransaction

public void commitTransaction()

Description copied from interface: TransactionOperator

提交事务

Specified by:

commitTransaction in interface TransactionOperator

rollbackTransaction

public void rollbackTransaction()

Description copied from interface: TransactionOperator

回滚事务

Specified by:

rollbackTransaction in interface TransactionOperator

getTransactionManager

public org.springframework.transaction.PlatformTransactionManager getTransactionManager()

setTransactionManager

public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)

Description copied from interface: TransactionOperator

设置事务管理对象

Specified by:

setTransactionManager in interface TransactionOperator

getTransactionDefinition

public org.springframework.transaction.TransactionDefinition getTransactionDefinition()

setTransactionDefinition

public void setTransactionDefinition(org.springframework.transaction.TransactionDefinition transactionDefinition)

Description copied from interface: TransactionOperator

设置事务定义，默认为PROPAGATION_REQUIRED,ISOLATION_DEFAULT

Specified by:

setTransactionDefinition in interface TransactionOperator

execute

public Object execute(TransactionCallBack callback)

Description copied from interface: TransactionOperator

以事务方式执行回调处理

Specified by:

execute in interface TransactionOperator

Returns:

operatorErrorLog

protected void operatorErrorLog(String sql,
                                org.springframework.dao.DataAccessException exception,
                                Object... parameters)

operatorDebugLog

protected void operatorDebugLog(String sql,
                                Object... parameters)

operatorErrorLogNoParam

protected void operatorErrorLogNoParam(String sql,
                                       org.springframework.dao.DataAccessException e)

operatorDebugLogNoParam

protected void operatorDebugLogNoParam(String sql)

checkNullParamList

protected Object[] checkNullParamList(List<Object> parameters)

deleteNullParamList

protected Object[] deleteNullParamList(List<Object> parameters)