net.sf.jailer.util

Class SqlUtil

java.lang.Object

net.sf.jailer.util.SqlUtil

public class SqlUtil
extends java.lang.Object

Some utility methods.

Author:

Ralf Wisser

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.List<java.lang.String>	JAILER_MH_TABLES List of all jailer tables (upper case).
static java.util.List<java.lang.String>	JAILER_TABLES List of all jailer tables (upper case).
static long	PG_NEGATIVE_INFINITY
static long	PG_NEGATIVE_SMALLER_INFINITY
static long	PG_POSITIVE_INFINITY
static long	PG_POSITIVE_SMALLER_INFINITY
static java.lang.String	SQL_TRUE Condition formulated in standard SQL that is always fulfilled.
static java.util.Map<java.lang.Integer,java.lang.String>	SQL_TYPE Maps SQL types from Types to clear text types.

Constructor Summary

Constructors

Constructor and Description
SqlUtil()

Method Summary

Modifier and Type	Method and Description
static java.lang.String	columnLabel(Quoting quoting, Session session, DBMS targetDBMSConfiguration, Table table, java.lang.String columnLabel)
static java.lang.String	createSQLFragmentSearchPattern(java.lang.String sql, boolean withFlags)
static int	getColumnType(DBMS configuration, java.sql.ResultSet resultSet, java.sql.ResultSetMetaData resultSetMetaData, int i, java.util.Map<java.lang.Integer,java.lang.Integer> typeCache) Gets type of column from result-set.
static int	getColumnType(java.sql.ResultSet resultSet, java.sql.ResultSetMetaData resultSetMetaData, java.lang.String columnName, java.util.Map<java.lang.String,java.lang.Integer> typeCache) Gets type of column from result-set.
static int	indexOfDot(java.lang.String fullName) Gets index of schema-table separator.
static boolean	isLetterOrDigit(char c)
static java.lang.String	mappedSchema(java.util.Map<java.lang.String,java.lang.String> schemaMapping, java.lang.String tableName) Replaces schema of qualified table name according to a schema-map.
static java.lang.String	normalizeRestrictionCondition(java.lang.String cond)
static java.util.Set<Table>	readTableList(CsvFile tableFile, DataModel dataModel, java.util.Map<java.lang.String,java.lang.String> sourceSchemaMapping) Reads a table-list from CSV-file.
static java.lang.String	removeComments(java.lang.String statement) Removes comments from SQL statement.
static java.lang.String	removeCommentsAndLiterals(java.lang.String statement) Removes comments and literals from SQL statement.
static java.lang.String	removeNonMeaningfulFragments(java.lang.String sqlStatement) Removes all non-meaningful fragments of an SQL statement that might interfere with the SQL parser.
static java.lang.String	removeSubQueries(java.lang.String sqlSelect) Removes sub-queries from SQL statement.
static java.lang.String	replaceAlias(java.lang.String condition, java.lang.String alias) Replaces the alias T with given alias in a SQL-condition.
static java.lang.String	replaceAliases(java.lang.String condition, java.lang.String aliasA, java.lang.String aliasB) Replaces the aliases A and B with given aliases in a SQL-condition.
static java.lang.String	resolvePseudoColumns(java.lang.String condition, int today, int birthdayOfSubject, boolean reversed, boolean inDeleteMode) Resolves the pseudo-columns in a restriction condition.
static java.lang.String	resolvePseudoColumns(java.lang.String condition, java.lang.String entityAAlias, java.lang.String entityBAlias, int today, int birthdayOfSubject, boolean inDeleteMode) Resolves the pseudo-columns in a restriction condition.
static java.lang.String	resolvePseudoColumns(java.lang.String condition, java.lang.String entityAAlias, java.lang.String entityBAlias, int today, int birthdayOfSubject, java.lang.String birthdayColumnName, java.lang.Boolean inDeleteMode) Resolves the pseudo-columns in a restriction condition.
static java.nio.charset.Charset	retrieveEncoding(java.lang.String scriptFileName) Retrieves SQL script file encoding.
static java.lang.String	reversRestrictionCondition(java.lang.String condition) Change alias A to B and B to A in a SQL-condition.
static java.lang.String	splitDMLStatement(java.lang.String sql, int maxLength) Splits a DML statement into several lines with limited length.
static java.lang.String	toString(java.math.BigDecimal content)
static java.lang.String	toString(java.lang.Double content)

