java.lang.Object
- org.compiere.db.DB_PostgreSQL

All Implemented Interfaces:

AdempiereDatabase
```
public class DB_PostgreSQL
extends Object
implements AdempiereDatabase
```
PostgreSQL Database Port

Version:

$Id: DB_PostgreSQL.java,v 1.23 2005/03/11 20:29:01 jjanke Exp $ --- Modifications: removed static references to database connection and instead always get a new connection from database pool manager which manages all connections set rw/ro properties for the connection accordingly.

Author:

, Jorg Janke, Victor Perez, Ashley Ramdass (Posterita)

Field Summary

Fields
Modifier and Type Field Description

static int DEFAULT_PORT
Default Port

static String DRIVER
Driver class
- Fields inherited from interface org.compiere.db.AdempiereDatabase
  CMD_CREATE_DATABASE, CMD_CREATE_USER, CMD_DROP_DATABASE, LOCK_TIME_OUT

Constructor Summary

Constructors
Constructor Description

DB_PostgreSQL()
PostgreSQL Database

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`String`	`addPagingSQL(String sql, int start, int end)`	Implemented using the limit and offset feature. use 1 base index for start and end parameter
`void`	`close()`	Close
`String`	`convertStatement(String oraStatement)`	Convert an individual Oracle Style statements to target database statement syntax
`ConnectionPoolDataSource`	`createPoolDataSource(CConnection connection)`	Create Pooled DataSource (Server)
`boolean`	`createSequence(String name, int increment, int minvalue, int maxvalue, int start, String trxName)`
`static void`	`dumpLocks(Connection conn)`	Dump table lock info to console for current transaction
`boolean`	`forUpdate(PO po, int timeout)`	Lock PO for update
`String`	`getAlternativeSQL(int reExNo, String msg, String sql)`	Check and generate an alternative SQL
`String`	`getBlobDataType()`
`Connection`	`getCachedConnection(CConnection connection, boolean autoCommit, int transactionIsolation)`	Get Cached Connection
`String`	`getCatalog()`	Get JDBC Catalog
`String`	`getCharacterDataType()`
`String`	`getClobDataType()`
`String[]`	`getCommands(int cmdType)`	Get SQL Commands
`String`	`getConnectionURL(String dbHost, int dbPort, String dbName, String userName)`	Get Connection URL
`String`	`getConnectionURL(String connectionURL, String userName)`	Get Database Connection String
`String`	`getConnectionURL(CConnection connection)`	Get Database Connection String.
`String`	`getConstraintType(Connection conn, String tableName, String IXName)`	Get constraint type associated with the index
`Convert`	`getConvert()`
`DataSource`	`getDataSource(CConnection connection)`	Create DataSource (Client)
`String`	`getDescription()`	Get Database Description
`Driver`	`getDriver()`	Get and register Database Driver
`Connection`	`getDriverConnection(String dbUrl, String dbUid, String dbPwd)`	Get Driver Connection
`Connection`	`getDriverConnection(CConnection connection)`	Get Connection from Driver
`String`	`getName()`	Get Database Name
`String`	`getNameOfUniqueConstraintError(Exception e)`
`int`	`getNextID(String name)`	Return next sequence this Sequence
`int`	`getNextID(String name, String trxName)`	Return next sequence this Sequence
`String`	`getNumericDataType()`
`RowSet`	`getRowSet(ResultSet rs)`	Get RowSet
`String`	`getSchema()`	Get JDBC Schema
`String`	`getSQLAdd(MTable table, MColumn column)`	Get SQL Add command
`String`	`getSQLDDL(MColumn column)`
`String`	`getSQLModify(MTable table, MColumn column, boolean setNullOption)`	Get SQL Modify command
`int`	`getStandardPort()`	Get Standard JDBC Port
`String`	`getStatus()`	Get Status
`String`	`getSystemDatabase(String databaseName)`	Get Name of System Database
`String`	`getSystemUser()`	Get Name of System User
`String`	`getTimestampDataType()`
`String`	`getVarcharDataType()`
`String`	`intersectClauseForCSV(String columnName, String csv)`
`boolean`	`isNativeMode()`
`boolean`	`isPagingSupported()`	Is the database have sql extension that return a subset of the query result
`boolean`	`isQueryTimeout(SQLException ex)`
`boolean`	`isQueryTimeoutSupported()`	Postgresql jdbc driver doesn't support setQueryTimeout, query/statement timeout is implemented using the "SET LOCAL statement_timeout TO" statement.
`boolean`	`isSupported(String sql)`	Check if DBMS support the sql statement
`static boolean`	`isUseNativeDialect()`
`static String`	`markNativeKeyword(String keyword)`
`String`	`quoteColumnName(String columnName)`	Quote column name if necessary (usually to avoid conflict with reserved keywords)
`static String`	`removeNativeKeyworkMarker(String statement)`
`String`	`subsetClauseForCSV(String columnName, String csv)`
`boolean`	`supportsBLOB()`	Supports BLOB
`String`	`TO_CHAR(String columnName, int displayType, String AD_Language)`	Create SQL for formatted Date, Number
`String`	`TO_DATE(Timestamp time, boolean dayOnly)`	Create SQL TO Date String from Timestamp
`String`	`TO_NUMBER(BigDecimal number, int displayType)`	Return number as string for INSERT statements with correct precision
`String`	`toString()`	String Representation

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.compiere.db.AdempiereDatabase
getSQLCreate, getVarcharLengthSuffix

