public class SqlTransExecutor extends Object
Constructor and Description |
---|
SqlTransExecutor(String sqlQuery,
List<org.pentaho.di.core.jdbc.TransDataService> services)
Create a new SqlTransExecutor without parameters
|
SqlTransExecutor(String sqlQuery,
List<org.pentaho.di.core.jdbc.TransDataService> services,
Map<String,String> parameters) |
SqlTransExecutor(String sqlQuery,
List<org.pentaho.di.core.jdbc.TransDataService> services,
Map<String,String> parameters,
Repository repository,
int rowLimit) |
Modifier and Type | Method and Description |
---|---|
static String |
calculateTransname(org.pentaho.di.core.sql.SQL sql,
boolean isService)
Calculate the name of the generated transformation based on the SQL
|
void |
executeQuery(RowListener resultRowListener) |
Trans |
getGenTrans() |
TransMeta |
getGenTransMeta() |
List<String> |
getParameterNames() |
org.pentaho.di.core.row.RowMetaInterface |
getResultStepFields() |
String |
getResultStepName() |
int |
getRowLimit() |
org.pentaho.di.core.row.RowMetaInterface |
getServiceFields() |
String |
getServiceName() |
List<org.pentaho.di.core.jdbc.TransDataService> |
getServices() |
String |
getServiceStepName() |
Trans |
getServiceTrans() |
TransMeta |
getServiceTransMeta() |
org.pentaho.di.core.sql.SQL |
getSql() |
String |
getSqlQuery() |
void |
setResultStepFields(org.pentaho.di.core.row.RowMetaInterface resultStepFields) |
void |
setServices(List<org.pentaho.di.core.jdbc.TransDataService> services) |
void |
waitUntilFinished() |
public SqlTransExecutor(String sqlQuery, List<org.pentaho.di.core.jdbc.TransDataService> services) throws org.pentaho.di.core.exception.KettleException
sqlQuery
- services
- org.pentaho.di.core.exception.KettleException
public SqlTransExecutor(String sqlQuery, List<org.pentaho.di.core.jdbc.TransDataService> services, Map<String,String> parameters) throws org.pentaho.di.core.exception.KettleException
sqlQuery
- services
- parameters
- org.pentaho.di.core.exception.KettleException
public SqlTransExecutor(String sqlQuery, List<org.pentaho.di.core.jdbc.TransDataService> services, Map<String,String> parameters, Repository repository, int rowLimit) throws org.pentaho.di.core.exception.KettleException
sqlQuery
- services
- repository
- org.pentaho.di.core.exception.KettleException
public void executeQuery(RowListener resultRowListener) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void waitUntilFinished()
public TransMeta getServiceTransMeta()
public String getServiceStepName()
public String getSqlQuery()
public TransMeta getGenTransMeta()
public Trans getServiceTrans()
public Trans getGenTrans()
public org.pentaho.di.core.row.RowMetaInterface getServiceFields()
public String getServiceName()
public org.pentaho.di.core.row.RowMetaInterface getResultStepFields()
public void setResultStepFields(org.pentaho.di.core.row.RowMetaInterface resultStepFields)
resultStepFields
- the resultStepFields to setpublic int getRowLimit()
public static String calculateTransname(org.pentaho.di.core.sql.SQL sql, boolean isService)
public List<org.pentaho.di.core.jdbc.TransDataService> getServices()
public void setServices(List<org.pentaho.di.core.jdbc.TransDataService> services)
servicesMap
- the servicesMap to setpublic org.pentaho.di.core.sql.SQL getSql()
public String getResultStepName()