net.sourceforge.fluxion.datapublisher.postgresql.impl
Class PostgresqlQuery<T>

java.lang.Object
  net.sourceforge.fluxion.datapublisher.sql.impl.SQLQuery<T>
      net.sourceforge.fluxion.datapublisher.postgresql.impl.PostgresqlQuery<T>

All Implemented Interfaces:

Query<T>

public class PostgresqlQuery<T>
extends SQLQuery<T>

Models a query against a Postgresql bean. Queries are typed with the type of bean the query acts against. A PostgresqlQuery would usually be generated from a PostgresqlQueryFactory.

Version:

0.3

Author:

Tony Burdett

Field Summary

Fields inherited from class net.sourceforge.fluxion.datapublisher.sql.impl.SQLQuery

connection, dbUri, password, user

Constructor Summary

PostgresqlQuery(java.lang.Class<T> beanClass, java.lang.String dbUrl, java.lang.String user, java.lang.String password, Filter filter)

Method Summary

protected void	closeConnection() Close the connection to a postgres database
protected void	openConnection() Open a connection to a Postgres database.

Methods inherited from class net.sourceforge.fluxion.datapublisher.sql.impl.SQLQuery

addFromClause, addSelectClause, addWhereClause, execute, hasMoreResults, nextResult

Methods inherited from class java.lang.Object

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

Constructor Detail

PostgresqlQuery

public PostgresqlQuery(java.lang.Class<T> beanClass,
                       java.lang.String dbUrl,
                       java.lang.String user,
                       java.lang.String password,
                       Filter filter)

Method Detail

openConnection

protected void openConnection()
                       throws QueryExecutionException

Open a connection to a Postgres database.

Specified by:

openConnection in class SQLQuery<T>

Throws:

QueryExecutionException - if opening the connection fails

closeConnection

protected void closeConnection()
                        throws QueryExecutionException

Close the connection to a postgres database

Specified by:

closeConnection in class SQLQuery<T>

Throws:

QueryExecutionException - if closing the connection fails