org.hcjf.layers.storage.postgres

Class PostgresStorageSession

java.lang.Object

org.hcjf.layers.storage.StorageSession

org.hcjf.layers.storage.postgres.PostgresStorageSession

All Implemented Interfaces:

Closeable, AutoCloseable

public class PostgresStorageSession
extends org.hcjf.layers.storage.StorageSession

This class implements the postgres session.

Author:

Javier Quiroga.

Nested Class Summary

Nested classes/interfaces inherited from class org.hcjf.layers.storage.StorageSession

org.hcjf.layers.storage.StorageSession.PostEvaluationStrategy

Constructor Summary

Constructors

Constructor and Description
PostgresStorageSession(String implName, Connection connection)

Method Summary

Modifier and Type	Method and Description
void	close() Close the postgres connection, when the connection is closed its is released to the connections pool.
<R extends org.hcjf.layers.storage.actions.ResultSet> R	createResultSet(org.hcjf.layers.query.Query query, ResultSet sqlResultSet, Class resultType) Creates a hcjf result set from a postgres data base result set.
Connection	getConnection() Return the instance of the pooled postgres connection asocciated to the session.
protected Object	getValueFromColumn(Object columnValue) Mapping some kind of data type from data base to java types.
void	onError(Throwable throwable) This method is callas when occurs an error in some operation over the session.
StringBuilder	processEvaluators(StringBuilder result, org.hcjf.layers.query.EvaluatorCollection collection) Put into the query builder all the restrictions based on collection evaluator.
org.hcjf.layers.storage.actions.Select	select(org.hcjf.layers.query.Query query) Return the select (postgres implementation) instance associated to the query parameter.
PreparedStatement	setValues(PreparedStatement statement, org.hcjf.layers.query.EvaluatorCollection collection, Integer index, Object... params) Set the values for the prepared statement.
org.hcjf.layers.storage.actions.Update	update(org.hcjf.layers.query.Query query, Map<String,Object> values) Returns the update operation implementation.

Methods inherited from class org.hcjf.layers.storage.StorageSession

delete, delete, delete, getImplName, getPostEvaluationStrategy, insert, insert, normalizeApplicationToDataSource, normalizeDataSourceToApplication, procedure, setPostEvaluationStrategy, update, update, update, update, update, upsert, upsert

Methods inherited from class java.lang.Object

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

Constructor Detail

PostgresStorageSession

public PostgresStorageSession(String implName,
                              Connection connection)

Method Detail

getConnection

public final Connection getConnection()

Return the instance of the pooled postgres connection asocciated to the session.

Returns:

Polled postgres connection.

onError

public final void onError(Throwable throwable)

This method is callas when occurs an error in some operation over the session.

Parameters:

throwable - Throwable that represents the error.

close

public void close()
           throws IOException

Close the postgres connection, when the connection is closed its is released to the connections pool.

Throws:

IOException

createResultSet

public <R extends org.hcjf.layers.storage.actions.ResultSet> R createResultSet(org.hcjf.layers.query.Query query,
                                                                               ResultSet sqlResultSet,
                                                                               Class resultType)
                                                                        throws SQLException,
                                                                               IllegalAccessException,
                                                                               InstantiationException

Creates a hcjf result set from a postgres data base result set.

Type Parameters:

R - Expected kind of result set.

Parameters:

query - Query instance that was evaluated for postgres engine.

sqlResultSet - Postgres result set.

resultType - Expected object to create hcjf result set.

Returns:

Result set instance.

Throws:

SQLException

IllegalAccessException

InstantiationException

getValueFromColumn

protected Object getValueFromColumn(Object columnValue)
                             throws SQLException

Mapping some kind of data type from data base to java types.

Parameters:

columnValue - Value from data base column.

Returns:

Java-friendly instance

Throws:

SQLException

processEvaluators

public StringBuilder processEvaluators(StringBuilder result,
                                       org.hcjf.layers.query.EvaluatorCollection collection)

Put into the query builder all the restrictions based on collection evaluator.

Parameters:

result - Query builder.

collection - Evaluator collection.

Returns:

Query builder.

setValues

public PreparedStatement setValues(PreparedStatement statement,
                                   org.hcjf.layers.query.EvaluatorCollection collection,
                                   Integer index,
                                   Object... params)

Set the values for the prepared statement.

Parameters:

statement - Prepared statement.

collection - Evaluator collection.

index - Starting index of the parameters.

params - Execution parameters.

Returns:

Prepared statement.

select

public org.hcjf.layers.storage.actions.Select select(org.hcjf.layers.query.Query query)
                                              throws org.hcjf.layers.storage.StorageAccessException

Return the select (postgres implementation) instance associated to the query parameter.

Overrides:

select in class org.hcjf.layers.storage.StorageSession

Parameters:

query - Query parameter.

Returns:

Select instance.

Throws:

org.hcjf.layers.storage.StorageAccessException

update

public org.hcjf.layers.storage.actions.Update update(org.hcjf.layers.query.Query query,
                                                     Map<String,Object> values)
                                              throws org.hcjf.layers.storage.StorageAccessException

Returns the update operation implementation.

Overrides:

update in class org.hcjf.layers.storage.StorageSession

Parameters:

query - Query to filter the update.

values - Values to be updated.

Returns:

update operation.

Throws:

org.hcjf.layers.storage.StorageAccessException