org.apache.oozie.workflow.lite
Class DBLiteWorkflowLib

java.lang.Object
  org.apache.oozie.workflow.lite.LiteWorkflowLib
      org.apache.oozie.workflow.lite.DBLiteWorkflowLib

All Implemented Interfaces:

WorkflowLib

public class DBLiteWorkflowLib
extends LiteWorkflowLib

Constructor Summary

DBLiteWorkflowLib(Schema schema, Class<? extends ControlNodeHandler> controlNodeHandler, Class<? extends DecisionNodeHandler> decisionHandlerClass, Class<? extends ActionNodeHandler> actionHandlerClass, Connection connection)

Method Summary

void	close() Close store.
void	commit() Commit changes to store.
void	delete(String id) Delets the Workflow Instance with the given id.
WorkflowInstance	get(String id) Loads the Workflow instance with the given ID.
void	insert(WorkflowInstance instance) Save the Workflow Instance for the given Workflow Application.
void	update(WorkflowInstance instance) Updates the Workflow Instance to DB.

Methods inherited from class org.apache.oozie.workflow.lite.LiteWorkflowLib

createInstance, createInstance, parseDef

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DBLiteWorkflowLib

public DBLiteWorkflowLib(Schema schema,
                         Class<? extends ControlNodeHandler> controlNodeHandler,
                         Class<? extends DecisionNodeHandler> decisionHandlerClass,
                         Class<? extends ActionNodeHandler> actionHandlerClass,
                         Connection connection)

Method Detail

insert

public void insert(WorkflowInstance instance)
            throws WorkflowException

Save the Workflow Instance for the given Workflow Application.

Parameters:

instance -

Throws:

WorkflowException

get

public WorkflowInstance get(String id)
                     throws WorkflowException

Loads the Workflow instance with the given ID.

Parameters:

id -

Returns:

Throws:

WorkflowException

update

public void update(WorkflowInstance instance)
            throws WorkflowException

Updates the Workflow Instance to DB.

Parameters:

instance -

Throws:

WorkflowException

delete

public void delete(String id)
            throws WorkflowException

Delets the Workflow Instance with the given id.

Parameters:

id -

Throws:

WorkflowException

commit

public void commit()
            throws WorkflowException

Description copied from interface: WorkflowLib

Commit changes to store.

Throws:

WorkflowException - thrown if the commit could not be done.

close

public void close()
           throws WorkflowException

Description copied from interface: WorkflowLib

Close store. It rollbacks if there was no commit.

Throws:

WorkflowException - thrown if the close could not be done.