- Field Detail
  - DRIVER
```
public static final String DRIVER
```
    Driver class
    
    See Also:
    
    Constant Field Values
  - DEFAULT_PORT
```
public static final int DEFAULT_PORT
```
    Default Port
    
    See Also:
    
    Constant Field Values
- Constructor Detail
  - DB_PostgreSQL
```
public DB_PostgreSQL()
```
    PostgreSQL Database
- Method Detail
  - getConvert
```
public Convert getConvert()
```
    Specified by:
    
    getConvert in interface AdempiereDatabase
  - getName
```
public String getName()
```
    Get Database Name
    
    Specified by:
    
    getName in interface AdempiereDatabase
    
    Returns:
    
    database short name
  - getDescription
```
public String getDescription()
```
    Get Database Description
    
    Specified by:
    
    getDescription in interface AdempiereDatabase
    
    Returns:
    
    database long name and version
  - getStandardPort
```
public int getStandardPort()
```
    Get Standard JDBC Port
    
    Specified by:
    
    getStandardPort in interface AdempiereDatabase
    
    Returns:
    
    standard port
  - getDriver
```
public Driver getDriver()
                 throws SQLException
```
    Get and register Database Driver
    
    Specified by:
    
    getDriver in interface AdempiereDatabase
    
    Returns:
    
    Driver
    
    Throws:
    
    SQLException
  - getConnectionURL
```
public String getConnectionURL(CConnection connection)
```
    Get Database Connection String. Requirements: - createdb -E UNICODE compiere
    
    Specified by:
    
    getConnectionURL in interface AdempiereDatabase
    
    Parameters:
    
    connection - Connection Descriptor
    
    Returns:
    
    connection String
  - getConnectionURL
```
public String getConnectionURL(String dbHost,
                               int dbPort,
                               String dbName,
                               String userName)
```
    Get Connection URL
    
    Specified by:
    
    getConnectionURL in interface AdempiereDatabase
    
    Parameters:
    
    dbHost - db Host
    
    dbPort - db Port
    
    dbName - sb Name
    
    userName - user name
    
    Returns:
    
    connection url
  - getConnectionURL
```
public String getConnectionURL(String connectionURL,
                               String userName)
```
    Get Database Connection String
    
    Specified by:
    
    getConnectionURL in interface AdempiereDatabase
    
    Parameters:
    
    connectionURL - Connection URL
    
    userName - user name
    
    Returns:
    
    connection String
  - getCatalog
```
public String getCatalog()
```
    Get JDBC Catalog
    
    Specified by:
    
    getCatalog in interface AdempiereDatabase
    
    Returns:
    
    catalog (database name)
  - getSchema
```
public String getSchema()
```
    Get JDBC Schema
    
    Specified by:
    
    getSchema in interface AdempiereDatabase
    
    Returns:
    
    schema (dbo)
  - supportsBLOB
```
public boolean supportsBLOB()
```
    Supports BLOB
    
    Specified by:
    
    supportsBLOB in interface AdempiereDatabase
    
    Returns:
    
    true if BLOB is supported
  - toString
```
public String toString()
```
    String Representation
    
    Specified by:
    
    toString in interface AdempiereDatabase
    
    Overrides:
    
    toString in class Object
    
    Returns:
    
    info
  - getStatus
```
public String getStatus()
```
    Get Status
    
    Specified by:
    
    getStatus in interface AdempiereDatabase
    
    Returns:
    
    status info
  - convertStatement
