org.gvsig.fmap.dal.store.jdbc

Class JDBCHelper

java.lang.Object

org.gvsig.tools.dispose.impl.AbstractDisposable

org.gvsig.fmap.dal.store.jdbc.JDBCHelper

All Implemented Interfaces:

ResourceConsumer, Disposable

Direct Known Subclasses:

H2Helper, PostgreSQLHelper

public class JDBCHelper
extends AbstractDisposable
implements ResourceConsumer

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	JDBCHelper.DalValueToJDBCException

Field Summary

Fields

Modifier and Type	Field and Description
protected String	defaultSchema
protected GeometryManager	geomManager
protected boolean	isOpen
protected String	name
protected JDBCConnectionParameters	params
protected JDBCHelperUser	user

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	JDBCHelper(JDBCHelperUser consumer, JDBCConnectionParameters params)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	allowAutomaticValues()
void	close()
void	closeConnection(Connection connection)
boolean	closeResourceRequested(ResourceProvider resource)
protected Geometry	coerce(GeometryType type, Geometry geometry)
String	compoundLimitAndOffset(long limit, long offset)
protected EditableFeatureAttributeDescriptor	createAttributeFromJDBC(EditableFeatureType fType, Connection conn, ResultSetMetaData rsMetadata, int colIndex)
protected EditableFeatureAttributeDescriptor	createAttributeFromJDBCNativeType(EditableFeatureType fType, ResultSetMetaData rsMetadata, int colIndex)
protected List	createGrantStatements(JDBCNewStoreParameters ndsp)
protected List	createGrantStatements(JDBCNewStoreParameters ndsp, String table)
protected List	createGrantStatements(String tableName, String privilege, String theRoles)
Object	dalValueToJDBC(FeatureAttributeDescriptor attributeDescriptor, Object value)
Object	doConnectionAction(ConnectionAction action) Executes an atomic action that uses an DB Connection.
protected void	doDispose() Internal implementation for the AbstractDisposable.dispose() method, to be implemented by child classes.
String	escapeFieldName(String field)
static void	execute(PreparedStatement st, String sql)
static void	execute(Statement st, String sql)
void	execute(String sql)
static ResultSet	executeQuery(PreparedStatement st, String sql)
static ResultSet	executeQuery(Statement st, String sql)
static int	executeUpdate(PreparedStatement st)
List	getAdditionalSqlToCreate(NewDataStoreParameters ndsp, FeatureType fType)
protected EditableFeatureAttributeDescriptor	getAttributeFromJDBC(EditableFeatureType fType, Connection conn, ResultSetMetaData rsMetadata, int colIndex)
Connection	getConnection()
protected String	getDefaltFieldValueString(FeatureAttributeDescriptor attr) Deprecated. use getDefaultFieldValueString this has a type writer error.
protected String	getDefaultFieldValueString(FeatureAttributeDescriptor attr)
protected String	getDefaultSchema(Connection conn)
Envelope	getFullEnvelopeOfField(JDBCStoreParameters storeParams, String geometryAttrName, Envelope limit) Override if provider has geometry support
Geometry	getGeometry(byte[] buffer)
protected String	getIdentifierQuoteString()
protected String[]	getPksFrom(Connection conn, JDBCStoreParameters params)
protected String[]	getPksFromInformationSchema(Connection conn, JDBCStoreParameters params)
int	getProviderSRID(IProjection srs)
int	getProviderSRID(String srs)
JDBCResource	getResource()
String	getSqlColumnTypeDescription(FeatureAttributeDescriptor attr)
String	getSqlFieldDescription(FeatureAttributeDescriptor attr)
String	getSqlFieldName(FeatureAttributeDescriptor attribute)
protected void	initializeResource()
boolean	isOpen()
protected boolean	isReservedWord(String field)
protected void	loadFeatureType(Connection conn, EditableFeatureType featureType, String sql, String[] pks, String defGeomName, String schema, String table)
void	loadFeatureType(EditableFeatureType featureType, JDBCStoreParameters storeParams)
void	loadFeatureType(EditableFeatureType featureType, JDBCStoreParameters storeParams, String sql, String schema, String table)
protected void	loadSRS_and_shapeType(Connection conn, ResultSetMetaData rsMetadata, EditableFeatureType featureType, String baseSchema, String baseTable) Fill featureType geometry attributes with SRS and ShapeType information Override this if provider has native eometry support
boolean	open() open the resource
void	resourceChanged(ResourceProvider resource)
protected void	setResource(JDBCResource resource)
String	stringJoin(List listToJoin, String sep)
void	stringJoin(List listToJoin, String sep, StringBuilder strb)
boolean	supportOffset()
protected boolean	supportsGeometry() Inform that provider has supports for geometry store and operations natively
boolean	supportsUnion()

