|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use AbstractWriteRequest | |
org.objectweb.cjdbc.common.sql | SQL requests that are sent from the C-JDBC driver to the C-JDBC controller. |
org.objectweb.cjdbc.controller.cache.result | ResultCache is an implementation of the AbstractResultCache. |
org.objectweb.cjdbc.controller.loadbalancer | All C-JDBC load balancers are subpackage of this one which provides the load balancer interface and the core backend thread. |
org.objectweb.cjdbc.controller.loadbalancer.paralleldb | ParallelDB load balancers to use with parallel databases. |
org.objectweb.cjdbc.controller.loadbalancer.raidb0 | RAIDb-0 load balancers. |
org.objectweb.cjdbc.controller.loadbalancer.raidb1 | RAIDb-1 (full replication) load balancers. |
org.objectweb.cjdbc.controller.loadbalancer.raidb2 | RAIDb-2 (partial replication) load balancers. |
org.objectweb.cjdbc.controller.loadbalancer.singledb | Load balancer for single backend systems. |
org.objectweb.cjdbc.controller.loadbalancer.tasks | BackendWorkerThread tasks for distributed query execution. |
org.objectweb.cjdbc.controller.recoverylog | Recovery Log core. |
org.objectweb.cjdbc.controller.requestmanager | Request Manager core including the request parsing cache. |
org.objectweb.cjdbc.controller.requestmanager.distributed | Distributed implementation of the request manager. |
org.objectweb.cjdbc.controller.scheduler | All C-JDBC schedulers are subpackage of this one which provides the scheduler interface in the AbstractScheduler class. |
org.objectweb.cjdbc.controller.scheduler.raidb0 | RAIDb-0 schedulers. |
org.objectweb.cjdbc.controller.scheduler.raidb1 | RAIDb-1 (full replication) schedulers. |
org.objectweb.cjdbc.controller.scheduler.raidb2 | RAIDb-2 (partial replication) schedulers. |
org.objectweb.cjdbc.controller.scheduler.singledb | Schedulers for single backend system. |
org.objectweb.cjdbc.controller.virtualdatabase | Virtual database core code including connection handling. |
org.objectweb.cjdbc.controller.virtualdatabase.protocol | Differemt group messages for the distributed version of the virtual database. |
org.objectweb.cjdbc.driver | C-JDBC driver core. |
Uses of AbstractWriteRequest in org.objectweb.cjdbc.common.sql |
Subclasses of AbstractWriteRequest in org.objectweb.cjdbc.common.sql | |
class |
AlterRequest
This class defines a AlterRequest |
class |
CreateRequest
A CreateRequest is a SQL request of the following syntax:
CREATE [TEMPORARY] TABLE table-name [(column-name column-type [,column-name colum-type]* [,table-constraint-definition]*)]
|
class |
DeleteRequest
An DeleteRequest is an SQL request with the following syntax:
DELETE [table1,table2,...] |
class |
DropRequest
An DropRequest is an SQL request with the following syntax:
DROP TABLE table-name
|
class |
InsertRequest
An InsertRequest is an SQL request of the following syntax:
INSERT INTO table-name [(column-name[,column-name]*)] {VALUES (constant|null[,constant|null]*)}|{SELECT query}
VALUES |
class |
UpdateRequest
An UpdateRequest is an SQL request with the following syntax:
UPDATE table-name SET (column-name=expression[,column-name=expression]*) WHERE search-condition
|
Methods in org.objectweb.cjdbc.common.sql with parameters of type AbstractWriteRequest | |
protected void |
AbstractWriteRequest.cloneTableNameAndColumns(AbstractWriteRequest abstractWriteRequest)
Clones table name and columns from an already parsed request. |
Uses of AbstractWriteRequest in org.objectweb.cjdbc.controller.cache.result |
Methods in org.objectweb.cjdbc.controller.cache.result with parameters of type AbstractWriteRequest | |
protected void |
ResultCacheColumnUnique.processWriteNotify(AbstractWriteRequest request)
|
protected void |
ResultCacheColumn.processWriteNotify(AbstractWriteRequest request)
|
protected void |
ResultCacheDatabase.processWriteNotify(AbstractWriteRequest request)
|
void |
ResultCache.writeNotify(AbstractWriteRequest request)
Notifies the cache that this write request has been issued, so that cache coherency can be maintained. |
protected abstract void |
ResultCache.processWriteNotify(AbstractWriteRequest request)
Implementation specific invalidation of the cache. |
protected void |
ResultCacheTable.processWriteNotify(AbstractWriteRequest request)
|
abstract void |
AbstractResultCache.writeNotify(AbstractWriteRequest request)
Notifies the cache that the given write request has been issued, so that cache coherency can be maintained. |
Uses of AbstractWriteRequest in org.objectweb.cjdbc.controller.loadbalancer |
Methods in org.objectweb.cjdbc.controller.loadbalancer with parameters of type AbstractWriteRequest | |
abstract int |
AbstractLoadBalancer.execWriteRequest(AbstractWriteRequest request)
Perform a write request. |
abstract ControllerResultSet |
AbstractLoadBalancer.execWriteRequestWithKeys(AbstractWriteRequest request,
MetadataCache metadataCache)
Perform a write request and return a ResultSet containing the auto generated keys. |
static int |
AbstractLoadBalancer.executeUpdateRequestOnBackend(AbstractWriteRequest request,
DatabaseBackend backend,
java.sql.Connection c)
Execute an update prepared statement on a backend. |
static ControllerResultSet |
AbstractLoadBalancer.executeUpdateRequestOnBackendWithKeys(AbstractWriteRequest request,
DatabaseBackend backend,
java.sql.Connection c,
MetadataCache metadataCache)
Execute an update prepared statement on a backend. |
Uses of AbstractWriteRequest in org.objectweb.cjdbc.controller.loadbalancer.paralleldb |
Methods in org.objectweb.cjdbc.controller.loadbalancer.paralleldb with parameters of type AbstractWriteRequest | |
DatabaseBackend |
ParallelDB_RR.chooseBackendForWriteRequest(AbstractWriteRequest request)
Choose a backend using a round-robin algorithm for write request execution. |
DatabaseBackend |
ParallelDB_LPRF.chooseBackendForWriteRequest(AbstractWriteRequest request)
|
int |
ParallelDB.execWriteRequest(AbstractWriteRequest request)
|
ControllerResultSet |
ParallelDB.execWriteRequestWithKeys(AbstractWriteRequest request,
MetadataCache metadataCache)
|
private int |
ParallelDB.executeWriteRequestOnBackend(AbstractWriteRequest request,
DatabaseBackend backend)
Execute a write request on the selected backend. |
private ControllerResultSet |
ParallelDB.executeWriteRequestWithKeysOnBackend(AbstractWriteRequest request,
DatabaseBackend backend,
MetadataCache metadataCache)
Execute a write request on the selected backend and return the autogenerated keys. |
abstract DatabaseBackend |
ParallelDB.chooseBackendForWriteRequest(AbstractWriteRequest request)
Choose a backend using the implementation specific load balancing algorithm for write request execution. |
Uses of AbstractWriteRequest in org.objectweb.cjdbc.controller.loadbalancer.raidb0 |
Methods in org.objectweb.cjdbc.controller.loadbalancer.raidb0 with parameters of type AbstractWriteRequest | |
int |
RAIDb0.execWriteRequest(AbstractWriteRequest request)
Performs a write request on the backend that has the needed tables to executes the request. |
ControllerResultSet |
RAIDb0.execWriteRequestWithKeys(AbstractWriteRequest request,
MetadataCache metadataCache)
|
Uses of AbstractWriteRequest in org.objectweb.cjdbc.controller.loadbalancer.raidb1 |
Methods in org.objectweb.cjdbc.controller.loadbalancer.raidb1 with parameters of type AbstractWriteRequest | |
int |
RAIDb1.execWriteRequest(AbstractWriteRequest request)
Performs a write request. |
ControllerResultSet |
RAIDb1.execWriteRequestWithKeys(AbstractWriteRequest request,
MetadataCache metadataCache)
Perform a write request and return the auto generated keys. |
private AbstractTask |
RAIDb1.execWriteRequest(AbstractWriteRequest request,
boolean useKeys,
MetadataCache metadataCache)
Common code for execWriteRequest(AbstractWriteRequest) and execWriteRequestWithKeys(AbstractWriteRequest). |
Uses of AbstractWriteRequest in org.objectweb.cjdbc.controller.loadbalancer.raidb2 |
Methods in org.objectweb.cjdbc.controller.loadbalancer.raidb2 with parameters of type AbstractWriteRequest | |
int |
RAIDb2.execWriteRequest(AbstractWriteRequest request)
Performs a write request. |
ControllerResultSet |
RAIDb2.execWriteRequestWithKeys(AbstractWriteRequest request,
MetadataCache metadataCache)
Perform a write request and return the auto generated keys. |
private AbstractTask |
RAIDb2.execWriteRequest(AbstractWriteRequest request,
boolean useKeys,
MetadataCache metadataCache)
Common code for execWriteRequest(AbstractWriteRequest) and execWriteRequestWithKeys(AbstractWriteRequest). |
Uses of AbstractWriteRequest in org.objectweb.cjdbc.controller.loadbalancer.singledb |
Methods in org.objectweb.cjdbc.controller.loadbalancer.singledb with parameters of type AbstractWriteRequest | |
int |
SingleDB.execWriteRequest(AbstractWriteRequest request)
Performs a write request on the backend. |
ControllerResultSet |
SingleDB.execWriteRequestWithKeys(AbstractWriteRequest request,
MetadataCache metadataCache)
|
Uses of AbstractWriteRequest in org.objectweb.cjdbc.controller.loadbalancer.tasks |
Fields in org.objectweb.cjdbc.controller.loadbalancer.tasks declared as AbstractWriteRequest | |
private AbstractWriteRequest |
WriteRequestWithKeysTask.request
|
private AbstractWriteRequest |
WriteRequestTask.request
|
Constructors in org.objectweb.cjdbc.controller.loadbalancer.tasks with parameters of type AbstractWriteRequest | |
WriteRequestWithKeysTask(int nbToComplete,
int totalNb,
AbstractWriteRequest request,
MetadataCache metadataCache)
Creates a new WriteRequestTask . |
|
WriteRequestTask(int nbToComplete,
int totalNb,
AbstractWriteRequest request)
Creates a new WriteRequestTask . |
Uses of AbstractWriteRequest in org.objectweb.cjdbc.controller.recoverylog |
Methods in org.objectweb.cjdbc.controller.recoverylog with parameters of type AbstractWriteRequest | |
void |
JDBCRecoveryLog.logRequest(AbstractWriteRequest request)
|
abstract void |
AbstractRecoveryLog.logRequest(AbstractWriteRequest request)
Log a write request. |
Uses of AbstractWriteRequest in org.objectweb.cjdbc.controller.requestmanager |
Methods in org.objectweb.cjdbc.controller.requestmanager with parameters of type AbstractWriteRequest | |
int |
RequestManager.execWriteRequest(AbstractWriteRequest request)
Perform a write request and return the number of rows affected Call first the scheduler (if defined), then notify the cache (if defined) and finally call the load balancer. |
ControllerResultSet |
RequestManager.execWriteRequestWithKeys(AbstractWriteRequest request)
Perform a write request and return the auto generated keys. |
void |
RequestManager.scheduleExecWriteRequest(AbstractWriteRequest request)
Schedule a request for execution. |
ControllerResultSet |
RequestManager.loadBalanceExecWriteRequestWithKeys(AbstractWriteRequest request)
Send the given query to the load balancer. |
int |
RequestManager.loadBalanceExecWriteRequest(AbstractWriteRequest request)
Send the given query to the load balancer. |
void |
RequestManager.updateAndNotifyExecWriteRequest(AbstractWriteRequest request,
boolean notifyRecoveryLogAndScheduler)
Update the cache, notify the recovery log and finally the scheduler. |
Uses of AbstractWriteRequest in org.objectweb.cjdbc.controller.requestmanager.distributed |
Methods in org.objectweb.cjdbc.controller.requestmanager.distributed with parameters of type AbstractWriteRequest | |
int |
RAIDb2DistributedRequestManager.execDistributedWriteRequest(AbstractWriteRequest request)
|
ControllerResultSet |
RAIDb2DistributedRequestManager.execDistributedWriteRequestWithKeys(AbstractWriteRequest request)
|
void |
DistributedRequestManager.scheduleExecWriteRequest(AbstractWriteRequest request)
|
int |
DistributedRequestManager.execWriteRequest(AbstractWriteRequest request)
|
ControllerResultSet |
DistributedRequestManager.execWriteRequestWithKeys(AbstractWriteRequest request)
|
abstract int |
DistributedRequestManager.execDistributedWriteRequest(AbstractWriteRequest request)
Distributed implementation of a write request execution. |
abstract ControllerResultSet |
DistributedRequestManager.execDistributedWriteRequestWithKeys(AbstractWriteRequest request)
Distributed implementation of a write request execution that returns auto-generated keys. |
int |
RAIDb1DistributedRequestManager.execDistributedWriteRequest(AbstractWriteRequest request)
|
ControllerResultSet |
RAIDb1DistributedRequestManager.execDistributedWriteRequestWithKeys(AbstractWriteRequest request)
|
Uses of AbstractWriteRequest in org.objectweb.cjdbc.controller.scheduler |
Methods in org.objectweb.cjdbc.controller.scheduler with parameters of type AbstractWriteRequest | |
void |
AbstractScheduler.scheduleWriteRequest(AbstractWriteRequest request)
Schedule a write request. |
abstract void |
AbstractScheduler.scheduleNonSuspendedWriteRequest(AbstractWriteRequest request)
Schedule a write request (implementation specific). |
void |
AbstractScheduler.writeCompleted(AbstractWriteRequest request)
Notify the completion of a write statement. |
abstract void |
AbstractScheduler.notifyWriteCompleted(AbstractWriteRequest request)
Notify the completion of a write statement. |
Uses of AbstractWriteRequest in org.objectweb.cjdbc.controller.scheduler.raidb0 |
Methods in org.objectweb.cjdbc.controller.scheduler.raidb0 with parameters of type AbstractWriteRequest | |
void |
RAIDb0QueryLevelScheduler.scheduleNonSuspendedWriteRequest(AbstractWriteRequest request)
|
void |
RAIDb0QueryLevelScheduler.notifyWriteCompleted(AbstractWriteRequest request)
|
void |
RAIDb0PessimisticTransactionLevelScheduler.scheduleNonSuspendedWriteRequest(AbstractWriteRequest request)
Additionally to scheduling the request, this method replaces the SQL Date macros such as now() with the current date. |
void |
RAIDb0PessimisticTransactionLevelScheduler.notifyWriteCompleted(AbstractWriteRequest request)
|
Uses of AbstractWriteRequest in org.objectweb.cjdbc.controller.scheduler.raidb1 |
Methods in org.objectweb.cjdbc.controller.scheduler.raidb1 with parameters of type AbstractWriteRequest | |
void |
RAIDb1QueryLevelScheduler.scheduleNonSuspendedWriteRequest(AbstractWriteRequest request)
|
private void |
RAIDb1QueryLevelScheduler.waitForReadCompletion(AbstractWriteRequest request)
Wait for the reads completion. |
void |
RAIDb1QueryLevelScheduler.notifyWriteCompleted(AbstractWriteRequest request)
|
void |
RAIDb1PessimisticTransactionLevelScheduler.scheduleNonSuspendedWriteRequest(AbstractWriteRequest request)
Note that CREATE statements are not synchronized. |
void |
RAIDb1PessimisticTransactionLevelScheduler.notifyWriteCompleted(AbstractWriteRequest request)
|
void |
RAIDb1OptimisticTransactionLevelScheduler.scheduleNonSuspendedWriteRequest(AbstractWriteRequest request)
Additionally to scheduling the request, this method replaces the SQL Date macros such as now() with the current date. |
private void |
RAIDb1OptimisticTransactionLevelScheduler.acquireLockAndSetRequestId(AbstractWriteRequest request,
TransactionExclusiveLock tableLock)
|
void |
RAIDb1OptimisticTransactionLevelScheduler.notifyWriteCompleted(AbstractWriteRequest request)
|
void |
RAIDb1OptimisticQueryLevelScheduler.scheduleNonSuspendedWriteRequest(AbstractWriteRequest request)
Additionally to scheduling the request, this method replaces the SQL Date macros such as now() with the current date. |
void |
RAIDb1OptimisticQueryLevelScheduler.notifyWriteCompleted(AbstractWriteRequest request)
|
Uses of AbstractWriteRequest in org.objectweb.cjdbc.controller.scheduler.raidb2 |
Methods in org.objectweb.cjdbc.controller.scheduler.raidb2 with parameters of type AbstractWriteRequest | |
void |
RAIDb2QueryLevelScheduler.scheduleNonSuspendedWriteRequest(AbstractWriteRequest request)
|
private void |
RAIDb2QueryLevelScheduler.waitForReadCompletion(AbstractWriteRequest request)
Wait for the reads completion. |
void |
RAIDb2QueryLevelScheduler.notifyWriteCompleted(AbstractWriteRequest request)
|
void |
RAIDb2PessimisticTransactionLevelScheduler.scheduleNonSuspendedWriteRequest(AbstractWriteRequest request)
Note that CREATE statements are not synchronized. |
void |
RAIDb2PessimisticTransactionLevelScheduler.notifyWriteCompleted(AbstractWriteRequest request)
|
Uses of AbstractWriteRequest in org.objectweb.cjdbc.controller.scheduler.singledb |
Methods in org.objectweb.cjdbc.controller.scheduler.singledb with parameters of type AbstractWriteRequest | |
void |
SingleDBQueryLevelScheduler.scheduleNonSuspendedWriteRequest(AbstractWriteRequest request)
|
void |
SingleDBQueryLevelScheduler.notifyWriteCompleted(AbstractWriteRequest request)
|
void |
SingleDBPessimisticTransactionLevelScheduler.scheduleNonSuspendedWriteRequest(AbstractWriteRequest request)
Additionally to scheduling the request, this method replaces the SQL Date macros such as now() with the current date. |
void |
SingleDBPessimisticTransactionLevelScheduler.notifyWriteCompleted(AbstractWriteRequest request)
|
Uses of AbstractWriteRequest in org.objectweb.cjdbc.controller.virtualdatabase |
Methods in org.objectweb.cjdbc.controller.virtualdatabase that return AbstractWriteRequest | |
private AbstractWriteRequest |
VirtualDatabaseWorkerThread.writeRequestFromStream(boolean withKeys)
Read a write request send by the Connection object. |
Methods in org.objectweb.cjdbc.controller.virtualdatabase with parameters of type AbstractWriteRequest | |
int |
VirtualDatabase.execWriteRequest(AbstractWriteRequest request)
Performs a write request and returns the number of rows affected. |
ControllerResultSet |
VirtualDatabase.execWriteRequestWithKeys(AbstractWriteRequest request)
Performs a write request and returns the auto generated keys. |
Uses of AbstractWriteRequest in org.objectweb.cjdbc.controller.virtualdatabase.protocol |
Constructors in org.objectweb.cjdbc.controller.virtualdatabase.protocol with parameters of type AbstractWriteRequest | |
CacheInvalidate(AbstractWriteRequest request)
Creates a new CacheInvalidate object |
|
ExecWriteRequestWithKeys(AbstractWriteRequest request)
|
|
ExecWriteRequest(AbstractWriteRequest request)
|
Uses of AbstractWriteRequest in org.objectweb.cjdbc.driver |
Methods in org.objectweb.cjdbc.driver with parameters of type AbstractWriteRequest | |
protected int |
Connection.execWriteRequest(AbstractWriteRequest request)
Performs a write request and return the number of rows affected. |
private void |
Connection.writeRequestOnStream(AbstractWriteRequest request,
boolean withKeys)
Serialize a write request on the output stream by sending only the needed parameters to reconstruct it on the controller |
protected java.sql.ResultSet |
Connection.execWriteRequestWithKeys(AbstractWriteRequest request)
Performs a write request and return the number of rows affected. |
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |