Package com.killcoding.datasource

Class CacheDriverExecutor

java.lang.Object

com.killcoding.datasource.DriverExecutor

com.killcoding.datasource.CacheDriverExecutor

public final class CacheDriverExecutor
extends DriverExecutor

This class uses a 'CacheArray' to process the asynchronous processing method of the data query result set. If you choose to use the mode 'DiskCache', temporary files will be generated. If you choose to use the mode 'MemoryCache', temporary files will not be generated but the physical memory size must be considered.

Field Summary

Fields

Modifier and Type	Field	Description
static long	READ_TIMER

Fields inherited from class com.killcoding.datasource.DriverExecutor

closed, COLUMN_NAME_CASE_LOWER, COLUMN_NAME_CASE_MODE, COLUMN_NAME_CASE_ORIGINAL, COLUMN_NAME_CASE_UPPER, connection, log, SYNC_EXECUTOR_MARK

Constructor Summary

Constructors

Constructor	Description
CacheDriverExecutor(Connection connection)	New a object CacheDriverExecutor

Method Summary

Modifier and Type	Method	Description
void	callAndReturnList(int cursorStart, int maxRows, String sql, CacheArray<Map<String,Object>> rows)	Execute stored proc(and return result to CacheArray)
void	callAndReturnList(int cursorStart, int maxRows, String sql, List<Object> params, CacheArray<Map<String,Object>> rows)	Execute stored proc(and return result)
void	callAndReturnList(int cursorStart, int maxRows, String sql, Map<String,Object> params, CacheArray<Map<String,Object>> rows)	Execute stored proc(and return result)
void	find(int cursorStart, int maxRows, String sql, CacheArray<Map<String,Object>> rows)	This is limited rows query function
void	find(int cursorStart, int maxRows, String sql, List<Object> params, CacheArray<Map<String,Object>> rows)	This is limited rows query function (use List param mode)
void	find(int cursorStart, int maxRows, String sql, Map<String,Object> params, CacheArray<Map<String,Object>> rows)	This is limited rows query function (use Map param mode)
void	find(String sql, CacheArray<Map<String,Object>> rows)	This is full table query function
void	find(String sql, List<Object> params, CacheArray<Map<String,Object>> rows)	This is full table query function
void	find(String sql, Map<String,Object> params, CacheArray<Map<String,Object>> rows)	This is full table query function
private long	getReadTimer()

Methods inherited from class com.killcoding.datasource.DriverExecutor

abort, abortSyncConnection, callAndReturnBoolean, callAndReturnBoolean, callAndReturnBoolean, callAndReturnBooleanSync, callAndReturnList, callAndReturnList, callAndReturnList, callAndReturnList, callAndReturnListSync, callAndReturnRows, callAndReturnRows, callAndReturnRows, callAndReturnRowsSync, checkSqlAvailable, checkSqlAvailable, checkSqlLogAvailable, close, closeSyncConnection, commit, commitSyncConnection, converCase, converParams, converSql, desc, execute, execute, execute, executeBatch, executeBatchList, executeBatchListSync, executeSync, find, find, find, find, find, first, first, first, getAllTables, getAllTables, getColumnClasses, getColumnTypes, getConnection, getPrimaryKeys, isClosed, openSyncConnection, rollback, rollbackSyncConnection, writeSqlLog, writeSqlLog

Methods inherited from class java.lang.Object

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

Field Details

READ_TIMER

public static long READ_TIMER

Constructor Details

CacheDriverExecutor

public CacheDriverExecutor(Connection connection)

New a object CacheDriverExecutor

Parameters:

connection - - it is jdbc connection

Method Details

find

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

This is full table query function

Parameters:

sql - - Query sql

params - - Query params

rows - - CacheArray object

Throws:

SQLException - - if query failed

find

public void find(String sql,
 Map<String,Object> params,
 CacheArray<Map<String,Object>> rows)
          throws SQLException

This is full table query function

Parameters:

sql - - Query sql

params - - Query params

rows - - CacheArray object

Throws:

SQLException - - if query failed

find

public void find(String sql,
 CacheArray<Map<String,Object>> rows)
          throws SQLException

This is full table query function

Parameters:

sql - - Query sql

rows - - CacheArray object

Throws:

SQLException - - if query failed

find

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

This is limited rows query function

Parameters:

cursorStart - - JDBC result Cursor start index

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

sql - - Query sql

rows - - CacheArray object

Throws:

SQLException - - if query failed

find

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

This is limited rows query function (use Map param mode)

Parameters:

cursorStart - - JDBC result Cursor start index

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

sql - - Query sql

rows - - CacheArray object

Throws:

SQLException - - if query failed

find

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

This is limited rows query function (use List param mode)

Parameters:

cursorStart - - JDBC result Cursor start index

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

sql - - Query sql

rows - - CacheArray object

Throws:

SQLException - - if query failed

callAndReturnList

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

Execute stored proc(and return result to CacheArray)

Parameters:

cursorStart - - JDBC result Cursor start index

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

sql - - Query sql

rows - - CacheArray object

Throws:

SQLException - - if query failed

callAndReturnList

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

Execute stored proc(and return result)

Parameters:

cursorStart - - JDBC result Cursor start index

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

sql - - Query sql

params - - Use Map param mode (use ':column_name' to mapping)

rows - - CacheArray object

Throws:

SQLException - - if query failed

callAndReturnList

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

Execute stored proc(and return result)

Parameters:

cursorStart - - JDBC result Cursor start index

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

sql - - Query sql (use '?' to mapping)

params - - Use List param mode

rows - - CacheArray object

Throws:

SQLException - - if query failed

getReadTimer

private long getReadTimer()