本文整理了Java中org.pentaho.di.core.database.Database.getRow()
方法的一些代码示例,展示了Database.getRow()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Database.getRow()
方法的具体详情如下:
包路径:org.pentaho.di.core.database.Database
类名称: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() ) {
内容来源于网络,如有侵权,请联系作者删除!