@Test public void testCreateKettleDatabaseBatchExceptionNullUpdatesWhenSQLException() { assertNull( Database.createKettleDatabaseBatchException( "", new SQLException() ).getUpdateCounts() ); }
public static KettleDatabaseBatchException createKettleDatabaseBatchException( String message, SQLException ex ) { KettleDatabaseBatchException kdbe = new KettleDatabaseBatchException( message, ex ); if ( ex instanceof BatchUpdateException ) { kdbe.setUpdateCounts( ( (BatchUpdateException) ex ).getUpdateCounts() ); } else { kdbe.setUpdateCounts( null ); } List<Exception> exceptions = new ArrayList<Exception>(); SQLException nextException = ex.getNextException(); SQLException oldException = null; while ( ( nextException != null ) && ( oldException != nextException ) ) { exceptions.add( nextException ); oldException = nextException; nextException = nextException.getNextException(); } kdbe.setExceptionsList( exceptions ); return kdbe; }
Database implements VariableSpace, LoggingObjectInterface { public static KettleDatabaseBatchException createKettleDatabaseBatchException( String message, SQLException ex ) { KettleDatabaseBatchException kdbe = new KettleDatabaseBatchException( message, ex ); if ( ex instanceof BatchUpdateException ) { kdbe.setUpdateCounts( ( (BatchUpdateException) ex ).getUpdateCounts() ); } else { kdbe.setUpdateCounts( null ); } List<Exception> exceptions = new ArrayList<Exception>(); SQLException nextException = ex.getNextException(); SQLException oldException = null; while ( ( nextException != null ) && ( oldException != nextException ) ) { exceptions.add( nextException ); oldException = nextException; nextException = nextException.getNextException(); } kdbe.setExceptionsList( exceptions ); return kdbe; } }
Database implements VariableSpace, LoggingObjectInterface { public static KettleDatabaseBatchException createKettleDatabaseBatchException( String message, SQLException ex ) { KettleDatabaseBatchException kdbe = new KettleDatabaseBatchException( message, ex ); if ( ex instanceof BatchUpdateException ) { kdbe.setUpdateCounts( ( (BatchUpdateException) ex ).getUpdateCounts() ); } else { kdbe.setUpdateCounts( null ); } List<Exception> exceptions = new ArrayList<Exception>(); SQLException nextException = ex.getNextException(); SQLException oldException = null; while ( ( nextException != null ) && ( oldException != nextException ) ) { exceptions.add( nextException ); oldException = nextException; nextException = nextException.getNextException(); } kdbe.setExceptionsList( exceptions ); return kdbe; } @Deprecated  Database( DatabaseMeta databaseMeta );  Database( LoggingObjectInterface parentObject, DatabaseMeta databaseMeta ); }
Database implements VariableSpace, LoggingObjectInterface { public static KettleDatabaseBatchException createKettleDatabaseBatchException( String message, SQLException ex ) { KettleDatabaseBatchException kdbe = new KettleDatabaseBatchException( message, ex ); if ( ex instanceof BatchUpdateException ) { kdbe.setUpdateCounts( ( (BatchUpdateException) ex ).getUpdateCounts() ); } else { kdbe.setUpdateCounts( null ); } List<Exception> exceptions = new ArrayList<Exception>(); SQLException nextException = ex.getNextException(); SQLException oldException = null; while ( ( nextException != null ) && ( oldException != nextException ) ) { exceptions.add( nextException ); oldException = nextException; nextException = nextException.getNextException(); } kdbe.setExceptionsList( exceptions ); return kdbe; } @Deprecated  Database( DatabaseMeta databaseMeta );  Database( LoggingObjectInterface parentObject, DatabaseMeta databaseMeta ); @Override boolean equals( Object obj ); void setConnection( Connection connection ); Connection getConnection(); void setQueryLimit( int rows ); PreparedStatement getPrepStatementInsert(); PreparedStatement getPrepStatementLookup(); PreparedStatement getPrepStatementUpdate(); void connect(); void connect( String partitionId ); synchronized void connect( String group, String partitionId ); void normalConnect( String partitionId ); synchronized void disconnect(); synchronized void closeConnectionOnly(); void cancelQuery(); void cancelStatement( Statement statement ); void setCommit( int commsize ); void setAutoCommit( boolean useAutoCommit ); void commit(); void commit( boolean force ); void commitLog( LogTableCoreInterface logTable ); void commitLog( boolean force, LogTableCoreInterface logTable ); void rollback(); void rollback( boolean force ); void prepareInsert( RowMetaInterface rowMeta, String tableName ); void prepareInsert( RowMetaInterface rowMeta, String schemaName, String tableName ); PreparedStatement prepareSQL( String sql ); PreparedStatement prepareSQL( String sql, boolean returnKeys ); void closeLookup(); void closePreparedStatement( PreparedStatement ps ); void closeInsert(); void closeUpdate(); void setValues( RowMetaInterface rowMeta, Object[] data ); void setValues( RowMetaAndData row ); void setValuesInsert( RowMetaInterface rowMeta, Object[] data ); void setValuesInsert( RowMetaAndData row ); void setValuesUpdate( RowMetaInterface rowMeta, Object[] data ); void setValuesLookup( RowMetaInterface rowMeta, Object[] data ); void setProcValues( RowMetaInterface rowMeta, Object[] data, int[] argnrs, String[] argdir, boolean result ); void setValue( PreparedStatement ps, ValueMetaInterface v, Object object, int pos ); void setValues( RowMetaAndData row, PreparedStatement ps ); void setValues( RowMetaInterface rowMeta, Object[] data, PreparedStatement ps ); void setValues( RowMetaInterface rowMeta, Object[] data, PreparedStatement ps, int ignoreThisValueIndex ); RowMetaAndData getGeneratedKeys( PreparedStatement ps ); Long getNextSequenceValue( String sequenceName, String keyfield ); Long getNextSequenceValue( String schemaName, String sequenceName, String keyfield ); void insertRow( String tableName, RowMetaInterface fields, Object[] data ); void insertRow( String schemaName, String tableName, RowMetaInterface fields, Object[] data ); String getInsertStatement( String tableName, RowMetaInterface fields ); String getInsertStatement( String schemaName, String tableName, RowMetaInterface fields ); void insertRow(); void insertRow( boolean batch ); void updateRow(); void insertRow( PreparedStatement ps ); boolean insertRow( PreparedStatement ps, boolean batch ); boolean getUseBatchInsert( boolean batch ); boolean insertRow( PreparedStatement ps, boolean batch, boolean handleCommit ); @Deprecated void clearInsertBatch(); void clearBatch( PreparedStatement preparedStatement ); void executeAndClearBatch( PreparedStatement preparedStatement ); void insertFinished( boolean batch ); void emptyAndCommit( PreparedStatement ps, boolean batch ); void emptyAndCommit( PreparedStatement ps, boolean batch, int batchCounter ); static KettleDatabaseBatchException createKettleDatabaseBatchException( String message, SQLException ex ); @Deprecated void insertFinished( PreparedStatement ps, boolean batch ); Result execStatement( String sql ); Result execStatement( String rawsql, RowMetaInterface params, Object[] data ); Result execStatements( String script ); Result execStatements( String script, RowMetaInterface params, Object[] data ); ResultSet openQuery( String sql ); ResultSet openQuery( String sql, RowMetaInterface params, Object[] data ); ResultSet openQuery( String sql, RowMetaInterface params, Object[] data, int fetch_mode ); ResultSet openQuery( String sql, RowMetaInterface params, Object[] data, int fetch_mode,
                              boolean lazyConversion ); ResultSet openQuery( PreparedStatement ps, RowMetaInterface params, Object[] data ); RowMetaInterface getTableFields( String tablename ); RowMetaInterface getQueryFields( String sql, boolean param ); boolean checkTableExists( String tablename ); boolean checkTableExistsByDbMeta( String shema, String tablename ); boolean checkColumnExists( String columnname, String tablename ); boolean checkSequenceExists( String sequenceName ); boolean checkSequenceExists( String schemaName, String sequenceName ); boolean checkIndexExists( String tableName, String[] idx_fields ); boolean checkIndexExists( String schemaName, String tableName, String[] idx_fields ); String getCreateIndexStatement( String tablename, String indexname, String[] idx_fields, boolean tk,
                                         boolean unique, boolean bitmap, boolean semi_colon ); String getCreateIndexStatement( String schemaname, String tablename, String indexname,
                                         String[] idx_fields, boolean tk, boolean unique, boolean bitmap,
                                         boolean semi_colon ); String getCreateSequenceStatement( String sequence, long start_at, long increment_by, long max_value,
                                            boolean semi_colon ); String getCreateSequenceStatement( String sequence, String start_at, String increment_by,
                                            String max_value, boolean semi_colon ); String getCreateSequenceStatement( String schemaName, String sequence, long start_at, long increment_by,
                                            long max_value, boolean semi_colon ); String getCreateSequenceStatement( String schemaName, String sequenceName, String start_at,
                                            String increment_by, String max_value, boolean semi_colon ); RowMetaInterface getQueryFields( String sql, boolean param, RowMetaInterface inform, Object[] data ); RowMetaInterface getQueryFieldsFromPreparedStatement( String sql ); RowMetaInterface getQueryFieldsFromDatabaseMetaData(); RowMetaInterface getQueryFieldsFallback( String sql, boolean param, RowMetaInterface inform,
                                                   Object[] data ); void closeQuery( ResultSet res ); boolean absolute( ResultSet rs, int position ); boolean relative( ResultSet rs, int rows ); void afterLast( ResultSet rs ); void first( ResultSet rs ); Object[] getRow( ResultSet rs ); Object[] getRow( ResultSet rs, boolean lazyConversion ); Object[] getRow( ResultSet rs, ResultSetMetaData dummy, RowMetaInterface rowInfo ); void printSQLException( SQLException ex ); void setLookup( String table, String[] codes, String[] condition, String[] gets, String[] rename,
                         String orderby ); void setLookup( String schema, String table, String[] codes, String[] condition, String[] gets,
                         String[] rename, String orderby ); void setLookup( String tableName, String[] codes, String[] condition, String[] gets, String[] rename,
                         String orderby, boolean checkForMultipleResults ); void setLookup( String schemaName, String tableName, String[] codes, String[] condition, String[] gets,
                         String[] rename, String orderby, boolean checkForMultipleResults ); boolean prepareUpdate( String table, String[] codes, String[] condition, String[] sets ); boolean prepareUpdate( String schemaName, String tableName, String[] codes, String[] condition,
                                String[] sets ); boolean prepareDelete( String table, String[] codes, String[] condition ); boolean prepareDelete( String schemaName, String tableName, String[] codes, String[] condition ); void setProcLookup( String proc, String[] arg, String[] argdir, int[] argtype, String returnvalue,
                             int returntype ); Object[] getLookup(); Object[] getLookup( boolean failOnMultipleResults ); Object[] getLookup( boolean failOnMultipleResults, boolean lazyConversion ); Object[] getLookup( PreparedStatement ps ); Object[] getLookup( PreparedStatement ps, boolean failOnMultipleResults ); Object[] getLookup( PreparedStatement ps, boolean failOnMultipleResults, boolean lazyConversion ); DatabaseMetaData getDatabaseMetaData(); String getDDL( String tablename, RowMetaInterface fields ); String getDDL( String tablename, RowMetaInterface fields, String tk, boolean use_autoinc, String pk ); String getDDL( String tableName, RowMetaInterface fields, String tk, boolean use_autoinc, String pk,
                        boolean semicolon ); String getCreateTableStatement( String tableName, RowMetaInterface fields, String tk,
                                         boolean use_autoinc, String pk, boolean semicolon ); String getAlterTableStatement( String tableName, RowMetaInterface fields, String tk, boolean use_autoinc,
                                        String pk, boolean semicolon ); void truncateTable( String tablename ); void truncateTable( String schema, String tablename ); RowMetaAndData getOneRow( String sql ); RowMeta getMetaFromRow( Object[] row, ResultSetMetaData md ); RowMetaAndData getOneRow( String sql, RowMetaInterface param, Object[] data ); RowMetaInterface getParameterMetaData( PreparedStatement ps ); int countParameters( String sql ); RowMetaInterface getParameterMetaData( String sql, RowMetaInterface inform, Object[] data ); void writeLogRecord( LogTableCoreInterface logTable, LogStatus status, Object subject, Object parent ); void cleanupLogRecords( LogTableCoreInterface logTable ); Object[] getLastLogDate( String logtable, String name, boolean job, LogStatus status ); synchronized Long getNextValue( Hashtable<String, Counter> counters, String tableName, String val_key ); synchronized Long getNextValue( Hashtable<String, Counter> counters, String schemaName, String tableName,
                                         String val_key ); @Override String toString(); boolean isSystemTable( String table_name ); List<Object[]> getRows( String sql, int limit ); List<Object[]> getRows( String sql, int limit, ProgressMonitorListener monitor ); List<Object[]> getRows( String sql, RowMetaInterface params, Object[] data, int fetch_mode,
                                 boolean lazyConversion, int limit, ProgressMonitorListener monitor ); List<Object[]> getRows( ResultSet rset, int limit, ProgressMonitorListener monitor ); List<Object[]> getFirstRows( String table_name, int limit ); List<Object[]> getFirstRows( String table_name, int limit, ProgressMonitorListener monitor ); RowMetaInterface getReturnRowMeta(); String[] getTableTypes(); String[] getTablenames(); String[] getTablenames( boolean includeSchema ); String[] getTablenames( String schemanamein, boolean includeSchema ); String[] getTablenames( String schemanamein, boolean includeSchema, Map<String, String> props ); Map<String, Collection<String>> getTableMap(); Map<String, Collection<String>> getTableMap( String schemanamein ); Map<String, Collection<String>> getTableMap( String schemanamein, Map<String, String> props ); String[] getViews(); String[] getViews( boolean includeSchema ); String[] getViews( String schemanamein, boolean includeSchema ); Map<String, Collection<String>> getViewMap(); Map<String, Collection<String>> getViewMap( String schemanamein ); String[] getSynonyms(); String[] getSynonyms( boolean includeSchema ); String[] getSynonyms( String schemanamein, boolean includeSchema ); Map<String, Collection<String>> getSynonymMap(); Map<String, Collection<String>> getSynonymMap( String schemanamein ); String[] getSchemas(); String[] getCatalogs(); String[] getProcedures(); boolean isAutoCommit(); DatabaseMeta getDatabaseMeta(); void lockTables( String[] tableNames ); void unlockTables( String[] tableNames ); int getOpened(); synchronized void setOpened( int opened ); String getConnectionGroup(); void setConnectionGroup( String connectionGroup ); String getPartitionId(); void setPartitionId( String partitionId ); int getCopy(); synchronized void setCopy( int copy ); @Override void copyVariablesFrom( VariableSpace space ); @Override String environmentSubstitute( String aString ); @Override String[] environmentSubstitute( String[] aString ); @Override String fieldSubstitute( String aString, RowMetaInterface rowMeta, Object[] rowData ); @Override VariableSpace getParentVariableSpace(); @Override void setParentVariableSpace( VariableSpace parent ); @Override String getVariable( String variableName, String defaultValue ); @Override String getVariable( String variableName ); @Override boolean getBooleanValueOfVariable( String variableName, boolean defaultValue ); @Override void initializeVariablesFrom( VariableSpace parent ); @Override String[] listVariables(); @Override void setVariable( String variableName, String variableValue ); @Override void shareVariablesWith( VariableSpace space ); @Override void injectVariables( Map<String, String> prop ); RowMetaAndData callProcedure( String[] arg, String[] argdir, int[] argtype, String resultname,
                                       int resulttype ); void closeProcedureStatement(); String getDDLCreationTable( String tableName, RowMetaInterface fields ); String getDDLTruncateTable( String schema, String tablename ); String getSQLOutput( String schemaName, String tableName, RowMetaInterface fields, Object[] r,
                              String dateFormat ); Savepoint setSavepoint(); Savepoint setSavepoint( String savePointName ); void releaseSavepoint( Savepoint savepoint ); void rollback( Savepoint savepoint ); Object getParentObject(); String[] getPrimaryKeyColumnNames( String tablename ); String[] getSequences(); @Override String getFilename(); @Override String getLogChannelId(); @Override String getObjectName(); @Override String getObjectCopy(); @Override ObjectId getObjectId(); @Override ObjectRevision getObjectRevision(); @Override LoggingObjectType getObjectType(); @Override LoggingObjectInterface getParent(); @Override RepositoryDirectory getRepositoryDirectory(); @Override LogLevel getLogLevel(); void setLogLevel( LogLevel logLevel ); @Override String getContainerObjectId(); void setContainerObjectId( String containerObjectId ); @Override Date getRegistrationDate(); int getNrExecutedCommits(); void setNrExecutedCommits( int nrExecutedCommits ); Result execStatementsFromFile( String filename, boolean sendSinglestatement ); @Override boolean isGatheringMetrics(); @Override void setGatheringMetrics( boolean gatheringMetrics ); @Override boolean isForcingSeparateLogging(); @Override void setForcingSeparateLogging( boolean forcingSeparateLogging ); }