```
public String convertStatement(String oraStatement)
```
    Convert an individual Oracle Style statements to target database statement syntax
    
    Specified by:
    
    convertStatement in interface AdempiereDatabase
    
    Parameters:
    
    oraStatement -
    
    Returns:
    
    converted Statement
    
    Throws:
    
    Exception
  - getSystemUser
```
public String getSystemUser()
```
    Get Name of System User
    
    Specified by:
    
    getSystemUser in interface AdempiereDatabase
    
    Returns:
    
    e.g. sa, system
  - getSystemDatabase
```
public String getSystemDatabase(String databaseName)
```
    Get Name of System Database
    
    Specified by:
    
    getSystemDatabase in interface AdempiereDatabase
    
    Parameters:
    
    databaseName - database Name
    
    Returns:
    
    e.g. master or database Name
  - TO_DATE
```
public String TO_DATE(Timestamp time,
                      boolean dayOnly)
```
    Create SQL TO Date String from Timestamp
    
    Specified by:
    
    TO_DATE in interface AdempiereDatabase
    
    Parameters:
    
    time - Date to be converted
    
    dayOnly - true if time set to 00:00:00
    
    Returns:
    
    TO_DATE('2001-01-30 18:10:20',''YYYY-MM-DD HH24:MI:SS') or TO_DATE('2001-01-30',''YYYY-MM-DD')
  - TO_CHAR
```
public String TO_CHAR(String columnName,
                      int displayType,
                      String AD_Language)
```
    Create SQL for formatted Date, Number
    
    Specified by:
    
    TO_CHAR in interface AdempiereDatabase
    
    Parameters:
    
    columnName - the column name in the SQL
    
    displayType - Display Type
    
    AD_Language - 6 character language setting (from Env.LANG_*)
    
    Returns:
    
    TRIM(TO_CHAR(columnName,'999G999G999G990D00','NLS_NUMERIC_CHARACTERS='',.''')) or TRIM(TO_CHAR(columnName,'TM9')) depending on DisplayType and Language
    
    See Also:
    
    DisplayType, Env
  - TO_NUMBER
```
public String TO_NUMBER(BigDecimal number,
                        int displayType)
```
    Return number as string for INSERT statements with correct precision
    
    Specified by:
    
    TO_NUMBER in interface AdempiereDatabase
    
    Parameters:
    
    number - number
    
    displayType - display Type
    
    Returns:
    
    number as string
  - getCommands
```
public String[] getCommands(int cmdType)
```
    Get SQL Commands
    
    Specified by:
    
    getCommands in interface AdempiereDatabase
    
    Parameters:
    
    cmdType - CMD_*
    
    Returns:
    
    array of commands to be executed
  - getRowSet
```
public RowSet getRowSet(ResultSet rs)
                 throws SQLException
```
    Get RowSet
    
    Parameters:
    
    rs - ResultSet
    
    Returns:
    
    RowSet
    
    Throws:
    
    SQLException
  - getCachedConnection
```
public Connection getCachedConnection(CConnection connection,
                                      boolean autoCommit,
                                      int transactionIsolation)
                               throws Exception
```
    Get Cached Connection
    
    Specified by:
    
    getCachedConnection in interface AdempiereDatabase
    
    Parameters:
    
    connection - connection
    
    autoCommit - auto commit
    
    transactionIsolation - trx isolation
    
    Returns:
    
    Connection
    
    Throws:
    
    Exception
  - getDataSource
```
public DataSource getDataSource(CConnection connection)
```
    Create DataSource (Client)
    
    Specified by:
    
    getDataSource in interface AdempiereDatabase
    
    Parameters:
    
    connection - connection
    
    Returns:
    
    data dource
  - createPoolDataSource
```
public ConnectionPoolDataSource createPoolDataSource(CConnection connection)
```
    Create Pooled DataSource (Server)
    
    Parameters:
    
    connection - connection
    
    Returns:
    
    data source
  - getDriverConnection
```
public Connection getDriverConnection(CConnection connection)
                               throws SQLException
```
    Get Connection from Driver
    
    Specified by:
    
    getDriverConnection in interface AdempiereDatabase
    
    Parameters:
    
    connection - info
    
    Returns:
    
    connection or null
    
    Throws:
    
    SQLException
  - getDriverConnection
```
public Connection getDriverConnection(String dbUrl,
                                      String dbUid,
                                      String dbPwd)
                               throws SQLException
```
    Get Driver Connection
    
    Specified by:
    
    getDriverConnection in interface AdempiereDatabase
    
    Parameters:
    
    dbUrl - URL
    
    dbUid - user
    
    dbPwd - password
    
    Returns:
    
    connection
    
    Throws:
    
    SQLException
  - close
