本文整理了Java中org.pentaho.di.core.database.Database.checkTableExists()方法的一些代码示例，展示了Database.checkTableExists()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Database.checkTableExists()方法的具体详情如下：
包路径：org.pentaho.di.core.database.Database
类名称：Database
方法名：checkTableExists

Database.checkTableExists介绍

[英]See if the table specified exists by reading
[中]通过读取查看指定的表是否存在

代码示例

代码示例来源：origin: pentaho/pentaho-kettle

return checkTableExists( databaseMeta.getQuotedSchemaTableCombination( schema, tablename ) );

代码示例来源：origin: pentaho/pentaho-kettle

public String getDDL( String tableName, RowMetaInterface fields, String tk, boolean use_autoinc, String pk,
           boolean semicolon ) throws KettleDatabaseException {
 String retval;
 // First, check for reserved SQL in the input row r...
 databaseMeta.quoteReservedWords( fields );
 String quotedTk = tk != null ? databaseMeta.quoteField( tk ) : null;
 if ( checkTableExists( tableName ) ) {
  retval = getAlterTableStatement( tableName, fields, quotedTk, use_autoinc, pk, semicolon );
 } else {
  retval = getCreateTableStatement( tableName, fields, quotedTk, use_autoinc, pk, semicolon );
 }
 return retval;
}

代码示例来源：origin: pentaho/pentaho-kettle

@Test
public void jobFail_columnNotExist() throws KettleException {
 doReturn( db ).when( jobEntry ).getNewDatabaseFromMeta();
 doNothing().when( db ).connect( anyString(), anyString() );
 doReturn( true ).when( db ).checkTableExists( anyString(), anyString() );
 doReturn( false ).when( db ).checkColumnExists( anyString(), anyString(), anyString() );
 final Result result = jobEntry.execute( new Result(), 0 );
 assertEquals( "Should be some errors", 1, result.getNrErrors() );
 assertFalse( "Result should be false", result.getResult() );
 verify( db, atLeastOnce() ).disconnect();
}

代码示例来源：origin: pentaho/pentaho-kettle

