Package | Description |
---|---|
com.toolsverse.etl.common | |
com.toolsverse.etl.core.config | |
com.toolsverse.etl.sql.util |
Modifier and Type | Interface and Description |
---|---|
interface |
EtlContext
A wrapper for @InfoLogger which is aware of current scenario, etl block and
task
|
Modifier and Type | Method and Description |
---|---|
int |
OnException.handleException(Connection conn,
String sql,
Exception ex,
long row,
MergeHandler mergeHandler,
InfoLogger infoLogger,
ConditionalExecution owner)
Handles the exception.
|
void |
OnException.log(InfoLogger infoLogger,
Exception ex,
String logMessage)
Log.
|
Modifier and Type | Class and Description |
---|---|
class |
EtlConfig
Represents an ETL configuration file.
|
class |
EtlContextImpl
A default implementation of the @EtlContext
|
Constructor and Description |
---|
EtlContextImpl(InfoLogger infoLogger,
String scenarioName,
String blockName,
String taskName)
Instantiates a new etl context.
|
Modifier and Type | Method and Description |
---|---|
static TypedKeyValue<ResultSet,Statement> |
SqlUtils.executeScriptAndReturnResultSetAndSaveException(Connection con,
String script,
Driver driver,
OnException onException,
Map<String,Object> bindVariables,
String using,
boolean commit,
InfoLogger infoLogger)
Executes SQL script for all rows of the data set if its not empty or just
once if it is.
|
static void |
SqlUtils.executeScriptAndSaveException(Connection con,
String script,
Driver driver,
DataSet dataSet,
OnException onException,
Map<String,Object> bindVariables,
String using,
boolean commit,
boolean isCallable,
boolean supportsPrepared,
InfoLogger infoLogger)
Executes SQL script for all rows of the data set if its not empty or just
once if it is.
|
static void |
SqlUtils.executeScriptAndSaveException(Connection con,
String script,
Driver driver,
DataSet dataSet,
OnException onException,
Map<String,Object> bindVariables,
String using,
boolean commit,
boolean isCallable,
InfoLogger infoLogger)
Executes SQL script for all rows of the data set if its not empty or just
once if it is.
|
static TypedKeyValue<Integer,TypedKeyValue<ResultSet,Statement>> |
SqlUtils.executeSqlAndReturnResultSetAndSaveException(Connection con,
String sql,
int action,
String exception,
Map<String,Object> bindVars,
Driver driver,
boolean supportsPrepared,
InfoLogger infoLogger)
Prepares sql, set bind variables using given
bindVars and
finally executes sql. |
static int |
SqlUtils.executeSqlAndSaveException(Connection con,
String sql,
int action,
String exception,
Map<String,Object> bindVars,
Driver driver,
boolean isCallable,
boolean supportsPrepared,
InfoLogger infoLogger)
Prepares sql, set bind variables using given
bindVars and
finally executes sql. |
Copyright © 2010-2020 Toolsverse. All Rights Reserved.