KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > continuent > sequoia > controller > virtualdatabase > protocol > DistributedStatementExecuteUpdate


1 /**
2  * Sequoia: Database clustering technology.
3  * Copyright (C) 2002-2004 French National Institute For Research In Computer
4  * Science And Control (INRIA).
5  * Copyright (C) 2005 AmicoSoft, Inc. dba Emic Networks
6  * Copyright (C) 2005-2006 Continuent, Inc.
7  * Contact: sequoia@continuent.org
8  *
9  * Licensed under the Apache License, Version 2.0 (the "License");
10  * you may not use this file except in compliance with the License.
11  * You may obtain a copy of the License at
12  *
13  * http://www.apache.org/licenses/LICENSE-2.0
14  *
15  * Unless required by applicable law or agreed to in writing, software
16  * distributed under the License is distributed on an "AS IS" BASIS,
17  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
18  * See the License for the specific language governing permissions and
19  * limitations under the License.
20  *
21  * Initial developer(s): Emmanuel Cecchet.
22  * Contributor(s): ______________________.
23  */
24
25 package org.continuent.sequoia.controller.virtualdatabase.protocol;
26
27 import java.io.Serializable JavaDoc;
28 import java.sql.SQLException JavaDoc;
29 import java.util.LinkedList JavaDoc;
30
31 import org.continuent.sequoia.common.exceptions.NoMoreBackendException;
32 import org.continuent.sequoia.common.i18n.Translate;
33 import org.continuent.sequoia.controller.backend.result.ExecuteUpdateResult;
34 import org.continuent.sequoia.controller.loadbalancer.AllBackendsFailedException;
35 import org.continuent.sequoia.controller.requestmanager.distributed.DistributedRequestManager;
36 import org.continuent.sequoia.controller.requests.AbstractWriteRequest;
37
38 /**
39  * Execute a distributed call to Statement.executeUpdate() between several
40  * controllers.
41  *
42  * @author <a HREF="mailto:Emmanuel.Cecchet@inria.fr">Emmanuel Cecchet </a>
43  * @version 1.0
44  */
45 public class DistributedStatementExecuteUpdate extends DistributedRequest
46 {
47   private static final long serialVersionUID = -4849018153223926739L;
48
49   /**
50    * @param request write request to execute
51    */
52   public DistributedStatementExecuteUpdate(AbstractWriteRequest request)
53   {
54     super(request);
55   }
56
57   /**
58    * @see org.continuent.sequoia.controller.virtualdatabase.protocol.DistributedRequest#scheduleRequest(org.continuent.sequoia.controller.requestmanager.distributed.DistributedRequestManager)
59    */
60   public Object JavaDoc scheduleRequest(DistributedRequestManager drm)
61       throws SQLException JavaDoc
62   {
63     LinkedList JavaDoc totalOrderQueue = drm.getVirtualDatabase().getTotalOrderQueue();
64     synchronized (totalOrderQueue)
65     {
66       totalOrderQueue.addLast(request);
67     }
68     return request;
69   }
70
71   /**
72    * @see org.continuent.sequoia.controller.virtualdatabase.protocol.DistributedRequest#executeScheduledRequest(org.continuent.sequoia.controller.requestmanager.distributed.DistributedRequestManager)
73    */
74   public Serializable JavaDoc executeScheduledRequest(DistributedRequestManager drm)
75       throws SQLException JavaDoc
76   {
77     boolean hasBeenScheduled = false;
78
79     try
80     {
81       drm.getLoadBalancer().waitForSuspendWritesToComplete(request);
82
83       // This call will trigger a lazyTransactionStart as well
84 drm.scheduleExecWriteRequest((AbstractWriteRequest) request);
85       hasBeenScheduled = true;
86
87       ExecuteUpdateResult execWriteRequestResult = drm
88           .loadBalanceStatementExecuteUpdate((AbstractWriteRequest) request);
89       drm.updateAndNotifyExecWriteRequest((AbstractWriteRequest) request,
90           execWriteRequestResult.getUpdateCount());
91       return execWriteRequestResult;
92     }
93     catch (NoMoreBackendException e)
94     {
95       if (drm.getLogger().isDebugEnabled())
96         drm.getLogger().debug(
97             Translate.get("virtualdatabase.distributed.write.logging.only",
98                 request.getSqlShortForm(drm.getVirtualDatabase()
99                     .getSqlShortFormLength())));
100
101       drm.addFailedOnAllBackends(request, hasBeenScheduled);
102       return e;
103     }
104     catch (AllBackendsFailedException e)
105     {
106       // Add to failed list, the scheduler has already been notified by either
107 // loadBalanceExecWriteRequest or updateAndNotifyExecWriteRequest.
108 drm.addFailedOnAllBackends(request, hasBeenScheduled);
109       if (drm.getLogger().isDebugEnabled())
110         drm
111             .getLogger()
112             .debug(
113                 Translate
114                     .get(
115                         "virtualdatabase.distributed.write.all.backends.locally.failed",
116                         request.getSqlShortForm(drm.getVirtualDatabase()
117                             .getSqlShortFormLength())));
118       return e;
119     }
120     catch (SQLException JavaDoc e)
121     {
122       // Something bad more likely happened during the update but the scheduler
123 // has already been notified.
124 drm.addFailedOnAllBackends(request, hasBeenScheduled);
125       // This maybe just invalid SQL, see SEQUOIA-809
126 drm.getLogger().debug(
127           Translate.get("virtualdatabase.distributed.write.sqlexception", e
128               .getMessage()), e);
129       return e;
130     }
131     catch (RuntimeException JavaDoc re)
132     {
133       // Something bad more likely happened during the update but the scheduler
134 // has already been notified.
135 drm.addFailedOnAllBackends(request, hasBeenScheduled);
136       drm.getLogger().warn(
137           Translate.get("virtualdatabase.distributed.write.exception", re
138               .getMessage()), re);
139       return new SQLException JavaDoc(re.getMessage());
140     }
141   }
142
143   /**
144    * @see java.lang.Object#toString()
145    */
146   public String JavaDoc toString()
147   {
148     return "W " + request.getId() + " " + request.getTransactionId() + " "
149         + request.getUniqueKey();
150   }
151
152 }
Popular Tags