Package org.hcjf.layers.storage.postgres

Class PostgresStorageSession

java.lang.Object

org.hcjf.layers.storage.StorageSession

org.hcjf.layers.storage.postgres.PostgresStorageSession

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	Description
PostgresStorageSession(java.lang.String implName, java.sql.Connection connection)

Method Summary

Modifier and Type	Method	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, java.sql.ResultSet sqlResultSet, java.lang.Class resultType)	Creates a hcjf result set from a postgres data base result set.
java.sql.Connection	getConnection()	Return the instance of the pooled postgres connection asocciated to the session.
protected java.lang.Object	getValueFromColumn(java.lang.Object columnValue)	Mapping some kind of data type from data base to java types.
org.hcjf.layers.storage.actions.Insert	insert()	Returns the insert operation implementation
void	onError(java.lang.Throwable throwable)	This method is callas when occurs an error in some operation over the session.
java.lang.StringBuilder	processEvaluators(java.lang.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.
java.sql.PreparedStatement	setValues(java.sql.PreparedStatement statement, org.hcjf.layers.query.EvaluatorCollection collection, java.lang.Integer index, java.lang.Object... params)	Set the values for the prepared statement.
org.hcjf.layers.storage.actions.Update	update(org.hcjf.layers.query.Query query, java.util.Map<java.lang.String,java.lang.Object> values)	Returns the update operation implementation.

Methods inherited from class java.lang.Object

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

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

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

Constructor Detail

PostgresStorageSession

public PostgresStorageSession(java.lang.String implName,
                              java.sql.Connection connection)

Method Detail

getConnection

public final java.sql.Connection getConnection()

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

Returns:

Polled postgres connection.

onError

public final void onError(java.lang.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 java.io.IOException

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

Throws:

java.io.IOException

createResultSet

public <R extends org.hcjf.layers.storage.actions.ResultSet> R createResultSet(org.hcjf.layers.query.Query query,
                                                                               java.sql.ResultSet sqlResultSet,
                                                                               java.lang.Class resultType)
                                                                        throws java.sql.SQLException,
                                                                               java.lang.IllegalAccessException,
                                                                               java.lang.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:

java.sql.SQLException

java.lang.IllegalAccessException

java.lang.InstantiationException

getValueFromColumn

protected java.lang.Object getValueFromColumn(java.lang.Object columnValue)
                                       throws java.sql.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:

java.sql.SQLException

processEvaluators

public java.lang.StringBuilder processEvaluators(java.lang.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 java.sql.PreparedStatement setValues(java.sql.PreparedStatement statement,
                                            org.hcjf.layers.query.EvaluatorCollection collection,
                                            java.lang.Integer index,
                                            java.lang.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,
                                                     java.util.Map<java.lang.String,java.lang.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

insert

public org.hcjf.layers.storage.actions.Insert insert()
                                              throws org.hcjf.layers.storage.StorageAccessException

Returns the insert operation implementation

Overrides:

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

Returns:

insert query

Throws:

org.hcjf.layers.storage.StorageAccessException