Modifier and Type | Class and Description |
---|---|
protected class |
SQLiteHistorian.Query |
protected class |
SQLiteHistorian.SQLiteStorageSession |
protected static class |
SQLiteHistorian.Tables |
protected static class |
SQLiteHistorian.Tag |
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
DRIVER_CLASS |
static Property<java.lang.String> |
FILE_PATH |
static Property<java.lang.Boolean> |
IN_MEMORY_DB |
static Property<java.lang.Integer> |
MAX_BATCH_SIZE |
QUALITY_NOT_FOUND
Constructor and Description |
---|
SQLiteHistorian() |
SQLiteHistorian(java.lang.String filePath) |
Modifier and Type | Method and Description |
---|---|
java.util.List<java.lang.String> |
browse(java.util.Optional<java.lang.String> filter)
Returns a list of paths with data stored, optionally matching a filter.
|
StorageSession |
createStorageSession()
Used to store values to the historian.
|
void |
delete(java.util.List<java.lang.String> paths)
Deletes the tags and all data for the specified paths.
|
void |
executeMaintenance() |
protected java.sql.Connection |
getConnection() |
Status |
getQueryStatus()
Returns the status of the storage system.
|
Status |
getStorageStatus()
Returns the status of the storage system.
|
long |
getTotalDataCount()
Returns an estimate of the total number of datapoints in the system.
|
void |
initDriver() |
void |
initialize(PropertySet properties) |
QueryResult |
query(java.util.List<java.lang.String> tags,
long startTime,
long endTime)
Queries the values for the given paths over the specified span of time.
|
void |
register(java.lang.String tag,
PropertySet properties)
Provides information about a path.
|
protected static java.lang.Object |
runPrepScalarQuery(java.sql.Connection c,
java.lang.String query,
java.lang.Object... args) |
protected static int |
runPrepUpdateQuery(java.sql.Connection c,
java.lang.String query,
java.lang.Object... args) |
protected static java.lang.Object |
runScalarQuery(java.sql.Connection c,
java.lang.String query) |
protected static int |
runUpdateQuery(java.sql.Connection c,
java.lang.String query) |
void |
shutdown() |
public static final Property<java.lang.String> FILE_PATH
public static final Property<java.lang.Boolean> IN_MEMORY_DB
public static final Property<java.lang.Integer> MAX_BATCH_SIZE
public static final java.lang.String DRIVER_CLASS
public SQLiteHistorian()
public SQLiteHistorian(java.lang.String filePath)
public long getTotalDataCount()
Historian
getTotalDataCount
in interface Historian
public Status getQueryStatus()
Historian
getQueryStatus
in interface Historian
public Status getStorageStatus()
Historian
getStorageStatus
in interface Historian
protected java.sql.Connection getConnection() throws java.sql.SQLException
java.sql.SQLException
public void initDriver() throws java.lang.Exception
java.lang.Exception
public void initialize(PropertySet properties) throws java.lang.Exception
initialize
in interface Historian
java.lang.Exception
public void register(java.lang.String tag, PropertySet properties)
Historian
public StorageSession createStorageSession() throws java.lang.Exception
Historian
createStorageSession
in interface Historian
java.lang.Exception
public java.util.List<java.lang.String> browse(java.util.Optional<java.lang.String> filter)
Historian
public void delete(java.util.List<java.lang.String> paths)
Historian
public QueryResult query(java.util.List<java.lang.String> tags, long startTime, long endTime)
Historian
public void executeMaintenance()
protected static int runUpdateQuery(java.sql.Connection c, java.lang.String query) throws java.sql.SQLException
java.sql.SQLException
protected static int runPrepUpdateQuery(java.sql.Connection c, java.lang.String query, java.lang.Object... args) throws java.sql.SQLException
java.sql.SQLException
protected static java.lang.Object runScalarQuery(java.sql.Connection c, java.lang.String query) throws java.sql.SQLException
java.sql.SQLException
protected static java.lang.Object runPrepScalarQuery(java.sql.Connection c, java.lang.String query, java.lang.Object... args) throws java.sql.SQLException
java.sql.SQLException