org.adroitlogic.x.feature.db.impl

Class DBFeatureImpl

java.lang.Object

org.adroitlogic.x.api.AbstractIntegrationFeature

org.adroitlogic.x.feature.db.impl.DBFeatureImpl

All Implemented Interfaces:

org.adroitlogic.x.api.dec.Initializable, DBFeature

@IntegrationFeature(clazz=DBFeature.class,
                    name="db")
public class DBFeatureImpl
extends org.adroitlogic.x.api.AbstractIntegrationFeature
implements DBFeature

An implementation of the DBFeature using a caching strategy.

Since:

17.01

Author:

Dulaj Atapattu

Constructor Summary

Constructors

Constructor and Description
DBFeatureImpl()

Method Summary

Modifier and Type	Method and Description
void	init(org.springframework.context.ApplicationContext context)
List<Map<String,Object>>	read(DataSource dataSource, File mappingFile, String parameterizedSQL, org.adroitlogic.x.api.XMessageContext xMessageContext) Can be used for database read operations.
int	update(DataSource dataSource, File mappingFile, String parameterizedSQL, org.adroitlogic.x.api.XMessageContext xMessageContext) Can be used for database insert, update and delete operations.

Methods inherited from class org.adroitlogic.x.api.AbstractIntegrationFeature

destroy, setProjectConfig, setProperties

Methods inherited from class java.lang.Object

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

Constructor Detail

DBFeatureImpl

public DBFeatureImpl()

Method Detail

init

public void init(org.springframework.context.ApplicationContext context)

Specified by:

init in interface org.adroitlogic.x.api.dec.Initializable

Overrides:

init in class org.adroitlogic.x.api.AbstractIntegrationFeature

update

public int update(DataSource dataSource,
                  File mappingFile,
                  String parameterizedSQL,
                  org.adroitlogic.x.api.XMessageContext xMessageContext)
           throws org.springframework.dao.DataAccessException

Description copied from interface: DBFeature

Can be used for database insert, update and delete operations.

Specified by:

update in interface DBFeature

Parameters:

dataSource - DataSource instance of the database to be used.

mappingFile - JSON configuration mapping file with the mapping between parameters and actual data.

parameterizedSQL - SQL query with parameters. Parameter should be in @{parameter-name} format.

xMessageContext - XMessageContext which contains the payload to extract data.

Returns:

the number of rows affected by the operation

Throws:

org.springframework.dao.DataAccessException

read

public List<Map<String,Object>> read(DataSource dataSource,
                                     File mappingFile,
                                     String parameterizedSQL,
                                     org.adroitlogic.x.api.XMessageContext xMessageContext)
                              throws org.springframework.dao.DataAccessException

Description copied from interface: DBFeature

Can be used for database read operations.

Specified by:

read in interface DBFeature

Parameters:

dataSource - DataSource instance of the database to be used.

mappingFile - JSON configuration mapping file with the mapping between parameters and actual data.

parameterizedSQL - SQL query with parameters. Parameter should be in @{parameter-name} format.

xMessageContext - message context used for the database read operation

Returns:

List of maps containing column values as keys and actual data read from the database as values.

Throws:

org.springframework.dao.DataAccessException