Public Member Functions | |
AbstractWriteRequest (String sqlQuery, boolean escapeProcessing, int timeout, String lineSeparator) | |
boolean | isReadRequest () |
boolean | isWriteRequest () |
boolean | isUnknownRequest () |
abstract boolean | isInsert () |
abstract boolean | isUpdate () |
abstract boolean | isDelete () |
abstract boolean | isAlter () |
abstract boolean | isCreate () |
abstract boolean | isDrop () |
String | getTableName () |
ArrayList | getColumns () |
boolean | mightBlock () |
void | setBlocking (boolean blocking) |
String | getPk () |
Protected Member Functions | |
void | cloneTableNameAndColumns (AbstractWriteRequest abstractWriteRequest) |
Protected Attributes | |
transient String | tableName |
transient ArrayList | columns |
transient boolean | blocking = true |
transient String | pkValue = null |
AbstractWriteRequest
defines the skeleton of read requests that are sent from the driver to the controller.
Definition at line 36 of file AbstractWriteRequest.java.
|
Creates a new
Definition at line 62 of file AbstractWriteRequest.java. 00064 { 00065 super(sqlQuery, escapeProcessing, timeout, lineSeparator); 00066 }
|
|
|
Returns an
Definition at line 159 of file AbstractWriteRequest.java. Referenced by org.objectweb.cjdbc.common.sql.AbstractWriteRequest.cloneTableNameAndColumns(), org.objectweb.cjdbc.controller.cache.result.ResultCacheColumnUnique.isUpdateNecessary(), org.objectweb.cjdbc.controller.cache.result.ResultCacheColumnUnique.processWriteNotify(), and org.objectweb.cjdbc.controller.cache.result.ResultCacheColumn.processWriteNotify(). 00160 {
00161 return columns;
00162 }
|
|
Definition at line 201 of file AbstractWriteRequest.java. Referenced by org.objectweb.cjdbc.common.sql.AbstractWriteRequest.cloneTableNameAndColumns(), and org.objectweb.cjdbc.controller.cache.result.ResultCacheColumnUnique.isUpdateNecessary(). 00202 {
00203 return pkValue;
00204 }
|
|
Returns the name of the table affected by this statement.
Definition at line 148 of file AbstractWriteRequest.java. Referenced by org.objectweb.cjdbc.common.sql.AbstractWriteRequest.cloneTableNameAndColumns(), org.objectweb.cjdbc.controller.cache.result.ResultCacheColumnUnique.isUpdateNecessary(), org.objectweb.cjdbc.controller.scheduler.raidb1.RAIDb1OptimisticTransactionLevelScheduler.notifyWriteCompleted(), org.objectweb.cjdbc.controller.cache.result.ResultCacheTable.processWriteNotify(), org.objectweb.cjdbc.controller.cache.result.ResultCacheColumnUnique.processWriteNotify(), and org.objectweb.cjdbc.controller.cache.result.ResultCacheColumn.processWriteNotify(). 00149 {
00150 return tableName;
00151 }
|
|
Returns
Implemented in org.objectweb.cjdbc.common.sql.AlterRequest, org.objectweb.cjdbc.common.sql.CreateRequest, org.objectweb.cjdbc.common.sql.DeleteRequest, org.objectweb.cjdbc.common.sql.DropRequest, org.objectweb.cjdbc.common.sql.InsertRequest, and org.objectweb.cjdbc.common.sql.UpdateRequest. Referenced by org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.handleMacros(), org.objectweb.cjdbc.controller.cache.result.ResultCacheColumnUnique.processWriteNotify(), and org.objectweb.cjdbc.controller.cache.result.ResultCacheColumn.processWriteNotify(). |
|
Returns
Implemented in org.objectweb.cjdbc.common.sql.AlterRequest, org.objectweb.cjdbc.common.sql.CreateRequest, org.objectweb.cjdbc.common.sql.DeleteRequest, org.objectweb.cjdbc.common.sql.DropRequest, org.objectweb.cjdbc.common.sql.InsertRequest, and org.objectweb.cjdbc.common.sql.UpdateRequest. Referenced by org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.handleMacros(), org.objectweb.cjdbc.controller.scheduler.raidb2.RAIDb2PessimisticTransactionLevelScheduler.notifyWriteCompleted(), org.objectweb.cjdbc.controller.scheduler.raidb1.RAIDb1PessimisticTransactionLevelScheduler.notifyWriteCompleted(), org.objectweb.cjdbc.controller.scheduler.raidb1.RAIDb1OptimisticTransactionLevelScheduler.notifyWriteCompleted(), and org.objectweb.cjdbc.controller.scheduler.raidb0.RAIDb0PessimisticTransactionLevelScheduler.notifyWriteCompleted(). |
|
Returns
Implemented in org.objectweb.cjdbc.common.sql.AlterRequest, org.objectweb.cjdbc.common.sql.CreateRequest, org.objectweb.cjdbc.common.sql.DeleteRequest, org.objectweb.cjdbc.common.sql.DropRequest, org.objectweb.cjdbc.common.sql.InsertRequest, and org.objectweb.cjdbc.common.sql.UpdateRequest. Referenced by org.objectweb.cjdbc.controller.cache.result.ResultCacheColumnUnique.processWriteNotify(). |
|
Returns
Implemented in org.objectweb.cjdbc.common.sql.AlterRequest, org.objectweb.cjdbc.common.sql.CreateRequest, org.objectweb.cjdbc.common.sql.DeleteRequest, org.objectweb.cjdbc.common.sql.DropRequest, org.objectweb.cjdbc.common.sql.InsertRequest, and org.objectweb.cjdbc.common.sql.UpdateRequest. Referenced by org.objectweb.cjdbc.controller.loadbalancer.AbstractLoadBalancer.handleMacros(), and org.objectweb.cjdbc.controller.scheduler.raidb1.RAIDb1OptimisticTransactionLevelScheduler.notifyWriteCompleted(). |
|
Returns
Implemented in org.objectweb.cjdbc.common.sql.AlterRequest, org.objectweb.cjdbc.common.sql.CreateRequest, org.objectweb.cjdbc.common.sql.DeleteRequest, org.objectweb.cjdbc.common.sql.DropRequest, org.objectweb.cjdbc.common.sql.InsertRequest, and org.objectweb.cjdbc.common.sql.UpdateRequest. Referenced by org.objectweb.cjdbc.controller.cache.result.ResultCacheColumnUnique.processWriteNotify(). |
|
Implements org.objectweb.cjdbc.common.sql.AbstractRequest. Reimplemented in org.objectweb.cjdbc.common.sql.AlterRequest. Definition at line 72 of file AbstractWriteRequest.java. 00073 { 00074 return false; 00075 }
|
|
Implements org.objectweb.cjdbc.common.sql.AbstractRequest. Reimplemented in org.objectweb.cjdbc.common.sql.AlterRequest. Definition at line 90 of file AbstractWriteRequest.java. 00091 { 00092 return false; 00093 }
|
|
Returns
Implemented in org.objectweb.cjdbc.common.sql.AlterRequest, org.objectweb.cjdbc.common.sql.CreateRequest, org.objectweb.cjdbc.common.sql.DeleteRequest, org.objectweb.cjdbc.common.sql.DropRequest, org.objectweb.cjdbc.common.sql.InsertRequest, and org.objectweb.cjdbc.common.sql.UpdateRequest. Referenced by org.objectweb.cjdbc.controller.cache.result.ResultCacheColumnUnique.processWriteNotify(). |
|
Implements org.objectweb.cjdbc.common.sql.AbstractRequest. Reimplemented in org.objectweb.cjdbc.common.sql.AlterRequest. Definition at line 81 of file AbstractWriteRequest.java. 00082 { 00083 return true; 00084 }
|
|
Tests if this request might block.
Definition at line 183 of file AbstractWriteRequest.java. 00184 {
00185 return blocking;
00186 }
|
|
Sets if this request might block.
Definition at line 193 of file AbstractWriteRequest.java. References org.objectweb.cjdbc.common.sql.AbstractWriteRequest.blocking. 00194 {
00195 this.blocking = blocking;
00196 }
|
|
Definition at line 48 of file AbstractWriteRequest.java. Referenced by org.objectweb.cjdbc.common.sql.AbstractWriteRequest.setBlocking(). |
|
Definition at line 45 of file AbstractWriteRequest.java. Referenced by org.objectweb.cjdbc.common.sql.AbstractWriteRequest.cloneTableNameAndColumns(). |
|
Primary key value Definition at line 51 of file AbstractWriteRequest.java. Referenced by org.objectweb.cjdbc.common.sql.AbstractWriteRequest.cloneTableNameAndColumns(). |
|
Name of the table involved in this write query. Definition at line 39 of file AbstractWriteRequest.java. Referenced by org.objectweb.cjdbc.common.sql.AbstractWriteRequest.cloneTableNameAndColumns(). |