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

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

本文整理了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

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

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

/**
 * Get a row from the resultset.
 *
 * @param rs             The resultset to get the row from
 * @param lazyConversion set to true if strings need to have lazy conversion enabled
 * @return one row or null if no row was found on the resultset or if an error occurred.
 */
public Object[] getRow( ResultSet rs, boolean lazyConversion ) throws KettleDatabaseException {
 if ( rowMeta == null ) {
  ResultSetMetaData rsmd = null;
  try {
   rsmd = rs.getMetaData();
  } catch ( SQLException e ) {
   throw new KettleDatabaseException( "Unable to retrieve metadata from resultset", e );
  }
  rowMeta = getRowInfo( rsmd, false, lazyConversion );
 }
 return getRow( rs, null, rowMeta );
}

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

ResultSet res = openQuery( sql );
if ( res != null ) {
 Object[] row = getRow( res );
 if ( row != null ) {
  retval = true;

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

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

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

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

代码示例来源: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

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

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

data.thisrow = data.db.getRow( data.rs );
if ( data.thisrow != null ) {
 incrementLinesInput();
 data.nextrow = data.db.getRow( data.rs );
 if ( data.nextrow != null ) {
  incrementLinesInput();

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

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

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

Object[] one = data.referenceDb.getRow( refSet );
if ( one != null ) {
 incrementLinesInput();
Object[] two = data.compareDb.getRow( cmpSet );
if ( two != null ) {
 incrementLinesInput();
  two = data.compareDb.getRow( cmpSet );
  if ( two != null ) {
   nrRecordsCompare++;
  one = data.referenceDb.getRow( refSet );
  if ( one != null ) {
   nrRecordsReference++;
    one = data.referenceDb.getRow( refSet );
    if ( one != null ) {
     nrRecordsReference++;
    two = data.compareDb.getRow( cmpSet );
    if ( two != null ) {
     nrRecordsCompare++;
     one = data.referenceDb.getRow( refSet );
     if ( one != null ) {
      nrRecordsReference++;
     two = data.compareDb.getRow( cmpSet );

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

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

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

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

相关文章

微信公众号

最新文章

更多