org.pentaho.di.core.database.Database.checkTableExists()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(14.1k)|赞(0)|评价(0)|浏览(201)

本文整理了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

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

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

  1. public String getDDL( String tableName, RowMetaInterface fields, String tk, boolean use_autoinc, String pk,
  2.            boolean semicolon ) throws KettleDatabaseException {
  3.  String retval;
  4.  // First, check for reserved SQL in the input row r...
  5.  databaseMeta.quoteReservedWords( fields );
  6.  String quotedTk = tk != null ? databaseMeta.quoteField( tk ) : null;
  7.  if ( checkTableExists( tableName ) ) {
  8.   retval = getAlterTableStatement( tableName, fields, quotedTk, use_autoinc, pk, semicolon );
  9.  } else {
  10.   retval = getCreateTableStatement( tableName, fields, quotedTk, use_autoinc, pk, semicolon );
  11.  }
  12.  return retval;
  13. }

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

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

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

  1. @Test
  2.  public void jobSuccess() throws KettleException {
  3.   doReturn( db ).when( jobEntry ).getNewDatabaseFromMeta();
  4.   doNothing().when( db ).connect( anyString(), anyString() );
  5.   doReturn( true ).when( db ).checkColumnExists( anyString(), anyString(), anyString() );
  6.   doReturn( true ).when( db ).checkTableExists( anyString(), anyString() );
  7.   final Result result = jobEntry.execute( new Result(), 0 );
  8.   assertEquals( "Should be no error", 0, result.getNrErrors() );
  9.   assertTrue( "Result should be true", result.getResult() );
  10.   assertEquals( "Lines written", COLUMNS.length, result.getNrLinesWritten() );
  11.   verify( db, atLeastOnce() ).disconnect();
  12.  }
  13. }

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

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

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

  1. /**
  2.  * Check if an index on certain fields in a table exists.
  3.  *
  4.  * @param tablename  The table on which the index is checked
  5.  * @param idx_fields The fields on which the indexe is checked
  6.  * @return True if the index exists
  7.  */
  8. public boolean checkIndexExists( String schemaName, String tableName, String[] idx_fields )
  9.  throws KettleDatabaseException {
  10.  String tablename = databaseMeta.getQuotedSchemaTableCombination( schemaName, tableName );
  11.  if ( !checkTableExists( tablename ) ) {
  12.   return false;
  13.  }
  14.  if ( log.isDebug() ) {
  15.   log.logDebug( "CheckIndexExists() tablename = " + tablename + " type = " + databaseMeta.getPluginId() );
  16.  }
  17.  return databaseMeta.getDatabaseInterface().checkIndexExists( this, schemaName, tableName, idx_fields );
  18. }

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

  1. private boolean truncateTables( String tablename, String schemaname, Database db ) {
  2.  boolean retval = false;
  3.  try {
  4.   // check if table exists!
  5.   if ( db.checkTableExists( schemaname, tablename ) ) {
  6.    if ( !Utils.isEmpty( schemaname ) ) {
  7.     db.truncateTable( schemaname, tablename );
  8.    } else {
  9.     db.truncateTable( tablename );
  10.    }
  11.    if ( log.isDetailed() ) {
  12.     logDetailed( BaseMessages.getString( PKG, "JobEntryTruncateTables.Log.TableTruncated", tablename ) );
  13.    }
  14.    retval = true;
  15.   } else {
  16.    logError( BaseMessages.getString( PKG, "JobEntryTruncateTables.Error.CanNotFindTable", tablename ) );
  17.   }
  18.  } catch ( Exception e ) {
  19.   logError( BaseMessages.getString( PKG, "JobEntryTruncateTables.Error.CanNotTruncateTables", tablename, e
  20.    .toString() ) );
  21.  }
  22.  return retval;
  23. }

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

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

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

  1. public RowMetaInterface getRequiredFields( VariableSpace space ) throws KettleException {
  2.  String realTableName = space.environmentSubstitute( tablename );
  3.  String realSchemaName = space.environmentSubstitute( schemaName );
  4.  if ( databaseMeta != null ) {
  5.   Database db = new Database( loggingObject, databaseMeta );
  6.   try {
  7.    db.connect();
  8.    if ( !Utils.isEmpty( realTableName ) ) {
  9.     // Check if this table exists...
  10.     if ( db.checkTableExists( realSchemaName, realTableName ) ) {
  11.      return db.getTableFieldsMeta( realSchemaName, realTableName );
  12.     } else {
  13.      throw new KettleException( BaseMessages.getString( PKG, "SQLFileOutputMeta.Exception.TableNotFound" ) );
  14.     }
  15.    } else {
  16.     throw new KettleException( BaseMessages.getString( PKG, "SQLFileOutputMeta.Exception.TableNotSpecified" ) );
  17.    }
  18.   } catch ( Exception e ) {
  19.    throw new KettleException(
  20.     BaseMessages.getString( PKG, "SQLFileOutputMeta.Exception.ErrorGettingFields" ), e );
  21.   } finally {
  22.    db.disconnect();
  23.   }
  24.  } else {
  25.   throw new KettleException( BaseMessages.getString( PKG, "SQLFileOutputMeta.Exception.ConnectionNotDefined" ) );
  26.  }
  27. }

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

  1. public RowMetaInterface getRequiredFields( VariableSpace space ) throws KettleException {
  2.  String realTableName = space.environmentSubstitute( tableName );
  3.  String realSchemaName = space.environmentSubstitute( schemaName );
  4.  if ( databaseMeta != null ) {
  5.   Database db = new Database( loggingObject, databaseMeta );
  6.   try {
  7.    db.connect();
  8.    if ( !Utils.isEmpty( realTableName ) ) {
  9.     // Check if this table exists...
  10.     if ( db.checkTableExists( realSchemaName, realTableName ) ) {
  11.      return db.getTableFieldsMeta( realSchemaName, realTableName );
  12.     } else {
  13.      throw new KettleException( BaseMessages.getString( PKG, "TableOutputMeta.Exception.TableNotFound" ) );
  14.     }
  15.    } else {
  16.     throw new KettleException( BaseMessages.getString( PKG, "TableOutputMeta.Exception.TableNotSpecified" ) );
  17.    }
  18.   } catch ( Exception e ) {
  19.    throw new KettleException(
  20.     BaseMessages.getString( PKG, "TableOutputMeta.Exception.ErrorGettingFields" ), e );
  21.   } finally {
  22.    db.disconnect();
  23.   }
  24.  } else {
  25.   throw new KettleException( BaseMessages.getString( PKG, "TableOutputMeta.Exception.ConnectionNotDefined" ) );
  26.  }
  27. }

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

  1. public RowMetaInterface getRequiredFields( VariableSpace space ) throws KettleException {
  2.  String realSchemaName = space.environmentSubstitute( schemaName );
  3.  String realTableName = space.environmentSubstitute( tableName );
  4.  if ( databaseMeta != null ) {
  5.   Database db = new Database( loggingObject, databaseMeta );
  6.   try {
  7.    db.connect();
  8.    if ( !Utils.isEmpty( realTableName ) ) {
  9.     // Check if this table exists...
  10.     if ( db.checkTableExists( realSchemaName, realTableName ) ) {
  11.      return db.getTableFieldsMeta( realSchemaName, realTableName );
  12.     } else {
  13.      throw new KettleException( BaseMessages.getString( PKG, "InsertUpdateMeta.Exception.TableNotFound" ) );
  14.     }
  15.    } else {
  16.     throw new KettleException( BaseMessages.getString( PKG, "InsertUpdateMeta.Exception.TableNotSpecified" ) );
  17.    }
  18.   } catch ( Exception e ) {
  19.    throw new KettleException(
  20.     BaseMessages.getString( PKG, "InsertUpdateMeta.Exception.ErrorGettingFields" ), e );
  21.   } finally {
  22.    db.disconnect();
  23.   }
  24.  } else {
  25.   throw new KettleException( BaseMessages.getString( PKG, "InsertUpdateMeta.Exception.ConnectionNotDefined" ) );
  26.  }
  27. }

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

  1. public RowMetaInterface getRequiredFields( VariableSpace space ) throws KettleException {
  2.  String realTableName = space.environmentSubstitute( tableName );
  3.  String realSchemaName = space.environmentSubstitute( schemaName );
  4.  if ( databaseMeta != null ) {
  5.   Database db = new Database( loggingObject, databaseMeta );
  6.   try {
  7.    db.connect();
  8.    if ( !Utils.isEmpty( realTableName ) ) {
  9.     String schemaTable = databaseMeta.getQuotedSchemaTableCombination( realSchemaName, realTableName );
  10.     // Check if this table exists...
  11.     if ( db.checkTableExists( schemaTable ) ) {
  12.      return db.getTableFields( schemaTable );
  13.     } else {
  14.      throw new KettleException( BaseMessages.getString( PKG, "OraBulkLoaderMeta.Exception.TableNotFound" ) );
  15.     }
  16.    } else {
  17.     throw new KettleException( BaseMessages.getString( PKG, "OraBulkLoaderMeta.Exception.TableNotSpecified" ) );
  18.    }
  19.   } catch ( Exception e ) {
  20.    throw new KettleException(
  21.     BaseMessages.getString( PKG, "OraBulkLoaderMeta.Exception.ErrorGettingFields" ), e );
  22.   } finally {
  23.    db.disconnect();
  24.   }
  25.  } else {
  26.   throw new KettleException( BaseMessages.getString( PKG, "OraBulkLoaderMeta.Exception.ConnectionNotDefined" ) );
  27.  }
  28. }

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

  1. public RowMetaInterface getRequiredFields( VariableSpace space ) throws KettleException {
  2.  String realTableName = space.environmentSubstitute( tableName );
  3.  String realSchemaName = space.environmentSubstitute( schemaName );
  4.  if ( databaseMeta != null ) {
  5.   Database db = new Database( loggingObject, databaseMeta );
  6.   try {
  7.    db.connect();
  8.    if ( !Utils.isEmpty( realTableName ) ) {
  9.     String schemaTable = databaseMeta.getQuotedSchemaTableCombination( realSchemaName, realTableName );
  10.     // Check if this table exists...
  11.     if ( db.checkTableExists( schemaTable ) ) {
  12.      return db.getTableFields( schemaTable );
  13.     } else {
  14.      throw new KettleException( BaseMessages.getString( PKG, "GPLoadMeta.Exception.TableNotFound" ) );
  15.     }
  16.    } else {
  17.     throw new KettleException( BaseMessages.getString( PKG, "GPLoadMeta.Exception.TableNotSpecified" ) );
  18.    }
  19.   } catch ( Exception e ) {
  20.    throw new KettleException( BaseMessages.getString( PKG, "GPLoadMeta.Exception.ErrorGettingFields" ), e );
  21.   } finally {
  22.    db.disconnect();
  23.   }
  24.  } else {
  25.   throw new KettleException( BaseMessages.getString( PKG, "GPLoadMeta.Exception.ConnectionNotDefined" ) );
  26.  }
  27. }

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

  1. public RowMetaInterface getRequiredFields( VariableSpace space ) throws KettleException {
  2.  String realTableName = space.environmentSubstitute( tableName );
  3.  String realSchemaName = space.environmentSubstitute( schemaName );
  4.  if ( databaseMeta != null ) {
  5.   Database db = new Database( loggingObject, databaseMeta );
  6.   try {
  7.    db.connect();
  8.    if ( !Utils.isEmpty( realTableName ) ) {
  9.     // Check if this table exists...
  10.     if ( db.checkTableExists( realSchemaName, realTableName ) ) {
  11.      return db.getTableFieldsMeta( realSchemaName, realTableName );
  12.     } else {
  13.      throw new KettleException( BaseMessages.getString(
  14.       PKG, "SynchronizeAfterMergeMeta.Exception.TableNotFound" ) );
  15.     }
  16.    } else {
  17.     throw new KettleException( BaseMessages.getString(
  18.      PKG, "SynchronizeAfterMergeMeta.Exception.TableNotSpecified" ) );
  19.    }
  20.   } catch ( Exception e ) {
  21.    throw new KettleException( BaseMessages.getString(
  22.     PKG, "SynchronizeAfterMergeMeta.Exception.ErrorGettingFields" ), e );
  23.   } finally {
  24.    db.disconnect();
  25.   }
  26.  } else {
  27.   throw new KettleException( BaseMessages.getString(
  28.    PKG, "SynchronizeAfterMergeMeta.Exception.ConnectionNotDefined" ) );
  29.  }
  30. }

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

  1. public RowMetaInterface getRequiredFields( VariableSpace space ) throws KettleException {
  2.  String realTableName = space.environmentSubstitute( tableName );
  3.  String realSchemaName = space.environmentSubstitute( schemaName );
  4.  if ( databaseMeta != null ) {
  5.   Database db = new Database( loggingObject, databaseMeta );
  6.   try {
  7.    db.connect();
  8.    if ( !Utils.isEmpty( realTableName ) ) {
  9.     String schemaTable = databaseMeta.getQuotedSchemaTableCombination( realSchemaName, realTableName );
  10.     // Check if this table exists...
  11.     if ( db.checkTableExists( schemaTable ) ) {
  12.      return db.getTableFields( schemaTable );
  13.     } else {
  14.      throw new KettleException( BaseMessages.getString( PKG, "GPBulkLoaderMeta.Exception.TableNotFound" ) );
  15.     }
  16.    } else {
  17.     throw new KettleException( BaseMessages.getString( PKG, "GPBulkLoaderMeta.Exception.TableNotSpecified" ) );
  18.    }
  19.   } catch ( Exception e ) {
  20.    throw new KettleException(
  21.     BaseMessages.getString( PKG, "GPBulkLoaderMeta.Exception.ErrorGettingFields" ), e );
  22.   } finally {
  23.    db.disconnect();
  24.   }
  25.  } else {
  26.   throw new KettleException( BaseMessages.getString( PKG, "GPBulkLoaderMeta.Exception.ConnectionNotDefined" ) );
  27.  }
  28. }

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

  1. @Override
  2. public RowMetaInterface getRequiredFields( VariableSpace space ) throws KettleException {
  3.  String realTableName = space.environmentSubstitute( tableName );
  4.  String realSchemaName = space.environmentSubstitute( schemaName );
  5.  if ( databaseMeta != null ) {
  6.   Database db = new Database( loggingObject, databaseMeta );
  7.   try {
  8.    db.connect();
  9.    if ( !Utils.isEmpty( realTableName ) ) {
  10.     String schemaTable = databaseMeta.getQuotedSchemaTableCombination( realSchemaName, realTableName );
  11.     // Check if this table exists...
  12.     if ( db.checkTableExists( schemaTable ) ) {
  13.      return db.getTableFields( schemaTable );
  14.     } else {
  15.      throw new KettleException( BaseMessages.getString( PKG, "GPBulkLoaderMeta.Exception.TableNotFound" ) );
  16.     }
  17.    } else {
  18.     throw new KettleException( BaseMessages.getString( PKG, "GPBulkLoaderMeta.Exception.TableNotSpecified" ) );
  19.    }
  20.   } catch ( Exception e ) {
  21.    throw new KettleException(
  22.     BaseMessages.getString( PKG, "GPBulkLoaderMeta.Exception.ErrorGettingFields" ), e );
  23.   } finally {
  24.    db.disconnect();
  25.   }
  26.  } else {
  27.   throw new KettleException( BaseMessages.getString( PKG, "GPBulkLoaderMeta.Exception.ConnectionNotDefined" ) );
  28.  }
  29. }

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

  1. public RowMetaInterface getRequiredFields( VariableSpace space ) throws KettleException {
  2.  String realTableName = space.environmentSubstitute( tableName );
  3.  String realSchemaName = space.environmentSubstitute( schemaName );
  4.  if ( databaseMeta != null ) {
  5.   Database db = new Database( loggingObject, databaseMeta );
  6.   try {
  7.    db.connect();
  8.    if ( !Utils.isEmpty( realTableName ) ) {
  9.     String schemaTable = databaseMeta.getQuotedSchemaTableCombination( realSchemaName, realTableName );
  10.     // Check if this table exists...
  11.     if ( db.checkTableExists( schemaTable ) ) {
  12.      return db.getTableFields( schemaTable );
  13.     } else {
  14.      throw new KettleException( BaseMessages.getString( PKG, "MySQLBulkLoaderMeta.Exception.TableNotFound" ) );
  15.     }
  16.    } else {
  17.     throw new KettleException( BaseMessages.getString( PKG, "MySQLBulkLoaderMeta.Exception.TableNotSpecified" ) );
  18.    }
  19.   } catch ( Exception e ) {
  20.    throw new KettleException( BaseMessages.getString( PKG, "MySQLBulkLoaderMeta.Exception.ErrorGettingFields" ), e );
  21.   } finally {
  22.    db.disconnect();
  23.   }
  24.  } else {
  25.   throw new KettleException( BaseMessages.getString( PKG, "MySQLBulkLoaderMeta.Exception.ConnectionNotDefined" ) );
  26.  }
  27. }

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

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

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

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

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

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

内容来源于网络，如有侵权，请联系作者删除！

Database

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Database类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com