com.goldencode.p2j.persist.deploy

Class PostgreSQLScriptRunner

java.lang.Object

com.goldencode.p2j.persist.deploy.ScriptRunner

com.goldencode.p2j.persist.deploy.PostgreSQLScriptRunner

public class PostgreSQLScriptRunner
extends ScriptRunner

Run SQL script against the PostgreSQL database

Nested Class Summary

Nested classes/interfaces inherited from class com.goldencode.p2j.persist.deploy.ScriptRunner

ScriptRunner.ScriptType

Field Summary

Fields

Modifier and Type	Field and Description
private static java.util.List<java.lang.String>	COUNT PostgreSQL query for counting the number of UDFs with a spicefic name.
private static java.util.regex.Pattern	PG_VER pattern for the PostgreSQL 'SELECT version()' result parsing
private static java.util.List<java.lang.String>	SCALE SCALE UDF (built-in for PostgreSQL 10+)

Fields inherited from class com.goldencode.p2j.persist.deploy.ScriptRunner

dialect, LOG, placeholders, scripts, scriptType, usePlaceholders

Constructor Summary

Constructors

Constructor and Description
PostgreSQLScriptRunner(Dialect dialect) Constructor.

Method Summary

Modifier and Type	Method and Description
protected void	applyUdfScripts(java.sql.Connection conn) Apply UDF SQL scripts.
private int	countUDFs(java.sql.Connection conn, java.lang.String schema, java.lang.String name) Count number of UDFs with a given name.
protected void	createMissingUdfs(java.lang.String dbname, java.lang.String url, java.lang.String adm, java.lang.String pwd) Check for missing UDFs and create them.
private void	createScaleUDF(java.sql.Connection conn) Create SCALE UDF.
private static int	getPgVersion(java.sql.Connection conn) Retrieve PostgreSQL server version.

Methods inherited from class com.goldencode.p2j.persist.deploy.ScriptRunner

addScriptPath, applyDDLScripts, applyPlaceholders, applySchema, applyScripts, createMissingUdfs, defaultUdfScripts, execute, main, makeScripts, parseCmdLine, supportsUdfScripts

Methods inherited from class java.lang.Object

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

Field Detail

PG_VER

private static final java.util.regex.Pattern PG_VER

pattern for the PostgreSQL 'SELECT version()' result parsing

COUNT

private static final java.util.List<java.lang.String> COUNT

PostgreSQL query for counting the number of UDFs with a spicefic name.

SCALE

private static final java.util.List<java.lang.String> SCALE

SCALE UDF (built-in for PostgreSQL 10+)

Constructor Detail

PostgreSQLScriptRunner

public PostgreSQLScriptRunner(Dialect dialect)

Constructor.

Parameters:

dialect - the target database dialect

Method Detail

applyUdfScripts

protected void applyUdfScripts(java.sql.Connection conn)
                        throws java.sql.SQLException,
                               java.io.IOException

Apply UDF SQL scripts.

Specified by:

applyUdfScripts in class ScriptRunner

Parameters:

conn - Database connection.

Throws:

java.sql.SQLException - on SQL error.

java.io.IOException - on script reading error.

createMissingUdfs

protected void createMissingUdfs(java.lang.String dbname,
                                 java.lang.String url,
                                 java.lang.String adm,
                                 java.lang.String pwd)
                          throws java.sql.SQLException,
                                 PersistenceException

Check for missing UDFs and create them.

Specified by:

createMissingUdfs in class ScriptRunner

Parameters:

dbname - Database name.

url - Database JDBC URL.

adm - Admin login.

pwd - Admin password.

Throws:

java.sql.SQLException - on SQL error.

PersistenceException - on script reading error.

getPgVersion

private static int getPgVersion(java.sql.Connection conn)
                         throws java.sql.SQLException

Retrieve PostgreSQL server version.

Parameters:

conn - The database connection.

Returns:

PostgreSQL server version as 100+major + minor.

Throws:

java.sql.SQLException - On error.

countUDFs

private int countUDFs(java.sql.Connection conn,
                      java.lang.String schema,
                      java.lang.String name)
               throws java.sql.SQLException

Count number of UDFs with a given name.

Parameters:

conn - The database connection.

schema - schema name.

name - UDF name.

Returns:

number of UDFs with a given name.

Throws:

java.sql.SQLException - On error.

createScaleUDF

private void createScaleUDF(java.sql.Connection conn)
                     throws java.sql.SQLException

Create SCALE UDF.

Parameters:

conn - The database connection.

Throws:

java.sql.SQLException - On error.