Methods inherited from class org.gvsig.tools.dispose.impl.AbstractDisposable

dispose, dispose

Methods inherited from class java.lang.Object

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

Field Detail

user

protected JDBCHelperUser user

isOpen

protected boolean isOpen

name

protected String name

defaultSchema

protected String defaultSchema

params

protected JDBCConnectionParameters params

geomManager

protected GeometryManager geomManager

Constructor Detail

JDBCHelper

protected JDBCHelper(JDBCHelperUser consumer,
          JDBCConnectionParameters params)
              throws InitializeException

Throws:

InitializeException

Method Detail

executeQuery

public static ResultSet executeQuery(Statement st,
                     String sql)
                              throws SQLException

Throws:

SQLException

execute

public static void execute(Statement st,
           String sql)
                    throws SQLException

Throws:

SQLException

executeQuery

public static ResultSet executeQuery(PreparedStatement st,
                     String sql)
                              throws SQLException

Throws:

SQLException

execute

public static void execute(PreparedStatement st,
           String sql)
                    throws SQLException

Throws:

SQLException

executeUpdate

public static int executeUpdate(PreparedStatement st)
                         throws SQLException

Throws:

SQLException

closeConnection

public void closeConnection(Connection connection)

execute

public void execute(String sql)
             throws JDBCExecuteSQLException

Throws:

JDBCExecuteSQLException

initializeResource

protected void initializeResource()
                           throws InitializeException

Throws:

InitializeException

setResource

protected final void setResource(JDBCResource resource)

closeResourceRequested

public boolean closeResourceRequested(ResourceProvider resource)

Specified by:

closeResourceRequested in interface ResourceConsumer

resourceChanged

public void resourceChanged(ResourceProvider resource)

Specified by:

resourceChanged in interface ResourceConsumer

open

public boolean open()
             throws OpenException

open the resource

Returns:

true if the resourse was open in this call

Throws:

OpenException

getResource

public JDBCResource getResource()

close

public void close()
           throws CloseException

Throws:

CloseException

getConnection

public Connection getConnection()
                         throws AccessResourceException

Throws:

AccessResourceException

doDispose

protected void doDispose()
                  throws BaseException

Description copied from class: AbstractDisposable

Internal implementation for the AbstractDisposable.dispose() method, to be implemented by child classes.

Specified by:

doDispose in class AbstractDisposable

Throws:

BaseException

See Also:

AbstractDisposable.dispose()

isOpen

public boolean isOpen()

doConnectionAction

public Object doConnectionAction(ConnectionAction action)
                          throws Exception

Executes an atomic action that uses an DB Connection.
This methos prepares a connection and close it at the end of execution of action.
if action is an instance of TransactionalAction the action will be execute inside of a DB transaction.

Parameters:

action -

Throws:

Exception

getDefaultSchema

protected String getDefaultSchema(Connection conn)
                           throws JDBCException

Throws:

JDBCException

createAttributeFromJDBC

protected EditableFeatureAttributeDescriptor createAttributeFromJDBC(EditableFeatureType fType,
                                                         Connection conn,
                                                         ResultSetMetaData rsMetadata,
                                                         int colIndex)
                                                              throws SQLException

Throws:

SQLException

createAttributeFromJDBCNativeType

protected EditableFeatureAttributeDescriptor createAttributeFromJDBCNativeType(EditableFeatureType fType,
                                                                   ResultSetMetaData rsMetadata,
                                                                   int colIndex)
                                                                        throws SQLException

Throws:

SQLException

getAttributeFromJDBC

protected EditableFeatureAttributeDescriptor getAttributeFromJDBC(EditableFeatureType fType,
                                                      Connection conn,
                                                      ResultSetMetaData rsMetadata,
                                                      int colIndex)
                                                           throws JDBCException

