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

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

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

Database.cancelStatement介绍

[英]Cancel an open/running SQL statement
[中]取消打开/运行SQL语句

代码示例

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

  1. /** Stop the running query */
  2. public void stopRunning( StepMetaInterface smi, StepDataInterface sdi ) throws KettleException {
  3. meta = (DatabaseJoinMeta) smi;
  4. data = (DatabaseJoinData) sdi;
  5. if ( data.db != null && !data.isCanceled ) {
  6. synchronized ( data.db ) {
  7. data.db.cancelStatement( data.pstmt );
  8. }
  9. setStopped( true );
  10. data.isCanceled = true;
  11. }
  12. }

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

  1. /**
  2. * Cancel the open/running queries on the database connection
  3. *
  4. * @throws KettleDatabaseException
  5. */
  6. public void cancelQuery() throws KettleDatabaseException {
  7. // Canceling statements only if we're not streaming results on MySQL with
  8. // the v3 driver
  9. //
  10. if ( databaseMeta.isMySQLVariant()
  11. && databaseMeta.isStreamingResults() && getDatabaseMetaData().getDriverMajorVersion() == 3 ) {
  12. return;
  13. }
  14. cancelStatement( pstmt );
  15. cancelStatement( sel_stmt );
  16. }

相关文章