public class SQLExecute extends SQLLookupRule
connection, connectionOwner, PREPARE_PARAMETER_PREFIX, preparedParameters, preparedQuery
COMPONENT_EXECUTE_FAIL, debug, MISSING_SESSION, UNKNOWN_COMPONENT_ID
EMPTYLOGID, loggingLevel, LOGID_MASK1, LOGID_MASK2, LOGID_SEPARATOR
Constructor and Description |
---|
SQLExecute() |
Modifier and Type | Method and Description |
---|---|
void |
addErrorCode(org.pentaho.commons.connection.memory.MemoryResultSet affectedRowsResultSet,
SQLException e,
String failMsg) |
org.apache.commons.logging.Log |
getLogger() |
static String |
removeLineTerminators(String inputStr) |
protected boolean |
runQuery(String rawQuery,
boolean live)
executes the specified query template.
|
protected boolean |
runSqlQuery(SQLConnection conn,
String rawQuery,
boolean live) |
boolean |
validateAction()
validates the action.
|
getResultOutputName, validateSystemSettings
dispose, done, doQuery, executeAction, executePrepared, getConnection, getConnection, getDatasourceConnection, getMaxRows, getMetadata, getQuery, getQueryTimeout, getReadOnly, getResultSet, init, prepareQuery, resolveParameter, setMaxRows, setQueryTimeout, setReadOnly, shareConnection, waitFor
addTempParameter, addTempParameterObject, applyInputsToFormat, audit, createFeedbackParameter, createFeedbackParameter, createFeedbackParameter, createFeedbackParameter, createFeedbackParameter, createFeedbackParameter, createFeedbackParameter, createNewInstance, execute, feedbackAllowed, getActionDefinition, getActionName, getActionTitle, getComponentDefinition, getComponentDefinition, getContentOutputItem, getDefaultOutputStream, getFeedbackOutputStream, getId, getInitFailMessage, getInitOk, getInputBooleanValue, getInputLongValue, getInputNames, getInputParameter, getInputStream, getInputStringValue, getInputStringValue, getInputValue, getInstanceId, getLogId, getObjectName, getOutputContentItem, getOutputContentItem, getOutputItem, getOutputItem, getOutputNames, getOutputPreference, getProcessId, getResource, getResourceAsString, getResourceDataSource, getResourceInputStream, getResourceNames, getRuntimeContext, getSession, getSetting, getSolutionName, getSolutionPath, getStringSetting, inputMissingError, isDefinedInput, isDefinedOutput, isDefinedResource, isPromptPending, outputMissingError, promptNeeded, promptNow, resourceComponentSettingError, resourceMissingError, saveSetting, setActionDefinition, setActionName, setComponentDefinition, setComponentDefinitionMap, setFeedbackMimeType, setInstanceId, setOutputMimeType, setOutputMimeType, setOutputValue, setProcessId, setRuntimeContext, setSession, validate
debug, debug, error, error, error, fatal, fatal, getMessages, getUserString, info, info, setMessages, trace, trace, warn, warn
genLogIdFromInfo, genLogIdFromInfo, genLogIdFromSession, getLoggingLevel, setLoggingLevel, setLogId
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
execute, getActionDefinition, getActionName, getComponentDefinition, getInstanceId, getMessages, getProcessId, getRuntimeContext, getSession, setActionDefinition, setActionName, setComponentDefinition, setComponentDefinitionMap, setInstanceId, setMessages, setProcessId, setRuntimeContext, setSession, validate
public org.apache.commons.logging.Log getLogger()
getLogger
in class SQLLookupRule
public boolean validateAction()
SQLBaseComponent
validateAction
in class SQLBaseComponent
protected boolean runQuery(String rawQuery, boolean live)
SQLBaseComponent
runQuery
in class SQLBaseComponent
rawQuery
- query templatelive
- returns original result set if true, memory result set if falseprotected boolean runSqlQuery(SQLConnection conn, String rawQuery, boolean live)
public void addErrorCode(org.pentaho.commons.connection.memory.MemoryResultSet affectedRowsResultSet, SQLException e, String failMsg)
Copyright © 2021 Hitachi Vantara. All rights reserved.