本文整理了Java中org.pentaho.di.core.database.Database.getCreateSequenceStatement()
方法的一些代码示例,展示了Database.getCreateSequenceStatement()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Database.getCreateSequenceStatement()
方法的具体详情如下:
包路径:org.pentaho.di.core.database.Database
类名称:Database
方法名:getCreateSequenceStatement
暂无
代码示例来源:origin: pentaho/pentaho-kettle
public String getCreateSequenceStatement( String sequence, String start_at, String increment_by,
String max_value, boolean semi_colon ) {
return getCreateSequenceStatement( null, sequence, start_at, increment_by, max_value, semi_colon );
}
代码示例来源:origin: pentaho/pentaho-kettle
public String getCreateSequenceStatement( String schemaName, String sequence, long start_at, long increment_by,
long max_value, boolean semi_colon ) {
return getCreateSequenceStatement( schemaName, sequence, Long.toString( start_at ), Long
.toString( increment_by ), Long.toString( max_value ), semi_colon );
}
代码示例来源:origin: pentaho/pentaho-kettle
public String getCreateSequenceStatement( String sequence, long start_at, long increment_by, long max_value,
boolean semi_colon ) {
return getCreateSequenceStatement(
null, sequence, Long.toString( start_at ), Long.toString( increment_by ), Long.toString( max_value ),
semi_colon );
}
代码示例来源: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
sql += db.getCreateSequenceStatement( schemaName, sequenceName, 1L, 1L, -1L, true );
代码示例来源:origin: pentaho/pentaho-kettle
if ( databaseMeta.supportsSequences() && !Utils.isEmpty( sequenceFrom ) ) {
if ( !db.checkSequenceExists( schemaName, sequenceFrom ) ) {
cr_seq += db.getCreateSequenceStatement( schemaName, sequenceFrom, 1L, 1L, -1L, true );
cr_seq += Const.CR;
内容来源于网络,如有侵权,请联系作者删除!