org.geotools.data.Query.<init>()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(8.4k)|赞(0)|评价(0)|浏览(239)

本文整理了Java中org.geotools.data.Query.<init>方法的一些代码示例,展示了Query.<init>的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Query.<init>方法的具体详情如下:
包路径:org.geotools.data.Query
类名称:Query
方法名:<init>

Query.<init>介绍

[英]Default constructor. Use setter methods to configure the Query before use (the default Query will retrieve all features).
[中]默认构造函数。使用setter方法在使用前配置查询(默认查询将检索所有功能)。

代码示例

代码示例来源:origin: geoserver/geoserver

  1. public FeatureCollection<T, F> getFeatures(Filter filter) throws IOException {
  2. return getFeatures(new Query(null, filter));
  3. }

代码示例来源:origin: geoserver/geoserver

  1. public int lockFeatures(Filter filter) throws IOException {
  2. return lockDelegate.lockFeatures(new Query(null, filter));
  3. }

代码示例来源:origin: geoserver/geoserver

  1. public void unLockFeatures(Filter filter) throws IOException {
  2. unLockFeatures(new Query(null, filter));
  3. }

代码示例来源:origin: geoserver/geoserver

  1. public SimpleFeatureCollection getFeatures(Filter filter) throws IOException {
  2. return getFeatures(new Query(typeMap.getName(), filter));
  3. }

代码示例来源:origin: geoserver/geoserver

  1. public SimpleFeatureCollection getFeatures(Filter filter) throws IOException {
  2. return getFeatures(new Query(schema.getTypeName(), filter));
  3. }

代码示例来源:origin: opentripplanner/OpenTripPlanner

  1. /**
  2. * Setup the WFS data source and add the DynamicStreetNotesSource to the graph
  3. */
  4. @Override
  5. public void setup(Graph graph) throws IOException, FactoryException {
  6. LOG.info("Setup WFS polling updater");
  7. HashMap<String, Object> connectionParameters = new HashMap<>();
  8. connectionParameters.put(WFSDataStoreFactory.URL.key, url);
  9. WFSDataStore data = (new WFSDataStoreFactory()).createDataStore(connectionParameters);
  10. query = new Query(featureType); // Read only single feature type from the source
  11. query.setCoordinateSystem(CRS.decode("EPSG:4326", true)); // Get coordinates in WGS-84
  12. featureSource = data.getFeatureSource(featureType);
  13. graph.streetNotesService.addNotesSource(notesSource);
  14. }

代码示例来源:origin: geoserver/geoserver

  1. /** Returns a GeoTools query build with the provided attributes and filters */
  2. private Query buildQuery(List<PropertyName> attributes, Filter filter) {
  3. if (attributes == null && (filter == null || filter == Filter.INCLUDE)) {
  4. return Query.ALL;
  5. } else {
  6. Query q = new Query();
  7. q.setFilter(filter);
  8. // TODO: switch this to property names when possible
  9. q.setPropertyNames(flattenNames(attributes));
  10. return q;
  11. }
  12. }

代码示例来源:origin: stackoverflow.com

  1. Query query = new Query("__BlobInfo__");
  2. query.addFilter("filename", FilterOperator.EQUAL, filename);
  3. DatastoreService datastore = DatastoreServiceFactory.getDatastoreService();
  4. PreparedQuery pq = datastore.prepare(query);
  5. List<Entity> entList = pq.asList(FetchOptions.Builder.withLimit(1));
  6. String name = entList.get(0).getKey().getName();

代码示例来源:origin: geoserver/geoserver

  1. /** Builds the write query based on the access limits class */
  2. public static Query getWriteQuery(WrapperPolicy policy) {
  3. if (policy.getAccessLevel() != AccessLevel.READ_WRITE) {
  4. return new Query(null, Filter.EXCLUDE);
  5. } else if (policy.getLimits() == null) {
  6. return Query.ALL;
  7. } else if (policy.getLimits() instanceof VectorAccessLimits) {
  8. VectorAccessLimits val = (VectorAccessLimits) policy.getLimits();
  9. return val.getWriteQuery();
  10. } else {
  11. throw new IllegalArgumentException(
  12. "SecureFeatureStore has been fed "
  13. + "with unexpected AccessLimits class "
  14. + policy.getLimits().getClass());
  15. }
  16. }