Database implements VariableSpace, LoggingObjectInterface { public static KettleDatabaseBatchException createKettleDatabaseBatchException( String message, SQLException ex ) { KettleDatabaseBatchException kdbe = new KettleDatabaseBatchException( message, ex ); if ( ex instanceof BatchUpdateException ) { kdbe.setUpdateCounts( ( (BatchUpdateException) ex ).getUpdateCounts() ); } else { kdbe.setUpdateCounts( null ); } List<Exception> exceptions = new ArrayList<Exception>(); SQLException nextException = ex.getNextException(); SQLException oldException = null; while ( ( nextException != null ) && ( oldException != nextException ) ) { exceptions.add( nextException ); oldException = nextException; nextException = nextException.getNextException(); } kdbe.setExceptionsList( exceptions ); return kdbe; } @Deprecated  Database( DatabaseMeta databaseMeta );  Database( LoggingObjectInterface parentObject, DatabaseMeta databaseMeta ); @Override boolean equals( Object obj ); void setConnection( Connection connection ); Connection getConnection(); void setQueryLimit( int rows ); PreparedStatement getPrepStatementInsert(); PreparedStatement getPrepStatementLookup(); PreparedStatement getPrepStatementUpdate(); void connect(); void connect( String partitionId ); synchronized void connect( String group, String partitionId ); void normalConnect( String partitionId ); synchronized void disconnect(); synchronized void closeConnectionOnly(); void cancelQuery(); void cancelStatement( Statement statement ); void setCommit( int commsize ); void setAutoCommit( boolean useAutoCommit ); void commit(); void commit( boolean force ); void commitLog( LogTableCoreInterface logTable ); void commitLog( boolean force, LogTableCoreInterface logTable ); void rollback(); void rollback( boolean force ); void prepareInsert( RowMetaInterface rowMeta, String tableName ); void prepareInsert( RowMetaInterface rowMeta, String schemaName, String tableName ); PreparedStatement prepareSQL( String sql ); PreparedStatement prepareSQL( String sql, boolean returnKeys ); void closeLookup(); void closePreparedStatement( PreparedStatement ps ); void closeInsert(); void closeUpdate(); void setValues( RowMetaInterface rowMeta, Object[] data ); void setValues( RowMetaAndData row ); void setValuesInsert( RowMetaInterface rowMeta, Object[] data ); void setValuesInsert( RowMetaAndData row ); void setValuesUpdate( RowMetaInterface rowMeta, Object[] data ); void setValuesLookup( RowMetaInterface rowMeta, Object[] data ); void setProcValues( RowMetaInterface rowMeta, Object[] data, int[] argnrs, String[] argdir, boolean result ); void setValue( PreparedStatement ps, ValueMetaInterface v, Object object, int pos ); void setValues( RowMetaAndData row, PreparedStatement ps ); void setValues( RowMetaInterface rowMeta, Object[] data, PreparedStatement ps ); void setValues( RowMetaInterface rowMeta, Object[] data, PreparedStatement ps, int ignoreThisValueIndex ); RowMetaAndData getGeneratedKeys( PreparedStatement ps ); Long getNextSequenceValue( String sequenceName, String keyfield ); Long getNextSequenceValue( String schemaName, String sequenceName, String keyfield ); void insertRow( String tableName, RowMetaInterface fields, Object[] data ); void insertRow( String schemaName, String tableName, RowMetaInterface fields, Object[] data ); String getInsertStatement( String tableName, RowMetaInterface fields ); String getInsertStatement( String schemaName, String tableName, RowMetaInterface fields ); void insertRow(); void insertRow( boolean batch ); void updateRow(); void insertRow( PreparedStatement ps ); boolean insertRow( PreparedStatement ps, boolean batch ); boolean getUseBatchInsert( boolean batch ); boolean insertRow( PreparedStatement ps, boolean batch, boolean handleCommit ); @Deprecated void clearInsertBatch(); void clearBatch( PreparedStatement preparedStatement ); void executeAndClearBatch( PreparedStatement preparedStatement ); void insertFinished( boolean batch ); void emptyAndCommit( PreparedStatement ps, boolean batch ); void emptyAndCommit( PreparedStatement ps, boolean batch, int batchCounter ); static KettleDatabaseBatchException createKettleDatabaseBatchException( String message, SQLException ex ); @Deprecated void insertFinished( PreparedStatement ps, boolean batch ); Result execStatement( String sql ); Result execStatement( String rawsql, RowMetaInterface params, Object[] data ); Result execStatements( String script ); Result execStatements( String script, RowMetaInterface params, Object[] data ); ResultSet openQuery( String sql ); ResultSet openQuery( String sql, RowMetaInterface params, Object[] data ); ResultSet openQuery( String sql, RowMetaInterface params, Object[] data, int fetch_mode ); ResultSet openQuery( String sql, RowMetaInterface params, Object[] data, int fetch_mode,
                              boolean lazyConversion ); ResultSet openQuery( PreparedStatement ps, RowMetaInterface params, Object[] data ); RowMetaInterface getTableFields( String tablename ); RowMetaInterface getQueryFields( String sql, boolean param ); boolean checkTableExists( String tablename ); boolean checkTableExistsByDbMeta( String shema, String tablename ); boolean checkColumnExists( String columnname, String tablename ); boolean checkSequenceExists( String sequenceName ); boolean checkSequenceExists( String schemaName, String sequenceName ); boolean checkIndexExists( String tableName, String[] idx_fields ); boolean checkIndexExists( String schemaName, String tableName, String[] idx_fields ); String getCreateIndexStatement( String tablename, String indexname, String[] idx_fields, boolean tk,
                                         boolean unique, boolean bitmap, boolean semi_colon ); String getCreateIndexStatement( String schemaname, String tablename, String indexname,
                                         String[] idx_fields, boolean tk, boolean unique, boolean bitmap,
                                         boolean semi_colon ); String getCreateSequenceStatement( String sequence, long start_at, long increment_by, long max_value,
                                            boolean semi_colon ); String getCreateSequenceStatement( String sequence, String start_at, String increment_by,
                                            String max_value, boolean semi_colon ); String getCreateSequenceStatement( String schemaName, String sequence, long start_at, long increment_by,
                                            long max_value, boolean semi_colon ); String getCreateSequenceStatement( String schemaName, String sequenceName, String start_at,
                                            String increment_by, String max_value, boolean semi_colon ); RowMetaInterface getQueryFields( String sql, boolean param, RowMetaInterface inform, Object[] data ); RowMetaInterface getQueryFieldsFromPreparedStatement( String sql ); RowMetaInterface getQueryFieldsFromDatabaseMetaData(); RowMetaInterface getQueryFieldsFallback( String sql, boolean param, RowMetaInterface inform,
                                                   Object[] data ); void closeQuery( ResultSet res ); boolean absolute( ResultSet rs, int position ); boolean relative( ResultSet rs, int rows ); void afterLast( ResultSet rs ); void first( ResultSet rs ); Object[] getRow( ResultSet rs ); Object[] getRow( ResultSet rs, boolean lazyConversion ); Object[] getRow( ResultSet rs, ResultSetMetaData dummy, RowMetaInterface rowInfo ); void printSQLException( SQLException ex ); void setLookup( String table, String[] codes, String[] condition, String[] gets, String[] rename,
                         String orderby ); void setLookup( String schema, String table, String[] codes, String[] condition, String[] gets,
                         String[] rename, String orderby ); void setLookup( String tableName, String[] codes, String[] condition, String[] gets, String[] rename,
                         String orderby, boolean checkForMultipleResults ); void setLookup( String schemaName, String tableName, String[] codes, String[] condition, String[] gets,
                         String[] rename, String orderby, boolean checkForMultipleResults ); boolean prepareUpdate( String table, String[] codes, String[] condition, String[] sets ); boolean prepareUpdate( String schemaName, String tableName, String[] codes, String[] condition,
                                String[] sets ); boolean prepareDelete( String table, String[] codes, String[] condition ); boolean prepareDelete( String schemaName, String tableName, String[] codes, String[] condition ); void setProcLookup( String proc, String[] arg, String[] argdir, int[] argtype, String returnvalue,
                             int returntype ); Object[] getLookup(); Object[] getLookup( boolean failOnMultipleResults ); Object[] getLookup( boolean failOnMultipleResults, boolean lazyConversion ); Object[] getLookup( PreparedStatement ps ); Object[] getLookup( PreparedStatement ps, boolean failOnMultipleResults ); Object[] getLookup( PreparedStatement ps, boolean failOnMultipleResults, boolean lazyConversion ); DatabaseMetaData getDatabaseMetaData(); String getDDL( String tablename, RowMetaInterface fields ); String getDDL( String tablename, RowMetaInterface fields, String tk, boolean use_autoinc, String pk ); String getDDL( String tableName, RowMetaInterface fields, String tk, boolean use_autoinc, String pk,
                        boolean semicolon ); String getCreateTableStatement( String tableName, RowMetaInterface fields, String tk,
                                         boolean use_autoinc, String pk, boolean semicolon ); String getAlterTableStatement( String tableName, RowMetaInterface fields, String tk, boolean use_autoinc,
                                        String pk, boolean semicolon ); void truncateTable( String tablename ); void truncateTable( String schema, String tablename ); RowMetaAndData getOneRow( String sql ); RowMeta getMetaFromRow( Object[] row, ResultSetMetaData md ); RowMetaAndData getOneRow( String sql, RowMetaInterface param, Object[] data ); RowMetaInterface getParameterMetaData( PreparedStatement ps ); int countParameters( String sql ); RowMetaInterface getParameterMetaData( String sql, RowMetaInterface inform, Object[] data ); void writeLogRecord( LogTableCoreInterface logTable, LogStatus status, Object subject, Object parent ); void cleanupLogRecords( LogTableCoreInterface logTable ); Object[] getLastLogDate( String logtable, String name, boolean job, LogStatus status ); synchronized Long getNextValue( Hashtable<String, Counter> counters, String tableName, String val_key ); synchronized Long getNextValue( Hashtable<String, Counter> counters, String schemaName, String tableName,
                                         String val_key ); @Override String toString(); boolean isSystemTable( String table_name ); List<Object[]> getRows( String sql, int limit ); List<Object[]> getRows( String sql, int limit, ProgressMonitorListener monitor ); List<Object[]> getRows( String sql, RowMetaInterface params, Object[] data, int fetch_mode,
                                 boolean lazyConversion, int limit, ProgressMonitorListener monitor ); List<Object[]> getRows( ResultSet rset, int limit, ProgressMonitorListener monitor ); List<Object[]> getFirstRows( String table_name, int limit ); List<Object[]> getFirstRows( String table_name, int limit, ProgressMonitorListener monitor ); RowMetaInterface getReturnRowMeta(); String[] getTableTypes(); String[] getTablenames(); String[] getTablenames( boolean includeSchema ); String[] getTablenames( String schemanamein, boolean includeSchema ); String[] getTablenames( String schemanamein, boolean includeSchema, Map<String, String> props ); Map<String, Collection<String>> getTableMap(); Map<String, Collection<String>> getTableMap( String schemanamein ); Map<String, Collection<String>> getTableMap( String schemanamein, Map<String, String> props ); String[] getViews(); String[] getViews( boolean includeSchema ); String[] getViews( String schemanamein, boolean includeSchema ); Map<String, Collection<String>> getViewMap(); Map<String, Collection<String>> getViewMap( String schemanamein ); String[] getSynonyms(); String[] getSynonyms( boolean includeSchema ); String[] getSynonyms( String schemanamein, boolean includeSchema ); Map<String, Collection<String>> getSynonymMap(); Map<String, Collection<String>> getSynonymMap( String schemanamein ); String[] getSchemas(); String[] getCatalogs(); String[] getProcedures(); boolean isAutoCommit(); DatabaseMeta getDatabaseMeta(); void lockTables( String[] tableNames ); void unlockTables( String[] tableNames ); int getOpened(); synchronized void setOpened( int opened ); String getConnectionGroup(); void setConnectionGroup( String connectionGroup ); String getPartitionId(); void setPartitionId( String partitionId ); int getCopy(); synchronized void setCopy( int copy ); @Override void copyVariablesFrom( VariableSpace space ); @Override String environmentSubstitute( String aString ); @Override String[] environmentSubstitute( String[] aString ); @Override String fieldSubstitute( String aString, RowMetaInterface rowMeta, Object[] rowData ); @Override VariableSpace getParentVariableSpace(); @Override void setParentVariableSpace( VariableSpace parent ); @Override String getVariable( String variableName, String defaultValue ); @Override String getVariable( String variableName ); @Override boolean getBooleanValueOfVariable( String variableName, boolean defaultValue ); @Override void initializeVariablesFrom( VariableSpace parent ); @Override String[] listVariables(); @Override void setVariable( String variableName, String variableValue ); @Override void shareVariablesWith( VariableSpace space ); @Override void injectVariables( Map<String, String> prop ); RowMetaAndData callProcedure( String[] arg, String[] argdir, int[] argtype, String resultname,
                                       int resulttype ); void closeProcedureStatement(); String getDDLCreationTable( String tableName, RowMetaInterface fields ); String getDDLTruncateTable( String schema, String tablename ); String getSQLOutput( String schemaName, String tableName, RowMetaInterface fields, Object[] r,
                              String dateFormat ); Savepoint setSavepoint(); Savepoint setSavepoint( String savePointName ); void releaseSavepoint( Savepoint savepoint ); void rollback( Savepoint savepoint ); Object getParentObject(); String[] getPrimaryKeyColumnNames( String tablename ); String[] getSequences(); @Override String getFilename(); @Override String getLogChannelId(); @Override String getObjectName(); @Override String getObjectCopy(); @Override ObjectId getObjectId(); @Override ObjectRevision getObjectRevision(); @Override LoggingObjectType getObjectType(); @Override LoggingObjectInterface getParent(); @Override RepositoryDirectory getRepositoryDirectory(); @Override LogLevel getLogLevel(); void setLogLevel( LogLevel logLevel ); @Override String getContainerObjectId(); void setContainerObjectId( String containerObjectId ); @Override Date getRegistrationDate(); int getNrExecutedCommits(); void setNrExecutedCommits( int nrExecutedCommits ); Result execStatementsFromFile( String filename, boolean sendSinglestatement ); @Override boolean isGatheringMetrics(); @Override void setGatheringMetrics( boolean gatheringMetrics ); @Override boolean isForcingSeparateLogging(); @Override void setForcingSeparateLogging( boolean forcingSeparateLogging );  }