com.inductiveautomation.gateway.tags.history.processing

Class SimpleDBTagHistoryWriter

java.lang.Object

com.inductiveautomation.gateway.tags.history.processing.SimpleDBTagHistoryWriter

All Implemented Interfaces:

DataHandler

public class SimpleDBTagHistoryWriter
extends java.lang.Object
implements DataHandler

Stores tag values to history partition tables. Supports both raw and optimized table formats.

Constructor Summary

Constructors

Constructor and Description
SimpleDBTagHistoryWriter(ConnectionProvider<? extends java.sql.Connection> connProvider, java.lang.String targetTable, boolean writeValType) Initializes the writer.
SimpleDBTagHistoryWriter(ConnectionProvider<? extends java.sql.Connection> connProvider, java.lang.String targetTable, boolean writeValType, java.lang.String dbQuoteChar)

Method Summary

Modifier and Type	Method and Description
void	flush() Indicate that the handler won't get any more data, at least for a while.
protected org.apache.log4j.Logger	getLogger()
void	putValue(RawTagValue inValue) Insert a value into the handler.
protected void	runBatch(java.util.List<RawTagValue> values)
void	setCommitTimeout(int ms) Sets how frequently commits will be made.

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleDBTagHistoryWriter

public SimpleDBTagHistoryWriter(ConnectionProvider<? extends java.sql.Connection> connProvider,
                                java.lang.String targetTable,
                                boolean writeValType)

Initializes the writer.

Parameters:

connProvider -

targetTable -

writeValType - if TRUE, the value type column will be written as well (for optimized tables). Raw tables will use FALSE.

SimpleDBTagHistoryWriter

public SimpleDBTagHistoryWriter(ConnectionProvider<? extends java.sql.Connection> connProvider,
                                java.lang.String targetTable,
                                boolean writeValType,
                                java.lang.String dbQuoteChar)

Method Detail

setCommitTimeout

public void setCommitTimeout(int ms)

Sets how frequently commits will be made. If 0, will only be committed when the commit record count is reached, or flush is called.

Parameters:

ms -

getLogger

protected org.apache.log4j.Logger getLogger()

putValue

public void putValue(RawTagValue inValue)
              throws java.lang.Exception

Description copied from interface: DataHandler

Insert a value into the handler.

Specified by:

putValue in interface DataHandler

Throws:

java.lang.Exception

runBatch

protected void runBatch(java.util.List<RawTagValue> values)
                 throws java.lang.Exception

Throws:

java.lang.Exception

flush

public void flush()
           throws java.lang.Exception

Description copied from interface: DataHandler

Indicate that the handler won't get any more data, at least for a while.

Specified by:

flush in interface DataHandler

Throws:

java.lang.Exception