net.sf.appstatus.batch.jdbc

Class BatchDao

java.lang.Object

net.sf.appstatus.batch.jdbc.BatchDao

Direct Known Subclasses:

BatchDaoOracle

public class BatchDao
extends Object

 <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"
 scope="singleton">
     <constructor-arg ref="dataSource" /> 
 </bean>
 
 <bean id="batchDao" class="net.sf.appstatus.batch.jdbc.BatchDao"
 scope="singleton"> <property name="jdbcTemplate" ref="jdbcTemplate" />
 </bean>
 
 
 
 <bean id="jdbcBatchManager"
 class="net.sf.appstatus.batch.jdbc.JdbcBatchManager" scope="singleton">
                <property name="batchDao" ref="batchDao" /> 
 </bean>
 
 

Create table: BATCH

UUID_BATCH	varchar (256)
GROUP_BATCH	varchar (256)
NAME_BATCH	varchar (256)
START_DATE	DATETIME
END_DATE	DATETIME
UPDATED	DATETIME
STATUS	varchar (64)
SUCCESS	BOOLEAN
ITEMCOUNT	LONG
ITEM	varchar (256)
CURRENT_TASK	varchar (256)
PROGRESS	Float
REJECT	CLOB
LAST_MSG	varchar (1024)

Field Summary

Fields

Modifier and Type	Field and Description
static int	BATCH_CREATE_TABLE
static int	BATCH_DELETE
static int	BATCH_DELETE_OLD
static int	BATCH_DELETE_SUCCESS
static int	BATCH_FETCH
static int	BATCH_FETCH_BY_NAME
static int	BATCH_INSERT
static int	BATCH_UPDATE
protected String	tableName

Constructor Summary

Constructors

Constructor and Description
BatchDao()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	createDbIfNecessary() Check for storage table and create if necessary.
void	deleteBatch(String uuidBatch)
void	deleteOldBatches(int delay)
void	deleteSuccessBatches()
List<BdBatch>	fetch(String group, String name, int max)
List<BdBatch>	fetchError(int max)
List<BdBatch>	fetchFinished(int max)
List<BdBatch>	fetchRunning(int max)
protected String	getSql(int query) Get SQL query for the requested action.
BdBatch	save(BdBatch bdBatch)
void	setJdbcTemplate(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate)
void	setTableName(String tableName)
void	update(BdBatch bdBatch)

Methods inherited from class java.lang.Object

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

Field Detail

BATCH_FETCH

public static final int BATCH_FETCH

See Also:

Constant Field Values

BATCH_DELETE

public static final int BATCH_DELETE

See Also:

Constant Field Values

BATCH_DELETE_OLD

public static final int BATCH_DELETE_OLD

See Also:

Constant Field Values

BATCH_DELETE_SUCCESS

public static final int BATCH_DELETE_SUCCESS

See Also:

Constant Field Values

BATCH_INSERT

public static final int BATCH_INSERT

See Also:

Constant Field Values

BATCH_UPDATE

public static final int BATCH_UPDATE

See Also:

Constant Field Values

BATCH_CREATE_TABLE

public static final int BATCH_CREATE_TABLE

See Also:

Constant Field Values

BATCH_FETCH_BY_NAME

public static final int BATCH_FETCH_BY_NAME

See Also:

Constant Field Values

tableName

protected String tableName

Constructor Detail

BatchDao

public BatchDao()

Method Detail

createDbIfNecessary

public boolean createDbIfNecessary()

Check for storage table and create if necessary.

Returns:

true if database was created.

deleteBatch

@Transactional(propagation=REQUIRES_NEW)
public void deleteBatch(String uuidBatch)

deleteOldBatches

@Transactional(propagation=REQUIRES_NEW)
public void deleteOldBatches(int delay)

deleteSuccessBatches

@Transactional(propagation=REQUIRES_NEW)
public void deleteSuccessBatches()

fetchError

@Transactional(readOnly=true)
public List<BdBatch> fetchError(int max)

fetchFinished

@Transactional(readOnly=true)
public List<BdBatch> fetchFinished(int max)

fetchRunning

@Transactional(readOnly=true)
public List<BdBatch> fetchRunning(int max)

getSql

protected String getSql(int query)

Get SQL query for the requested action.

Override this method to adapt to a new SQL Dialect.

Parameters:

query - BATCH_FETCH BATCH_CREATE_TABLE

Returns:

the SQL query

save

@Transactional(propagation=REQUIRES_NEW)
public BdBatch save(BdBatch bdBatch)

update

@Transactional(propagation=REQUIRES_NEW)
public void update(BdBatch bdBatch)

fetch

@Transactional(readOnly=true)
public List<BdBatch> fetch(String group,
                                String name,
                                int max)

setJdbcTemplate

public void setJdbcTemplate(org.springframework.jdbc.core.JdbcTemplate jdbcTemplate)

setTableName

public void setTableName(String tableName)