public class DatabasePersistenceServiceImpl extends java.lang.Object implements DatabasePersistenceService
Constructor and Description |
---|
DatabasePersistenceServiceImpl() |
Modifier and Type | Method and Description |
---|---|
void |
deleteFromDB(MessageWrapper message, java.lang.String dataSourceName) |
void |
persistToDB(MessageWrapper message, java.lang.String dataSourceName) |
MessageWrapper |
queryDB(java.lang.String messageType, java.lang.String dataSourceName, java.lang.String queryName, java.lang.String parameters) |
protected MessageWrapper |
resultToWrapper(java.lang.String messageType, MessageContextImpl processor, DataObjectSection queryResults) |
int |
updateDB(java.lang.String dataSourceName, java.lang.String sql) |
public int updateDB(java.lang.String dataSourceName, java.lang.String sql) throws DatabaseException
updateDB
in interface DatabasePersistenceService
DatabaseException
public void deleteFromDB(MessageWrapper message, java.lang.String dataSourceName) throws DeleteException
deleteFromDB
in interface DatabasePersistenceService
DeleteException
public void persistToDB(MessageWrapper message, java.lang.String dataSourceName) throws PersistenceException
persistToDB
in interface DatabasePersistenceService
PersistenceException
public MessageWrapper queryDB(java.lang.String messageType, java.lang.String dataSourceName, java.lang.String queryName, java.lang.String parameters) throws QueryException
queryDB
in interface DatabasePersistenceService
QueryException
protected MessageWrapper resultToWrapper(java.lang.String messageType, MessageContextImpl processor, DataObjectSection queryResults) throws QueryException
messageType
-processor
-queryResults
-QueryException