本文整理了Java中org.pentaho.di.core.database.Database.checkSequenceExists()
方法的一些代码示例,展示了Database.checkSequenceExists()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Database.checkSequenceExists()
方法的具体详情如下:
包路径:org.pentaho.di.core.database.Database
类名称:Database
方法名:checkSequenceExists
[英]Check whether the sequence exists, Oracle only!
[中]检查序列是否存在,仅限Oracle!
代码示例来源:origin: pentaho/pentaho-kettle
/**
* Check whether the sequence exists, Oracle only!
*
* @param sequenceName The name of the sequence
* @return true if the sequence exists.
*/
public boolean checkSequenceExists( String sequenceName ) throws KettleDatabaseException {
return checkSequenceExists( null, sequenceName );
}
代码示例来源:origin: pentaho/pentaho-kettle
try {
db.connect();
if ( db.checkSequenceExists( transMeta.environmentSubstitute( schemaName ), transMeta
.environmentSubstitute( sequenceName ) ) ) {
cr =
代码示例来源:origin: pentaho/pentaho-kettle
if ( db.checkSequenceExists( sequenceFrom ) ) {
error_message =
BaseMessages
代码示例来源:origin: pentaho/pentaho-kettle
if ( db.checkSequenceExists( sequenceName ) ) {
error_message =
BaseMessages.getString( PKG, "DimensionLookupMeta.CheckResult.SequenceExists", sequenceName );
代码示例来源:origin: pentaho/pentaho-kettle
@Override
public SQLStatement getSQLStatements( TransMeta transMeta, StepMeta stepMeta, RowMetaInterface prev,
Repository repository, IMetaStore metaStore ) {
SQLStatement retval = new SQLStatement( stepMeta.getName(), database, null ); // default: nothing to do!
if ( useDatabase ) {
// Otherwise, don't bother!
if ( database != null ) {
Database db = new Database( loggingObject, database );
db.shareVariablesWith( transMeta );
try {
db.connect();
if ( !db.checkSequenceExists( schemaName, sequenceName ) ) {
String cr_table = db.getCreateSequenceStatement( sequenceName, startAt, incrementBy, maxValue, true );
retval.setSQL( cr_table );
} else {
retval.setSQL( null ); // Empty string means: nothing to do: set it to null...
}
} catch ( KettleException e ) {
retval.setError( BaseMessages.getString( PKG, "AddSequenceMeta.ErrorMessage.UnableToConnectDB" )
+ Const.CR + e.getMessage() );
} finally {
db.disconnect();
}
} else {
retval.setError( BaseMessages.getString( PKG, "AddSequenceMeta.ErrorMessage.NoConnectionDefined" ) );
}
}
return retval;
}
代码示例来源:origin: pentaho/pentaho-kettle
if ( !db.checkSequenceExists( schemaName, sequenceName ) ) {
sql += db.getCreateSequenceStatement( schemaName, sequenceName, 1L, 1L, -1L, true );
代码示例来源:origin: pentaho/pentaho-kettle
if ( !db.checkSequenceExists( schemaName, sequenceFrom ) ) {
cr_seq += db.getCreateSequenceStatement( schemaName, sequenceFrom, 1L, 1L, -1L, true );
cr_seq += Const.CR;
内容来源于网络,如有侵权,请联系作者删除!