Class SQLQueryConnector
java.lang.Object
com.almis.awe.config.ServiceConfig
com.almis.awe.service.data.connector.query.AbstractQueryConnector
com.almis.awe.service.data.connector.query.SQLQueryConnector
- All Implemented Interfaces:
QueryConnector
,org.springframework.beans.factory.Aware
,org.springframework.context.ApplicationContextAware
SQLQueryConnector Class
Connection class between QueryLauncher and SQLQueryBuilder
- Author:
- Jorge BELLON 24-02-2017
-
Constructor Summary
ConstructorDescriptionSQLQueryConnector
(AweDatabaseContextHolder contextHolder, QueryUtil queryUtil, DataSource dataSource, BaseConfigProperties baseConfigProperties, AweElements elements, NumericService numericService, EncodeService encodeService, DatabaseConfigProperties databaseConfigProperties, com.fasterxml.jackson.databind.ObjectMapper mapper) Autowired constructor -
Method Summary
Modifier and TypeMethodDescriptionLaunch querysubscribe
(Query query, ComponentAddress address, com.fasterxml.jackson.databind.node.ObjectNode parameters) Subscribe to a queueMethods inherited from class com.almis.awe.service.data.connector.query.AbstractQueryConnector
buildResults, fillDataList, generateResults, getQueryUtil, processDataList, sortDataList
Methods inherited from class com.almis.awe.config.ServiceConfig
containsBean, getApplicationContext, getBean, getBean, getElements, getLocale, getLocale, getProperty, getProperty, getRequest, getSession, setApplicationContext
-
Constructor Details
-
SQLQueryConnector
@Autowired public SQLQueryConnector(AweDatabaseContextHolder contextHolder, QueryUtil queryUtil, DataSource dataSource, BaseConfigProperties baseConfigProperties, AweElements elements, NumericService numericService, EncodeService encodeService, DatabaseConfigProperties databaseConfigProperties, com.fasterxml.jackson.databind.ObjectMapper mapper) Autowired constructor- Parameters:
contextHolder
- Database context holderqueryUtil
- Query utilitiesdataSource
- DatasourcebaseConfigProperties
- Base configuration propertieselements
- AWE elementsnumericService
- Numeric serviceencodeService
- Encode servicedatabaseConfigProperties
- Database configuration propertiesmapper
- Object mapper
-
-
Method Details
-
launch
public ServiceData launch(Query query, com.fasterxml.jackson.databind.node.ObjectNode parameters) throws AWException Launch query- Parameters:
query
- Query to be launchedparameters
- Parameters- Returns:
- Query output as service data
- Throws:
AWException
- Error launching query
-
subscribe
public ServiceData subscribe(Query query, ComponentAddress address, com.fasterxml.jackson.databind.node.ObjectNode parameters) throws AWException Description copied from interface:QueryConnector
Subscribe to a queue- Parameters:
query
- Query to be subscribed toaddress
- Address of the subscribed componentparameters
- Parameters- Returns:
- Service data with execution info
- Throws:
AWException
- Error on subscription
-