Methods inherited from class java.lang.Object

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

Field Detail

JAILER_TABLES

public static final java.util.List<java.lang.String> JAILER_TABLES

List of all jailer tables (upper case).

JAILER_MH_TABLES

public static final java.util.List<java.lang.String> JAILER_MH_TABLES

List of all jailer tables (upper case).

SQL_TRUE

public static final java.lang.String SQL_TRUE

Condition formulated in standard SQL that is always fulfilled.

See Also:

Constant Field Values

SQL_TYPE

public static final java.util.Map<java.lang.Integer,java.lang.String> SQL_TYPE

Maps SQL types from Types to clear text types.

PG_NEGATIVE_INFINITY

public static final long PG_NEGATIVE_INFINITY

See Also:

Constant Field Values

PG_NEGATIVE_SMALLER_INFINITY

public static final long PG_NEGATIVE_SMALLER_INFINITY

See Also:

Constant Field Values

PG_POSITIVE_INFINITY

public static final long PG_POSITIVE_INFINITY

See Also:

Constant Field Values

PG_POSITIVE_SMALLER_INFINITY

public static final long PG_POSITIVE_SMALLER_INFINITY

See Also:

Constant Field Values

Constructor Detail

SqlUtil

public SqlUtil()

Method Detail

reversRestrictionCondition

public static java.lang.String reversRestrictionCondition(java.lang.String condition)

Change alias A to B and B to A in a SQL-condition.

Parameters:

condition - the condition

Returns:

condition with revered aliases

replaceAliases

public static java.lang.String replaceAliases(java.lang.String condition,
                                              java.lang.String aliasA,
                                              java.lang.String aliasB)

Replaces the aliases A and B with given aliases in a SQL-condition.

Parameters:

condition - the condition

aliasA - alias for A

aliasB - alias for B

Returns:

condition with replaced aliases

replaceAlias

public static java.lang.String replaceAlias(java.lang.String condition,
                                            java.lang.String alias)

Replaces the alias T with given alias in a SQL-condition.

Parameters:

condition - the condition

alias - alias for T

Returns:

condition with replaced aliases

resolvePseudoColumns

public static java.lang.String resolvePseudoColumns(java.lang.String condition,
                                                    java.lang.String entityAAlias,
                                                    java.lang.String entityBAlias,
                                                    int today,
                                                    int birthdayOfSubject,
                                                    boolean inDeleteMode)

Resolves the pseudo-columns in a restriction condition.

Parameters:

condition - the condition

entityAAlias - alias for entity table joined with A

entityBAlias - alias for entity table joined with B

birthdayOfSubject - birthday of subject

today - today

inDeleteMode -

resolvePseudoColumns

public static java.lang.String resolvePseudoColumns(java.lang.String condition,
                                                    java.lang.String entityAAlias,
                                                    java.lang.String entityBAlias,
                                                    int today,
                                                    int birthdayOfSubject,
                                                    java.lang.String birthdayColumnName,
                                                    java.lang.Boolean inDeleteMode)

Resolves the pseudo-columns in a restriction condition.

Parameters:

condition - the condition

entityAAlias - alias for entity table joined with A

entityBAlias - alias for entity table joined with B

birthdayOfSubject - birthday of subject

today - today

birthdayColumnName - name of the column which holds the birthday of an entity ('birthday' or 'orig_birthday')

inDeleteMode -

resolvePseudoColumns

public static java.lang.String resolvePseudoColumns(java.lang.String condition,
                                                    int today,
                                                    int birthdayOfSubject,
                                                    boolean reversed,
                                                    boolean inDeleteMode)

Resolves the pseudo-columns in a restriction condition.

Parameters:

condition - the condition

