Package com.killcoding.datasource

Class DriverExecutor

java.lang.Object

com.killcoding.datasource.DriverExecutor

Direct Known Subclasses:

CacheDriverExecutor

public class DriverExecutor
extends Object

This class is execute sql base class. Support database replication. Support database multi-activity. Support database CRUD

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	closed
static final String	COLUMN_NAME_CASE_LOWER
static String	COLUMN_NAME_CASE_MODE
static final String	COLUMN_NAME_CASE_ORIGINAL
static final String	COLUMN_NAME_CASE_UPPER
protected Connection	connection
protected Logger	log
private static final Map<String,String>	SQL_LOG_MSG_MAPPING
private static final Map<String,Boolean>	SQL_LOG_OVERSPEND_MAPPING
private static CacheArray	sqlLogCacheArray
private static final Map<Integer,Long>	SYNC_CONN_ERROR_TIME
protected static final Map<Integer,List<DriverExecutor>>	SYNC_EXECUTOR_MARK

Constructor Summary

Constructors

Constructor	Description
DriverExecutor(Connection connection)	New a DriverExecutor object

Method Summary

Modifier and Type	Method	Description
void	abort()	Abort connection
protected static void	abortSyncConnection(Connection masterConn)	For database replication
private static void	archiveLog(int archiveDays, File sqlLogFolder)	Archive Log
private static void	backupLog(File logFolder, File logFile, String logFileNamePrefix, int logIndex, String header, String msg)	Backup log file
boolean	callAndReturnBoolean(String sql)	Execute stored proc (and return boolean)
boolean	callAndReturnBoolean(String sql, List<Object> params)	Execute stored proc (and return boolean)
boolean	callAndReturnBoolean(String sql, Map<String,Object> params)	Execute stored proc (and return boolean)
protected static void	callAndReturnBooleanSync(Connection masterConn, long seq, String sql, List<Object> params, boolean returnResult)	For database replication
List<Map<String,Object>>	callAndReturnList(int cursorStart, int maxRows, String sql)	Execute stored proc (and return List)
List<Map<String,Object>>	callAndReturnList(int cursorStart, int maxRows, String sql, List<Object> params)	Execute stored proc (and return List)
List<Map<String,Object>>	callAndReturnList(int cursorStart, int maxRows, String sql, Map<String,Object> params)	Execute stored proc (and return List)
List<Map<String,Object>>	callAndReturnList(String sql)	Execute stored proc (and return List)
protected static void	callAndReturnListSync(Connection masterConn, int cursorStart, int maxRows, String sql, List<Object> params)	For database replication
Object	callAndReturnRows(int sqlTypes, String sql, List<Object> params)	Execute stored proc (and return rows)
int	callAndReturnRows(String sql)	Execute stored proc (and return rows)
int	callAndReturnRows(String sql, List<Object> params)
int	callAndReturnRows(String sql, Map<String,Object> params)	Execute stored proc (and return rows)
protected static void	callAndReturnRowsSync(Connection masterConn, long seq, String sql, List<Object> params, Object returnRows)	For database replication
protected boolean	checkSqlAvailable(String sql)	Check available sql to execute
private static boolean	checkSqlAvailable(String sql, List<String> sqlAllowed, List<String> sqlIgnored)	Check available sql to execute
protected static boolean	checkSqlAvailable(Connection connection, String sql)	Check available sql to execute
protected static boolean	checkSqlLogAvailable(Connection connection, String sql)	Check available sql to write to log
void	close()	Close connection
protected static void	closeSyncConnection(Connection masterConn)	For database replication
void	commit()	Commit connection
protected static void	commitSyncConnection(Connection masterConn)	For database replication
protected String	converCase(String s)	Covner to upper or lower
protected List<Object>	converParams(String sql, Map<String,Object> map)	Conver param from map to list
protected String	converSql(String sql)	Conver sql from ':column_name' to '?'
private static void	deleteFilesOlderThan(File directory, long archiveDaysMs)	Delete old archive logs
List<Map<String,Object>>	desc(String tableName)	Show column data type and java type mapping
int	execute(String sql)	Execute sql
int	execute(String sql, List<Object> params)	Execute sql
int	execute(String sql, Map<String,Object> params)	Execute sql
int	executeBatch(String sql, List<Map<String,Object>> records)	Execute batch
int	executeBatchList(String sql, List<List<Object>> records)	Execute batch
protected static void	executeBatchListSync(Connection masterConn, long seq, String sql, List<List<Object>> records, int returnRows)	For database replication
protected static void	executeSync(Connection masterConn, long seq, String sql, List<Object> params, int returnRows)	For database replication
List<Map<String,Object>>	find(int cursorStart, int maxRows, String sql)	Query all matched records
List<Map<String,Object>>	find(int cursorStart, int maxRows, String sql, List<Object> params)	Query all matched records
List<Map<String,Object>>	find(int cursorStart, int maxRows, String sql, Map<String,Object> params)	Query all matched records
List<Map<String,Object>>	find(String sql)	Query all matched records
List<Map<String,Object>>	find(String sql, Map<String,Object> params)	Query all matched records
Map<String,Object>	first(String sql)	Query first record
Map<String,Object>	first(String sql, List<Object> params)	Query first record
Map<String,Object>	first(String sql, Map<String,Object> params)	Query first record
List<Map<String,Object>>	getAllTables()	Get all tables
List<Map<String,Object>>	getAllTables(String _schema)	Get all tables by schema
Map<String,Object>	getColumnClasses(String tableName)	Get column classes by table name
Map<String,Object>	getColumnTypes(String tableName)	Get column db data types by table name
Connection	getConnection()	Get current Connection
private String	getDataSourceName()	Get data source thread name
private static int	getLogFileIndex(ConfigProperties configProperties, File folder, String prefix, String suffix)	Get log file index For backup log file use
private Integer	getOriginConnectionHashCode()	Get origin connection hash code
List<String>	getPrimaryKeys(String _tableName)	Get primary Keys by table name
private static String	handleParams(int paramMaxLength, Object params)	Hahdle Params For write csv log
boolean	isClosed()	Check connection is closed
protected static boolean	openSyncConnection(Connection masterConn)	For database replication
private static String	replaceToSigleLine(String msg)	Replace to sigle line For write csv log
void	rollback()	Rollback connection
protected static void	rollbackSyncConnection(Connection masterConn)	For database replication
protected static boolean	writeSqlLog(int deHashCode, Connection connection, String type, long seq, String sql, Object params)	Write sql log
protected boolean	writeSqlLog(String type, long seq, String sql, Object params)	Write sql log

