org.oddjob.sql

Class SQLPersisterService

java.lang.Object

org.oddjob.sql.SQLPersisterService

public class SQLPersisterService
extends java.lang.Object

Description

Persists job state to a database. The database must have a table which can be created with the following sql.

 CREATE TABLE oddjob(
   path VARCHAR(128), 
   id VARCHAR(32), 
   job BLOB, 
  CONSTRAINT oddjob_pk PRIMARY KEY (path, id))
 

Example

Using a SQL Persister.

<oddjob id="this">
    <job>
        <sequential>
            <jobs>
                <sql-persister-service id="sql-persister">
                    <connection>
                        <connection driver="org.hsqldb.jdbcDriver" url="jdbc:hsqldb:mem:test" username="sa"/>
                    </connection>
                </sql-persister-service>
                <oddjob id="oj" file="${this.dir}/SQLPersisterInner.xml">
                    <persister>
                        <value value="${sql-persister.persister(test)}"/>
                    </persister>
                </oddjob>
                <stop job="${sql-persister}"/>
            </jobs>
        </sequential>
    </job>
</oddjob>

Note that because this is a service, it must be stopped once the inner Oddjob has completed it's work. In an Oddjob that was running continually this would not be necessary.

Author:

Rob Gordon.

Constructor Summary

Constructors

Constructor and Description
SQLPersisterService()

Method Summary

Modifier and Type	Method and Description
java.lang.String	getName()
OddjobPersister	getPersister(java.lang.String path)
SQLSerializationFactory	getSerializationFactory()
void	setConnection(java.sql.Connection connection) Set the connection.
void	setName(java.lang.String name)
void	setSerializationFactory(SQLSerializationFactory serializationFactory)
void	start()
void	stop()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

SQLPersisterService

public SQLPersisterService()

Method Detail

start

public void start()
           throws java.sql.SQLException

Throws:

java.sql.SQLException

stop

public void stop()
          throws java.sql.SQLException

Throws:

java.sql.SQLException

setConnection

public void setConnection(java.sql.Connection connection)
                   throws java.sql.SQLException

Set the connection.

Parameters:

connection - The connection.

Throws:

java.sql.SQLException

getName

public java.lang.String getName()

setName

public void setName(java.lang.String name)

getSerializationFactory

public SQLSerializationFactory getSerializationFactory()

setSerializationFactory

public void setSerializationFactory(SQLSerializationFactory serializationFactory)

getPersister

public OddjobPersister getPersister(java.lang.String path)

Property: persister

Description: The persister.

Required: R/O.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object