jp.ac.tokushima_u.db.logistics

Class ExtRDBCluster<R extends ExtRDB>

java.lang.Object

java.lang.Thread

jp.ac.tokushima_u.db.common.SharableResource.Cluster<R>

jp.ac.tokushima_u.db.common.PgRDB.Cluster<R>

jp.ac.tokushima_u.db.logistics.ExtRDBCluster<R>

All Implemented Interfaces:

Runnable

public class ExtRDBCluster<R extends ExtRDB>
extends PgRDB.Cluster<R>

Handle RDB data retrieved from External Database.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ExtRDBCluster.TableInf

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
(package private) List<String>	rdbURLs

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
ExtRDBCluster(PgRDB.RDBCreator<R> creator, List<String> urls, int num, long ttp)

Method Summary

Modifier and Type	Method and Description
void	defineTable(ExtRDBCluster.TableInf table)
void	flushAll() Flush buffered rows for all tables.
boolean	idlingAll() Execute idling jobs.
String	retrieve1value(PgRDB.Column column, PgRDB.From from, PgRDB.Where where) Retrieve 1 value.
void	sweepAll(long before) Sweep old rows for all tables.

Methods inherited from class jp.ac.tokushima_u.db.common.PgRDB.Cluster

count, count, createIndex, createIndex, createTable, createTable, deleteAndInsert, deleteAndInsert, deleteAndMultipleInsert, deleteFrom, deleteFrom, dropTable, executeCommand, executeCommandOutsideOfTransaction, exists, grantTableTo, insertInto, insertInto, max, min, multipleDeleteAndInsert, multipleInsertInto, releaseRDB, reserveRDB, select, select, select1, select1, select1row, select1row, vacuum, vacuum

Methods inherited from class jp.ac.tokushima_u.db.common.SharableResource.Cluster

add, addAll, releaseResource, reserveResource, run, terminate

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

rdbURLs

List<String> rdbURLs

Constructor Detail

ExtRDBCluster

ExtRDBCluster(PgRDB.RDBCreator<R> creator,
              List<String> urls,
              int num,
              long ttp)

Method Detail

defineTable

public void defineTable(ExtRDBCluster.TableInf table)

idlingAll

public boolean idlingAll()

Execute idling jobs.

Returns:

There are extra idling jobs.

flushAll

public void flushAll()

Flush buffered rows for all tables.

sweepAll

public void sweepAll(long before)

Sweep old rows for all tables.

Parameters:

before - epoch time (milliseconds).

retrieve1value

public String retrieve1value(PgRDB.Column column,
                             PgRDB.From from,
                             PgRDB.Where where)

Retrieve 1 value.

Parameters:

column - Column

from - from phrase

where - condition

Returns:

Value String. If there is no value which the specified condtion are satisfied, return null.