org.rvpf.store.server.the.sql

Class Updater

Object

Updater

public final class Updater
extends Object

Updater.

Constructor Summary

Constructors

Constructor and Description
Updater(TheStoreConnection connection, boolean dropDeleted) Constructs an instance.

Method Summary

Modifier and Type	Method and Description
void	close() Closes.
void	commit() Commits.
int	delete(VersionedValue versionedValue) Deletes a point value.
TheStoreConnection	getConnection() Gets the store connection.
int	purge(UUID pointUUID, TimeInterval timeInterval) Purges values of a point.
void	rollback() Rolls back.
void	update(VersionedValue versionedValue) Updates a value.

Methods inherited from class Object

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

Constructor Detail

Updater

public Updater(@Nonnull
               TheStoreConnection connection,
               boolean dropDeleted)

Constructs an instance.

Parameters:

connection - The connection to use for database services.

dropDeleted - The drop deleted indicator.

Method Detail

close

public void close()

Closes.

commit

public void commit()

Commits.

delete

@CheckReturnValue
public int delete(@Nonnull
                                     VersionedValue versionedValue)

Deletes a point value.

Parameters:

versionedValue - The point value to delete.

Returns:

True if there was a value to delete.

getConnection

@Nonnull
 @CheckReturnValue
public TheStoreConnection getConnection()

Gets the store connection.

Returns:

The store connection.

purge

@CheckReturnValue
public int purge(@Nonnull
                                    UUID pointUUID,
                                    @Nonnull
                                    TimeInterval timeInterval)

Purges values of a point.

Parameters:

pointUUID - The UUID of the point.

timeInterval - The purge interval.

Returns:

The number of values purged.

rollback

public void rollback()

Rolls back.

update

public void update(@Nonnull
                   VersionedValue versionedValue)

Updates a value.

Parameters:

versionedValue - The new Point value.