CJDBCversion1.0rc6: org.objectweb.cjdbc.controller.loadbalancer.tasks.SelectRequestTask class Reference

00071   {
00072     DatabaseBackend backend = backendThread.getBackend();
00073 
00074     AbstractConnectionManager cm = backend.getConnectionManager(request
00075         .getLogin());
00076     if (request.isAutoCommit())
00077     { // Use a connection just for this request
00078       Connection c = null;
00079       try
00080       {
00081         c = cm.getConnection();
00082       }
00083       catch (UnreachableBackendException e1)
00084       {
00085         backendThread.getLogger().error(
00086             "Disabling backend " + backend.getName()
00087                 + " because it is no more reachable.");
00088         backend.disable();
00089         throw new SQLException("Backend " + backend.getName()
00090             + " is no more reachable.");
00091       }
00092 
00093       // Sanity check
00094       if (c == null)
00095       {
00096         SQLException se = new SQLException("No more connections");
00097         try
00098         { // All backends failed, just ignore
00099           if (!notifyFailure(backendThread, (long) request.getTimeout() * 1000,
00100               se))
00101             return;
00102         }
00103         catch (SQLException ignore)
00104         {
00105         }
00106         // Disable this backend (it is no more in sync) by killing the backend
00107         // thread
00108         backendThread.kill();
00109         throw new SQLException("Request '"
00110             + request.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH)
00111             + "' failed on backend " + backend.getName() + " (" + se + ")");
00112       }
00113 
00114       // Execute Query
00115       try
00116       {
00117         Statement s = c.createStatement();
00118         if (backend.getDriverCompliance().supportSetQueryTimeout())
00119           s.setQueryTimeout(request.getTimeout());
00120         if ((request.getMaxRows() > 0)
00121             && backend.getDriverCompliance().supportSetMaxRows())
00122           s.setMaxRows(request.getMaxRows());
00123 
00124         String sql = request.getSQL();
00125         // Rewrite the query if needed
00126         sql = backend.rewriteQuery(sql);
00127         result = s.executeQuery(sql);
00128       }
00129       catch (SQLException e)
00130       {
00131         try
00132         { // All backends failed, just ignore
00133           if (!notifyFailure(backendThread, (long) request.getTimeout() * 1000,
00134               e))
00135             return;
00136         }
00137         catch (SQLException ignore)
00138         {
00139         }
00140         throw new SQLException("Request '"
00141             + request.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH)
00142             + "' failed on backend " + backend.getName() + " (" + e + ")");
00143       }
00144       finally
00145       {
00146         cm.releaseConnection(c);
00147       }
00148     }
00149     else
00150     { // Re-use the connection used by this transaction
00151       Connection c = cm.retrieveConnection(request.getTransactionId());
00152 
00153       // Sanity check
00154       if (c == null)
00155       { // Bad connection
00156         SQLException se = new SQLException(
00157             "Unable to retrieve connection for transaction "
00158                 + request.getTransactionId());
00159         try
00160         { // All backends failed, just ignore
00161           if (!notifyFailure(backendThread, (long) request.getTimeout() * 1000,
00162               se))
00163             return;
00164         }
00165         catch (SQLException ignore)
00166         {
00167         }
00168         throw new SQLException("Request '"
00169             + request.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH)
00170             + "' failed on backend " + backend.getName() + " (" + se + ")");
00171       }
00172 
00173       // Execute Query
00174       try
00175       {
00176         Statement s = c.createStatement();
00177         if (backend.getDriverCompliance().supportSetQueryTimeout())
00178           s.setQueryTimeout(request.getTimeout());
00179         if ((request.getMaxRows() > 0)
00180             && backend.getDriverCompliance().supportSetMaxRows())
00181           s.setMaxRows(request.getMaxRows());
00182 
00183         String sql = request.getSQL();
00184         // Rewrite the query if needed
00185         sql = backend.rewriteQuery(sql);
00186         result = s.executeQuery(sql);
00187       }
00188       catch (SQLException e)
00189       {
00190         try
00191         { // All backends failed, just ignore
00192           if (!notifyFailure(backendThread, (long) request.getTimeout() * 1000,
00193               e))
00194             return;
00195         }
00196         catch (SQLException ignore)
00197         {
00198         }
00199         throw new SQLException("Request '"
00200             + request.getSQLShortForm(Constants.SQL_SHORT_FORM_LENGTH)
00201             + "' failed on backend " + backend.getName() + " (" + e + ")");
00202       }
00203     }
00204     notifySuccess();
00205   }


Public メソッド
	SelectRequestTask (int nbToComplete, int totalNb, SelectRequest request)
void	execute (BackendWorkerThread backendThread) throws SQLException
ResultSet	getResult ()
String	toString ()
boolean	hasTid ()
synchronized void	notifySuccess ()
synchronized boolean	notifyFailure (BackendWorkerThread backendThread, long timeout, SQLException e) throws SQLException
ArrayList	getExceptions ()
int	getFailed ()
int	getNbToComplete ()
int	getSuccess ()
int	getTotalNb ()
void	setTotalNb (int totalNb)
void	setHasTid (boolean hasTid)
Private 変数
SelectRequest	request
ResultSet	result

クラス org.objectweb.cjdbc.controller.loadbalancer.tasks.SelectRequestTask

説明

Public メソッド

Private 変数

コンストラクタとデストラクタ

メソッド

変数