Class ExecuteSqlWorkItemHandler

  • All Implemented Interfaces:
    org.kie.api.runtime.process.WorkItemHandler, org.kie.internal.runtime.Cacheable

    @Wid(widfile="ExecuteSQLDefinitions.wid",name="ExecuteSQL",displayName="ExecuteSQL",defaultHandler="mvel: new org.jbpm.process.workitem.executesql.ExecuteSqlWorkItemHandler(\"dataSourceName\")",documentation="execute-sql-workitem/index.html",category="execute-sql-workitem",icon="ExecuteSQL.png",parameters={@WidParameter(name="SQLStatement",required=true),@WidParameter(name="MaxResults"),@WidParameter(name="ColumnSeparator")},results=@WidResult(name="Result",runtimeType="java.lang.Object"),mavenDepends=@WidMavenDepends(group="org.jbpm.contrib",artifact="execute-sql-workitem",version="7.66.0.Final"),serviceInfo=@WidService(category="Execute SQL",description="Execute SQL statements",keywords="database,fetch,sql,execute",action=@WidAction(title="Execute SQL statements"),authinfo=@WidAuth(required=true,params="Data source JNDI",paramsdescription="Data source JNDI")))
    public class ExecuteSqlWorkItemHandler
    extends org.jbpm.process.workitem.core.AbstractLogOrThrowWorkItemHandler
    implements org.kie.internal.runtime.Cacheable
    • Constructor Detail

      • ExecuteSqlWorkItemHandler

        public ExecuteSqlWorkItemHandler​(String dataSourceName)
      • ExecuteSqlWorkItemHandler

        public ExecuteSqlWorkItemHandler​(DataSource ds)
    • Method Detail

      • executeWorkItem

        public void executeWorkItem​(org.kie.api.runtime.process.WorkItem workItem,
                                    org.kie.api.runtime.process.WorkItemManager workItemManager)
        Specified by:
        executeWorkItem in interface org.kie.api.runtime.process.WorkItemHandler
      • abortWorkItem

        public void abortWorkItem​(org.kie.api.runtime.process.WorkItem workItem,
                                  org.kie.api.runtime.process.WorkItemManager manager)
        Specified by:
        abortWorkItem in interface org.kie.api.runtime.process.WorkItemHandler
      • close

        public void close()
        Specified by:
        close in interface org.kie.internal.runtime.Cacheable