edu.sc.seis.fissuresUtil.database
Class DBDataCenter

java.lang.Object
  edu.sc.seis.fissuresUtil.database.DBDataCenter

All Implemented Interfaces:

DataCenterOperations, LocalDCOperations

public class DBDataCenter
extends java.lang.Object
implements DataCenterOperations, LocalDCOperations

DBDataCenter.java Created: Tue Feb 4 10:55:16 2003

Method Summary

RequestFilter[]	available_data(RequestFilter[] a_filterseq)
void	cancel_request(java.lang.String a_request)
static DBDataCenter	getDataCenter(java.lang.String directoryName, java.lang.String databaseName)
static DBDataCenter	getDataCenter(java.lang.String directoryName, java.lang.String databaseName, DataCenterOperations dataCenterRouter)
java.lang.String	getFileIds(ChannelId channelId, MicroSecondDate beginDate, MicroSecondDate endDate)
LocalSeismogram	getSeismogram(java.lang.String fileIds)
java.lang.String	queue_seismograms(RequestFilter[] a_filterseq)
java.lang.String	request_seismograms(RequestFilter[] a_filterseq, DataCenterCallBack a_client, boolean long_lived, Time expiration_time)
java.lang.String	request_seismograms(RequestFilter[] a_filterseq, LocalDataCenterCallBack a_client, SeisDataChangeListener initiator, boolean long_lived, Time expiration_time) if long_lived is true then the request is "sticky" in that the client wants the data center to return not just the data that it has in its archive currently, but also any data that it receives up to the expiration_time.
java.lang.String	request_status(java.lang.String a_request)
static java.lang.String	requestToString(RequestFilter[] a_filterseq)
LocalSeismogram[]	retrieve_queue(java.lang.String a_request)
LocalSeismogram[]	retrieve_seismograms(RequestFilter[] a_filterseq)

Methods inherited from class java.lang.Object

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

Method Detail

getDataCenter

public static DBDataCenter getDataCenter(java.lang.String directoryName,
                                         java.lang.String databaseName,
                                         DataCenterOperations dataCenterRouter)
                                  throws java.sql.SQLException

Throws:

java.sql.SQLException

getDataCenter

public static DBDataCenter getDataCenter(java.lang.String directoryName,
                                         java.lang.String databaseName)
                                  throws java.sql.SQLException

Throws:

java.sql.SQLException

available_data

public RequestFilter[] available_data(RequestFilter[] a_filterseq)

Specified by:

available_data in interface DataCenterOperations

Specified by:

available_data in interface LocalDCOperations

request_seismograms

public java.lang.String request_seismograms(RequestFilter[] a_filterseq,
                                            DataCenterCallBack a_client,
                                            boolean long_lived,
                                            Time expiration_time)

Specified by:

request_seismograms in interface DataCenterOperations

request_seismograms

public java.lang.String request_seismograms(RequestFilter[] a_filterseq,
                                            LocalDataCenterCallBack a_client,
                                            SeisDataChangeListener initiator,
                                            boolean long_lived,
                                            Time expiration_time)

if long_lived is true then the request is "sticky" in that the client wants the data center to return not just the data that it has in its archive currently, but also any data that it receives up to the expiration_time. For instance if a station sends its data by mailing tapes, then a researcher could issue a request for data that is expected to be delivered from a recent earthquake, even thought the data center does not yet have the data. Note that expiration_time is ignored if long_lived is false.

Specified by:

request_seismograms in interface LocalDCOperations

retrieve_seismograms

public LocalSeismogram[] retrieve_seismograms(RequestFilter[] a_filterseq)
                                       throws FissuresException

Specified by:

retrieve_seismograms in interface DataCenterOperations

Specified by:

retrieve_seismograms in interface LocalDCOperations

Throws:

FissuresException

requestToString

public static java.lang.String requestToString(RequestFilter[] a_filterseq)

queue_seismograms

public java.lang.String queue_seismograms(RequestFilter[] a_filterseq)

Specified by:

queue_seismograms in interface DataCenterOperations

Specified by:

queue_seismograms in interface LocalDCOperations

retrieve_queue

public LocalSeismogram[] retrieve_queue(java.lang.String a_request)

Specified by:

retrieve_queue in interface DataCenterOperations

Specified by:

retrieve_queue in interface LocalDCOperations

cancel_request

public void cancel_request(java.lang.String a_request)

Specified by:

cancel_request in interface DataCenterOperations

Specified by:

cancel_request in interface LocalDCOperations

request_status

public java.lang.String request_status(java.lang.String a_request)

Specified by:

request_status in interface DataCenterOperations

Specified by:

request_status in interface LocalDCOperations

getFileIds

public java.lang.String getFileIds(ChannelId channelId,
                                   MicroSecondDate beginDate,
                                   MicroSecondDate endDate)
                            throws java.sql.SQLException

Throws:

java.sql.SQLException

getSeismogram

public LocalSeismogram getSeismogram(java.lang.String fileIds)
                              throws java.sql.SQLException,
                                     java.io.IOException,
                                     FissuresException

Throws:

java.sql.SQLException

java.io.IOException

FissuresException