代码示例来源:origin: geoserver/geoserver

  1. /**
  2. * Retrieves the total extent of this FeatureSource.
  3. *
  4. * <p>Please note this extent will reflect the provided definitionQuery.
  5. *
  6. * @return Extent of this FeatureSource, or <code>null</code> if no optimizations exist.
  7. * @throws IOException If bounds of definitionQuery
  8. */
  9. public ReferencedEnvelope getBounds() throws IOException {
  10. // since CRS is at most forced, we don't need to change this code
  11. if (definitionQuery == Filter.INCLUDE) {
  12. return source.getBounds();
  13. } else {
  14. Query query = new Query(getSchema().getTypeName(), definitionQuery);
  15. return source.getBounds(query);
  16. }
  17. }

代码示例来源:origin: geoserver/geoserver

  1. public SimpleFeatureCollection getFeatures(Query query) throws IOException {
  2. if (query.getTypeName() == null) {
  3. query = new Query(query);
  4. ((Query) query).setTypeName(typeMap.getName());
  5. } else if (!typeMap.getName().equals(query.getTypeName())) {
  6. throw new IOException(
  7. "Cannot query this feature source with "
  8. + query.getTypeName()
  9. + " since it serves only "
  10. + typeMap.getName());
  11. }
  12. // GEOS-3210, if the query specifies a subset of property names we need to take that into
  13. // account
  14. SimpleFeatureType target = typeMap.getFeatureType(query);
  15. return new RetypingFeatureCollection(
  16. wrapped.getFeatures(store.retypeQuery(query, typeMap)), target);
  17. }

代码示例来源:origin: geoserver/geoserver

  1. public void removeFeatures(Filter filter) throws IOException {
  2. // are we limiting anything?
  3. Query writeQuery = getWriteQuery(policy);
  4. if (writeQuery == Query.ALL) {
  5. storeDelegate.removeFeatures(filter);
  6. } else if (writeQuery.getFilter() == Filter.EXCLUDE
  7. || writeQuery.getPropertyNames() == Query.NO_NAMES) {
  8. throw unsupportedOperation();
  9. }
  10. // get the mixed filter
  11. final Query local = new Query(null, filter);
  12. Query mixed = mixQueries(local, writeQuery);
  13. storeDelegate.removeFeatures(mixed.getFilter());
  14. }

代码示例来源:origin: geoserver/geoserver

  1. @Test
  2. public void testDelete() throws Exception {
  3. final Query queryAll = new Query(RENAMED);
  4. SimpleFeatureStore store;
  5. store = (SimpleFeatureStore) rts.getFeatureSource(RENAMED);
  6. int count = store.getCount(queryAll);
  7. store.removeFeatures(fidFilter);
  8. assertEquals(count - 1, store.getCount(queryAll));
  9. }

代码示例来源:origin: geoserver/geoserver

  1. @Test
  2. public void testDelete() throws Exception {
  3. final Query queryAll = new Query(RENAMED);
  4. SimpleFeatureStore store;
  5. store = (SimpleFeatureStore) rts.getFeatureSource(RENAMED);
  6. int count = store.getCount(queryAll);
  7. store.removeFeatures(fidFilter);
  8. assertEquals(count - 1, store.getCount(queryAll));
  9. }

代码示例来源:origin: geoserver/geoserver

  1. @Test
  2. public void testGetFeaturesReader() throws Exception {
  3. FeatureReader<SimpleFeatureType, SimpleFeature> fr;
  4. fr = rts.getFeatureReader(new Query(RENAMED), Transaction.AUTO_COMMIT);
  5. SimpleFeature sf = fr.next();
  6. fr.close();
  7. assertEquals(primitive, sf.getFeatureType());
  8. // check the feature ids have been renamed as well
  9. assertTrue(
  10. "Feature id has not been renamed, it's still " + sf.getID(),
  11. sf.getID().startsWith(RENAMED));
  12. }

