Package marauroa.server.db.adapter

Class PostgresDatabaseAdapter

java.lang.Object

marauroa.server.db.adapter.AbstractDatabaseAdapter

marauroa.server.db.adapter.PostgresDatabaseAdapter

All Implemented Interfaces:

DatabaseAdapter

public class PostgresDatabaseAdapter
extends AbstractDatabaseAdapter

abstracts from PostgreSQL specifications

Author:

hendrik

Field Summary

Fields inherited from class marauroa.server.db.adapter.AbstractDatabaseAdapter

connection, resultSets, statements

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	PostgresDatabaseAdapter()	creates a new PostgresqlDatabaseAdapter for test purposes, without connection to the DB
	PostgresDatabaseAdapter(Properties connInfo)	creates a new PostgresqlDatabaseAdapter

Method Summary

Modifier and Type	Method	Description
protected Connection	createConnection(Properties connInfo)	This method creates the real connection to database.
boolean	doesColumnExist(String table, String column)	checks whether the specified column exists
int	getLastInsertId(String table, String idcolumn)	gets the id of the last insert.
protected String	rewriteSql(String sql)	rewrites CREATE TABLE statements to add TYPE=InnoDB

Methods inherited from class marauroa.server.db.adapter.AbstractDatabaseAdapter

close, commit, doesTableExist, execute, execute, executeBatch, getColumnLength, isConnectionError, prepareStatement, query, querySingleCellInt, rollback, verifyConnection

Methods inherited from class java.lang.Object

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

Constructor Details

PostgresDatabaseAdapter

public PostgresDatabaseAdapter(Properties connInfo)
                        throws DatabaseConnectionException

creates a new PostgresqlDatabaseAdapter

Parameters:

connInfo - parameters specifying the connection

Throws:

DatabaseConnectionException - if the connection cannot be established.

PostgresDatabaseAdapter

protected PostgresDatabaseAdapter()
                           throws DatabaseConnectionException

creates a new PostgresqlDatabaseAdapter for test purposes, without connection to the DB

Throws:

DatabaseConnectionException - if the connection cannot be established.

Method Details

createConnection

protected Connection createConnection(Properties connInfo)
                               throws SQLException,
DatabaseConnectionException

Description copied from class: AbstractDatabaseAdapter

This method creates the real connection to database.

Overrides:

createConnection in class AbstractDatabaseAdapter

Parameters:

connInfo - connection information like url, username and password

Returns:

a connection to the database

Throws:

SQLException - if the connection cannot be established.

DatabaseConnectionException - if the connection cannot be established.

doesColumnExist

public boolean doesColumnExist(String table,
 String column)
                        throws SQLException

Description copied from interface: DatabaseAdapter

checks whether the specified column exists

Specified by:

doesColumnExist in interface DatabaseAdapter

Overrides:

doesColumnExist in class AbstractDatabaseAdapter

Parameters:

table - name of table

column - name of column

Returns:

true, if the column exists, false otherwise

Throws:

SQLException - in case of an database error

getLastInsertId

public int getLastInsertId(String table,
 String idcolumn)
                    throws SQLException

gets the id of the last insert. Note: The table and idcolumn parameters must match the last insert statement. This is because on some database systems a SELECT IDENTITY is performed and on other database systems a SELECT curval(table_idcolumn_seq).

Specified by:

getLastInsertId in interface DatabaseAdapter

Overrides:

getLastInsertId in class AbstractDatabaseAdapter

Parameters:

table - name of table on which the last insert was done

idcolumn - name autoincrement serial column of that table

Returns:

generated id

Throws:

SQLException - in case of an database error

rewriteSql

protected String rewriteSql(String sql)
                     throws SQLException

rewrites CREATE TABLE statements to add TYPE=InnoDB

Overrides:

rewriteSql in class AbstractDatabaseAdapter

Parameters:

sql - original SQL statement

Returns:

modified SQL statement

Throws:

SQLException - in case of a database error