Package | Description |
---|---|
org.pentaho.di.core | |
org.pentaho.di.core.database |
Contains all the different database dialects as well as the DatabaseMeta class (definition) and the Database class (execution)
|
org.pentaho.di.core.logging |
This package contains the Log4j Kettle appenders and Kettle layout as well as the Kettle Log Message.
|
org.pentaho.di.core.row | |
org.pentaho.di.core.row.value | |
org.pentaho.di.metastore |
Modifier and Type | Method and Description |
---|---|
DatabaseMeta |
SQLStatement.getDatabase()
Get the database connection for this SQL Statement
|
Modifier and Type | Method and Description |
---|---|
static List<DatabaseMeta> |
ConstDB.selectSAPR3Databases(List<DatabaseMeta> databases)
Select the SAP ERP databases in the List of databases.
|
Modifier and Type | Method and Description |
---|---|
void |
SQLStatement.setDatabase(DatabaseMeta dbinfo)
Sets the database connection for this SQL Statement
|
Modifier and Type | Method and Description |
---|---|
static List<DatabaseMeta> |
ConstDB.selectSAPR3Databases(List<DatabaseMeta> databases)
Select the SAP ERP databases in the List of databases.
|
Constructor and Description |
---|
SQLStatement(String stepname,
DatabaseMeta dbinfo,
String sql)
Creates a new SQLStatement
|
Modifier and Type | Field and Description |
---|---|
static Comparator<DatabaseMeta> |
DatabaseMeta.comparator |
Modifier and Type | Method and Description |
---|---|
static DatabaseMeta |
DatabaseMeta.findDatabase(List<? extends SharedObjectInterface> databases,
String dbname)
Find a database with a certain name in an arraylist of databases.
|
static DatabaseMeta |
DatabaseMeta.findDatabase(List<DatabaseMeta> databases,
ObjectId id)
Find a database with a certain ID in an arraylist of databases.
|
DatabaseMeta |
Database.getDatabaseMeta() |
DatabaseMeta |
DatabaseMetaInformation.getDbInfo() |
Modifier and Type | Method and Description |
---|---|
static Connection |
ConnectionPoolUtil.getConnection(LogChannelInterface log,
DatabaseMeta dbMeta,
String partitionId) |
static Connection |
ConnectionPoolUtil.getConnection(LogChannelInterface log,
DatabaseMeta dbMeta,
String partitionId,
int initialSize,
int maximumSize) |
String |
DatabaseFactoryInterface.getConnectionTestReport(DatabaseMeta databaseMeta) |
String |
DatabaseFactory.getConnectionTestReport(DatabaseMeta databaseMeta) |
String |
DatabaseInterface.getDataTablespaceDDL(VariableSpace variables,
DatabaseMeta databaseMeta)
Returns the tablespace DDL fragment for a "Data" tablespace.
|
String |
BaseDatabaseMeta.getDataTablespaceDDL(VariableSpace variables,
DatabaseMeta databaseMeta)
Returns the tablespace DDL fragment for a "Data" tablespace.
|
String |
DatabaseInterface.getIndexTablespaceDDL(VariableSpace variables,
DatabaseMeta databaseMeta)
Returns the tablespace DDL fragment for a "Index" tablespace.
|
String |
BaseDatabaseMeta.getIndexTablespaceDDL(VariableSpace variables,
DatabaseMeta databaseMeta)
Returns the tablespace DDL fragment for a "Index" tablespace.
|
Long |
DatabaseInterface.getNextBatchId(DatabaseMeta dbm,
Database ldb,
String schemaName,
String tableName,
String fieldName)
Get the next Batch ID from the logging tables.
|
Long |
BaseDatabaseMeta.getNextBatchId(DatabaseMeta dbm,
Database ldb,
String schemaName,
String tableName,
String fieldName) |
Long |
BaseDatabaseMeta.getNextBatchIdUsingAutoIncSQL(String autoIncSQL,
DatabaseMeta dbm,
Database ldb) |
Long |
MSSQLServerDatabaseMeta.getNextBatchIdUsingLockTables(DatabaseMeta dbm,
Database ldb,
String schemaName,
String tableName,
String fieldName) |
Long |
BaseDatabaseMeta.getNextBatchIdUsingLockTables(DatabaseMeta dbm,
Database ldb,
String schemaName,
String tableName,
String fieldName) |
Long |
BaseDatabaseMeta.getNextBatchIdUsingSequence(String sequenceName,
String schemaName,
DatabaseMeta dbm,
Database ldb) |
String |
OracleDatabaseMeta.getTablespaceDDL(VariableSpace variables,
DatabaseMeta databaseMeta,
String tablespace)
Returns an empty string as most databases do not support tablespaces.
|
String |
BaseDatabaseMeta.getTablespaceDDL(VariableSpace variables,
DatabaseMeta databaseMeta,
String tablespaceName)
Returns an empty string as most databases do not support tablespaces.
|
void |
DatabaseMeta.replaceMeta(DatabaseMeta databaseMeta) |
void |
DatabaseMetaInformation.setDbInfo(DatabaseMeta value) |
void |
DatabaseMeta.setValues(DatabaseMeta info) |
Modifier and Type | Method and Description |
---|---|
static DatabaseMeta |
DatabaseMeta.findDatabase(List<DatabaseMeta> databases,
ObjectId id)
Find a database with a certain ID in an arraylist of databases.
|
String |
DatabaseMeta.verifyAndModifyDatabaseName(List<DatabaseMeta> databases,
String oldname)
Verify the name of the database and if required, change it if it already exists in the list of databases.
|
Constructor and Description |
---|
Database(DatabaseMeta databaseMeta)
Deprecated.
Please specify the parent object so that we can see which object is initiating a database connection
|
Database(LoggingObjectInterface parentObject,
DatabaseMeta databaseMeta)
Construct a new Database Connection
|
DatabaseMetaInformation(DatabaseMeta databaseMeta)
Create a new DatabaseMetaData object for the given database connection
|
Modifier and Type | Method and Description |
---|---|
DatabaseMeta |
LogTableCoreInterface.getDatabaseMeta() |
Modifier and Type | Method and Description |
---|---|
ValueMetaInterface |
ValueMetaInterface.getValueFromSQLType(DatabaseMeta databaseMeta,
String name,
ResultSetMetaData rm,
int index,
boolean ignoreLength,
boolean lazyConversion)
Investigate JDBC result set metadata at the specified index.
|
void |
ValueMetaInterface.setPreparedStatementValue(DatabaseMeta databaseMeta,
PreparedStatement preparedStatement,
int index,
Object data)
Set a value on a JDBC prepared statement on the specified position
|
Modifier and Type | Method and Description |
---|---|
ValueMetaInterface |
ValueMetaTimestamp.getValueFromSQLType(DatabaseMeta databaseMeta,
String name,
ResultSetMetaData rm,
int index,
boolean ignoreLength,
boolean lazyConversion) |
ValueMetaInterface |
ValueMetaInternetAddress.getValueFromSQLType(DatabaseMeta databaseMeta,
String name,
ResultSetMetaData rm,
int index,
boolean ignoreLength,
boolean lazyConversion) |
ValueMetaInterface |
ValueMetaBase.getValueFromSQLType(DatabaseMeta databaseMeta,
String name,
ResultSetMetaData rm,
int index,
boolean ignoreLength,
boolean lazyConversion) |
void |
ValueMetaTimestamp.setPreparedStatementValue(DatabaseMeta databaseMeta,
PreparedStatement preparedStatement,
int index,
Object data) |
void |
ValueMetaInternetAddress.setPreparedStatementValue(DatabaseMeta databaseMeta,
PreparedStatement preparedStatement,
int index,
Object data) |
void |
ValueMetaBase.setPreparedStatementValue(DatabaseMeta databaseMeta,
PreparedStatement preparedStatement,
int index,
Object data) |
Modifier and Type | Method and Description |
---|---|
static DatabaseMeta |
DatabaseMetaStoreUtil.loadDatabaseMetaFromDatabaseElement(org.pentaho.metastore.api.IMetaStore metaStore,
org.pentaho.metastore.api.IMetaStoreElement element) |
Modifier and Type | Method and Description |
---|---|
static List<DatabaseMeta> |
DatabaseMetaStoreUtil.getDatabaseElements(org.pentaho.metastore.api.IMetaStore metaStore) |
Modifier and Type | Method and Description |
---|---|
static void |
DatabaseMetaStoreUtil.createDatabaseElement(org.pentaho.metastore.api.IMetaStore metaStore,
DatabaseMeta databaseMeta) |
static org.pentaho.metastore.api.IMetaStoreElement |
DatabaseMetaStoreUtil.populateDatabaseElement(org.pentaho.metastore.api.IMetaStore metaStore,
DatabaseMeta databaseMeta) |