Methods inherited from class java.lang.Object

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

Field Details

SYNC_EXECUTOR_MARK

protected static final Map<Integer,List<DriverExecutor>> SYNC_EXECUTOR_MARK

SYNC_CONN_ERROR_TIME

private static final Map<Integer,Long> SYNC_CONN_ERROR_TIME

SQL_LOG_MSG_MAPPING

private static final Map<String,String> SQL_LOG_MSG_MAPPING

SQL_LOG_OVERSPEND_MAPPING

private static final Map<String,Boolean> SQL_LOG_OVERSPEND_MAPPING

log

protected Logger log

COLUMN_NAME_CASE_UPPER

public static final String COLUMN_NAME_CASE_UPPER

See Also:

• Constant Field Values

COLUMN_NAME_CASE_LOWER

public static final String COLUMN_NAME_CASE_LOWER

See Also:

• Constant Field Values

COLUMN_NAME_CASE_ORIGINAL

public static final String COLUMN_NAME_CASE_ORIGINAL

See Also:

• Constant Field Values

COLUMN_NAME_CASE_MODE

public static String COLUMN_NAME_CASE_MODE

closed

protected boolean closed

connection

protected Connection connection

sqlLogCacheArray

private static CacheArray sqlLogCacheArray

Constructor Details

DriverExecutor

public DriverExecutor(Connection connection)

New a DriverExecutor object

Parameters:

connection - - JDBC connection

Method Details

getConnection

public Connection getConnection()

Get current Connection

Returns:

Connection

getColumnClasses

public Map<String,Object> getColumnClasses(String tableName)
                                    throws SQLException

Get column classes by table name

Parameters:

tableName - - table name

Returns:

Map<String,Object> - column and java type class mapping

Throws:

SQLException

getColumnTypes

public Map<String,Object> getColumnTypes(String tableName)
                                  throws SQLException

