| Modifier and Type | Method and Description | 
|---|---|
Driver | 
DataSet.getDriver()
Gets the driver. 
 | 
Driver | 
DataSet.getSourceDriver()
Gets the source driver. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Object | 
DataSet.decode(FieldDef fieldDef,
      String fieldValue,
      Driver driver,
      Map<String,String> params)
Decodes value of the field using Base64 algorithm. 
 | 
Object | 
DataSet.decode(FieldDef fieldDef,
      String fieldValue,
      Driver driver,
      Map<String,String> params,
      boolean decode)
Decodes value of the field using Base64 algorithm. 
 | 
String | 
DataSet.encode(FieldDef fieldDef,
      Object fieldValue,
      Driver driver,
      Map<String,String> params,
      boolean encode,
      boolean booleanToNumber)
Encodes value of the field using Base64 algorithm. 
 | 
DataSetRecord | 
DataSet.getCursorRecord(Driver driver)
Gets the current record as a "cursor" using given driver. 
 | 
static void | 
CommonEtlUtils.processFiles(Alias alias,
            IoProcessorCallable callable,
            boolean disconnect,
            boolean closeIfNotDone,
            boolean doneOnDone,
            String ownerName,
            Driver driver)
Process files for the give alias. 
 | 
static void | 
CommonEtlUtils.processFiles(Alias alias,
            IoProcessorCallable callable,
            boolean disconnect,
            Driver driver)
Process files for the give alias. 
 | 
void | 
DataSet.setDriver(Driver value)
Sets the driver. 
 | 
void | 
DataSet.setSourceDriver(Driver value)
Sets the source driver. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Driver | 
BaseStreamingPackage.getDriver()
Gets the driver. 
 | 
Driver | 
AddRecordCallback.getEtlDriver()
Gets the driver. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
BaseDataSetConnector.basePostPersist(DataSetConnectorParams params,
               DataSet dataSet,
               Driver driver)
Executed when persisting is done. 
 | 
void | 
DataSetConnector.cleanUp(P params,
       DataSet dataSet,
       Driver driver)
Cleans up after DataSetConnector populated or persisted DataSet. 
 | 