Throws:

JDBCException

loadSRS_and_shapeType

protected void loadSRS_and_shapeType(Connection conn,
                         ResultSetMetaData rsMetadata,
                         EditableFeatureType featureType,
                         String baseSchema,
                         String baseTable)
                              throws JDBCException

Fill featureType geometry attributes with SRS and ShapeType information Override this if provider has native eometry support

Parameters:

conn -

rsMetadata -

featureType -

Throws:

ReadException

JDBCException

loadFeatureType

public void loadFeatureType(EditableFeatureType featureType,
                   JDBCStoreParameters storeParams)
                     throws DataException

Throws:

DataException

loadFeatureType

public void loadFeatureType(EditableFeatureType featureType,
                   JDBCStoreParameters storeParams,
                   String sql,
                   String schema,
                   String table)
                     throws DataException

Throws:

DataException

getPksFrom

protected String[] getPksFrom(Connection conn,
                  JDBCStoreParameters params)
                       throws JDBCException

Throws:

JDBCException

getPksFromInformationSchema

protected String[] getPksFromInformationSchema(Connection conn,
                                   JDBCStoreParameters params)
                                        throws JDBCException

Throws:

JDBCException

loadFeatureType

protected void loadFeatureType(Connection conn,
                   EditableFeatureType featureType,
                   String sql,
                   String[] pks,
                   String defGeomName,
                   String schema,
                   String table)
                        throws DataException

Throws:

DataException

getFullEnvelopeOfField

public Envelope getFullEnvelopeOfField(JDBCStoreParameters storeParams,
                              String geometryAttrName,
                              Envelope limit)
                                throws DataException

Override if provider has geometry support

Parameters:

storeParams -

geometryAttrName -

limit -

Returns:

Throws:

DataException

getGeometry

public Geometry getGeometry(byte[] buffer)
                     throws BaseException

Throws:

BaseException

escapeFieldName

public String escapeFieldName(String field)

coerce

protected Geometry coerce(GeometryType type,
              Geometry geometry)

dalValueToJDBC

public Object dalValueToJDBC(FeatureAttributeDescriptor attributeDescriptor,
                    Object value)
                      throws WriteException

Throws:

WriteException

getSqlColumnTypeDescription

public String getSqlColumnTypeDescription(FeatureAttributeDescriptor attr)

getProviderSRID

public int getProviderSRID(String srs)

getProviderSRID

public int getProviderSRID(IProjection srs)

getSqlFieldName

public String getSqlFieldName(FeatureAttributeDescriptor attribute)

getSqlFieldDescription

public String getSqlFieldDescription(FeatureAttributeDescriptor attr)
                              throws DataException

Throws:

DataException

getDefaltFieldValueString

protected String getDefaltFieldValueString(FeatureAttributeDescriptor attr)
                                    throws WriteException

Deprecated. use getDefaultFieldValueString this has a type writer error.

Throws:

WriteException

getDefaultFieldValueString

protected String getDefaultFieldValueString(FeatureAttributeDescriptor attr)
                                     throws WriteException

Throws:

WriteException

compoundLimitAndOffset

public String compoundLimitAndOffset(long limit,
                            long offset)

supportOffset

public boolean supportOffset()

getAdditionalSqlToCreate

public List getAdditionalSqlToCreate(NewDataStoreParameters ndsp,
                            FeatureType fType)

stringJoin

public String stringJoin(List listToJoin,
                String sep)

stringJoin

public void stringJoin(List listToJoin,
              String sep,
              StringBuilder strb)

supportsGeometry

protected boolean supportsGeometry()

Inform that provider has supports for geometry store and operations natively

Returns:

allowAutomaticValues

public boolean allowAutomaticValues()

supportsUnion

public boolean supportsUnion()

getIdentifierQuoteString

protected String getIdentifierQuoteString()

isReservedWord

protected boolean isReservedWord(String field)

createGrantStatements

protected List createGrantStatements(JDBCNewStoreParameters ndsp)

createGrantStatements

protected List createGrantStatements(JDBCNewStoreParameters ndsp,
                         String table)

createGrantStatements

protected List createGrantStatements(String tableName,
                         String privilege,
                         String theRoles)