KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > objectstyle > cayenne > service > ServerObjectContext


1 /* ====================================================================
2  *
3  * The ObjectStyle Group Software License, version 1.1
4  * ObjectStyle Group - http://objectstyle.org/
5  *
6  * Copyright (c) 2002-2005, Andrei (Andrus) Adamchik and individual authors
7  * of the software. All rights reserved.
8  *
9  * Redistribution and use in source and binary forms, with or without
10  * modification, are permitted provided that the following conditions
11  * are met:
12  *
13  * 1. Redistributions of source code must retain the above copyright
14  * notice, this list of conditions and the following disclaimer.
15  *
16  * 2. Redistributions in binary form must reproduce the above copyright
17  * notice, this list of conditions and the following disclaimer in
18  * the documentation and/or other materials provided with the
19  * distribution.
20  *
21  * 3. The end-user documentation included with the redistribution, if any,
22  * must include the following acknowlegement:
23  * "This product includes software developed by independent contributors
24  * and hosted on ObjectStyle Group web site (http://objectstyle.org/)."
25  * Alternately, this acknowlegement may appear in the software itself,
26  * if and wherever such third-party acknowlegements normally appear.
27  *
28  * 4. The names "ObjectStyle Group" and "Cayenne" must not be used to endorse
29  * or promote products derived from this software without prior written
30  * permission. For written permission, email
31  * "andrus at objectstyle dot org".
32  *
33  * 5. Products derived from this software may not be called "ObjectStyle"
34  * or "Cayenne", nor may "ObjectStyle" or "Cayenne" appear in their
35  * names without prior written permission.
36  *
37  * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
38  * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
39  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
40  * DISCLAIMED. IN NO EVENT SHALL THE OBJECTSTYLE GROUP OR
41  * ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
42  * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
43  * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
44  * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
45  * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
46  * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
47  * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
48  * SUCH DAMAGE.
49  * ====================================================================
50  *
51  * This software consists of voluntary contributions made by many
52  * individuals and hosted on ObjectStyle Group web site. For more
53  * information on the ObjectStyle Group, please see
54  * <http://objectstyle.org/>.
55  */
56 package org.objectstyle.cayenne.service;
57
58 import java.util.ArrayList JavaDoc;
59 import java.util.List JavaDoc;
60
61 import org.objectstyle.cayenne.CayenneRuntimeException;
62 import org.objectstyle.cayenne.QueryResponse;
63 import org.objectstyle.cayenne.access.DataDomain;
64 import org.objectstyle.cayenne.access.DataRowStore;
65 import org.objectstyle.cayenne.access.PersistenceContext;
66 import org.objectstyle.cayenne.client.ClientEntityResolver;
67 import org.objectstyle.cayenne.distribution.BootstrapMessage;
68 import org.objectstyle.cayenne.distribution.ClientMessageHandler;
69 import org.objectstyle.cayenne.distribution.CommitMessage;
70 import org.objectstyle.cayenne.distribution.GenericQueryMessage;
71 import org.objectstyle.cayenne.distribution.SelectMessage;
72 import org.objectstyle.cayenne.distribution.UpdateMessage;
73 import org.objectstyle.cayenne.graph.GraphDiff;
74 import org.objectstyle.cayenne.map.EntityResolver;
75
76 /**
77  * A server-side peer of a ClientDataContext. Client messages are processed via callback
78  * methods defined in ClientMessageHandler interface.
79  *
80  * @since 1.2
81  * @author Andrus Adamchik
82  */
83 public class ServerObjectContext extends ObjectDataContext implements
84         ClientMessageHandler {
85
86     public ServerObjectContext(DataDomain parentDomain) {
87         super(parentDomain);
88     }
89
90     public ServerObjectContext(PersistenceContext parent, EntityResolver entityResolver,
91             DataRowStore cache) {
92
93         super(parent, entityResolver, cache);
94     }
95
96     public GraphDiff onCommit(CommitMessage message) {
97         // sync client changes
98 message.getSenderChanges().apply(new ClientToServerDiffConverter(this));
99
100         GraphDiff diff = commit();
101
102         if (diff.isNoop()) {
103             return diff;
104         }
105         else {
106             // create client diff
107 ServerToClientDiffConverter clientConverter = new ServerToClientDiffConverter(
108                     getEntityResolver());
109             diff.apply(clientConverter);
110             return clientConverter.getClientDiff();
111         }
112     }
113
114     public QueryResponse onGenericQuery(GenericQueryMessage message) {
115         return performGenericQuery(message.getQueryPlan());
116     }
117
118     public List JavaDoc onSelectQuery(SelectMessage message) {
119         List JavaDoc objects = performSelectQuery(message.getQueryPlan());
120
121         // create client objects for a list of server object
122
123         if (objects.isEmpty()) {
124             return new ArrayList JavaDoc(0);
125         }
126
127         try {
128             return ClientServerUtils.toClientObjects(getEntityResolver(), objects);
129         }
130         catch (Exception JavaDoc e) {
131             throw new CayenneRuntimeException("Error converting to client objects: "
132                     + e.getLocalizedMessage(), e);
133         }
134     }
135
136     public int[] onUpdateQuery(UpdateMessage message) {
137         return performUpdateQuery(message.getQueryPlan());
138     }
139
140     public ClientEntityResolver onBootstrap(BootstrapMessage message) {
141         return entityResolver.getClientEntityResolver();
142     }
143 }
Popular Tags