com.vividsolutions.jump.datastore.postgis

Class PostgisFeatureInputStream

java.lang.Object

com.vividsolutions.jump.io.BaseFeatureInputStream

com.vividsolutions.jump.datastore.postgis.PostgisFeatureInputStream

All Implemented Interfaces:

FeatureInputStream

public class PostgisFeatureInputStream
extends BaseFeatureInputStream

Reads features from a PostgreSQL/PostGIS database.

Constructor Summary

Constructors

Constructor and Description
PostgisFeatureInputStream(java.sql.Connection conn, java.lang.String queryString)
PostgisFeatureInputStream(java.sql.Connection conn, java.lang.String queryString, java.lang.String externalIdentifier)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
java.sql.Connection	getConnection()
FeatureSchema	getFeatureSchema()
java.sql.Statement	getStatement()
protected Feature	readNext() Read the next feature, if any.

Methods inherited from class com.vividsolutions.jump.io.BaseFeatureInputStream

hasNext, next

Methods inherited from class java.lang.Object

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

Constructor Detail

PostgisFeatureInputStream

public PostgisFeatureInputStream(java.sql.Connection conn,
                         java.lang.String queryString)

PostgisFeatureInputStream

public PostgisFeatureInputStream(java.sql.Connection conn,
                         java.lang.String queryString,
                         java.lang.String externalIdentifier)

Method Detail

getConnection

public java.sql.Connection getConnection()

Returns:

The underlaying Connection.

getStatement

public java.sql.Statement getStatement()

Returns:

The underlaying Statement. Useful to cancel the query on the server if the PlugIn is interrupted

readNext

protected Feature readNext()
                    throws java.lang.Exception

Description copied from class: BaseFeatureInputStream

Read the next feature, if any.

Specified by:

readNext in class BaseFeatureInputStream

Returns:

the next Feature, or null if there is none

Throws:

java.lang.Exception

close

public void close()
           throws java.sql.SQLException

Specified by:

close in interface FeatureInputStream

Specified by:

close in class BaseFeatureInputStream

Throws:

java.sql.SQLException

getFeatureSchema

public FeatureSchema getFeatureSchema()

Specified by:

getFeatureSchema in interface FeatureInputStream

Specified by:

getFeatureSchema in class BaseFeatureInputStream