Get column db data types by table name

Parameters:

tableName - - Table name

Returns:

Map<String, Object> - column and db data type mapping

Throws:

SQLException

desc

public List<Map<String,Object>> desc(String tableName)
                              throws SQLException

Show column data type and java type mapping

Parameters:

tableName - - Table name

Returns:

List<Map<String, Object>> - Mapping list

Throws:

SQLException

getPrimaryKeys

public List<String> getPrimaryKeys(String _tableName)

Get primary Keys by table name

Parameters:

_tableName - - Table name

Returns:

List - Primary Keys

getAllTables

public List<Map<String,Object>> getAllTables()
                                      throws SQLException

Get all tables

Returns:

List<Map<String, Object>>

Throws:

SQLException

getAllTables

public List<Map<String,Object>> getAllTables(String _schema)
                                      throws SQLException

Get all tables by schema

Returns:

List<Map<String, Object>>

Throws:

SQLException

first

public Map<String,Object> first(String sql,
 Map<String,Object> params)
                         throws SQLException

Query first record

Parameters:

sql - - Condition use format ':column_name'

params -

Returns:

Map<String,Object> - First result

Throws:

SQLException

first

public Map<String,Object> first(String sql)
                         throws SQLException

Query first record

Parameters:

sql -

Returns:

Map<String,Object> - First result

Throws:

SQLException

first

public Map<String,Object> first(String sql,
 List<Object> params)
                         throws SQLException

Query first record

Parameters:

sql - - Condition use format '?'

params -

Returns:

Map<String,Object> - First result

Throws:

SQLException

find

public List<Map<String,Object>> find(String sql)
                              throws SQLException

Query all matched records

Parameters:

sql -

params -

Returns:

List<Map<String, Object>>

Throws:

SQLException

find

public List<Map<String,Object>> find(int cursorStart,
 int maxRows,
 String sql)
                              throws SQLException

Query all matched records

Parameters:

cursorStart - - JDBC result Cursor start index

maxRows - - JDBC result max rows (JDBC limited rows 50,000,000)

sql -

params -

Returns:

List<Map<String, Object>>

Throws:

SQLException

find

public List<Map<String,Object>> find(String sql,
 Map<String,Object> params)
                              throws SQLException

Query all matched records

Parameters:

sql - - Condition use format ':column_name'

params -

Returns:

List<Map<String, Object>>

Throws:

SQLException

find

public List<Map<String,Object>> find(int cursorStart,
 int maxRows,
 String sql,
 Map<String,Object> params)
                              throws SQLException

Query all matched records

Parameters:

cursorStart - - JDBC result Cursor start index

maxRows - - JDBC result max rows (JDBC limited rows 50,000,000)

sql - - Condition use format ':column_name'

params -

Returns:

List<Map<String, Object>>

Throws:

SQLException

find

public List<Map<String,Object>> find(int cursorStart,
 int maxRows,
 String sql,
 List<Object> params)
                              throws SQLException

Query all matched records

Parameters:

cursorStart - - JDBC result Cursor start index

maxRows - - JDBC result max rows (JDBC limited rows 50,000,000)

sql - - Condition use format '?'

params -

Returns:

List<Map<String, Object>>

Throws:

SQLException

callAndReturnBoolean

public boolean callAndReturnBoolean(String sql)
                             throws SQLException

Execute stored proc (and return boolean)

Parameters:

sql - - Query sql

Returns:

boolean

Throws:

SQLException

callAndReturnBoolean

public boolean callAndReturnBoolean(String sql,
 Map<String,Object> params)
                             throws SQLException

Execute stored proc (and return boolean)

Parameters:

sql - - Query sql, condition use format ':column_name'

params -

Returns:

boolean

Throws:

SQLException

callAndReturnBoolean

public boolean callAndReturnBoolean(String sql,
 List<Object> params)
                             throws SQLException

Execute stored proc (and return boolean)

Parameters:

sql - - Query sql,condition use format '?'

params -

Returns:

boolean

Throws:

SQLException

callAndReturnRows

public int callAndReturnRows(String sql)
                      throws SQLException

Execute stored proc (and return rows)

Parameters:

sql - - Query sql

Returns:

int

Throws:

SQLException

