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

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

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

Database.getRow介绍

[英]Get a row from the resultset. Do not use lazy conversion
[中]从结果集中获取一行。不要使用惰性转换

代码示例

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

  1. /**
  2. * Get a row from the resultset. Do not use lazy conversion
  3. *
  4. * @param rs The resultset to get the row from
  5. * @return one row or null if no row was found on the resultset or if an error occurred.
  6. */
  7. public Object[] getRow( ResultSet rs ) throws KettleDatabaseException {
  8. return getRow( rs, false );
  9. }

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

  1. /**
  2. * Get a row from the resultset.
  3. *
  4. * @param rs The resultset to get the row from
  5. * @param lazyConversion set to true if strings need to have lazy conversion enabled
  6. * @return one row or null if no row was found on the resultset or if an error occurred.
  7. */
  8. public Object[] getRow( ResultSet rs, boolean lazyConversion ) throws KettleDatabaseException {
  9. if ( rowMeta == null ) {
  10. ResultSetMetaData rsmd = null;
  11. try {
  12. rsmd = rs.getMetaData();
  13. } catch ( SQLException e ) {
  14. throw new KettleDatabaseException( "Unable to retrieve metadata from resultset", e );
  15. }
  16. rowMeta = getRowInfo( rsmd, false, lazyConversion );
  17. }
  18. return getRow( rs, null, rowMeta );
  19. }

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

  1. public RowMetaAndData getOneRow( String sql, RowMetaInterface param, Object[] data ) throws KettleDatabaseException {
  2. ResultSet rs = openQuery( sql, param, data );
  3. if ( rs != null ) {
  4. Object[] row = getRow( rs ); // One value: a number;

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

  1. return new RowMetaAndData( rowMeta, getRow( keys, resultSetMetaData, rowMeta ) );
  2. } catch ( Exception ex ) {
  3. throw new KettleDatabaseException( "Unable to retrieve key(s) from auto-increment field(s)", ex );

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

  1. res = database.openQuery( sql.toString() );
  2. if ( res != null ) {
  3. Object[] row = database.getRow( res );
  4. while ( row != null ) {
  5. String column = database.getReturnRowMeta().getString( row, "column_name", "" );
  6. row = database.getRow( res );

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

  1. if ( res != null ) {
  2. rowMeta = getRowInfo( res.getMetaData(), false, false );
  3. row = getRow( res );
  4. res.close();

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

  1. ResultSet rs = openQuery( sql );
  2. if ( rs != null ) {
  3. Object[] row = getRow( rs ); // One row only;

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

  1. res = ps.executeQuery();
  2. Object[] ret = getRow( res, lazyConversion );

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

  1. Object[] row = getRow( rset );
  2. if ( row != null ) {
  3. result.add( row );

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

  1. res = database.openQuery( sql );
  2. if ( res != null ) {
  3. Object[] row = database.getRow( res );
  4. while ( row != null ) {
  5. String column = database.getReturnRowMeta().getString( row, "COLUMN_NAME", "" );
  6. row = database.getRow( res );

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

  1. ResultSet res = openQuery( sql );
  2. if ( res != null ) {
  3. Object[] row = getRow( res );
  4. if ( row != null ) {
  5. retval = true;

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

  1. Object[] rowData = database.getRow( resultSet );
  2. int rowsFetched = 1;
  3. while ( rowData != null ) {
  4. rows.add( rowData );
  5. rowData = database.getRow( resultSet );
  6. rowsFetched++;

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

  1. Object[] rowData = database.getRow( resultSet );
  2. int rowsFetched = 1;
  3. while ( rowData != null ) {
  4. rows.add( rowData );
  5. rowData = database.getRow( resultSet );
  6. rowsFetched++;

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

  1. @Override public RowMetaAndData call() throws Exception {
  2. ResultSet resultSet = null;
  3. resultSet = database.openQuery( ps, parameterMeta, parameterData );
  4. Object[] result = database.getRow( resultSet );
  5. if ( resultSet != null ) {
  6. database.closeQuery( resultSet );
  7. }
  8. if ( result == null ) {
  9. return new RowMetaAndData( database.getReturnRowMeta(), RowDataUtil.allocateRowData( database
  10. .getReturnRowMeta().size() ) );
  11. }
  12. return new RowMetaAndData( database.getReturnRowMeta(), result );
  13. }
  14. } );

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

  1. rs = openQuery( sql, params, data );
  2. if ( rs != null ) {
  3. Object[] row = getRow( rs );
  4. while ( row != null ) {
  5. result.setNrLinesRead( result.getNrLinesRead() + 1 );
  6. log.logDetailed( rowMeta.getString( row ) );
  7. row = getRow( rs );

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

  1. data.thisrow = data.db.getRow( data.rs );
  2. if ( data.thisrow != null ) {
  3. incrementLinesInput();
  4. data.nextrow = data.db.getRow( data.rs );
  5. if ( data.nextrow != null ) {
  6. incrementLinesInput();

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

  1. Object[] add = data.db.getRow( rs );
  2. RowMetaInterface addMeta = data.db.getReturnRowMeta();
  3. add = data.db.getRow( rs );
  4. incrementLinesInput();

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

  1. Object[] one = data.referenceDb.getRow( refSet );
  2. if ( one != null ) {
  3. incrementLinesInput();
  4. Object[] two = data.compareDb.getRow( cmpSet );
  5. if ( two != null ) {
  6. incrementLinesInput();
  7. two = data.compareDb.getRow( cmpSet );
  8. if ( two != null ) {
  9. nrRecordsCompare++;
  10. one = data.referenceDb.getRow( refSet );
  11. if ( one != null ) {
  12. nrRecordsReference++;
  13. one = data.referenceDb.getRow( refSet );
  14. if ( one != null ) {
  15. nrRecordsReference++;
  16. two = data.compareDb.getRow( cmpSet );
  17. if ( two != null ) {
  18. nrRecordsCompare++;
  19. one = data.referenceDb.getRow( refSet );
  20. if ( one != null ) {
  21. nrRecordsReference++;
  22. two = data.compareDb.getRow( cmpSet );

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

  1. Object[] add = data.db.getRow( rs );
  2. RowMetaInterface addMeta = data.db.getReturnRowMeta();
  3. add = data.db.getRow( rs );
  4. incrementLinesInput();

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

  1. data.nextrow = data.db.getRow( data.rs, meta.isLazyConversionActive() );
  2. } catch ( KettleDatabaseException e ) {
  3. if ( e.getCause() instanceof SQLException && isStopped() ) {

相关文章