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

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

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

Database.checkSequenceExists介绍

[英]Check whether the sequence exists, Oracle only!
[中]检查序列是否存在,仅限Oracle!

代码示例

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

  1. /**
  2. * Check whether the sequence exists, Oracle only!
  3. *
  4. * @param sequenceName The name of the sequence
  5. * @return true if the sequence exists.
  6. */
  7. public boolean checkSequenceExists( String sequenceName ) throws KettleDatabaseException {
  8. return checkSequenceExists( null, sequenceName );
  9. }

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

  1. try {
  2. db.connect();
  3. if ( db.checkSequenceExists( transMeta.environmentSubstitute( schemaName ), transMeta
  4. .environmentSubstitute( sequenceName ) ) ) {
  5. cr =

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

  1. if ( db.checkSequenceExists( sequenceFrom ) ) {
  2. error_message =
  3. BaseMessages

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

  1. if ( db.checkSequenceExists( sequenceName ) ) {
  2. error_message =
  3. BaseMessages.getString( PKG, "DimensionLookupMeta.CheckResult.SequenceExists", sequenceName );

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

  1. @Override
  2. public SQLStatement getSQLStatements( TransMeta transMeta, StepMeta stepMeta, RowMetaInterface prev,
  3. Repository repository, IMetaStore metaStore ) {
  4. SQLStatement retval = new SQLStatement( stepMeta.getName(), database, null ); // default: nothing to do!
  5. if ( useDatabase ) {
  6. // Otherwise, don't bother!
  7. if ( database != null ) {
  8. Database db = new Database( loggingObject, database );
  9. db.shareVariablesWith( transMeta );
  10. try {
  11. db.connect();
  12. if ( !db.checkSequenceExists( schemaName, sequenceName ) ) {
  13. String cr_table = db.getCreateSequenceStatement( sequenceName, startAt, incrementBy, maxValue, true );
  14. retval.setSQL( cr_table );
  15. } else {
  16. retval.setSQL( null ); // Empty string means: nothing to do: set it to null...
  17. }
  18. } catch ( KettleException e ) {
  19. retval.setError( BaseMessages.getString( PKG, "AddSequenceMeta.ErrorMessage.UnableToConnectDB" )
  20. + Const.CR + e.getMessage() );
  21. } finally {
  22. db.disconnect();
  23. }
  24. } else {
  25. retval.setError( BaseMessages.getString( PKG, "AddSequenceMeta.ErrorMessage.NoConnectionDefined" ) );
  26. }
  27. }
  28. return retval;
  29. }

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

  1. if ( !db.checkSequenceExists( schemaName, sequenceName ) ) {
  2. sql += db.getCreateSequenceStatement( schemaName, sequenceName, 1L, 1L, -1L, true );

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

  1. if ( !db.checkSequenceExists( schemaName, sequenceFrom ) ) {
  2. cr_seq += db.getCreateSequenceStatement( schemaName, sequenceFrom, 1L, 1L, -1L, true );
  3. cr_seq += Const.CR;

相关文章