Package nz.org.riskscape.engine.defaults.data.jdbc

Class GeoPackageOutputStore

java.lang.Object

nz.org.riskscape.engine.defaults.data.jdbc.BaseJdbcOutputStore

nz.org.riskscape.engine.defaults.data.jdbc.GeoPackageOutputStore

All Implemented Interfaces:

AutoCloseable

public class GeoPackageOutputStore
extends BaseJdbcOutputStore
implements AutoCloseable

For writing to GeoPackage files.

Note that writing to GeoPackage files uses a shared connection. It is important that is called to close this shared connection.</p>

Nested Class Summary

Nested classes/interfaces inherited from class nz.org.riskscape.engine.defaults.data.jdbc.BaseJdbcOutputStore

BaseJdbcOutputStore.JdbcRiskscapeWriter, BaseJdbcOutputStore.LocalProblems, BaseJdbcOutputStore.StructMappingToColumnMapping

Field Summary

Fields inherited from class nz.org.riskscape.engine.defaults.data.jdbc.BaseJdbcOutputStore

DEFAULT_BATCH_INSERT_SIZE, ds, PROBLEMS, replaceExistingTables

Constructor Summary

Constructors

Constructor	Description
GeoPackageOutputStore(File geoPackageFile, nz.org.riskscape.engine.pipeline.ExecutionContext context, boolean replaceExistingTables)

Method Summary

Modifier and Type	Method	Description
void	close()
protected BaseJdbcOutputStore.JdbcRiskscapeWriter	createJdbcWriter(String tableName, List<BaseJdbcOutputStore.StructMappingToColumnMapping> mappings, Connection conn, URI storedAt)
protected void	deleteTable(String tableName, Connection conn)
protected Connection	getConnection()	Get a Connection that will be used to both create and then populate the table.
File	getGeoPackageFile()
URI	getTableURI(String tableName)	Get a URI that represents the given table at the JDBC data source.
protected void	initDbIfNecessary(Connection conn)	Initializes the GeoPackage with required tables should they not exist already
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)	Provide a BaseJdbcOutputStore.StructMappingToColumnMapping for the given structMapping.
static nz.org.riskscape.problem.ResultOrProblems<nz.org.riskscape.engine.output.RiskscapeWriter>	writerFor(File geoPackageFile, nz.org.riskscape.engine.pipeline.ExecutionContext context, nz.org.riskscape.engine.types.Struct type, String name, boolean replaceExistingTables)	Get a RiskscapeWriter that can write the given type/name to geoPackageFile.

Methods inherited from class nz.org.riskscape.engine.defaults.data.jdbc.BaseJdbcOutputStore

appendingWriterFor, doWriterFor, getExistingTableNames, normalizeSridAndAxisOrder, quoteIdentifier, runScript, urlEncode, writerFor

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

GeoPackageOutputStore

public GeoPackageOutputStore(File geoPackageFile,
 nz.org.riskscape.engine.pipeline.ExecutionContext context,
 boolean replaceExistingTables)

Method Details

writerFor

public static nz.org.riskscape.problem.ResultOrProblems<nz.org.riskscape.engine.output.RiskscapeWriter> writerFor(File geoPackageFile,
 nz.org.riskscape.engine.pipeline.ExecutionContext context,
 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

context - the execution context that will be using the writer

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

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()