本文整理了Java中org.pentaho.di.core.database.Database.execStatements()
方法的一些代码示例,展示了Database.execStatements()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Database.execStatements()
方法的具体详情如下:
包路径:org.pentaho.di.core.database.Database
类名称:Database
方法名:execStatements
[英]Execute a series of SQL statements, separated by ;
We are already connected...
Multiple statements have to be split into parts We use the ";" to separate statements...
We keep the results in Result object from Jobs
[中]执行一系列SQL语句,以分隔;
我们已经联系上了。。。
必须将多个语句拆分为多个部分,我们使用“;”要分离语句。。。
我们将结果保存在作业的结果对象中
代码示例来源:origin: pentaho/pentaho-kettle
/**
* Execute a series of SQL statements, separated by ;
* <p/>
* We are already connected...
* <p/>
* Multiple statements have to be split into parts We use the ";" to separate statements...
* <p/>
* We keep the results in Result object from Jobs
*
* @param script The SQL script to be execute
* @return A result with counts of the number or records updates, inserted, deleted or read.
* @throws KettleDatabaseException In case an error occurs
*/
public Result execStatements( String script ) throws KettleDatabaseException {
return execStatements( script, null, null );
}
代码示例来源:origin: pentaho/pentaho-kettle
data.result = data.db.execStatement( sql );
} else {
data.result = data.db.execStatements( sql );
代码示例来源:origin: pentaho/pentaho-kettle
/**
* Lock a tables in the database for write operations
*
* @param tableNames The tables to lock. These need to be the appropriately quoted fully qualified (schema+table)
* names.
* @throws KettleDatabaseException
*/
public void lockTables( String[] tableNames ) throws KettleDatabaseException {
if ( Utils.isEmpty( tableNames ) ) {
return;
}
// Get the SQL to lock the (quoted) tables
//
String sql = databaseMeta.getSQLLockTables( tableNames );
if ( sql != null ) {
execStatements( sql );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
return execStatement( sql );
} else {
return execStatements( sql );
代码示例来源:origin: pentaho/pentaho-kettle
db.connect();
try {
db.execStatements( stat.getSQL() );
} catch ( KettleDatabaseException dbe ) {
errors++;
代码示例来源:origin: pentaho/pentaho-kettle
db.execStatement( theSQL );
} else {
db.execStatements( theSQL );
代码示例来源:origin: pentaho/pentaho-kettle
execStatements( sql );
if ( log.isDetailed() ) {
log.logDetailed( "Executed connect time SQL statements:" + Const.CR + sql );
代码示例来源:origin: pentaho/pentaho-kettle
data.result = data.db.execStatement( sql, data.paramsMeta, paramsData );
} else {
data.result = data.db.execStatements( sql, data.paramsMeta, paramsData );
代码示例来源:origin: pentaho/pentaho-kettle
database.execStatements( sql );
if ( log.isDetailed() ) {
log.logDetailed( "Created/altered table " + schemaTable );
database.execStatements( sql );
if ( log.isDetailed() ) {
log.logDetailed( "Created/altered table " + schemaTable );
database.execStatements( sql );
if ( log.isDetailed() ) {
log.logDetailed( "Created/altered table " + schemaTable );
database.execStatements( sql );
if ( log.isDetailed() ) {
log.logDetailed( "Created or altered table " + schemaTable );
database.execStatements( sql );
if ( log.isDetailed() ) {
log.logDetailed( "Created or altered table " + schemaTable );
database.execStatements( sql );
if ( log.isDetailed() ) {
log.logDetailed( "Created or altered table " + schemaTable );
database.execStatements( sql );
if ( log.isDetailed() ) {
log.logDetailed( "Created or altered table " + schemaTable );
database.execStatements( sql );
代码示例来源:origin: pentaho/pentaho-kettle
data.result = data.db.execStatement( data.sql );
} else {
data.result = data.db.execStatements( data.sql );
内容来源于网络,如有侵权,请联系作者删除!