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

Database.closeQuery介绍

暂无

代码示例

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

private void closePreviousQuery() throws KettleDatabaseException {
 if ( data.db != null ) {
  data.db.closeQuery( data.rs );
 }
}

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

database.closeQuery( res );

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

closeQuery( rset );
if ( monitor != null ) {
 monitor.done();

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

@Override public Collection<RowMetaAndData> call() throws Exception {
  ResultSet resultSet = null;
  try {
   resultSet = database.openQuery( ps, parameterMeta, parameterData );
   List<Object[]> rows = database.getRows( resultSet, 0, null );
   for ( Object[] row : rows ) {
    RowMetaAndData rowWithMeta = new RowMetaAndData( database.getReturnRowMeta(), row );
    long id =
     rowWithMeta.getInteger(
      quote( KettleDatabaseRepository.FIELD_DATABASE_ATTRIBUTE_ID_DATABASE_ATTRIBUTE ), 0 );
    if ( id > 0 ) {
     attrs.add( rowWithMeta );
    }
   }
   return attrs;
  } catch ( KettleDatabaseException e ) {
   throw e;
  } finally {
   database.closeQuery( resultSet );
  }
 }
} );

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

@Override public List<RepositoryElementMetaInterface> call() throws Exception {
  List<RepositoryElementMetaInterface> repositoryObjects = new ArrayList<RepositoryElementMetaInterface>();
  ResultSet rs = database.openQuery( sql, directoryIdRow.getRowMeta(), directoryIdRow.getData() );
  if ( rs != null ) {
   List<Object[]> rows = database.getRows( rs, -1, null );
   if ( rs != null ) {
    database.closeQuery( rs );
   }
   RowMetaInterface rowMeta = database.getReturnRowMeta();
   for ( Object[] r : rows ) {
    ObjectId id = new LongObjectId( rowMeta.getInteger( r, 4 ) );
    repositoryObjects.add( new RepositoryObject( id, rowMeta.getString( r, 0 ), repositoryDirectory, rowMeta
     .getString( r, 1 ), rowMeta.getDate( r, 2 ), objectType, rowMeta.getString( r, 3 ), false ) );
   }
  }
  return repositoryObjects;
 }
} );

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

retval = true;
closeQuery( res );

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

@Override public RowMetaAndData call() throws Exception {
  ResultSet resultSet = null;
  resultSet = database.openQuery( ps, parameterMeta, parameterData );
  Object[] result = database.getRow( resultSet );
  if ( resultSet != null ) {
   database.closeQuery( resultSet );
  }
  if ( result == null ) {
   return new RowMetaAndData( database.getReturnRowMeta(), RowDataUtil.allocateRowData( database
    .getReturnRowMeta().size() ) );
  }
  return new RowMetaAndData( database.getReturnRowMeta(), result );
 }
} );

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

database.closeQuery( resultSet );

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

database.closeQuery( resultSet );

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

database.closeQuery( res );

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

data.db.closeQuery( rs );

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

data.db.closeQuery( rs );