com.serotonin.mango.db.dao

Class PointValueDao

java.lang.Object

com.serotonin.db.DaoUtils

com.serotonin.mango.db.dao.BaseDao

com.serotonin.mango.db.dao.PointValueDao

public class PointValueDao
extends BaseDao

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	PointValueDao.BatchWriteBehind
(package private) class	PointValueDao.BatchWriteBehindEntry
(package private) class	PointValueDao.IdPointValueRowMapper Note: this does not extract source information from the annotation.
(package private) class	PointValueDao.PointValueRowMapper
(package private) class	PointValueDao.UnsavedPointValue Class that stored point value data when it could not be saved to the database due to concurrency errors.

Field Summary

Fields

Modifier and Type	Field and Description
private static org.apache.commons.logging.Log	LOG
private static java.lang.String	POINT_ID_VALUE_SELECT
private static java.lang.String	POINT_VALUE_ANNOTATION_INSERT
private static java.lang.String	POINT_VALUE_INSERT
private static java.lang.String	POINT_VALUE_INSERT_START
private static java.lang.String	POINT_VALUE_INSERT_VALUES
private static int	POINT_VALUE_INSERT_VALUES_COUNT
private static java.lang.String	POINT_VALUE_SELECT
private static java.util.List<PointValueDao.UnsavedPointValue>	UNSAVED_POINT_VALUES

Fields inherited from class com.serotonin.db.DaoUtils

dataSource, ejt, tm

Constructor Summary

Constructors

Constructor and Description
PointValueDao()
PointValueDao(javax.sql.DataSource dataSource)

Method Summary

Modifier and Type	Method and Description
private void	clearUnsavedPointValues()
void	compressTables()
(package private) MangoValue	createMangoValue(java.sql.ResultSet rs, int firstParameter)
long	dateRangeCount(int dataPointId, long from, long to)
long	deleteAllPointData()
long	deletePointValues(int dataPointId)
private long	deletePointValues(java.lang.String sql, java.lang.Object[] params)
long	deletePointValuesBefore(int dataPointId, long time)
long	deletePointValuesWithMismatchedType(int dataPointId, int dataType)
void	executeBatchUpdate(java.lang.String sql, java.lang.Object[][] params)
long	getEndTime(java.util.List<java.lang.Integer> dataPointIds)
java.util.List<java.lang.Long>	getFiledataIds()
long	getInceptionDate(int dataPointId)
PointValueTime	getLatestPointValue(int dataPointId)
java.util.List<PointValueTime>	getLatestPointValues(int dataPointId, int limit)
java.util.List<PointValueTime>	getLatestPointValues(int dataPointId, int limit, long before)
private PointValueTime	getPointValue(long id)
PointValueTime	getPointValueAt(int dataPointId, long time)
PointValueTime	getPointValueBefore(int dataPointId, long time)
java.util.List<PointValueTime>	getPointValues(int dataPointId, long since)
java.util.List<PointValueTime>	getPointValuesBetween(int dataPointId, long from, long to)
void	getPointValuesBetween(int dataPointId, long from, long to, com.serotonin.db.MappedRowCallback<PointValueTime> callback)
void	getPointValuesBetween(java.util.List<java.lang.Integer> dataPointIds, long from, long to, com.serotonin.db.MappedRowCallback<IdPointValueTime> callback)
LongPair	getStartAndEndTime(java.util.List<java.lang.Integer> dataPointIds)
long	getStartTime(java.util.List<java.lang.Integer> dataPointIds)
private PointValueTime	pointValueQuery(java.lang.String sql, java.lang.Object[] params)
private java.util.List<PointValueTime>	pointValuesQuery(java.lang.String sql, java.lang.Object[] params, int limit)
(package private) long	savePointValue(int pointId, int dataType, double dvalue, long time, java.lang.String svalue, SetPointSource source, boolean async)
void	savePointValue(int pointId, PointValueTime pointValue)
void	savePointValueAsync(int pointId, PointValueTime pointValue, SetPointSource source) Only the PointValueCache should call this method during runtime.
private long	savePointValueImpl(int pointId, int dataType, double dvalue, long time, java.lang.String svalue, SetPointSource source)
(package private) long	savePointValueImpl(int pointId, PointValueTime pointValue, SetPointSource source, boolean async)
PointValueTime	savePointValueSync(int pointId, PointValueTime pointValue, SetPointSource source) Only the PointValueCache should call this method during runtime.
private void	updateAnnotations(java.util.List<PointValueTime> values)
private void	updateAnnotations(java.lang.String sql, java.util.Map<java.lang.Integer,java.util.List<AnnotatedPointValueTime>> idMap)

Methods inherited from class com.serotonin.mango.db.dao.BaseDao

boolToChar, charToBool, deleteInChunks, doInsert, doInsert, doInsert, doInsertLong, doInsertLong, doInsertLong, generateUniqueXid, getGeneratedKeyName, getPreparedStatementCreator, isXidUnique

Methods inherited from class com.serotonin.db.DaoUtils

batchUpdate, createDelimitedList, createDelimitedList, createDelimitedList, createIntValuePairs, createKeyValuePairs, dbEncodeSearchString, getInt, getTransactionManager, getTransactionTemplate, now, query, query, query, query, query, query, queryForList, queryForList, queryForObject, queryForObject, queryForObject, setInt

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.apache.commons.logging.Log LOG

UNSAVED_POINT_VALUES

