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.