public class DwsDatabase
extends org.pentaho.di.core.database.Database
| 构造器和说明 |
|---|
DwsDatabase(org.pentaho.di.core.logging.LoggingObjectInterface parentObject,
DwsTableOutputMeta meta) |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
close() |
void |
connect(String group,
String partitionId) |
void |
disconnect() |
void |
insertRow(String schemaName,
String tableName,
org.pentaho.di.core.row.RowMetaInterface fields,
Object[] insertRowData) |
absolute, afterLast, callProcedure, cancelQuery, cancelStatement, checkColumnExists, checkColumnExists, checkColumnExistsByDbMeta, checkIndexExists, checkIndexExists, checkSequenceExists, checkSequenceExists, checkTableExists, checkTableExists, checkTableExistsByDbMeta, cleanupLogRecords, clearBatch, clearInsertBatch, closeConnectionOnly, closeInsert, closeLookup, closePreparedStatement, closeProcedureStatement, closeQuery, closeUpdate, commit, commit, commitLog, commitLog, connect, connect, copyVariablesFrom, countParameters, createKettleDatabaseBatchException, emptyAndCommit, emptyAndCommit, environmentSubstitute, environmentSubstitute, equals, execStatement, execStatement, execStatements, execStatements, execStatementsFromFile, executeAndClearBatch, fieldSubstitute, first, getAlterTableStatement, getBooleanValueOfVariable, getCatalogs, getConnection, getConnectionGroup, getContainerObjectId, getCopy, getCreateIndexStatement, getCreateIndexStatement, getCreateSequenceStatement, getCreateSequenceStatement, getCreateSequenceStatement, getCreateSequenceStatement, getCreateTableStatement, getDatabaseMeta, getDatabaseMetaData, getDDL, getDDL, getDDL, getDDLCreationTable, getDDLTruncateTable, getFilename, getFirstRows, getFirstRows, getGeneratedKeys, getInsertStatement, getInsertStatement, getLastLogDate, getLogChannelId, getLogLevel, getLookup, getLookup, getLookup, getLookup, getLookup, getLookup, getMetaFromRow, getNextSequenceValue, getNextSequenceValue, getNextValue, getNextValue, getNrExecutedCommits, getObjectCopy, getObjectId, getObjectName, getObjectRevision, getObjectType, getOneRow, getOneRow, getOpened, getParameterMetaData, getParameterMetaData, getParent, getParentObject, getParentVariableSpace, getPartitionId, getPrepStatementInsert, getPrepStatementLookup, getPrepStatementUpdate, getPrimaryKeyColumnNames, getProcedures, getQueryFields, getQueryFields, getQueryFieldsFallback, getQueryFieldsFromDatabaseMetaData, getQueryFieldsFromPreparedStatement, getRegistrationDate, getRepositoryDirectory, getReturnRowMeta, getRow, getRow, getRow, getRows, getRows, getRows, getRows, getSchemas, getSequences, getSQLOutput, getSynonymMap, getSynonymMap, getSynonyms, getSynonyms, getSynonyms, getTableFields, getTableFieldsMeta, getTableFieldsMetaByDbMeta, getTableMap, getTableMap, getTableMap, getTablenames, getTablenames, getTablenames, getTablenames, getTableTypes, getUseBatchInsert, getVariable, getVariable, getViewMap, getViewMap, getViews, getViews, getViews, initializeVariablesFrom, injectVariables, insertFinished, insertFinished, insertRow, insertRow, insertRow, insertRow, insertRow, insertRow, isAutoCommit, isForcingSeparateLogging, isGatheringMetrics, isSystemTable, listVariables, lockTables, normalConnect, openQuery, openQuery, openQuery, openQuery, openQuery, prepareDelete, prepareDelete, prepareInsert, prepareInsert, prepareSQL, prepareSQL, prepareUpdate, prepareUpdate, printSQLException, relative, releaseSavepoint, rollback, rollback, rollback, setAutoCommit, setCommit, setConnection, setConnectionGroup, setContainerObjectId, setCopy, setForcingSeparateLogging, setGatheringMetrics, setLogLevel, setLookup, setLookup, setLookup, setLookup, setNrExecutedCommits, setOpened, setParentVariableSpace, setPartitionId, setProcLookup, setProcValues, setQueryLimit, setSavepoint, setSavepoint, setValue, setValues, setValues, setValues, setValues, setValues, setValuesInsert, setValuesInsert, setValuesLookup, setValuesUpdate, setVariable, shareVariablesWith, toString, truncateTable, truncateTable, unlockTables, updateRow, writeLogRecordpublic DwsDatabase(org.pentaho.di.core.logging.LoggingObjectInterface parentObject,
DwsTableOutputMeta meta)
public void connect(String group, String partitionId) throws org.pentaho.di.core.exception.KettleDatabaseException
connect 在类中 org.pentaho.di.core.database.Databaseorg.pentaho.di.core.exception.KettleDatabaseExceptionpublic void close()
close 在接口中 Closeableclose 在接口中 AutoCloseableclose 在类中 org.pentaho.di.core.database.Databasepublic void disconnect()
disconnect 在类中 org.pentaho.di.core.database.Databasepublic void insertRow(String schemaName, String tableName, org.pentaho.di.core.row.RowMetaInterface fields, Object[] insertRowData) throws org.pentaho.di.core.exception.KettleDatabaseException
insertRow 在类中 org.pentaho.di.core.database.Databaseorg.pentaho.di.core.exception.KettleDatabaseExceptionCopyright © 2024. All rights reserved.