void | 
SourceConnector.cleanUp(SourceConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
IoProcessor | 
BaseDataSetConnector.getIoProcessor(Alias alias,
              Driver driver)
Gets the io processor. 
 | 
String | 
SourceConnectorParams.getPropsWizardResource(Driver driver,
                      String connectionDriver)  | 
abstract String | 
DataSetConnectorParams.getPropsWizardResource(Driver driver,
                      String connectionDriver)
Gets the name of the xml file used to create a wizard for editing
 properties. 
 | 
void | 
DataSetConnector.inlinePersist(P params,
             DataSet dataSet,
             Driver driver,
             DataSetRecord record,
             int row,
             int records)
Persists data set row. 
 | 
void | 
SourceConnector.inlinePersist(SourceConnectorParams params,
             DataSet dataSet,
             Driver driver,
             DataSetRecord record,
             int row,
             int records)  | 
void | 
AddFieldValueCallback.onAddFieldValue(DataSet dataSet,
               Driver driver,
               DataSetRecord record,
               FieldDef fieldDef)
Called when value is set for the field. 
 | 
void | 
AddRecordCallback.onAddRecord(DataSet dataSet,
           Driver driver,
           DataSetRecord record,
           int index,
           String crudAction,
           String target)
Called when record is added to the data set. 
 | 
void | 
AfterCallback.onAfter(DataSet dataSet,
       Driver driver)
Executed when DataSetConnector finishes populating data set. 
 | 
void | 
BeforeCallback.onBefore(DataSet dataSet,
        Driver driver)
Executed when DataSetConnector starts populating data set. 
 | 
ConnectorResult | 
DataSetConnector.persist(P params,
       DataSet dataSet,
       Driver driver)
Persists data set. 
 | 
ConnectorResult | 
SourceConnector.persist(SourceConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
ConnectorResult | 
DataSetConnector.populate(P params,
        DataSet dataSet,
        Driver driver)
Populates data set. 
 | 
ConnectorResult | 
SourceConnector.populate(SourceConnectorParams params,
        DataSet dataSet,
        Driver driver)  | 
void | 
DataSetConnector.postPersist(P params,
           DataSet dataSet,
           Driver driver)
Called when DataSetConnector finished persisting data set. 
 | 
void | 
SourceConnector.postPersist(SourceConnectorParams params,
           DataSet dataSet,
           Driver driver)  | 
void | 
DataSetConnector.prePersist(P params,
          DataSet dataSet,
          Driver driver)
Called when DataSetConnector starts persisting data set. 
 | 
void | 
SourceConnector.prePersist(SourceConnectorParams params,
          DataSet dataSet,
          Driver driver)  | 
void | 
BaseStreamingPackage.setDriver(Driver driver)
Sets the driver. 
 | 
ConnectorResult | 
DataSetConnector.writeMetaData(P params,
             DataSet dataSet,
             Driver driver)
Writes meta data. 
 | 
ConnectorResult | 
SourceConnector.writeMetaData(SourceConnectorParams params,
             DataSet dataSet,
             Driver driver)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ExcelXlsxConnector.cleanUp(ExcelConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
void | 
ExcelConnector.cleanUp(ExcelConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
String | 
ExcelConnectorParams.getPropsWizardResource(Driver driver,
                      String connectionDriver)  | 
void | 
ExcelXlsxConnector.inlinePersist(ExcelConnectorParams params,
             DataSet dataSet,
             Driver driver,
             DataSetRecord record,
             int row,
             int records)  | 
void | 
ExcelConnector.inlinePersist(ExcelConnectorParams params,
             DataSet dataSet,
             Driver driver,
             DataSetRecord record,
             int row,
             int records)  | 
ConnectorResult | 
ExcelXlsxConnector.persist(ExcelConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
ConnectorResult | 
ExcelConnector.persist(ExcelConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
ConnectorResult | 
ExcelXlsxConnector.populate(ExcelConnectorParams params,
        DataSet dataSet,
        Driver driver)  | 
ConnectorResult | 
ExcelConnector.populate(ExcelConnectorParams params,
        DataSet dataSet,
        Driver driver)  | 
void | 
ExcelXlsxConnector.postPersist(ExcelConnectorParams params,
           DataSet dataSet,
           Driver driver)  | 
void | 
ExcelConnector.postPersist(ExcelConnectorParams params,
           DataSet dataSet,
           Driver driver)  | 
void | 
ExcelXlsxConnector.prePersist(ExcelConnectorParams params,
          DataSet dataSet,
          Driver driver)  | 
void | 
ExcelConnector.prePersist(ExcelConnectorParams params,
          DataSet dataSet,
          Driver driver)  | 
void | 
ExcelXlsxConnector.process(org.apache.poi.openxml4j.opc.OPCPackage xlsxPackage,
       String sheetName,
       ExcelConnectorParams params,
       DataSet dataSet,
       Driver driver)
Initiates the processing of the XLS workbook file. 
 | 
void | 
ExcelXlsxConnector.processSheet(org.apache.poi.xssf.model.StylesTable styles,
            org.apache.poi.xssf.eventusermodel.ReadOnlySharedStringsTable strings,
            InputStream sheetInputStream,
            ExcelConnectorParams params,
            DataSet dataSet,
            Driver driver)
Parses and shows the content of one sheet using the specified styles and
 shared-strings tables. 
 | 
ConnectorResult | 
ExcelXlsxConnector.writeMetaData(ExcelConnectorParams params,
             DataSet dataSet,
             Driver driver)  | 
ConnectorResult | 
ExcelConnector.writeMetaData(ExcelConnectorParams params,
             DataSet dataSet,
             Driver driver)  | 
| Constructor and Description | 
|---|
XlsProcessor(ExcelConnectorParams params,
            DataSet dataSet,
            Driver driver)
Instantiates a new XlsProcessor. 
 | 
XSSFSheetHandler(org.apache.poi.xssf.model.StylesTable styles,
                org.apache.poi.xssf.eventusermodel.ReadOnlySharedStringsTable strings,
                ExcelConnectorParams params,
                DataSet dataSet,
                Driver driver)
Accepts objects needed while parsing. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
HtmlConnector.cleanUp(HtmlConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
String | 
HtmlConnectorParams.getPropsWizardResource(Driver driver,
                      String connectionDriver)  | 
void | 
HtmlConnector.inlinePersist(HtmlConnectorParams params,
             DataSet dataSet,
             Driver driver,
             DataSetRecord record,
             int row,
             int records)  | 
ConnectorResult | 
HtmlConnector.persist(HtmlConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
ConnectorResult | 
HtmlConnector.populate(HtmlConnectorParams params,
        DataSet dataSet,
        Driver driver)  | 
void | 
HtmlConnector.postPersist(HtmlConnectorParams params,
           DataSet dataSet,
           Driver driver)  | 
void | 
HtmlConnector.prePersist(HtmlConnectorParams params,
          DataSet dataSet,
          Driver driver)  | 
ConnectorResult | 
HtmlConnector.writeMetaData(HtmlConnectorParams params,
             DataSet dataSet,
             Driver driver)  | 
| Modifier and Type | Method and Description | 
|---|---|
static String | 
JsonDatasetConnector.asString(DataSet dataSet,
        Driver driver)
Convert data set to the json object and return a json string. 
 | 
static String | 
JsonConnector.asString(DataSet dataSet,
        Driver driver)
Convert data set to the json object and return a json string. 
 | 
void | 
JsonConnector.cleanUp(JsonConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
void | 
JsonDatasetConnector.cleanUp(JsonDatasetConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
String | 
JsonDatasetConnectorParams.getPropsWizardResource(Driver driver,
                      String connectionDriver)  | 
String | 
JsonConnectorParams.getPropsWizardResource(Driver driver,
                      String connectionDriver)  | 
void | 
JsonConnector.inlinePersist(JsonConnectorParams params,
             DataSet dataSet,
             Driver driver,
             DataSetRecord record,
             int row,
             int records)  | 
void | 
JsonDatasetConnector.inlinePersist(JsonDatasetConnectorParams params,
             DataSet dataSet,
             Driver driver,
             DataSetRecord record,
             int row,
             int records)  | 
ConnectorResult | 
JsonConnector.persist(JsonConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
ConnectorResult | 
JsonDatasetConnector.persist(JsonDatasetConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
ConnectorResult | 
JsonConnector.populate(JsonConnectorParams params,
        DataSet dataSet,
        Driver driver)  | 
ConnectorResult | 
JsonDatasetConnector.populate(JsonDatasetConnectorParams params,
        DataSet dataSet,
        Driver driver)  | 
void | 
JsonConnector.postPersist(JsonConnectorParams params,
           DataSet dataSet,
           Driver driver)  | 
void | 
JsonDatasetConnector.postPersist(JsonDatasetConnectorParams params,
           DataSet dataSet,
           Driver driver)  | 
void | 
JsonConnector.prePersist(JsonConnectorParams params,
          DataSet dataSet,
          Driver driver)  | 
void | 
JsonDatasetConnector.prePersist(JsonDatasetConnectorParams params,
          DataSet dataSet,
          Driver driver)  | 
ConnectorResult | 
JsonConnector.writeMetaData(JsonConnectorParams params,
             DataSet dataSet,
             Driver driver)  | 
ConnectorResult | 
JsonDatasetConnector.writeMetaData(JsonDatasetConnectorParams params,
             DataSet dataSet,
             Driver driver)  | 
| Constructor and Description | 
|---|
JsonStreamingPackage(DataSet dataSet,
                    Driver driver,
                    JsonConnectorParams params)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
PdfConnector.cleanUp(PdfConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
String | 
PdfConnectorParams.getPropsWizardResource(Driver driver,
                      String connectionDriver)  | 
void | 
PdfConnector.inlinePersist(PdfConnectorParams params,
             DataSet dataSet,
             Driver driver,
             DataSetRecord record,
             int row,
             int records)  | 
ConnectorResult | 
PdfConnector.persist(PdfConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
ConnectorResult | 
PdfConnector.populate(PdfConnectorParams params,
        DataSet dataSet,
        Driver driver)  | 
void | 
PdfConnector.postPersist(PdfConnectorParams params,
           DataSet dataSet,
           Driver driver)  | 
void | 
PdfConnector.prePersist(PdfConnectorParams params,
          DataSet dataSet,
          Driver driver)  | 
ConnectorResult | 
PdfConnector.writeMetaData(PdfConnectorParams params,
             DataSet dataSet,
             Driver driver)  | 
| Modifier and Type | Method and Description | 
|---|---|
Driver | 
ConnectorRequest.getDriver()
Gets the driver. 
 | 
| Constructor and Description | 
|---|
ConnectorRequest(Driver driver,
                int maxRows,
                DataSetConnector<DataSetConnectorParams,?> connector,
                String connectorClassName,
                DataSetConnectorParams connectorParams,
                String objectName,
                String ownerName,
                int maxThreads)
Instantiates a new ConnectorRequest. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
SqlConnector.cleanUp(SqlConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
String | 
SqlConnectorParams.getPropsWizardResource(Driver driver,
                      String connectionDriver)  | 
void | 
SqlConnector.inlinePersist(SqlConnectorParams params,
             DataSet dataSet,
             Driver driver,
             DataSetRecord record,
             int row,
             int records)  | 
ConnectorResult | 
SqlConnector.persist(SqlConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
ConnectorResult | 
SqlConnector.populate(SqlConnectorParams params,
        DataSet dataSet,
        Driver driver)  | 
void | 
SqlConnector.postPersist(SqlConnectorParams params,
           DataSet dataSet,
           Driver driver)  | 
void | 
SqlConnector.prePersist(SqlConnectorParams params,
          DataSet dataSet,
          Driver driver)  | 
ConnectorResult | 
SqlConnector.writeMetaData(SqlConnectorParams params,
             DataSet dataSet,
             Driver driver)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ClobConnector.cleanUp(ClobConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
void | 
KeyValueConnector.cleanUp(KeyValueConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
void | 
TextConnector.cleanUp(TextConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
String | 
TextConnectorParams.getPropsWizardResource(Driver driver,
                      String connectionDriver)  | 
String | 
KeyValueConnectorParams.getPropsWizardResource(Driver driver,
                      String connectionDriver)  | 
String | 
ClobConnectorParams.getPropsWizardResource(Driver driver,
                      String connectionDriver)  | 
void | 
ClobConnector.inlinePersist(ClobConnectorParams params,
             DataSet dataSet,
             Driver driver,
             DataSetRecord record,
             int row,
             int records)  | 
void | 
KeyValueConnector.inlinePersist(KeyValueConnectorParams params,
             DataSet dataSet,
             Driver driver,
             DataSetRecord record,
             int row,
             int records)  | 
void | 
TextConnector.inlinePersist(TextConnectorParams params,
             DataSet dataSet,
             Driver driver,
             DataSetRecord record,
             int row,
             int records)  | 
ConnectorResult | 
ClobConnector.persist(ClobConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
ConnectorResult | 
KeyValueConnector.persist(KeyValueConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
ConnectorResult | 
TextConnector.persist(TextConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
ConnectorResult | 
ClobConnector.populate(ClobConnectorParams params,
        DataSet dataSet,
        Driver driver)  | 
ConnectorResult | 
KeyValueConnector.populate(KeyValueConnectorParams params,
        DataSet dataSet,
        Driver driver)  | 
ConnectorResult | 
TextConnector.populate(TextConnectorParams params,
        DataSet dataSet,
        Driver driver)  | 
void | 
ClobConnector.postPersist(ClobConnectorParams params,
           DataSet dataSet,
           Driver driver)  | 
void | 
KeyValueConnector.postPersist(KeyValueConnectorParams params,
           DataSet dataSet,
           Driver driver)  | 
void | 
TextConnector.postPersist(TextConnectorParams params,
           DataSet dataSet,
           Driver driver)  | 
void | 
ClobConnector.prePersist(ClobConnectorParams params,
          DataSet dataSet,
          Driver driver)  | 
void | 
KeyValueConnector.prePersist(KeyValueConnectorParams params,
          DataSet dataSet,
          Driver driver)  | 
void | 
TextConnector.prePersist(TextConnectorParams params,
          DataSet dataSet,
          Driver driver)  | 
ConnectorResult | 
ClobConnector.writeMetaData(ClobConnectorParams params,
             DataSet dataSet,
             Driver driver)  | 
ConnectorResult | 
KeyValueConnector.writeMetaData(KeyValueConnectorParams params,
             DataSet dataSet,
             Driver driver)  | 
ConnectorResult | 
TextConnector.writeMetaData(TextConnectorParams params,
             DataSet dataSet,
             Driver driver)  | 
| Constructor and Description | 
|---|
KeyValueStreamingPackage(DataSet dataSet,
                        Driver driver,
                        KeyValueConnectorParams params)  | 
TextStreamingPackage(DataSet dataSet,
                    Driver driver,
                    TextConnectorParams params)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
XmlConnector.cleanUp(XmlConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
void | 
XmlObjectStreamingConnector.cleanUp(XmlObjectConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
String | 
XmlObjectConnectorParams.getPropsWizardResource(Driver driver,
                      String connectionDriver)  | 
String | 
XmlConnectorParams.getPropsWizardResource(Driver driver,
                      String connectionDriver)  | 
void | 
XmlConnector.inlinePersist(XmlConnectorParams params,
             DataSet dataSet,
             Driver driver,
             DataSetRecord record,
             int row,
             int records)  | 
void | 
XmlObjectStreamingConnector.inlinePersist(XmlObjectConnectorParams params,
             DataSet dataSet,
             Driver driver,
             DataSetRecord record,
             int row,
             int records)  | 
void | 
XmlObjectConnector.parseNode(XmlUtils xml,
         org.w3c.dom.Node node,
         XmlObjectConnectorParams params,
         Driver driver,
         Map<Integer,Boolean> types,
         DataSet dataSet,
         DataSetRecord record,
         XmlUtils.NodeType rootNodeType,
         DataSet newDataSet)  | 
DataSetRecord | 
XmlObjectConnector.parseXml(XmlUtils xml,
        org.w3c.dom.Node root,
        XmlObjectConnectorParams params,
        Driver driver,
        Map<Integer,Boolean> types,
        DataSet dataSet,
        DataSetRecord record,
        XmlUtils.NodeType rootNodeType,
        org.w3c.dom.NodeList nodeList,
        XmlUtils.NodeType thisNodeType)
Parses the xml and creates a hierarchy of the data sets. 
 | 
ConnectorResult | 
XmlConnector.persist(XmlConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
ConnectorResult | 
XmlObjectStreamingConnector.persist(XmlObjectConnectorParams params,
       DataSet dataSet,
       Driver driver)  | 
ConnectorResult | 
XmlConnector.populate(XmlConnectorParams params,
        DataSet dataSet,
        Driver driver)  | 
ConnectorResult | 
XmlObjectStreamingConnector.populate(XmlObjectConnectorParams params,
        DataSet dataSet,
        Driver driver)  | 
ConnectorResult | 
XmlObjectConnector.populate(XmlObjectConnectorParams params,
        DataSet dataSet,
        Driver driver)  | 
void | 
XmlConnector.postPersist(XmlConnectorParams params,
           DataSet dataSet,
           Driver driver)  | 
void | 
XmlObjectStreamingConnector.postPersist(XmlObjectConnectorParams params,
           DataSet dataSet,
           Driver driver)  | 
void | 
XmlConnector.prePersist(XmlConnectorParams params,
          DataSet dataSet,
          Driver driver)  | 
void | 
XmlObjectStreamingConnector.prePersist(XmlObjectConnectorParams params,
          DataSet dataSet,
          Driver driver)  | 
ConnectorResult | 
XmlConnector.writeMetaData(XmlConnectorParams params,
             DataSet dataSet,
             Driver driver)  | 
ConnectorResult | 
XmlObjectStreamingConnector.writeMetaData(XmlObjectConnectorParams params,
             DataSet dataSet,
             Driver driver)  | 
| Constructor and Description | 
|---|
XmlStreamingPackage(DataSet dataSet,
                   Driver driver,
                   XmlObjectConnectorParams params)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
DefaultCodeGen.assembleCode(EtlConfig config,
            Scenario scenario,
            Driver driver,
            int loadIndex,
            boolean silent)  | 
void | 
DefaultCodeGen.cleanUp(EtlConfig config,
       Scenario scenario,
       Driver driver,
       Connection conn)  | 
void | 
DefaultCodeGen.cleanUpOnException(EtlConfig config,
                  Scenario scenario,
                  Driver driver,
                  Connection cleanUpConn)  | 
void | 
DefaultCodeGen.execute(EtlConfig config,
       Scenario scenario,
       Driver driver,
       boolean silent,
       Connection conn,
       Connection cleanUpConn,
       Destination destination)  | 
String | 
DefaultCodeGen.setCurrentCode(Driver driver,
              String name,
              int index)
Sets the current code. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Set<Driver> | 
EtlConfig.getDrivers()
Gets the drivers. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Driver | 
Task.getDriver()
Gets the driver. 
 | 
Driver | 
Destination.getDriver()
Gets the ETL driver. 
 | 
Driver | 
EtlFactory.getDriver(String value,
         DriverDiscovery driverDiscovery,
         String jdbcClassName)
Gets the driver using given string. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
List<Driver> | 
EtlProcess.getDrivers()
Gets drivers. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
CodeGen.assembleCode(EtlConfig config,
            Scenario scenario,
            Driver driver,
            int loadIndex,
            boolean silent)
Assembles prepared code. 
 | 
void | 
CodeGen.cleanUp(EtlConfig config,
       Scenario scenario,
       Driver driver,
       Connection conn)
Clean up after last block of code is executed. 
 | 
void | 
CodeGen.cleanUpOnException(EtlConfig config,
                  Scenario scenario,
                  Driver driver,
                  Connection cleanUpConn)
Clean up database objects on exception. 
 | 
void | 
CodeGen.execute(EtlConfig config,
       Scenario scenario,
       Driver driver,
       boolean silent,
       Connection conn,
       Connection cleanUpConn,
       Destination destination)
Executes code. 
 | 
String | 
Destination.getCursorTableName(Driver driver)
Gets the name of the source table for the cursor using database specific
 semantic implemented in the  
Driver. | 
String | 
MetadataTracker.getLoadKey(EtlConfig config,
          Destination destination,
          String destTableName,
          List<String> fields,
          DataSetFields dataSetFields,
          Driver driver)
Gets the load key. 
 | 
void | 
Task.setDriver(Driver value)
Sets the driver. 
 | 
List<FieldDef> | 
Destination.updateFields(Driver driver,
            boolean add)
Updates fields visibility based on variable.isInclude() flag. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected String | 
DefFunctions.getVarSql(ListHashMap<String,Variable> variables,
         Variable var,
         Driver driver,
         Map<String,Variable> candidates)
Gets the sql associated with the variable. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static String | 
EtlUtils.mergeSqlWithVars(String sql,
                ListHashMap<String,Variable> vars,
                Driver driver)
Merges sql with variables. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AbstractDriver
The base abstract implementation of the Driver interface. 
 | 
class  | 
CallableDriver
The default abstract implementation of the Driver interface which supports
 callable statements. 
 | 
class  | 
GenericFileDriver
Default ETL driver for the file based data sources, such as text files, xml
 files, Excel etc. 
 | 
class  | 
GenericFileDriverNoMetadataOnWrite
Same as  
GenericFileDriver except it does not create metadata files on write. | 
class  | 
GenericJdbcDriver
Default ETL driver for the jdbc compliant databases which does not support
 callable statements. 
 | 
class  | 
GenericJdbcDriverNoErrorOnGetObject
Default ETL driver for the jdbc compliant databases which does not throw an
 exception on getObject . 
 | 
class  | 
GenericJdbcDriverNoPreparedStatement
Default ETL driver for the jdbc compliant databases which does not support
 callable and prepared statements. 
 | 
class  | 
ReadOnlyFileDriver
The read only version of the  
GenericFileDriverNoMetadataOnWrite. | 
class  | 
SimpleDriver
The default abstract implementation of the Driver interface which does not
 support callable statements. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Driver | 
DriverUnit.getDriverByJdbcClassName(String jdbcClassName)  | 
Driver | 
DriverDiscovery.getDriverByJdbcClassName(String jdbcClassName)
Gets the driver by jdbc class name. 
 | 
Driver | 
SimpleDriver.getParentDriver()  | 
Driver | 
Driver.getParentDriver()
Gets the parent driver. 
 | 
Driver | 
AbstractDriver.getParentDriver()  | 
| Modifier and Type | Method and Description | 
|---|---|
List<Driver> | 
DriverUnit.getList()  | 
Map<String,Driver> | 
DriverUnit.getObjects()
Gets the objects. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
boolean | 
GenericJdbcDriver.isEqualDriver(Driver driver)  | 
boolean | 
Driver.isEqualDriver(Driver driver)
Checks if given driver equals to this driver. 
 | 
boolean | 
AbstractDriver.isEqualDriver(Driver driver)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
Db2Driver
The Db2 implementation of the Driver interface. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
InformixDriver
The Informix implementation of the Driver interface. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
MySqlDriver
The MySql implementation of the Driver interface. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
OracleDriver
The Oracle implementation of the Driver interface. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
PostgresDriver
The PostgreSQL implementation of the Driver interface. 
 | 
class  | 
RedshiftDriver
The Redshift implementation of the Driver interface. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
SnowflakeDriver
Snowflake ETL driver. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AzureSynapseAnalyticsDriver
The Azure Synapse Analytics ETL driver. 
 | 
class  | 
MsSqlDriver
The Microsoft Sql server implementation of the Driver interface. 
 | 
class  | 
SybaseDriver
The Sybase Sql server implementation of the Driver interface. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Driver | 
MetadataProvider.getDriver()
Gets the driver. 
 | 
Driver | 
Metadata.getDriver()
Gets the driver. 
 | 
Driver | 
BaseMetadata.getDriver()  | 
| Modifier and Type | Method and Description | 
|---|---|
static List<String> | 
JdbcMetadata.getDbObjectsByWildcard(String wildcard,
                      Alias alias,
                      Driver driver,
                      Set<String> excludedObjects,
                      Set<String> includedObjects,
                      boolean includeViews,
                      boolean includeTables)
Gets the database objects by a wildcard. 
 | 
Map<String,FieldDef> | 
MetadataExtractor.getMetaData(String objectName,
           Connection connection,
           Driver driver,
           String sql,
           boolean useTypes,
           boolean keepOrder)
Extracts fields definitions for the object or given sql. 
 | 
Map<String,FieldDef> | 
GenericMetadataExtractor.getMetaData(String objectName,
           Connection connection,
           Driver driver,
           String sql,
           boolean useTypes,
           boolean keepOrder)  | 
static List<String> | 
JdbcMetadata.getSuggestedKeyFields(Connection connection,
                     Driver driver,
                     String theTableName,
                     DataSetFields dataSetFields)
Gets the suggested key fields. 
 | 
void | 
Metadata.init(ConnectionFactory connectionFactory,
    ConnectionParamsProvider<Alias> connectionParamsProvider,
    Driver driver)
Initializes metadata driver. 
 | 
void | 
BaseMetadata.init(ConnectionFactory connectionFactory,
    ConnectionParamsProvider<Alias> connectionParamsProvider,
    Driver driver)  | 
| Modifier and Type | Method and Description | 
|---|---|
Variable | 
SqlParser.getVariable(String name,
           Driver driver)
Creates a variable using given name and a driver. 
 | 
Variable | 
GenericSqlParser.getVariable(String name,
           Driver driver)  | 
String | 
SqlParser.parseParams(String sql,
           Map<String,Object> params,
           Map<String,List<Integer>> paramMap,
           List<String> outputParams,
           Driver driver)
Parses the sql, updates params, paramMap and outputParams. 
 | 
String | 
GenericSqlParser.parseParams(String sql,
           Map<String,Object> params,
           Map<String,List<Integer>> paramMap,
           List<String> outputParams,
           Driver driver)  | 
void | 
SqlParser.setBindVariables(PreparedStatement st,
                Map<String,Object> properties,
                Map<String,List<Integer>> paramMap,
                List<String> outpurParams,
                Driver driver)
Sets the bind variables for the given prepared statement, including registering output parameters if any exist. 
 | 
void | 
GenericSqlParser.setBindVariables(PreparedStatement st,
                Map<String,Object> properties,
                Map<String,List<Integer>> paramMap,
                List<String> outpurParams,
                Driver driver)  | 
| Constructor and Description | 
|---|
ParamsParser(String sql,
            Map<String,Object> params,
            Map<String,List<Integer>> paramMap,
            List<String> outputParams,
            Driver driver,
            Pattern pattern)
Instantiates a new ParamsParser. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Driver | 
SqlRequest.getDriver()
Gets the driver. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
SqlRequest.setDriver(Driver driver)
Sets the driver. 
 | 
| Constructor and Description | 
|---|
SqlRequest(SessionConnectionProvider<Alias> provider,
          ConnectionParamsProvider<Alias> paramsProvider,
          SqlParser parser,
          Driver driver,
          Map<String,Object> properties,
          String sql,
          boolean hasParams,
          boolean doNotLog)
Instantiates a new sql request. 
 | 
SqlRequest(SessionConnectionProvider<Alias> provider,
          ConnectionParamsProvider<Alias> paramsProvider,
          SqlParser parser,
          Driver driver,
          Map<String,Object> properties,
          String sql,
          boolean hasParams,
          boolean commit,
          boolean close,
          boolean doNotLog)
Instantiates a new sql request. 
 | 
SqlRequest(SessionConnectionProvider<Alias> provider,
          ConnectionParamsProvider<Alias> paramsProvider,
          SqlParser parser,
          Driver driver,
          Map<String,Object> properties,
          String sql,
          boolean hasParams,
          boolean commit,
          boolean close,
          int maxRows,
          boolean doNotLog)
Instantiates a new sql request. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
SqlUtils.executeScript(Connection con,
             String script,
             Driver driver,
             DataSet dataSet,
             OnException onException,
             Map<String,Object> bindVariables,
             String using,
             boolean commit)
Executes SQL script for all rows of the data set if its not empty or just
 once if it is. 
 | 
static void | 
SqlUtils.executeScript(Connection con,
             String script,
             Driver driver,
             DataSet dataSet,
             OnException onException,
             Map<String,Object> bindVariables,
             String using,
             boolean commit,
             boolean isCallable)
Executes SQL script for all rows of the data set if its not empty or just
 once if it is. 
 | 
static void | 
SqlUtils.executeScript(Connection con,
             String script,
             Driver driver,
             DataSet dataSet,
             OnException onException,
             Map<String,Object> bindVariables,
             String using,
             boolean commit,
             boolean isCallable,
             boolean supportsPrepared)
Executes SQL script for all rows of the data set if its not empty or just
 once if it is. 
 | 
static TypedKeyValue<ResultSet,Statement> | 
SqlUtils.executeScriptAndReturnResultSet(Connection con,
                               String script,
                               Driver driver,
                               OnException onException,
                               Map<String,Object> bindVariables,
                               String using,
                               boolean commit)
Executes SQL script for all rows of the data set if its not empty or just
 once if it is. 
 | 
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 int | 
SqlUtils.executeSql(Connection con,
          String sql,
          int action,
          String exception,
          Driver driver,
          boolean isCallable,
          Object... bindVars)
Prepares sql, set bind variables using given  
bindVars and
 finally executes sql. | 
static int | 
SqlUtils.executeSql(Connection con,
          String sql,
          int action,
          String exception,
          Map<String,Object> bindVars,
          Driver driver)
Prepares sql, set bind variables using given  
bindVars and
 finally executes sql. | 
static int | 
SqlUtils.executeSql(Connection con,
          String sql,
          int action,
          String exception,
          Map<String,Object> bindVars,
          Driver driver,
          boolean isCallable)
Prepares sql, set bind variables using given  
bindVars and
 finally executes sql. | 
static int | 
SqlUtils.executeSql(Connection con,
          String sql,
          int action,
          String exception,
          Map<String,Object> bindVars,
          Driver driver,
          boolean isCallable,
          boolean supportsPrepared)
Prepares sql, set bind variables using given  
bindVars and
 finally executes sql. | 
static void | 
SqlUtils.executeSql(Connection con,
          String sql,
          LinkedHashMap<String,Object> params,
          Driver driver)
Prepares sql, set bind variables using given  
params and
 finally executes sql. | 
static TypedKeyValue<Integer,TypedKeyValue<ResultSet,Statement>> | 
SqlUtils.executeSqlAndReturnResultSet(Connection con,
                            String sql,
                            int action,
                            String exception,
                            Map<String,Object> bindVars,
                            Driver driver)
Prepares sql, set bind variables using given  
bindVars and
 finally executes sql. | 
static TypedKeyValue<Integer,TypedKeyValue<ResultSet,Statement>> | 
SqlUtils.executeSqlAndReturnResultSet(Connection con,
                            String sql,
                            int action,
                            String exception,
                            Map<String,Object> bindVars,
                            Driver driver,
                            boolean supportsPrepared)
Prepares sql, set bind variables using given  
bindVars and
 finally executes sql. | 
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. | 
static boolean | 
SqlUtils.exists(Connection con,
      String table,
      Driver driver,
      List<TypedKeyValue<String,Object>> fieldAndValues,
      boolean useBindVariables)
Checks if record exists. 
 | 
static boolean | 
SqlUtils.exists(Connection con,
      String table,
      Driver driver,
      TypedKeyValue<List<String>,List<Object>> fieldsAndValues,
      String fields,
      boolean useBindVariables)
Checks if record exists for the given dataset and list of fields. 
 | 
static boolean | 
SqlUtils.fieldNameNeedQuotes(String fieldName,
                   char quote,
                   Driver driver)
Checks if field name need quotes. 
 | 
static String | 
SqlUtils.filter(Driver driver,
      String value,
      int fieldType)
Executes  
filter(String) if field is a flavor of char or
 clob. | 
static String | 
SqlUtils.getAlterTableAddColumns(String tableName,
                       DataSet dataSet,
                       List<String> missingColumns,
                       Driver driver)
Gets the SQL for "alter table add column". 
 | 
static String | 
SqlUtils.getAlterTableAddColumns(String tableName,
                       DataSet dataSet,
                       List<String> missingColumns,
                       Driver driver,
                       boolean withNotNull)
Gets the SQL for "alter table add column". 
 | 
static String | 
SqlUtils.getBindParameterName(String fieldName,
                    Driver driver)
Gets the bind parameter name from field name. 
 | 
static String | 
SqlUtils.getConditions(List<TypedKeyValue<String,Object>> fieldAndValues,
             Driver driver,
             boolean useBindVariables)
Gets the where clause conditions for the list of fields. 
 | 
static String | 
SqlUtils.getFieldAsText(Driver driver,
              String name,
              String fType,
              Object size,
              Object decimal,
              Object nullable,
              int javaType)
Gets the field definition. 
 | 
static String[] | 
SqlUtils.getFieldNamesWithSpaces(String[] fields,
                       char quote,
                       Driver driver)
Gets the field names with spaces. 
 | 
static String | 
SqlUtils.getFieldNameWithSpaces(String fieldName,
                      char quote,
                      Driver driver)
Gets the field name with spaces. 
 | 
static String | 
SqlUtils.getFieldNameWithSpacesForced(String fieldName,
                            char quote,
                            Driver driver)
Gets the field name with spaces forced. 
 | 
static String | 
SqlUtils.getFieldsSql(DataSet dataSet,
            Driver driver,
            String key,
            FieldsRepository fieldsRepository)
Gets the fields definitions for all fields in the data set. 
 | 
static String | 
SqlUtils.getFieldsSql(DataSet dataSet,
            Driver driver,
            String key,
            FieldsRepository fieldsRepository,
            boolean withNotNull)
Gets the fields definitions for all fields in the data set. 
 | 
static String | 
SqlUtils.getInsertSelectSql(DataSet dataSet,
                  Driver driver,
                  String from,
                  String to,
                  boolean withTruncate)  | 
static String | 
SqlUtils.getNameForWildcard(String wildcard,
                  String name,
                  Driver fromDriver,
                  Driver toDriver)
Gets the table name for wildcard. 
 | 
static String | 
SqlUtils.getNameWithoutOwnersAndWithOptionalQuotes(String name,
                                         Driver fromDriver,
                                         Driver toDriver)
Gets the name without quotes and owners. 
 | 
static Object | 
SqlUtils.getObject(ResultSet rs,
         int index,
         FieldDef fieldDef,
         Driver driver)
Gets the object from result set. 
 | 
static PreparedStatement | 
SqlUtils.getPreparedStatementAndSetBindVars(Connection con,
                                  String sql,
                                  List<TypedKeyValue<String,Object>> fieldAndValues,
                                  Driver driver,
                                  boolean useBindVariables)
Gets the prepared statement and set bind variables. 
 | 
static String | 
SqlUtils.getSelectClause(Driver driver)
Gets the select clause for metadata extraction. 
 | 
static String | 
SqlUtils.getSqlForExplainPlan(String sql,
                    Driver driver,
                    SqlParser sqlParser)
Gets the sql for explain plan. 
 | 
static String | 
SqlUtils.getSqlForMetadataExtraction(String objectName,
                           Driver driver)
Gets the sql for metadata extraction. 
 | 
static String | 
SqlUtils.getTableNameWithSpaces(String tableName,
                      char quote,
                      Driver driver)
Gets the table name with spaces. 
 | 
static String | 
SqlUtils.getTableNameWithSuffix(String tableName,
                      String suffix,
                      Driver driver)
Gets the table name with suffix. 
 | 
static String | 
SqlUtils.getWhereClause(Driver driver)
Gets the where clause for metadata extraction. 
 | 
static String | 
SqlUtils.name2RightCase(Driver driver,
              String name)
Converts name to the right case. 
 | 
static void | 
SqlUtils.populateDataSet(DataSet dataSet,
               Driver driver,
               ResultSet rs,
               ListHashMap<String,String> fieldsMapping,
               boolean unique,
               boolean checkKeyField)
Populates data set from the result set. 
 | 
static void | 
SqlUtils.populateDataSet(DataSet dataSet,
               Driver driver,
               ResultSet rs,
               ListHashMap<String,String> fieldsMapping,
               boolean unique,
               boolean checkKeyField,
               String filterByField,
               String filterByFieldValue)
Populates data set from the result set. 
 | 
static void | 
SqlUtils.populateDataSet(DataSet dataSet,
               Driver driver,
               ResultSet rs,
               ListHashMap<String,String> fieldsMapping,
               boolean unique,
               boolean checkKeyField,
               String filterByField,
               String filterByFieldValue,
               int maxRows,
               boolean ignoreGetObjectErrors)
Populates data set from the result set. 
 | 
static void | 
SqlUtils.registerOutputParams(CallableStatement cst,
                    String output,
                    Driver driver,
                    int start)
Register output params. 
 | 
static String | 
SqlUtils.removeQuotes(String name,
            Driver driver)
Removes the quotes. 
 | 
static void | 
SqlUtils.setBindVarAndRegisterOutputParams(PreparedStatement statement,
                                 Object bindVar,
                                 int index,
                                 Driver driver)
Sets the bind var and register output parameters. 
 | 
static void | 
SqlUtils.setBindVars(PreparedStatement statement,
           List<TypedKeyValue<String,Object>> fieldAndValues,
           Driver driver)
Sets the bind variables. 
 | 
static String | 
SqlUtils.suggestBestFieldForTheKey(List<String> fields,
                         String tableName,
                         Driver driver,
                         boolean includingFirst)
Suggest best field for the key. 
 | 
Copyright © 2010-2020 Toolsverse. All Rights Reserved.