代码示例来源:origin: geoserver/geoserver

  1. @Test
  2. public void testGetFeaturesReader() throws Exception {
  3. FeatureReader<SimpleFeatureType, SimpleFeature> fr;
  4. fr = rts.getFeatureReader(new Query(RENAMED), Transaction.AUTO_COMMIT);
  5. SimpleFeature sf = fr.next();
  6. fr.close();
  7. assertEquals(RENAMED, sf.getFeatureType().getName().getLocalPart());
  8. // check the feature ids have been renamed as well
  9. assertTrue(
  10. "Feature id has not been renamed, it's still " + sf.getID(),
  11. sf.getID().startsWith(RENAMED));
  12. }

代码示例来源:origin: geoserver/geoserver

  1. @Test
  2. public void testFeatureReaderFidFilter() throws Exception {
  3. FeatureReader<SimpleFeatureType, SimpleFeature> fr;
  4. fr = rts.getFeatureReader(new Query(RENAMED, fidFilter), Transaction.AUTO_COMMIT);
  5. assertEquals(primitive, fr.getFeatureType());
  6. assertTrue(fr.hasNext());
  7. SimpleFeature sf = fr.next();
  8. assertFalse(fr.hasNext());
  9. fr.close();
  10. assertEquals(fid, sf.getID());
  11. }

代码示例来源:origin: geoserver/geoserver

  1. @Test
  2. public void testFeautureReaderFidFilter() throws Exception {
  3. FeatureReader<SimpleFeatureType, SimpleFeature> fr;
  4. fr = rts.getFeatureReader(new Query(RENAMED, fidFilter), Transaction.AUTO_COMMIT);
  5. assertEquals(RENAMED, fr.getFeatureType().getName().getLocalPart());
  6. assertTrue(fr.hasNext());
  7. SimpleFeature sf = fr.next();
  8. assertFalse(fr.hasNext());
  9. fr.close();
  10. assertEquals(fid, sf.getID());
  11. }

代码示例来源:origin: geoserver/geoserver

  1. @Test
  2. public void testModify() throws Exception {
  3. final Query queryAll = new Query(RENAMED);
  4. SimpleFeatureStore store;
  5. store = (SimpleFeatureStore) rts.getFeatureSource(RENAMED);
  6. SimpleFeature original = store.getFeatures(fidFilter).features().next();
  7. String newAddress = ((String) original.getAttribute("ADDRESS")) + " xxx";
  8. store.modifyFeatures(
  9. original.getFeatureType().getDescriptor("ADDRESS"), newAddress, fidFilter);
  10. SimpleFeature modified = store.getFeatures(fidFilter).features().next();
  11. assertEquals(newAddress, modified.getAttribute("ADDRESS"));
  12. }

代码示例来源:origin: geoserver/geoserver

  1. @Test
  2. public void testQueryWithPropertyNames() throws Exception {
  3. // check the schemas in feature source and feature collection
  4. SimpleFeatureSource fs = rts.getFeatureSource(RENAMED);
  5. Query q = new Query(RENAMED, Filter.INCLUDE, new String[] {"ADDRESS"});
  6. FeatureCollection<SimpleFeatureType, SimpleFeature> fc = fs.getFeatures(q);
  7. assertEquals(1, fc.getSchema().getAttributeCount());
  8. // make sure the feature schema is good as well
  9. FeatureIterator<SimpleFeature> it = fc.features();
  10. SimpleFeature sf = it.next();
  11. it.close();
  12. assertEquals(1, sf.getAttributeCount());
  13. assertNull(sf.getAttribute("FID"));
  14. assertNotNull(sf.getAttribute("ADDRESS"));
  15. }
  16. }

相关文章