Class DB_To_DBThread
java.lang.Object
com.dandymadeproductions.ajqvue.utilities.db.DB_To_DBThread
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionDB_To_DBThread(ConnectionInstance connectionInstanceSource, ConnectionInstance connectionInstanceSink, String sqlQueryString, String sinkDBTableNameString, Properties threadProperties) DB_To_DBThread(ConnectionInstance connectionInstanceSource, String sqlQueryString) DB_To_DBThread(ConnectionInstance connectionInstanceSource, String sqlQueryString, String sinkDBTableNameString) -
Method Summary
Modifier and TypeMethodDescriptionvoidintexecuteDB_CheckTransfer(ConnectionInstance connInstance, Connection localConnection, int sampleRows) voidexecuteDB_To_DB_Transfer(ConnectionInstance localConnectionInstance, Connection localConnection) booleanexecuteSinkDBCreation(Connection dbConnectionSink) doubleintbooleanbooleanbooleangetDebug()static Propertiesintintbooleanbooleanbooleanbooleanstatic booleanstatic booleanvoidvoidvoidrun()void
-
Field Details
-
connectionInstanceSink
-
dbConnectionSink
-
dbSinkTypeString
-
connectionInstanceSource
-
TRANSFER_PARAM_FILE
- See Also:
-
SINK_DB_TABLE_NAME
- See Also:
-
CREATE_SINKDB
public static final boolean CREATE_SINKDB- See Also:
-
USE_SQLITE_CAST
public static final boolean USE_SQLITE_CAST- See Also:
-
BLOCKING_QUEUE_SIZE
public static final int BLOCKING_QUEUE_SIZE- See Also:
-
BLOCKING_QUEUE_FIFO
public static final boolean BLOCKING_QUEUE_FIFO- See Also:
-
CONNECTION_DEBUG
public static final boolean CONNECTION_DEBUG- See Also:
-
VARCHAR_LIMIT
public static final int VARCHAR_LIMIT- See Also:
-
-
Constructor Details
-
DB_To_DBThread
-
DB_To_DBThread
public DB_To_DBThread(ConnectionInstance connectionInstanceSource, String sqlQueryString, String sinkDBTableNameString) -
DB_To_DBThread
public DB_To_DBThread(ConnectionInstance connectionInstanceSource, ConnectionInstance connectionInstanceSink, String sqlQueryString, String sinkDBTableNameString, Properties threadProperties)
-
-
Method Details
-
run
-
openConnectionSink
public void openConnectionSink() -
closeConnectionSink
public void closeConnectionSink() -
executeSinkDBCreation
-
executeDB_To_DB_Transfer
public void executeDB_To_DB_Transfer(ConnectionInstance localConnectionInstance, Connection localConnection) -
executeDB_CheckTransfer
public int executeDB_CheckTransfer(ConnectionInstance connInstance, Connection localConnection, int sampleRows) -
log
-
isBlob
-
isText
-
setLogger
-
getLogger
-
getSinkDBTableNameString
-
getCreateSinkTable
public boolean getCreateSinkTable() -
getUseSQLiteCast
public boolean getUseSQLiteCast() -
getQueueCapacity
public int getQueueCapacity() -
getQueueFIFOEnabled
public boolean getQueueFIFOEnabled() -
getDebug
public boolean getDebug() -
getUseLimits
public boolean getUseLimits() -
getLimitIncrement
public int getLimitIncrement() -
getShowProgressBar
public boolean getShowProgressBar() -
getBatchSizeEnabled
public boolean getBatchSizeEnabled() -
getBatchSize
public int getBatchSize() -
getAvgQueueSize
public double getAvgQueueSize() -
getDefaultProperties
-
getParameterString
-