weave.geometrystream

Class SQLGeometryStreamDestination

java.lang.Object

weave.geometrystream.SQLGeometryStreamDestination

All Implemented Interfaces:

weave.geometrystream.IGeometryStreamDestination

public class SQLGeometryStreamDestination
extends java.lang.Object
implements weave.geometrystream.IGeometryStreamDestination

This class writes a geometry stream to a SQL table.

Author:

adufilie

Field Summary

Fields

Modifier and Type	Field and Description
protected weave.utils.SerialIDGenerator	geometryTileIDGenerator
static java.lang.String	MAX_IMPORTANCE
protected weave.utils.SerialIDGenerator	metadataTileIDGenerator
static java.lang.String	MIN_IMPORTANCE
static java.lang.String	SQL_TABLE_GEOMETRY_SUFFIX
static java.lang.String	SQL_TABLE_METADATA_SUFFIX
static java.lang.String	TILE_DATA
static java.lang.String	TILE_ID
static java.lang.String	X_MAX_BOUNDS
static java.lang.String	X_MIN_BOUNDS
static java.lang.String	Y_MAX_BOUNDS
static java.lang.String	Y_MIN_BOUNDS

Constructor Summary

Constructors

Constructor and Description
SQLGeometryStreamDestination(java.sql.Connection conn, java.lang.String sqlSchema, java.lang.String sqlTablePrefix, boolean overwriteTables)

Method Summary

Methods

Modifier and Type	Method and Description
void	commit()
protected void	createTileTable(java.lang.String sqlTable)
java.lang.String	getGeometryTableName()
java.lang.String	getMetadataTableName()
void	writeGeometryTiles(java.util.List<weave.geometrystream.StreamTile> tiles)
void	writeMetadataTiles(java.util.List<weave.geometrystream.StreamTile> tiles)
protected void	writeTilesToSQL(java.util.List<weave.geometrystream.StreamTile> streamTiles, java.lang.String sqlTable, weave.utils.SerialIDGenerator tileIDGenerator)

Methods inherited from class java.lang.Object

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

Field Detail

SQL_TABLE_METADATA_SUFFIX

public static final java.lang.String SQL_TABLE_METADATA_SUFFIX

See Also:

Constant Field Values

SQL_TABLE_GEOMETRY_SUFFIX

public static final java.lang.String SQL_TABLE_GEOMETRY_SUFFIX

See Also:

Constant Field Values

MIN_IMPORTANCE

public static final java.lang.String MIN_IMPORTANCE

See Also:

Constant Field Values

MAX_IMPORTANCE

public static final java.lang.String MAX_IMPORTANCE

See Also:

Constant Field Values

X_MIN_BOUNDS

public static final java.lang.String X_MIN_BOUNDS

See Also:

Constant Field Values

Y_MIN_BOUNDS

public static final java.lang.String Y_MIN_BOUNDS

See Also:

Constant Field Values

X_MAX_BOUNDS

public static final java.lang.String X_MAX_BOUNDS

See Also:

Constant Field Values

Y_MAX_BOUNDS

public static final java.lang.String Y_MAX_BOUNDS

See Also:

Constant Field Values

TILE_ID

public static final java.lang.String TILE_ID

See Also:

Constant Field Values

TILE_DATA

public static final java.lang.String TILE_DATA

See Also:

Constant Field Values

metadataTileIDGenerator

protected weave.utils.SerialIDGenerator metadataTileIDGenerator

geometryTileIDGenerator

protected weave.utils.SerialIDGenerator geometryTileIDGenerator

Constructor Detail

SQLGeometryStreamDestination

public SQLGeometryStreamDestination(java.sql.Connection conn,
                            java.lang.String sqlSchema,
                            java.lang.String sqlTablePrefix,
                            boolean overwriteTables)
                             throws java.sql.SQLException

Parameters:

conn - The SQL connection to use to create tables.

sqlSchema - The schema to use when creating a table.

sqlTablePrefix - The prefix that will be used when generating table names for metadata and geometry tiles.

overwriteTables - If true and the sql tables exist, an SQLException will be thrown.

Throws:

java.sql.SQLException - Thrown if the sql tables could not be created.

Method Detail

getMetadataTableName

public java.lang.String getMetadataTableName()

getGeometryTableName

public java.lang.String getGeometryTableName()

createTileTable

protected void createTileTable(java.lang.String sqlTable)
                        throws java.sql.SQLException

Throws:

java.sql.SQLException

writeMetadataTiles

public void writeMetadataTiles(java.util.List<weave.geometrystream.StreamTile> tiles)
                        throws java.lang.Exception

Specified by:

writeMetadataTiles in interface weave.geometrystream.IGeometryStreamDestination

Throws:

java.lang.Exception

writeGeometryTiles

public void writeGeometryTiles(java.util.List<weave.geometrystream.StreamTile> tiles)
                        throws java.lang.Exception

Specified by:

writeGeometryTiles in interface weave.geometrystream.IGeometryStreamDestination

Throws:

java.lang.Exception

commit

public void commit()
            throws java.lang.Exception

Specified by:

commit in interface weave.geometrystream.IGeometryStreamDestination

Throws:

java.lang.Exception

writeTilesToSQL

protected void writeTilesToSQL(java.util.List<weave.geometrystream.StreamTile> streamTiles,
                   java.lang.String sqlTable,
                   weave.utils.SerialIDGenerator tileIDGenerator)
                        throws java.io.IOException,
                               java.sql.SQLException

Throws:

java.io.IOException

java.sql.SQLException