Public Member Functions | |
ExecReadRequest (long controllerId, SelectRequest request) | |
void | scheduleRequest (DistributedRequestManager drm) throws SQLException |
Object | executeScheduledRequest (DistributedRequestManager drm) throws SQLException |
Definition at line 39 of file ExecReadRequest.java.
|
Creates a new
Definition at line 50 of file ExecReadRequest.java. 00051 {
00052 super(request);
00053 this.controllerId = controllerId;
00054 }
|
|
Implements org.objectweb.cjdbc.controller.virtualdatabase.protocol.DistributedRequest. Definition at line 72 of file ExecReadRequest.java. 00074 { 00075 try 00076 { 00077 return drm.execReadRequest((SelectRequest) request); 00078 } 00079 catch (SQLException e) 00080 { 00081 drm.getLogger().warn( 00082 Translate.get("virtualdatabase.distributed.read.sqlexception", e 00083 .getMessage()), e); 00084 throw e; 00085 } 00086 catch (RuntimeException re) 00087 { 00088 drm.getLogger().warn( 00089 Translate.get("virtualdatabase.distributed.read.exception", re 00090 .getMessage()), re); 00091 throw new SQLException(re.getMessage()); 00092 } 00093 }
|
|
Implements org.objectweb.cjdbc.controller.virtualdatabase.protocol.DistributedRequest. Definition at line 59 of file ExecReadRequest.java. References org.objectweb.cjdbc.common.sql.AbstractRequest.getSQLShortForm(). 00061 { 00062 if (controllerId == drm.getControllerId()) 00063 throw new SQLException( 00064 "No backends are available in the cluster to execute the query (" 00065 + request.getSQLShortForm(drm.getVirtualDatabase() 00066 .getSQLShortFormLength()) + ")"); 00067 }
|