Class WeatherSocketStore

java.lang.Object

ecmwf.common.database.WeatherSocketStore

public final class WeatherSocketStore
extends Object

Transactional background store, cached schema capability and indexed transfer-detail provenance.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	WeatherSocketStore.Result

Constructor Summary

Constructors

Constructor	Description
WeatherSocketStore()

Method Summary

Modifier and Type	Method	Description
static void	checkConfigurationCapacity(String document)
void	checkSchema()
static void	checkSchema(Connection connection)	Read-only capability probe; never creates or alters production schema.
static void	decorate(long transferId, List<TransferStatistics> statistics)
static int	legacySendingIndex(long transferId, int candidate)
WeatherSocketStore.Result	persist(WeatherObservation observation)
static WeatherSocketStore.Result	write(Connection connection, WeatherObservation observation)	The caller owns commit/rollback.

Methods inherited from class Object

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

Constructor Details

WeatherSocketStore

public WeatherSocketStore()

Method Details

checkSchema

public void checkSchema()
                 throws SQLException

Throws:

SQLException

checkConfigurationCapacity

public static void checkConfigurationCapacity(String document)
                                       throws SQLException

Throws:

SQLException

decorate

public static void decorate(long transferId,
 List<TransferStatistics> statistics)

legacySendingIndex

public static int legacySendingIndex(long transferId,
 int candidate)

checkSchema

public static void checkSchema(Connection connection)
                        throws SQLException

Read-only capability probe; never creates or alters production schema.

Throws:

SQLException

persist

public WeatherSocketStore.Result persist(WeatherObservation observation)
                                  throws SQLException

Throws:

SQLException

write

public static WeatherSocketStore.Result write(Connection connection,
 WeatherObservation observation)
                                       throws SQLException

The caller owns commit/rollback. No explicit transfer-row lock or DDL; foreign keys still take engine locks.

Throws:

SQLException