Package com.inductiveautomation.ignition.gateway.datasource.storage

Class DatasourceQuerySink

java.lang.Object

com.inductiveautomation.ignition.gateway.storeforward.sinks.AbstractSink<T>

com.inductiveautomation.ignition.gateway.storeforward.sinks.AbstractDatasourceSink<QuerySFData>

com.inductiveautomation.ignition.gateway.datasource.storage.DatasourceQuerySink

All Implemented Interfaces:

DataConsumer<QuerySFData>, DataSink<QuerySFData>

public class DatasourceQuerySink
extends AbstractDatasourceSink<QuerySFData>

A sink that executes queries to a datasource.

Nested Class Summary

Nested classes/interfaces inherited from class com.inductiveautomation.ignition.gateway.storeforward.sinks.AbstractSink

AbstractSink.SinkWriter

Field Summary

Fields inherited from class com.inductiveautomation.ignition.gateway.storeforward.sinks.AbstractDatasourceSink

datasourceName, queryCache

Fields inherited from class com.inductiveautomation.ignition.gateway.storeforward.sinks.AbstractSink

batchSize, flavor, id, status, storageKey, storeMetric

Constructor Summary

Constructors

Constructor	Description
DatasourceQuerySink(GatewayContext context, String dataSource)	Creates a new instance of this sink with the specified context and datasource.

Method Summary

Modifier and Type	Method	Description
protected LocalizedString	getTypeDescription()
protected void	storeToConnection(SRConnection conn, List<QuerySFData> querySFData)	Stores the given data to the specified connection.

Methods inherited from class com.inductiveautomation.ignition.gateway.storeforward.sinks.AbstractDatasourceSink

getDatasource, getQueryCache, isDatasourceAvailable, onInitialize, onShutdown, onStartup, onStorageFailure, onUninitialize, runFirstTimeChecks, storeData, storeToDatasource, useBatching

Methods inherited from class com.inductiveautomation.ignition.gateway.storeforward.sinks.AbstractSink

createLogger, getContext, getFaultError, getInfo, getLogger, getMetricPrefix, getStorageKey, getSupportedFlavor, getWriter, initialize, isAccepting, markStoreMetric, onFailure, shutdown, startup, toString, uninitialize, updateStatus, validateFlavor

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.inductiveautomation.ignition.gateway.storeforward.DataConsumer

storeData

Constructor Details

DatasourceQuerySink

public DatasourceQuerySink(GatewayContext context,
 String dataSource)

Creates a new instance of this sink with the specified context and datasource. The default flavor for QuerySFData will be used as the sink's supported flavor.

Parameters:

context - the gateway context

dataSource - the data source to execute the underling queries within QuerySFData

Method Details

storeToConnection

protected void storeToConnection(SRConnection conn,
 List<QuerySFData> querySFData)
                          throws Exception

Description copied from class: AbstractDatasourceSink

Stores the given data to the specified connection.

Specified by:

storeToConnection in class AbstractDatasourceSink<QuerySFData>

Parameters:

conn - the connection to store the data to

querySFData - the data to be stored

Throws:

Exception - if there is an error storing the data

getTypeDescription

@Nonnull
protected LocalizedString getTypeDescription()

Specified by:

getTypeDescription in class AbstractSink<QuerySFData>