votorola.a.diff.harvest.cache

Class DiffMessageTable

java.lang.Object

DiffMessageTable

@ThreadSafe
public final class DiffMessageTable
extends Object

The relational store for diff messages. This class automatically creates the necessary table if it does not exist and basically hides away the database layer. Note: It throws errors on double insertions.

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_RESULTS Maximum rows in the result.
static String	SCHEMA_NAME This is only exposed as a quick hint for somebody trying to understand the database structure.
static String	TABLE_NAME This is only exposed as a quick hint for somebody trying to understand the database structure.

Constructor Summary

Constructors

Constructor and Description
DiffMessageTable(Database database) Constructs a Table.

Method Summary

Methods

Modifier and Type	Method and Description
(package private) void	create() Creates this table in the database.
(package private) void	drop() Drops this table from the database.
boolean	exists() Returns true if this table exists in the database; false otherwise.
ResultSet	get(String poll, String[] users, int id) Query the table for the parameters.
(package private) Database	getDatabase() Returns the database in which this table is stored.
(package private) void	put(AuthDiffMessage authMsg) Stores a message.
int	removeArchive(String archiveUrl) Remove all stored messages for an archive selected by its archive url.

Methods inherited from class java.lang.Object

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

Field Detail

SCHEMA_NAME

@Warning(value="non-Api")
public static final String SCHEMA_NAME

This is only exposed as a quick hint for somebody trying to understand the database structure. This value might change.

See Also:

Constant Field Values

TABLE_NAME

@Warning(value="non-Api")
public static final String TABLE_NAME

This is only exposed as a quick hint for somebody trying to understand the database structure. This value might change.

See Also:

Constant Field Values

MAX_RESULTS

@Warning(value="non-Api")
public static final int MAX_RESULTS

Maximum rows in the result. This should match the maximum client fetch length.

See Also:

Constant Field Values

Constructor Detail

DiffMessageTable

DiffMessageTable(Database database)
           throws SQLException

Constructs a Table.

Parameters:

database - Database to connect to.

Throws:

SQLException

NoSuchAlgorithmException

Method Detail

create

void create()
      throws SQLException

Creates this table in the database.

Throws:

SQLException

getDatabase

Database getDatabase()

Returns the database in which this table is stored.

Returns:

This objects database.

drop

void drop()
    throws SQLException

Drops this table from the database.

Throws:

SQLException

exists

public boolean exists()
               throws SQLException

Returns true if this table exists in the database; false otherwise.

Returns:

whether database already exists or not.

Throws:

SQLException

get

@ThreadRestricted(value="rs holds lock on database")
public ResultSet get(String poll,
                                  String[] users,
                                  int id)
              throws SQLException,
                     AddressException

Query the table for the parameters. Order is: id, author, addressee, pollname, content, archive_url, path, sent_ts, a, ar, b, br, selectand

Parameters:

poll - poll-name

users - mailish-username of one or two users

id - only fetch posts newer than id

Returns:

rs ResultSet with newest first.

Throws:

SQLException

AddressException

put

void put(AuthDiffMessage authMsg)
   throws SQLException

Stores a message. This throws an exception on double insert attempts on the primary key, which consists author,addresse,url and sentDate

Throws:

SQLException

removeArchive

public int removeArchive(String archiveUrl)
                  throws SQLException

Remove all stored messages for an archive selected by its archive url.

Parameters:

archiveUrl -

Returns:

number of removed messages

Throws:

SQLException