```
public void close()
```
    Close
    
    Specified by:
    
    close in interface AdempiereDatabase
  - getAlternativeSQL
```
public String getAlternativeSQL(int reExNo,
                                String msg,
                                String sql)
```
    Check and generate an alternative SQL
    
    Specified by:
    
    getAlternativeSQL in interface AdempiereDatabase
    
    Returns:
    
    String, the alternative SQL, null if no alternative
  - getConstraintType
```
public String getConstraintType(Connection conn,
                                String tableName,
                                String IXName)
```
    Get constraint type associated with the index
    
    Specified by:
    
    getConstraintType in interface AdempiereDatabase
    
    Returns:
    
    String[0] = 0: do not know, 1: Primary Key 2: Foreign Key String[1] - String[n] = Constraint Name
  - isSupported
```
public boolean isSupported(String sql)
```
    Check if DBMS support the sql statement
    
    Specified by:
    
    isSupported in interface AdempiereDatabase
    
    Returns:
    
    true: yes
  - dumpLocks
```
public static void dumpLocks(Connection conn)
```
    Dump table lock info to console for current transaction
    
    Parameters:
    
    conn -
  - getNextID
```
public int getNextID(String name)
```
    Description copied from interface: AdempiereDatabase
    
    Return next sequence this Sequence
    
    Specified by:
    
    getNextID in interface AdempiereDatabase
    
    Parameters:
    
    name - Sequence
  - getNextID
```
public int getNextID(String name,
                     String trxName)
```
    Description copied from interface: AdempiereDatabase
    
    Return next sequence this Sequence
    
    Specified by:
    
    getNextID in interface AdempiereDatabase
    
    Parameters:
    
    name - Sequence
    
    trxName - Transaction
  - createSequence
```
public boolean createSequence(String name,
                              int increment,
                              int minvalue,
                              int maxvalue,
                              int start,
                              String trxName)
```
    Specified by:
    
    createSequence in interface AdempiereDatabase
  - isQueryTimeoutSupported
```
public boolean isQueryTimeoutSupported()
```
    Postgresql jdbc driver doesn't support setQueryTimeout, query/statement timeout is implemented using the "SET LOCAL statement_timeout TO" statement.
    
    Specified by:
    
    isQueryTimeoutSupported in interface AdempiereDatabase
    
    Returns:
    
    true
  - addPagingSQL
```
public String addPagingSQL(String sql,
                           int start,
                           int end)
```
    Implemented using the limit and offset feature. use 1 base index for start and end parameter
    
    Specified by:
    
    addPagingSQL in interface AdempiereDatabase
    
    Parameters:
    
    sql -
    
    start -
    
    end -
    
    Returns:
  - isPagingSupported
```
public boolean isPagingSupported()
```
    Description copied from interface: AdempiereDatabase
    
    Is the database have sql extension that return a subset of the query result
    
    Specified by:
    
    isPagingSupported in interface AdempiereDatabase
    
    Returns:
    
    boolean
  - forUpdate
```
public boolean forUpdate(PO po,
                         int timeout)
```
    Description copied from interface: AdempiereDatabase
    
    Lock PO for update
    
    Specified by:
    
    forUpdate in interface AdempiereDatabase
    
    Returns:
    
    true if lock is granted
  - getNameOfUniqueConstraintError
```
public String getNameOfUniqueConstraintError(Exception e)
```
    Specified by:
    
    getNameOfUniqueConstraintError in interface AdempiereDatabase
  - subsetClauseForCSV
```
public String subsetClauseForCSV(String columnName,
                                 String csv)
```
    Specified by:
    
    subsetClauseForCSV in interface AdempiereDatabase
    
    csv - comma separated value
    
    Returns:
    
    subset sql clause
  - quoteColumnName
```
public String quoteColumnName(String columnName)
```
    Description copied from interface: AdempiereDatabase
    
    Quote column name if necessary (usually to avoid conflict with reserved keywords)
    
    Specified by:
    
    quoteColumnName in interface AdempiereDatabase
    
    Returns:
    
    columnName or quoted columnName
  - intersectClauseForCSV
```
public String intersectClauseForCSV(String columnName,
                                    String csv)
```
    Specified by:
    
    intersectClauseForCSV in interface AdempiereDatabase
    
    csv - comma separated value
    
    Returns:
    
    subset sql clause
  - isNativeMode
