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 DatabasePersistenceServiceDatabaseExceptionpublic void deleteFromDB(MessageWrapper message, java.lang.String dataSourceName) throws DeleteException
deleteFromDB in interface DatabasePersistenceServiceDeleteExceptionpublic void persistToDB(MessageWrapper message, java.lang.String dataSourceName) throws PersistenceException
persistToDB in interface DatabasePersistenceServicePersistenceExceptionpublic MessageWrapper queryDB(java.lang.String messageType, java.lang.String dataSourceName, java.lang.String queryName, java.lang.String parameters) throws QueryException
queryDB in interface DatabasePersistenceServiceQueryExceptionprotected MessageWrapper resultToWrapper(java.lang.String messageType, MessageContextImpl processor, DataObjectSection queryResults) throws QueryException
messageType -processor -queryResults -QueryException