@Test
 public void jobSuccess() throws KettleException {
  doReturn( db ).when( jobEntry ).getNewDatabaseFromMeta();
  doNothing().when( db ).connect( anyString(), anyString() );
  doReturn( true ).when( db ).checkColumnExists( anyString(), anyString(), anyString() );
  doReturn( true ).when( db ).checkTableExists( anyString(), anyString() );
  final Result result = jobEntry.execute( new Result(), 0 );
  assertEquals( "Should be no error", 0, result.getNrErrors() );
  assertTrue( "Result should be true", result.getResult() );
  assertEquals( "Lines written", COLUMNS.length, result.getNrLinesWritten() );
  verify( db, atLeastOnce() ).disconnect();
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

@Test
public void jobFail_tableNotExist() throws KettleException {
 when( jobEntry.getNewDatabaseFromMeta() ).thenReturn( db );
 doNothing().when( db ).connect( anyString(), any() );
 doReturn( false ).when( db ).checkTableExists( anyString(), anyString() );
 final Result result = jobEntry.execute( new Result(), 0 );
 assertEquals( "Should be error", 1, result.getNrErrors() );
 assertFalse( "Result should be false", result.getResult() );
 verify( db, atLeastOnce() ).disconnect();
}

代码示例来源：origin: pentaho/pentaho-kettle

/**
 * Check if an index on certain fields in a table exists.
 *
 * @param tablename  The table on which the index is checked
 * @param idx_fields The fields on which the indexe is checked
 * @return True if the index exists
 */
public boolean checkIndexExists( String schemaName, String tableName, String[] idx_fields )
 throws KettleDatabaseException {
 String tablename = databaseMeta.getQuotedSchemaTableCombination( schemaName, tableName );
 if ( !checkTableExists( tablename ) ) {
  return false;
 }
 if ( log.isDebug() ) {
  log.logDebug( "CheckIndexExists() tablename = " + tablename + " type = " + databaseMeta.getPluginId() );
 }
 return databaseMeta.getDatabaseInterface().checkIndexExists( this, schemaName, tableName, idx_fields );
}

代码示例来源：origin: pentaho/pentaho-kettle

private boolean truncateTables( String tablename, String schemaname, Database db ) {
 boolean retval = false;
 try {
  // check if table exists!
  if ( db.checkTableExists( schemaname, tablename ) ) {
   if ( !Utils.isEmpty( schemaname ) ) {
    db.truncateTable( schemaname, tablename );
   } else {
    db.truncateTable( tablename );
   }
   if ( log.isDetailed() ) {
    logDetailed( BaseMessages.getString( PKG, "JobEntryTruncateTables.Log.TableTruncated", tablename ) );
   }
   retval = true;
  } else {
   logError( BaseMessages.getString( PKG, "JobEntryTruncateTables.Error.CanNotFindTable", tablename ) );
  }
 } catch ( Exception e ) {
  logError( BaseMessages.getString( PKG, "JobEntryTruncateTables.Error.CanNotTruncateTables", tablename, e
   .toString() ) );
 }
 return retval;
}

代码示例来源：origin: pentaho/pentaho-kettle

upgrade = getDatabase().checkTableExists( userTableName );
if ( upgrade ) {

代码示例来源：origin: pentaho/pentaho-kettle

public RowMetaInterface getRequiredFields( VariableSpace space ) throws KettleException {
 String realTableName = space.environmentSubstitute( tablename );
 String realSchemaName = space.environmentSubstitute( schemaName );
 if ( databaseMeta != null ) {
  Database db = new Database( loggingObject, databaseMeta );
  try {
   db.connect();
   if ( !Utils.isEmpty( realTableName ) ) {
    // Check if this table exists...
    if ( db.checkTableExists( realSchemaName, realTableName ) ) {
     return db.getTableFieldsMeta( realSchemaName, realTableName );
    } else {
     throw new KettleException( BaseMessages.getString( PKG, "SQLFileOutputMeta.Exception.TableNotFound" ) );
    }
   } else {
    throw new KettleException( BaseMessages.getString( PKG, "SQLFileOutputMeta.Exception.TableNotSpecified" ) );
   }
  } catch ( Exception e ) {
   throw new KettleException(
    BaseMessages.getString( PKG, "SQLFileOutputMeta.Exception.ErrorGettingFields" ), e );
  } finally {
   db.disconnect();
  }
 } else {
  throw new KettleException( BaseMessages.getString( PKG, "SQLFileOutputMeta.Exception.ConnectionNotDefined" ) );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

public RowMetaInterface getRequiredFields( VariableSpace space ) throws KettleException {
 String realTableName = space.environmentSubstitute( tableName );
 String realSchemaName = space.environmentSubstitute( schemaName );
 if ( databaseMeta != null ) {
  Database db = new Database( loggingObject, databaseMeta );
  try {
   db.connect();
   if ( !Utils.isEmpty( realTableName ) ) {
    // Check if this table exists...
    if ( db.checkTableExists( realSchemaName, realTableName ) ) {
     return db.getTableFieldsMeta( realSchemaName, realTableName );
    } else {
     throw new KettleException( BaseMessages.getString( PKG, "TableOutputMeta.Exception.TableNotFound" ) );
    }
   } else {
    throw new KettleException( BaseMessages.getString( PKG, "TableOutputMeta.Exception.TableNotSpecified" ) );
   }
  } catch ( Exception e ) {
   throw new KettleException(
    BaseMessages.getString( PKG, "TableOutputMeta.Exception.ErrorGettingFields" ), e );
  } finally {
   db.disconnect();
  }
 } else {
  throw new KettleException( BaseMessages.getString( PKG, "TableOutputMeta.Exception.ConnectionNotDefined" ) );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

public RowMetaInterface getRequiredFields( VariableSpace space ) throws KettleException {
 String realSchemaName = space.environmentSubstitute( schemaName );
 String realTableName = space.environmentSubstitute( tableName );
 if ( databaseMeta != null ) {
  Database db = new Database( loggingObject, databaseMeta );
  try {
   db.connect();
   if ( !Utils.isEmpty( realTableName ) ) {
    // Check if this table exists...
    if ( db.checkTableExists( realSchemaName, realTableName ) ) {
     return db.getTableFieldsMeta( realSchemaName, realTableName );
    } else {
     throw new KettleException( BaseMessages.getString( PKG, "InsertUpdateMeta.Exception.TableNotFound" ) );
    }
   } else {
    throw new KettleException( BaseMessages.getString( PKG, "InsertUpdateMeta.Exception.TableNotSpecified" ) );
   }
  } catch ( Exception e ) {
   throw new KettleException(
    BaseMessages.getString( PKG, "InsertUpdateMeta.Exception.ErrorGettingFields" ), e );
  } finally {
   db.disconnect();
  }
 } else {
  throw new KettleException( BaseMessages.getString( PKG, "InsertUpdateMeta.Exception.ConnectionNotDefined" ) );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

public RowMetaInterface getRequiredFields( VariableSpace space ) throws KettleException {
 String realTableName = space.environmentSubstitute( tableName );
 String realSchemaName = space.environmentSubstitute( schemaName );
 if ( databaseMeta != null ) {
  Database db = new Database( loggingObject, databaseMeta );
  try {
   db.connect();
   if ( !Utils.isEmpty( realTableName ) ) {
    String schemaTable = databaseMeta.getQuotedSchemaTableCombination( realSchemaName, realTableName );
    // Check if this table exists...
    if ( db.checkTableExists( schemaTable ) ) {
     return db.getTableFields( schemaTable );
    } else {
     throw new KettleException( BaseMessages.getString( PKG, "OraBulkLoaderMeta.Exception.TableNotFound" ) );
    }
   } else {
    throw new KettleException( BaseMessages.getString( PKG, "OraBulkLoaderMeta.Exception.TableNotSpecified" ) );
   }
  } catch ( Exception e ) {
   throw new KettleException(
    BaseMessages.getString( PKG, "OraBulkLoaderMeta.Exception.ErrorGettingFields" ), e );
  } finally {
   db.disconnect();
  }
 } else {
  throw new KettleException( BaseMessages.getString( PKG, "OraBulkLoaderMeta.Exception.ConnectionNotDefined" ) );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

public RowMetaInterface getRequiredFields( VariableSpace space ) throws KettleException {
 String realTableName = space.environmentSubstitute( tableName );
 String realSchemaName = space.environmentSubstitute( schemaName );
 if ( databaseMeta != null ) {
  Database db = new Database( loggingObject, databaseMeta );
  try {
   db.connect();
   if ( !Utils.isEmpty( realTableName ) ) {
    String schemaTable = databaseMeta.getQuotedSchemaTableCombination( realSchemaName, realTableName );
    // Check if this table exists...
    if ( db.checkTableExists( schemaTable ) ) {
     return db.getTableFields( schemaTable );
    } else {
     throw new KettleException( BaseMessages.getString( PKG, "GPLoadMeta.Exception.TableNotFound" ) );
    }
   } else {
    throw new KettleException( BaseMessages.getString( PKG, "GPLoadMeta.Exception.TableNotSpecified" ) );
   }
  } catch ( Exception e ) {
   throw new KettleException( BaseMessages.getString( PKG, "GPLoadMeta.Exception.ErrorGettingFields" ), e );
  } finally {
   db.disconnect();
  }
 } else {
  throw new KettleException( BaseMessages.getString( PKG, "GPLoadMeta.Exception.ConnectionNotDefined" ) );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

public RowMetaInterface getRequiredFields( VariableSpace space ) throws KettleException {
 String realTableName = space.environmentSubstitute( tableName );
 String realSchemaName = space.environmentSubstitute( schemaName );
 if ( databaseMeta != null ) {
  Database db = new Database( loggingObject, databaseMeta );
  try {
   db.connect();
   if ( !Utils.isEmpty( realTableName ) ) {
    // Check if this table exists...
    if ( db.checkTableExists( realSchemaName, realTableName ) ) {
     return db.getTableFieldsMeta( realSchemaName, realTableName );
    } else {
     throw new KettleException( BaseMessages.getString(
      PKG, "SynchronizeAfterMergeMeta.Exception.TableNotFound" ) );
    }
   } else {
    throw new KettleException( BaseMessages.getString(
     PKG, "SynchronizeAfterMergeMeta.Exception.TableNotSpecified" ) );
   }
  } catch ( Exception e ) {
   throw new KettleException( BaseMessages.getString(
    PKG, "SynchronizeAfterMergeMeta.Exception.ErrorGettingFields" ), e );
  } finally {
   db.disconnect();
  }
 } else {
  throw new KettleException( BaseMessages.getString(
   PKG, "SynchronizeAfterMergeMeta.Exception.ConnectionNotDefined" ) );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

public RowMetaInterface getRequiredFields( VariableSpace space ) throws KettleException {
 String realTableName = space.environmentSubstitute( tableName );
 String realSchemaName = space.environmentSubstitute( schemaName );
 if ( databaseMeta != null ) {
  Database db = new Database( loggingObject, databaseMeta );
  try {
   db.connect();
   if ( !Utils.isEmpty( realTableName ) ) {
    String schemaTable = databaseMeta.getQuotedSchemaTableCombination( realSchemaName, realTableName );
    // Check if this table exists...
    if ( db.checkTableExists( schemaTable ) ) {
     return db.getTableFields( schemaTable );
    } else {
     throw new KettleException( BaseMessages.getString( PKG, "GPBulkLoaderMeta.Exception.TableNotFound" ) );
    }
   } else {
    throw new KettleException( BaseMessages.getString( PKG, "GPBulkLoaderMeta.Exception.TableNotSpecified" ) );
   }
  } catch ( Exception e ) {
   throw new KettleException(
    BaseMessages.getString( PKG, "GPBulkLoaderMeta.Exception.ErrorGettingFields" ), e );
  } finally {
   db.disconnect();
  }
 } else {
  throw new KettleException( BaseMessages.getString( PKG, "GPBulkLoaderMeta.Exception.ConnectionNotDefined" ) );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

@Override
public RowMetaInterface getRequiredFields( VariableSpace space ) throws KettleException {
 String realTableName = space.environmentSubstitute( tableName );
 String realSchemaName = space.environmentSubstitute( schemaName );
 if ( databaseMeta != null ) {
  Database db = new Database( loggingObject, databaseMeta );
  try {
   db.connect();
   if ( !Utils.isEmpty( realTableName ) ) {
    String schemaTable = databaseMeta.getQuotedSchemaTableCombination( realSchemaName, realTableName );
    // Check if this table exists...
    if ( db.checkTableExists( schemaTable ) ) {
     return db.getTableFields( schemaTable );
    } else {
     throw new KettleException( BaseMessages.getString( PKG, "GPBulkLoaderMeta.Exception.TableNotFound" ) );
    }
   } else {
    throw new KettleException( BaseMessages.getString( PKG, "GPBulkLoaderMeta.Exception.TableNotSpecified" ) );
   }
  } catch ( Exception e ) {
   throw new KettleException(
    BaseMessages.getString( PKG, "GPBulkLoaderMeta.Exception.ErrorGettingFields" ), e );
  } finally {
   db.disconnect();
  }
 } else {
  throw new KettleException( BaseMessages.getString( PKG, "GPBulkLoaderMeta.Exception.ConnectionNotDefined" ) );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

public RowMetaInterface getRequiredFields( VariableSpace space ) throws KettleException {
 String realTableName = space.environmentSubstitute( tableName );
 String realSchemaName = space.environmentSubstitute( schemaName );
 if ( databaseMeta != null ) {
  Database db = new Database( loggingObject, databaseMeta );
  try {
   db.connect();
   if ( !Utils.isEmpty( realTableName ) ) {
    String schemaTable = databaseMeta.getQuotedSchemaTableCombination( realSchemaName, realTableName );
    // Check if this table exists...
    if ( db.checkTableExists( schemaTable ) ) {
     return db.getTableFields( schemaTable );
    } else {
     throw new KettleException( BaseMessages.getString( PKG, "MySQLBulkLoaderMeta.Exception.TableNotFound" ) );
    }
   } else {
    throw new KettleException( BaseMessages.getString( PKG, "MySQLBulkLoaderMeta.Exception.TableNotSpecified" ) );
   }
  } catch ( Exception e ) {
   throw new KettleException( BaseMessages.getString( PKG, "MySQLBulkLoaderMeta.Exception.ErrorGettingFields" ), e );
  } finally {
   db.disconnect();
  }
 } else {
  throw new KettleException( BaseMessages.getString( PKG, "MySQLBulkLoaderMeta.Exception.ConnectionNotDefined" ) );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

if ( db.checkTableExists( schemaTable ) ) {
 return db.getTableFields( schemaTable );
} else {

代码示例来源：origin: pentaho/pentaho-kettle

if ( db.checkTableExists( schemaTable ) ) {
 return db.getTableFields( schemaTable );
} else {

代码示例来源：origin: pentaho/pentaho-kettle

String realSchemaname = environmentSubstitute( schemaname );
if ( db.checkTableExists( realSchemaname, realTablename ) ) {
 if ( log.isDetailed() ) {
  logDetailed( BaseMessages.getString( PKG, "TableExists.Log.TableExists", realTablename ) );