Class GeoPackageOutputStore

Method Details

• writerFor

  public static nz.org.riskscape.problem.ResultOrProblems<nz.org.riskscape.engine.output.RiskscapeWriter> writerFor(File geoPackageFile, nz.org.riskscape.engine.types.Struct type, String name, boolean replaceExistingTables)

  Get a RiskscapeWriter that can write the given type/name to geoPackageFile.

  Note that the GeoPackageOutputStore will be closed when the returned RiskscapeWriter is closed.

  This method is only appropriate when a single layer is to be written to the GeoPackage. If multiple layers are to be written then BaseJdbcOutputStore.writerFor(Struct, String) should be used.

  Parameters:

  geoPackageFile - the GeoPackage file to be written to

  type - the type to write

  name - the desired name to write to

  replaceExistingTables - true if existing tables should be replaced

  Returns:

  riskscape writer or problems preventing one from being created

• getConnection

  protected Connection getConnection() throws SQLException

  Description copied from class: BaseJdbcOutputStore

  Get a Connection that will be used to both create and then populate the table.

  Note that if this method is overridden to return a shared connection then BaseJdbcOutputStore.createJdbcWriter(java.lang.String, java.util.List, java.sql.Connection, java.net.URI) should also be overridden to return a BaseJdbcOutputStore.JdbcRiskscapeWriter that will not close the shared connection. In this case the implementation will need to take other steps to ensure that the connection is closed.

  Overrides:

  getConnection in class BaseJdbcOutputStore

  Throws:

  SQLException

• createJdbcWriter

  protected BaseJdbcOutputStore.JdbcRiskscapeWriter createJdbcWriter(String tableName, List<BaseJdbcOutputStore.StructMappingToColumnMapping> mappings, Connection conn, URI storedAt) throws SQLException

  Overrides:

  createJdbcWriter in class BaseJdbcOutputStore

  Throws:

  SQLException

• close

  public void close() throws Exception

  Specified by:

  close in interface AutoCloseable

  Throws:

  Exception

• toColumnMapping

  protected nz.org.riskscape.problem.ResultOrProblems<BaseJdbcOutputStore.StructMappingToColumnMapping> toColumnMapping(nz.org.riskscape.engine.output.StructFlattener.StructMapping structMapping, nz.org.riskscape.engine.output.StructFlattener.StructMapping firstGeomMapping, Connection conn) throws nz.org.riskscape.problem.ProblemException

  Description copied from class: BaseJdbcOutputStore

  Provide a BaseJdbcOutputStore.StructMappingToColumnMapping for the given structMapping.

  firstGeomMapping is also provided to allow implementations that only allow one spatial entry to map subsequent geometries, maybe to text WKT.

  Specified by:

  toColumnMapping in class BaseJdbcOutputStore

  Parameters:

  structMapping - the struct mapping to map

  firstGeomMapping - the first geometry mapping, if one exists

  Returns:

  a mapper

  Throws:

  nz.org.riskscape.problem.ProblemException

• postTableCreate

  protected void postTableCreate(String tableName, nz.org.riskscape.engine.output.StructFlattener.StructMapping geomMapping, Connection conn) throws SQLException, nz.org.riskscape.problem.ProblemException

  Description copied from class: BaseJdbcOutputStore

  Allow implementations to perform any other actions that may be required now that a feature table has been created. This could be to register the table such as a GeoPackage will register a table in 'gpkgcontents' and 'gpkggeometry_columns' for a geometry column.

  Overrides:

  postTableCreate in class BaseJdbcOutputStore

  Parameters:

  tableName - the name of the table that has been created

  geomMapping - the first geometry mapping from that table, or null if none exist

  conn - a connection that can be used for further sql statements.

  Throws:

  SQLException

  nz.org.riskscape.problem.ProblemException

• getTableURI

  public URI getTableURI(String tableName)

  Description copied from class: BaseJdbcOutputStore

  Get a URI that represents the given table at the JDBC data source. Will be returned from RiskscapeWriter.getStoredAt() when writing is complete.

  Specified by:

  getTableURI in class BaseJdbcOutputStore

  Parameters:

  tableName - the table that is being written with URL encoding

  Returns:

  URI representing the table

• initDbIfNecessary

  protected void initDbIfNecessary(Connection conn)

  Initializes the GeoPackage with required tables should they not exist already

  Overrides:

  initDbIfNecessary in class BaseJdbcOutputStore

  Parameters:

  conn -

• deleteTable

  protected void deleteTable(String tableName, Connection conn) throws SQLException

  Overrides:

  deleteTable in class BaseJdbcOutputStore

  Throws:

  SQLException

• getGeoPackageFile

  public File getGeoPackageFile()