Java: WFSDatastore возвращает компоненты, которые будут использоваться в основном классе

Question

Я довольно новичок в программировании на Java, поэтому я благодарен за любую помощь. В настоящее время я пытаюсь получить доступ к функциям хранилища данных WFS в другом классе проекта - для дальнейшего повторного преобразования проекции и отображения этих функций с обработкой.

с возвратом wfsDSF я почему-то не могу получить доступ к функциям (долг, широта, дата, время, скорость..)

Печать функций в консоли уже работает для меня.

здесь код (кроме url и featuresource):

import java.io.IOException;
import java.sql.SQLException;
import java.util.HashMap;

import org.geotools.data.simple.SimpleFeatureCollection;
import org.geotools.data.simple.SimpleFeatureIterator;
import org.geotools.data.simple.SimpleFeatureSource;
import org.geotools.data.wfs.WFSDataStore;
import org.geotools.data.wfs.WFSDataStoreFactory;
import org.opengis.feature.Feature;


public class WFSConnector {

public static WFSDataStoreFactory wfsDSF () throws SQLException {

    // define the getCapabilities request
    String wfsGetCapabilitiesURL = "URL";

    // create WFSDataStoreFactory object
    WFSDataStoreFactory wfsDSF = new WFSDataStoreFactory();

    // create HashMap and fill it with connection parameters
    HashMap connectionParameters = new HashMap();
    connectionParameters.put(WFSDataStoreFactory.URL.key, wfsGetCapabilitiesURL);
    connectionParameters.put(WFSDataStoreFactory.TIMEOUT.key, 20000);

    try {
        WFSDataStore wfsDS = wfsDSF.createDataStore(connectionParameters);          
        SimpleFeatureSource sfSource = wfsDS.getFeatureSource("SELECTED-FEATURE");
        SimpleFeatureCollection sfCollection = sfSource.getFeatures();
        SimpleFeatureIterator sfIterator = sfCollection.features();          

       // check if the FeatureReader object holds another
       while(sfIterator.hasNext() == true)
       {
            //iterate through the "rows" of the WFS response
            Feature currentFeature = sfIterator.next();

            String coordinates = currentFeature.getProperty("the_geom").getValue().toString();
            String fphenomenon = currentFeature.getProperty("phenomenon").getValue().toString();
            String ftriptime = currentFeature.getProperty("tripTime").getValue().toString();
            String fheartrate = currentFeature.getProperty("heartrate").getValue().toString();

            //get rid of the name "point" and the brackets of the geometry string
            int x = coordinates.lastIndexOf('(');
            int y = coordinates.lastIndexOf(')');
            String coord = coordinates.substring(x+1, y);                

            //split the coordinates into 2 parts
            String[] splitcoordinates = coord.split(" ");
            String lon = splitcoordinates[0];
            String lat = splitcoordinates[1];

            //split phenomenon into date and time                                
            String date = fphenomenon.substring(0,10); 
            String time = fphenomenon.substring(11,19);  

            {
                System.out.println(lon  + " : " + lat + " : " + date + " : " + time + " : " + ftriptime + " : " + fheartrate);
            }
       }          
    } 
    catch (IOException e2) {
        e2.printStackTrace();
        }

    return wfsDSF;  

} // main
} // class

Answer 1

Вы идете в правильном направлении, но есть несколько более простых способов помочь с тем, что вы пытаетесь сделать. Обычно я бы вернул FeatureCollection в моей основной программе, чтобы провести там обработку.

Так что-то вроде:

private SimpleFeatureCollection getFeatureCollection(String typeName) throws IOException {
   return dataStore.getFeatureSource(typeName).getFeatures();
}

String typeName = "topp:states";
SimpleFeatureCollection features = me.getFeatureCollection(typeName);
try (SimpleFeatureIterator itr = features.features()) {
  while (itr.hasNext()) {
    SimpleFeature f = itr.next();
    //[.......]
  }
}

это общая модель. Обратите внимание, если не заставлять всегда использовать SimpleFeatures а не общие. Тогда вместо сложных манипуляций со строками к атрибутам можно обращаться как к объектам Java с подходящими приведениями.

    SimpleFeature f = itr.next();
    Geometry geom = (Geometry) f.getDefaultGeometry();
    double lat = geom.getCentroid().getY();
    double lon = geom.getCentroid().getX();
    String name = (String) f.getAttribute("STATE_NAME");
    String abbr = (String) f.getAttribute("STATE_ABBR");
    double people = (double) f.getAttribute("PERSONS");
    System.out.println(name + "\t(" + abbr + ")\t" + people + "\t(" + lat + "," + lon + ")");

Очевидно, что вы можете делать любую обработку в этом цикле. Для геометрии я взял centroid так как я знал, что у меня есть многоугольник, если у вас есть очки, просто позвоните .getX() & .getY() прямо по делу.

Вот вся программа:

import java.io.IOException;
import java.io.Serializable;
import java.util.HashMap;
import java.util.Map;

import org.geotools.data.DataStore;
import org.geotools.data.DataStoreFinder;
import org.geotools.data.simple.SimpleFeatureCollection;
import org.geotools.data.simple.SimpleFeatureIterator;
import org.geotools.data.wfs.WFSDataStoreFactory;
import org.locationtech.jts.geom.Geometry;
import org.opengis.feature.simple.SimpleFeature;
import org.opengis.feature.simple.SimpleFeatureType;

public class GetWFSAttributes {
  DataStore dataStore = null;

  public static void main(String[] args) throws IOException {
    String getCapabilities = "http://localhost:8080/geoserver/ows?service=wfs&version=1.1.0&request=GetCapabilities";
    GetWFSAttributes me = new GetWFSAttributes(getCapabilities);
    String[] names = me.getTypeNames();
    for (String name : names) {
      SimpleFeatureType schema = me.getSchema(name);
      System.out.println(name + ":" + schema);
    }

    String typeName = "topp:states";
    SimpleFeatureCollection features = me.getFeatureCollection(typeName);
    try (SimpleFeatureIterator itr = features.features()) {
      while (itr.hasNext()) {
        SimpleFeature f = itr.next();
        Geometry geom = (Geometry) f.getDefaultGeometry();
        double lat = geom.getCentroid().getY();
        double lon = geom.getCentroid().getX();
        String name = (String) f.getAttribute("STATE_NAME");
        String abbr = (String) f.getAttribute("STATE_ABBR");
        double people = (double) f.getAttribute("PERSONS");
        System.out.println(name + "\t(" + abbr + ")\t" + people + "\t(" + lat + "," + lon + ")");
      }
    }
  }

  private SimpleFeatureCollection getFeatureCollection(String typeName) throws IOException {
    return dataStore.getFeatureSource(typeName).getFeatures();
  }

  private String[] getTypeNames() throws IOException {
    return dataStore.getTypeNames();
  }

  private SimpleFeatureType getSchema(String name) throws IOException {
    return dataStore.getSchema(name);
  }

  public GetWFSAttributes(String capabilities) {
    aquireDataStoreWFS(capabilities);
  }

  public void aquireDataStoreWFS(String capabilities) {
    if (dataStore == null) {
      try {
        Map<String, Serializable> connectionParameters = new HashMap<>();
        connectionParameters.put(WFSDataStoreFactory.URL.key, capabilities);
        dataStore = DataStoreFinder.getDataStore(connectionParameters);
      } catch (IOException e) {
        e.printStackTrace();
      }
    }
  }
}