private static java.util.List<PointValueDao.UnsavedPointValue> UNSAVED_POINT_VALUES

POINT_VALUE_INSERT_START

private static final java.lang.String POINT_VALUE_INSERT_START

See Also:

Constant Field Values

POINT_VALUE_INSERT_VALUES

private static final java.lang.String POINT_VALUE_INSERT_VALUES

See Also:

Constant Field Values

POINT_VALUE_INSERT_VALUES_COUNT

private static final int POINT_VALUE_INSERT_VALUES_COUNT

See Also:

Constant Field Values

POINT_VALUE_INSERT

private static final java.lang.String POINT_VALUE_INSERT

See Also:

Constant Field Values

POINT_VALUE_ANNOTATION_INSERT

private static final java.lang.String POINT_VALUE_ANNOTATION_INSERT

See Also:

Constant Field Values

POINT_VALUE_SELECT

private static final java.lang.String POINT_VALUE_SELECT

See Also:

Constant Field Values

POINT_ID_VALUE_SELECT

private static final java.lang.String POINT_ID_VALUE_SELECT

See Also:

Constant Field Values

Constructor Detail

PointValueDao

public PointValueDao()

PointValueDao

public PointValueDao(javax.sql.DataSource dataSource)

Method Detail

savePointValueSync

public PointValueTime savePointValueSync(int pointId,
                                         PointValueTime pointValue,
                                         SetPointSource source)

Only the PointValueCache should call this method during runtime. Do not use.

savePointValueAsync

public void savePointValueAsync(int pointId,
                                PointValueTime pointValue,
                                SetPointSource source)

Only the PointValueCache should call this method during runtime. Do not use.

savePointValueImpl

long savePointValueImpl(int pointId,
                        PointValueTime pointValue,
                        SetPointSource source,
                        boolean async)

clearUnsavedPointValues

private void clearUnsavedPointValues()

savePointValue

public void savePointValue(int pointId,
                           PointValueTime pointValue)

savePointValue

long savePointValue(int pointId,
                    int dataType,
                    double dvalue,
                    long time,
                    java.lang.String svalue,
                    SetPointSource source,
                    boolean async)

savePointValueImpl

private long savePointValueImpl(int pointId,
                                int dataType,
                                double dvalue,
                                long time,
                                java.lang.String svalue,
                                SetPointSource source)

getPointValues

public java.util.List<PointValueTime> getPointValues(int dataPointId,
                                                     long since)

getPointValuesBetween

public java.util.List<PointValueTime> getPointValuesBetween(int dataPointId,
                                                            long from,
                                                            long to)

getLatestPointValues

public java.util.List<PointValueTime> getLatestPointValues(int dataPointId,
                                                           int limit)

getLatestPointValues

public java.util.List<PointValueTime> getLatestPointValues(int dataPointId,
                                                           int limit,
                                                           long before)

getLatestPointValue

public PointValueTime getLatestPointValue(int dataPointId)

getPointValue

private PointValueTime getPointValue(long id)

getPointValueBefore

public PointValueTime getPointValueBefore(int dataPointId,
                                          long time)

getPointValueAt

public PointValueTime getPointValueAt(int dataPointId,
                                      long time)

pointValueQuery

private PointValueTime pointValueQuery(java.lang.String sql,
                                       java.lang.Object[] params)

pointValuesQuery

private java.util.List<PointValueTime> pointValuesQuery(java.lang.String sql,
                                                        java.lang.Object[] params,
                                                        int limit)

getPointValuesBetween

public void getPointValuesBetween(int dataPointId,
                                  long from,
                                  long to,
                                  com.serotonin.db.MappedRowCallback<PointValueTime> callback)

createMangoValue

MangoValue createMangoValue(java.sql.ResultSet rs,
                            int firstParameter)
                     throws java.sql.SQLException

Throws:

java.sql.SQLException

updateAnnotations

private void updateAnnotations(java.util.List<PointValueTime> values)

updateAnnotations

private void updateAnnotations(java.lang.String sql,
                               java.util.Map<java.lang.Integer,java.util.List<AnnotatedPointValueTime>> idMap)

getPointValuesBetween

public void getPointValuesBetween(java.util.List<java.lang.Integer> dataPointIds,
                                  long from,
                                  long to,
                                  com.serotonin.db.MappedRowCallback<IdPointValueTime> callback)

deletePointValuesBefore

public long deletePointValuesBefore(int dataPointId,
                                    long time)

deletePointValues

public long deletePointValues(int dataPointId)

deleteAllPointData

public long deleteAllPointData()

deletePointValuesWithMismatchedType

public long deletePointValuesWithMismatchedType(int dataPointId,
                                                int dataType)

compressTables

public void compressTables()

deletePointValues

private long deletePointValues(java.lang.String sql,
                               java.lang.Object[] params)

dateRangeCount

public long dateRangeCount(int dataPointId,
                           long from,
                           long to)

getInceptionDate

public long getInceptionDate(int dataPointId)

getStartTime

public long getStartTime(java.util.List<java.lang.Integer> dataPointIds)

getEndTime

public long getEndTime(java.util.List<java.lang.Integer> dataPointIds)

getStartAndEndTime

public LongPair getStartAndEndTime(java.util.List<java.lang.Integer> dataPointIds)

getFiledataIds

public java.util.List<java.lang.Long> getFiledataIds()

executeBatchUpdate

public void executeBatchUpdate(java.lang.String sql,
                               java.lang.Object[][] params)