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

Database.getQueryFields介绍

暂无

代码示例

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

public RowMetaInterface getQueryFields( String sql, boolean param ) throws KettleDatabaseException {
 return getQueryFields( sql, param, null, null );
}

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

/**
 * Returns a RowMeta describing the fields of a table expression.
 *
 * <p>Note that this implementation makes use of a SQL statement
 * in order to populate the ValueMeta object in the RowMeta it returns.
 * This is sometimes necessary when the caller needs the ValueMeta
 * values to be properly casted.
 *
 * <p>In cases where a simple list of columns is required, it is preferable
 * to use {@link #getTableFieldsMeta(String, String)}. This other method
 * will not use a SQL query and will populate whatever information it can
 * using @link {@link DatabaseMetaData#getColumns(String, String, String, String)}.
 *
 * @param tablename This is the properly quoted, and schema prefixed table name.
 */
public RowMetaInterface getTableFields( String tablename ) throws KettleDatabaseException {
 return getQueryFields( databaseMeta.getSQLQueryFields( tablename ), false );
}

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

public void run( IProgressMonitor monitor ) throws InvocationTargetException, InterruptedException {
  db = new Database( Spoon.loggingObject, dbMeta );
  try {
   db.connect();
   result = db.getQueryFields( sql, false );
   if ( monitor.isCanceled() ) {
    throw new InvocationTargetException( new Exception( "This operation was cancelled!" ) );
   }
  } catch ( Exception e ) {
   throw new InvocationTargetException( e, "Problem encountered determining query fields: " + e.toString() );
  } finally {
   db.disconnect();
  }
 }
};

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

return getQueryFields( databaseMeta.getQuotedSchemaTableCombination( schemaName, tableName ), false );

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

RowMetaInterface r = db.getQueryFields( sql, true );
if ( r != null ) {
 cr =

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

@Test
public void testGetFields() throws Exception {
 TableInputMetaHandler meta = new TableInputMetaHandler();
 meta.setLazyConversionActive( true );
 DatabaseMeta dbMeta = mock( DatabaseMeta.class );
 meta.setDatabaseMeta( dbMeta );
 Database mockDB = meta.getDatabase();
 when( mockDB.getQueryFields( anyString(), anyBoolean() ) ).thenReturn( createMockFields() );
 RowMetaInterface expectedRowMeta = new RowMeta();
 ValueMetaInterface valueMeta = new ValueMetaString( "field1" );
 valueMeta.setStorageMetadata( new ValueMetaString( "field1" ) );
 valueMeta.setStorageType( ValueMetaInterface.STORAGE_TYPE_BINARY_STRING );
 expectedRowMeta.addValueMeta( valueMeta );
 VariableSpace space = mock( VariableSpace.class );
 RowMetaInterface rowMetaInterface = new RowMeta();
 meta.getFields( rowMetaInterface, "TABLE_INPUT_META", null, null, space, null, null );
 assertEquals( expectedRowMeta.toString(), rowMetaInterface.toString() );
}

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

db.getQueryFields( transMeta.environmentSubstitute( sql ), true, param, new Object[param.size()] );
if ( r != null ) {
 cr =

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

add = db.getQueryFields( realSQL, false );
} catch ( KettleDatabaseException dbe ) {
 throw new KettleStepException( BaseMessages.getString(
  add = db.getQueryFields( realSQL, false );
  for ( int i = 0; i < add.size(); i++ ) {
   ValueMetaInterface v = add.getValueMeta( i );

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

if ( db != null ) {
 if ( isAddRowsResult && iscustomSQL && ar != null ) {
  rowMeta = db.getQueryFields( countStatement, false );

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

add = db.getQueryFields( space.environmentSubstitute( sql ), true, param, new Object[param.size()] );
} catch ( KettleDatabaseException dbe ) {
 throw new KettleStepException( BaseMessages.getString(
  add = db.getQueryFields( space.environmentSubstitute( sql ), true, param, new Object[param.size()] );
  for ( int i = 0; i < add.size(); i++ ) {
   ValueMetaInterface v = add.getValueMeta( i );

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

@Override
public RowMetaInterface getTableFields() {
 // Build a dummy parameter row...
 //
 RowMetaInterface param = new RowMeta();
 for ( int i = 0; i < parameterField.length; i++ ) {
  ValueMetaInterface v;
  try {
   v = ValueMetaFactory.createValueMeta( parameterField[i], parameterType[i] );
  } catch ( KettlePluginException e ) {
   v = new ValueMetaNone( parameterField[i] );
  }
  param.addValueMeta( v );
 }
 RowMetaInterface fields = null;
 if ( databaseMeta != null ) {
  Database db = new Database( loggingObject, databaseMeta );
  databases = new Database[] { db }; // Keep track of this one for cancelQuery
  try {
   db.connect();
   fields =
    db.getQueryFields( databaseMeta.environmentSubstitute( sql ), true, param, new Object[param.size()] );
  } catch ( KettleDatabaseException dbe ) {
   logError( BaseMessages.getString( PKG, "DatabaseJoinMeta.Log.DatabaseErrorOccurred" ) + dbe.getMessage() );
  } finally {
   db.disconnect();
  }
 }
 return fields;
}

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

add = db.getQueryFields( sNewSQL, param );
} catch ( KettleDatabaseException dbe ) {
 throw new KettleStepException( "Unable to get queryfields for SQL: " + Const.CR + sNewSQL, dbe );
  add = db.getQueryFields( sNewSQL, param, paramRowMeta, paramData );

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

RowMetaInterface rowMeta = db.getQueryFields( countSQLStatement, false );

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

try {
 db.connect();
 RowMetaInterface fields = db.getQueryFields( sql, false );
 if ( fields != null ) {
  sql = "SELECT" + Const.CR;

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

try {
 db.connect();
 RowMetaInterface fields = db.getQueryFields( sql, false );
 if ( fields != null ) {
  sql = "SELECT" + Const.CR;

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

try {
 db.connect();
 RowMetaInterface fields = db.getQueryFields( sql, false );
 if ( fields != null ) {
  sql = "SELECT" + Const.CR;