org.jumpmind.symmetric.service.impl
Class IncomingBatchService

java.lang.Object
  org.jumpmind.symmetric.service.impl.IncomingBatchService

All Implemented Interfaces:

IIncomingBatchService

public class IncomingBatchService
extends java.lang.Object
implements IIncomingBatchService

Field Summary

protected org.springframework.jdbc.core.JdbcTemplate	jdbcTemplate
protected IParameterService	parameterService

Constructor Summary

IncomingBatchService()

Method Summary

boolean	acquireIncomingBatch(IncomingBatch status)
IncomingBatch	findIncomingBatch(long batchId, java.lang.String nodeId)
java.util.List<IncomingBatch>	findIncomingBatchErrors(int maxRows)
java.util.List<IncomingBatchHistory>	findIncomingBatchHistory(long batchId, java.lang.String nodeId)
protected org.springframework.jdbc.core.simple.SimpleJdbcTemplate	getSimpleTemplate()
java.lang.String	getSql(java.lang.String key)
void	insertIncomingBatch(IncomingBatch status)
void	insertIncomingBatchHistory(IncomingBatchHistory history)
void	setDbDialect(IDbDialect dbDialect)
void	setJdbcTemplate(org.springframework.jdbc.core.JdbcTemplate jdbc)
void	setParameterService(IParameterService parameterService)
void	setSql(java.util.Map<java.lang.String,java.lang.String> sql)
protected java.sql.SQLException	unwrapSqlException(java.lang.Throwable e)
int	updateIncomingBatch(IncomingBatch status)

Methods inherited from class java.lang.Object

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

Field Detail

parameterService

protected IParameterService parameterService

jdbcTemplate

protected org.springframework.jdbc.core.JdbcTemplate jdbcTemplate

Constructor Detail

IncomingBatchService

public IncomingBatchService()

Method Detail

findIncomingBatch

public IncomingBatch findIncomingBatch(long batchId,
                                       java.lang.String nodeId)

Specified by:

findIncomingBatch in interface IIncomingBatchService

findIncomingBatchErrors

public java.util.List<IncomingBatch> findIncomingBatchErrors(int maxRows)

Specified by:

findIncomingBatchErrors in interface IIncomingBatchService

findIncomingBatchHistory

public java.util.List<IncomingBatchHistory> findIncomingBatchHistory(long batchId,
                                                                     java.lang.String nodeId)

Specified by:

findIncomingBatchHistory in interface IIncomingBatchService

acquireIncomingBatch

public boolean acquireIncomingBatch(IncomingBatch status)

Specified by:

acquireIncomingBatch in interface IIncomingBatchService

insertIncomingBatch

public void insertIncomingBatch(IncomingBatch status)

Specified by:

insertIncomingBatch in interface IIncomingBatchService

updateIncomingBatch

public int updateIncomingBatch(IncomingBatch status)

Specified by:

updateIncomingBatch in interface IIncomingBatchService

insertIncomingBatchHistory

public void insertIncomingBatchHistory(IncomingBatchHistory history)

Specified by:

insertIncomingBatchHistory in interface IIncomingBatchService

setDbDialect

public void setDbDialect(IDbDialect dbDialect)

setJdbcTemplate

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

getSimpleTemplate

protected org.springframework.jdbc.core.simple.SimpleJdbcTemplate getSimpleTemplate()

unwrapSqlException

protected java.sql.SQLException unwrapSqlException(java.lang.Throwable e)

setSql

public void setSql(java.util.Map<java.lang.String,java.lang.String> sql)

getSql

public java.lang.String getSql(java.lang.String key)

setParameterService

public void setParameterService(IParameterService parameterService)