birthdayOfSubject - birthday of subject

today - today

reversed -

inDeleteMode -

readTableList

public static java.util.Set<Table> readTableList(CsvFile tableFile,
                                                 DataModel dataModel,
                                                 java.util.Map<java.lang.String,java.lang.String> sourceSchemaMapping)

Reads a table-list from CSV-file.

Parameters:

dataModel - to get tables from

tableFile - the file containing the list

Returns:

set of tables, empty list if file contains no tables

mappedSchema

public static java.lang.String mappedSchema(java.util.Map<java.lang.String,java.lang.String> schemaMapping,
                                            java.lang.String tableName)

Replaces schema of qualified table name according to a schema-map.

Parameters:

schemaMapping - the mapping

tableName - the table name

Returns:

table name with replaced schema

getColumnType

public static int getColumnType(DBMS configuration,
                                java.sql.ResultSet resultSet,
                                java.sql.ResultSetMetaData resultSetMetaData,
                                int i,
                                java.util.Map<java.lang.Integer,java.lang.Integer> typeCache)
                         throws java.sql.SQLException

Gets type of column from result-set.

Parameters:

resultSet - result-set

i - column index

typeCache - for caching types

Returns:

type according to Types

Throws:

java.sql.SQLException

getColumnType

public static int getColumnType(java.sql.ResultSet resultSet,
                                java.sql.ResultSetMetaData resultSetMetaData,
                                java.lang.String columnName,
                                java.util.Map<java.lang.String,java.lang.Integer> typeCache)
                         throws java.sql.SQLException

Gets type of column from result-set.

Parameters:

resultSet - result-set

columnName - column name

typeCache - for caching types

Returns:

object

Throws:

java.sql.SQLException

splitDMLStatement

public static java.lang.String splitDMLStatement(java.lang.String sql,
                                                 int maxLength)

Splits a DML statement into several lines with limited length.

Parameters:

sql - the DML statement

maxLength - maximum line length

Returns:

DML statement with line breaks

toString

public static java.lang.String toString(java.lang.Double content)

toString

public static java.lang.String toString(java.math.BigDecimal content)

normalizeRestrictionCondition

public static java.lang.String normalizeRestrictionCondition(java.lang.String cond)

removeNonMeaningfulFragments

public static java.lang.String removeNonMeaningfulFragments(java.lang.String sqlStatement)

Removes all non-meaningful fragments of an SQL statement that might interfere with the SQL parser. (Comments, Literals, etc.)

Parameters:

sqlStatement -

Returns:

removeComments

public static java.lang.String removeComments(java.lang.String statement)

Removes comments from SQL statement.

Parameters:

statement - the statement

Returns:

statement the statement without comments

removeCommentsAndLiterals

public static java.lang.String removeCommentsAndLiterals(java.lang.String statement)

Removes comments and literals from SQL statement.

Parameters:

statement - the statement

Returns:

statement the statement without comments and literals

removeSubQueries

public static java.lang.String removeSubQueries(java.lang.String sqlSelect)

Removes sub-queries from SQL statement.

Parameters:

sqlSelect - the statement

Returns:

statement the statement without sub-queries

columnLabel

public static java.lang.String columnLabel(Quoting quoting,
                                           Session session,
                                           DBMS targetDBMSConfiguration,
                                           Table table,
                                           java.lang.String columnLabel)

isLetterOrDigit

public static boolean isLetterOrDigit(char c)

createSQLFragmentSearchPattern

public static java.lang.String createSQLFragmentSearchPattern(java.lang.String sql,
                                                              boolean withFlags)

indexOfDot

public static int indexOfDot(java.lang.String fullName)

Gets index of schema-table separator.

retrieveEncoding

public static java.nio.charset.Charset retrieveEncoding(java.lang.String scriptFileName)
                                                 throws java.io.FileNotFoundException,
                                                        java.io.IOException

Retrieves SQL script file encoding.

Parameters:

scriptFileName - file name of script

Returns:

encoding or null

Throws:

java.io.FileNotFoundException

java.io.IOException