callAndReturnRows

public int callAndReturnRows(String sql,
 Map<String,Object> params)
                      throws SQLException

Execute stored proc (and return rows)

Parameters:

sql - - Query sql,condition use format ':column_name'

params -

Returns:

int

Throws:

SQLException

callAndReturnRows

public int callAndReturnRows(String sql,
 List<Object> params)
                      throws SQLException

Throws:

SQLException

callAndReturnRows

public Object callAndReturnRows(int sqlTypes,
 String sql,
 List<Object> params)
                         throws SQLException

Execute stored proc (and return rows)

Parameters:

sqltypes - - e.g Types.INTEGER

sql - - Query sql,condition use format '?'

params -

Returns:

Object

Throws:

SQLException

callAndReturnList

public List<Map<String,Object>> callAndReturnList(String sql)
                                           throws SQLException

Execute stored proc (and return List)

Parameters:

sql - - Query sql

Returns:

List<Map<String, Object>>

Throws:

SQLException

callAndReturnList

public List<Map<String,Object>> callAndReturnList(int cursorStart,
 int maxRows,
 String sql)
                                           throws SQLException

Execute stored proc (and return List)

Parameters:

cursorStart - - JDBC result Cursor start index

maxRows - - JDBC result max rows (JDBC limited rows 50,000,000)

sql - - Query sql

Returns:

List<Map<String, Object>>

Throws:

SQLException

callAndReturnList

public List<Map<String,Object>> callAndReturnList(int cursorStart,
 int maxRows,
 String sql,
 Map<String,Object> params)
                                           throws SQLException

Execute stored proc (and return List)

Parameters:

cursorStart - - JDBC result Cursor start index

maxRows - - JDBC result max rows (JDBC limited rows 50,000,000)

sql - - Query sql, condition use format ':column_name'

Returns:

List<Map<String, Object>>

Throws:

SQLException

callAndReturnList

public List<Map<String,Object>> callAndReturnList(int cursorStart,
 int maxRows,
 String sql,
 List<Object> params)
                                           throws SQLException

Execute stored proc (and return List)

Parameters:

cursorStart - - JDBC result Cursor start index

maxRows - - JDBC result max rows (JDBC limited rows 50,000,000)

sql - - Query sql, condition use format '?'

Returns:

List<Map<String, Object>>

Throws:

SQLException

execute

public int execute(String sql)
            throws SQLException

Execute sql

Parameters:

sql -

Returns:

int

Throws:

SQLException

execute

public int execute(String sql,
 Map<String,Object> params)
            throws SQLException

Execute sql

Parameters:

sql - - Condition use format ':column_name'

params -

Returns:

int

Throws:

SQLException

execute

public int execute(String sql,
 List<Object> params)
            throws SQLException

Execute sql

Parameters:

sql - - Condition use format '?'

params -

Returns:

int

Throws:

SQLException

executeBatch

public int executeBatch(String sql,
 List<Map<String,Object>> records)
                 throws SQLException

Execute batch

Parameters:

sql - - Condition use format ':column_name'

records -

Returns:

int - Return rows

Throws:

SQLException

executeBatchList

public int executeBatchList(String sql,
 List<List<Object>> records)
                     throws SQLException

Execute batch

Parameters:

sql - - Condition use format '?'

records -

Returns:

int - Return rows

Throws:

SQLException

isClosed

public boolean isClosed()

Check connection is closed

Returns:

boolean

abort

public void abort()
           throws SQLException

Abort connection

Throws:

SQLException

close

public void close()
           throws SQLException

Close connection

Throws:

SQLException

commit

public void commit()
            throws SQLException

Commit connection

Throws:

SQLException

rollback

public void rollback()
              throws SQLException

Rollback connection

Throws:

SQLException

getOriginConnectionHashCode

private Integer getOriginConnectionHashCode()

Get origin connection hash code

Returns:

Integer - hash code

getDataSourceName

private String getDataSourceName()

Get data source thread name

Returns:

String - DataSource thread name

converSql

protected String converSql(String sql)

Conver sql from ':column_name' to '?'

Returns:

String

converParams

protected List<Object> converParams(String sql,
 Map<String,Object> map)

Conver param from map to list

Parameters:

sql -

map -

Returns:

List