001: //$Header: /deegreerepository/deegree/src/org/deegree/ogcwebservices/wfs/WFService.java,v 1.46 2007/03/14 14:43:44 mschneider Exp $
002: /*---------------- FILE HEADER ------------------------------------------
003:
004: This file is part of deegree.
005: Copyright (C) 2001-2008 by:
006: EXSE, Department of Geography, University of Bonn
007: http://www.giub.uni-bonn.de/deegree/
008: lat/lon GmbH
009: http://www.lat-lon.de
010:
011: This library is free software; you can redistribute it and/or
012: modify it under the terms of the GNU Lesser General Public
013: License as published by the Free Software Foundation; either
014: version 2.1 of the License, or (at your option) any later version.
015:
016: This library is distributed in the hope that it will be useful,
017: but WITHOUT ANY WARRANTY; without even the implied warranty of
018: MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
019: Lesser General Public License for more details.
020:
021: You should have received a copy of the GNU Lesser General Public
022: License along with this library; if not, write to the Free Software
023: Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
024:
025: Contact:
026:
027: Andreas Poth
028: lat/lon GmbH
029: Aennchenstr. 19
030: 53115 Bonn
031: Germany
032: E-Mail: poth@lat-lon.de
033:
034: Prof. Dr. Klaus Greve
035: Department of Geography
036: University of Bonn
037: Meckenheimer Allee 166
038: 53115 Bonn
039: Germany
040: E-Mail: greve@giub.uni-bonn.de
041:
042: ---------------------------------------------------------------------------*/
043: package org.deegree.ogcwebservices.wfs;
044:
045: import java.util.Map;
046:
047: import org.deegree.datatypes.QualifiedName;
048: import org.deegree.framework.log.ILogger;
049: import org.deegree.framework.log.LoggerFactory;
050: import org.deegree.framework.trigger.TriggerProvider;
051: import org.deegree.io.datastore.LockManager;
052: import org.deegree.io.datastore.schema.MappedFeatureType;
053: import org.deegree.ogcwebservices.OGCWebService;
054: import org.deegree.ogcwebservices.OGCWebServiceException;
055: import org.deegree.ogcwebservices.OGCWebServiceRequest;
056: import org.deegree.ogcwebservices.wfs.capabilities.WFSCapabilities;
057: import org.deegree.ogcwebservices.wfs.configuration.WFSConfiguration;
058: import org.deegree.ogcwebservices.wfs.operation.DescribeFeatureType;
059: import org.deegree.ogcwebservices.wfs.operation.GetFeature;
060: import org.deegree.ogcwebservices.wfs.operation.GetFeatureWithLock;
061: import org.deegree.ogcwebservices.wfs.operation.LockFeature;
062: import org.deegree.ogcwebservices.wfs.operation.WFSGetCapabilities;
063: import org.deegree.ogcwebservices.wfs.operation.transaction.Transaction;
064:
065: /**
066: * This class implements access to the methods defined in the OGC WFS 1.1.0 specification.
067: *
068: * @author <a href="mailto:schneider@lat-lon.de">Markus Schneider</a>
069: * @author <a href="mailto:poth@lat-lon.de">Andreas Poth</a>
070: *
071: * @author last edited by: $Author: apoth $
072: *
073: * @version $Revision: 9345 $, $Date: 2007-12-27 08:22:25 -0800 (Thu, 27 Dec 2007) $
074: *
075: * @see OGCWebService
076: */
077: public class WFService implements OGCWebService {
078:
079: private static final ILogger LOG = LoggerFactory
080: .getLogger(WFService.class);
081:
082: /** Only OGC standard version currently implemented by this service. */
083: public static final String VERSION = "1.1.0";
084:
085: private static final TriggerProvider TP = TriggerProvider
086: .create(WFService.class);
087:
088: private WFSConfiguration configuration;
089:
090: // shared instance that handles all GetFeature requests to this service
091: private GetFeatureHandler getFeatureHandler;
092:
093: // shared instance that handles all DescribeFeatureType requests to this service
094: private DescribeFeatureTypeHandler describeFTHandler;
095:
096: // shared instance that handles all LockFeature requests to this service
097: private LockFeatureHandler lockFeatureHandler;
098:
099: /**
100: * Creates a new instance of <code>WFService</code> with the given configuration.
101: *
102: * @param configuration
103: * @throws OGCWebServiceException
104: */
105: WFService(WFSConfiguration configuration)
106: throws OGCWebServiceException {
107: this .configuration = configuration;
108: this .getFeatureHandler = new GetFeatureHandler(this );
109: this .describeFTHandler = new DescribeFeatureTypeHandler(this );
110: this .lockFeatureHandler = new LockFeatureHandler(this );
111: }
112:
113: /**
114: * Returns the capabilities of the <code>WFService</code>.
115: *
116: * @return the capabilities, this is actually a <code>WFSConfiguration</code> instance
117: */
118: public WFSCapabilities getCapabilities() {
119: return this .configuration;
120: }
121:
122: /**
123: * Performs the handling of the passed OGCWebServiceEvent directly and returns the result to the
124: * calling class/ method.
125: *
126: * @param request
127: * WFS request to perform
128: *
129: * @throws OGCWebServiceException
130: */
131: public Object doService(OGCWebServiceRequest request)
132: throws OGCWebServiceException {
133:
134: long ts = System.currentTimeMillis();
135: request = (OGCWebServiceRequest) TP.doPreTrigger(this , request)[0];
136:
137: Object response = null;
138: char rtype = 'C';
139: if (request instanceof WFSGetCapabilities) {
140: // TODO implement partial responses (if only some sections are requested)
141: response = this .configuration;
142: rtype = 'C';
143: } else if (request instanceof GetFeatureWithLock) {
144: response = this .lockFeatureHandler
145: .handleRequest((GetFeatureWithLock) request);
146: rtype = 'W';
147: } else if (request instanceof GetFeature) {
148: response = this .getFeatureHandler
149: .handleRequest((GetFeature) request);
150: rtype = 'F';
151: } else if (request instanceof DescribeFeatureType) {
152: response = this .describeFTHandler
153: .handleRequest((DescribeFeatureType) request);
154: rtype = 'D';
155: } else if (request instanceof Transaction) {
156: TransactionHandler handler = new TransactionHandler(this ,
157: (Transaction) request);
158: response = handler.handleRequest();
159: rtype = 'T';
160: } else if (request instanceof LockFeature) {
161: response = this .lockFeatureHandler
162: .handleRequest((LockFeature) request);
163: rtype = 'L';
164: } else {
165: String msg = "Unknown request type: "
166: + request.getClass().getName();
167: throw new OGCWebServiceException(getClass().getName(), msg);
168: }
169: if (LOG.getLevel() == ILogger.LOG_DEBUG) {
170: LOG.logDebug("" + LockManager.getInstance());
171: }
172:
173: Object o = TP.doPostTrigger(this , response)[0];
174: LOG.logDebug("WFS processing time for request type " + rtype
175: + ": ", Long
176: .toString((System.currentTimeMillis() - ts)));
177: return o;
178: }
179:
180: /**
181: * Returns a clone of the <code>WFService</code> instance.
182: * <p>
183: * Note that the configuration of the new service will refer to the same instance.
184: */
185: @Override
186: public Object clone() {
187:
188: WFService clone = null;
189: try {
190: clone = new WFService(configuration);
191: } catch (OGCWebServiceException e) {
192: // can never happen
193: }
194: return clone;
195: }
196:
197: /**
198: * Returns the <code>MappedFeatureType</code> with the given name.
199: *
200: * @param name
201: * name of the feature type
202: * @return the mapped feature type with the given name, or null if it is not known to this
203: * WFService instance
204: */
205: public MappedFeatureType getMappedFeatureType(QualifiedName name) {
206: return this .configuration.getMappedFeatureTypes().get(name);
207: }
208:
209: /**
210: * Returns a <code>Map</code> of the feature types that this WFS serves.
211: *
212: * @return keys: feature type names, values: mapped feature types
213: */
214: public Map<QualifiedName, MappedFeatureType> getMappedFeatureTypes() {
215: return this.configuration.getMappedFeatureTypes();
216: }
217: }
|