```
public boolean isNativeMode()
```
    Specified by:
    
    isNativeMode in interface AdempiereDatabase
    
    Returns:
    
    true if using native dialect, false if using oracle dialect
  - isUseNativeDialect
```
public static final boolean isUseNativeDialect()
```
    Returns:
    
    true if it is using native dialect
  - markNativeKeyword
```
public static final String markNativeKeyword(String keyword)
```
    Parameters:
    
    keyword -
    
    Returns:
    
    if not using native dialect, return native_marker + keyword
  - removeNativeKeyworkMarker
```
public static final String removeNativeKeyworkMarker(String statement)
```
    Parameters:
    
    statement -
    
    Returns:
    
    statement after the removal of native keyword marker
  - getNumericDataType
```
public String getNumericDataType()
```
    Specified by:
    
    getNumericDataType in interface AdempiereDatabase
    
    Returns:
    
    numeric data type name
  - getCharacterDataType
```
public String getCharacterDataType()
```
    Specified by:
    
    getCharacterDataType in interface AdempiereDatabase
    
    Returns:
    
    fixed lenght character data type name
  - getVarcharDataType
```
public String getVarcharDataType()
```
    Specified by:
    
    getVarcharDataType in interface AdempiereDatabase
    
    Returns:
    
    variable length character data type name
  - getBlobDataType
```
public String getBlobDataType()
```
    Specified by:
    
    getBlobDataType in interface AdempiereDatabase
    
    Returns:
    
    binary large object data type name
  - getClobDataType
```
public String getClobDataType()
```
    Specified by:
    
    getClobDataType in interface AdempiereDatabase
    
    Returns:
    
    character large object data type name
  - getTimestampDataType
```
public String getTimestampDataType()
```
    Specified by:
    
    getTimestampDataType in interface AdempiereDatabase
    
    Returns:
    
    time stamp data type name
  - getSQLDDL
```
public String getSQLDDL(MColumn column)
```
    Specified by:
    
    getSQLDDL in interface AdempiereDatabase
    
    Returns:
    
    ddl sql for column
  - getSQLAdd
```
public String getSQLAdd(MTable table,
                        MColumn column)
```
    Get SQL Add command
    
    Specified by:
    
    getSQLAdd in interface AdempiereDatabase
    
    Parameters:
    
    table - table
    
    Returns:
    
    sql
  - getSQLModify
```
public String getSQLModify(MTable table,
                           MColumn column,
                           boolean setNullOption)
```
    Get SQL Modify command
    
    Specified by:
    
    getSQLModify in interface AdempiereDatabase
    
    Parameters:
    
    table - table
    
    setNullOption - generate null / not null statement
    
    Returns:
    
    sql separated by ;
  - isQueryTimeout
```
public boolean isQueryTimeout(SQLException ex)
```
    Specified by:
    
    isQueryTimeout in interface AdempiereDatabase
    
    Returns:
    
    true if ex is caused by query timeout

Modifier and Type	Field	Description
`static int`	`DEFAULT_PORT`	Default Port
`static String`	`DRIVER`	Driver class

Class DB_PostgreSQL

Field Summary

Fields inherited from interface org.compiere.db.AdempiereDatabase

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface org.compiere.db.AdempiereDatabase

Field Detail

DRIVER

DEFAULT_PORT

Constructor Detail

DB_PostgreSQL

Method Detail

getConvert

getName

getDescription

getStandardPort

getDriver

getConnectionURL

getConnectionURL

getConnectionURL

getCatalog

getSchema

supportsBLOB

toString

getStatus

convertStatement

getSystemUser

getSystemDatabase

TO_DATE

TO_CHAR

TO_NUMBER

getCommands

getRowSet

getCachedConnection

getDataSource

createPoolDataSource

getDriverConnection

getDriverConnection

close

getAlternativeSQL

getConstraintType

isSupported

dumpLocks

getNextID

getNextID

createSequence

isQueryTimeoutSupported

addPagingSQL

isPagingSupported

forUpdate

getNameOfUniqueConstraintError

subsetClauseForCSV

quoteColumnName

intersectClauseForCSV

isNativeMode

isUseNativeDialect

markNativeKeyword

removeNativeKeyworkMarker

getNumericDataType

getCharacterDataType

getVarcharDataType

getBlobDataType

getClobDataType

getTimestampDataType

getSQLDDL

getSQLAdd

getSQLModify

isQueryTimeout