|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.edg.info.InstanceBase
org.edg.info.DeclarableInstance
org.edg.info.InsertableInstance
org.edg.info.CleanableInstance
Base class for database (history and latest) producers.
Nested Class Summary | |
class |
CleanableInstance.CleanUpThread
Thread used to clean up database in DBProducer |
Field Summary | |
static java.lang.String |
s_dbAdminDriver
Driver for the admin database. |
static java.lang.String |
s_dbAdminPassword
Password of the admin user. |
static java.lang.String |
s_dbAdminURL
DB URL of the main admin user (required to create new databases). |
static java.lang.String |
s_dbAdminUserName
Username of the admin user. |
Fields inherited from class org.edg.info.InstanceBase |
DEFAULT_TERMINATION_INTERVAL_MS, s_maxTerminationInterval, s_minTerminationInterval |
Method Summary | |
void |
abort(java.lang.String consumerURL,
int consumerId)
Aborts the one-time query belonging to the specified consumer. |
void |
declareTable(java.lang.String tableName,
java.lang.String predicate,
int hrpSec,
int lrpSec)
Declares table in Registry (via call to supertype) and creates table in database. |
void |
declareTable(java.lang.String tableName,
java.lang.String predicate,
java.lang.String cleanUpPredicate,
long cleanUpInterval,
int hrpSec,
int lrpSec)
Declares a table in this producer. |
void |
destroy()
Destroys a CleanableInstance. |
org.glite.rgma.system.ResultSet |
execute(java.lang.String select)
Deprecated. |
void |
execute(java.lang.String select,
java.lang.String consumerURL,
int consumerId,
java.lang.String streamingUrl,
int streamingPort,
long timeoutMS,
int consumerBufferSize)
Executes the specified SQL SELECT statement on this producer and sends the results to the specified consumer via streaming. |
void |
undeclareTable(java.lang.String tableName)
Deprecated. |
Methods inherited from class org.edg.info.DeclarableInstance |
declareTable, getProducerType, updateRegistry |
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
public static java.lang.String s_dbAdminURL
public static java.lang.String s_dbAdminPassword
public static java.lang.String s_dbAdminUserName
public static java.lang.String s_dbAdminDriver
Method Detail |
public void declareTable(java.lang.String tableName, java.lang.String predicate, int hrpSec, int lrpSec) throws org.glite.rgma.system.RGMAUserException, org.glite.rgma.system.RGMAInternalException
declareTable
in class InsertableInstance
tableName
- Name of table to declarepredicate
- Predicate (can be empty string)hrpSec
- History retention period (in seconds).lrpSec
- Latest retention period (in seconds).
org.glite.rgma.system.RGMAUserException
org.glite.rgma.system.RGMAInternalException
DeclarableInstance.declareTable(String, String)
public void execute(java.lang.String select, java.lang.String consumerURL, int consumerId, java.lang.String streamingUrl, int streamingPort, long timeoutMS, int consumerBufferSize) throws org.glite.rgma.system.RGMAException
select
- SQL SELECT queryconsumerURL
- URL of Consumer; used to uniquely identify this execution.consumerId
- ID of consumer to send data.streamingUrl
- URL to stream data.streamingPort
- Port to stream data.
org.glite.rgma.system.RGMAException
public org.glite.rgma.system.ResultSet execute(java.lang.String select) throws org.glite.rgma.system.RGMAException
select
- the sql select query
org.glite.rgma.system.RGMAException
- if the instance is disconnected; if there's a
problem with the query.public void destroy()
destroy
in class InsertableInstance
public void declareTable(java.lang.String tableName, java.lang.String predicate, java.lang.String cleanUpPredicate, long cleanUpInterval, int hrpSec, int lrpSec) throws org.glite.rgma.system.RGMAException
tableName
- Name of table.predicate
- SQL WHERE clause.cleanUpPredicate
- Clean-up WHERE clause.cleanUpInterval
- Clean-up interval (in millis).hrpSec
- History retention period (in seconds).lrpSec
- Latest retention period (in seconds).
org.glite.rgma.system.RGMAException
public void undeclareTable(java.lang.String tableName) throws org.glite.rgma.system.RGMAException
undeclareTable
in class DeclarableInstance
tableName
- Name of table to undeclare
org.glite.rgma.system.RGMAException
public void abort(java.lang.String consumerURL, int consumerId)
consumerURL
- consumerId
-
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |