public class SqlUtil extends Object
| Modifier and Type | Field and Description |
|---|---|
static List<String> |
JAILER_MH_TABLES
List of all jailer tables (upper case).
|
static List<String> |
JAILER_TABLES
List of all jailer tables (upper case).
|
static String |
LETTERS_AND_DIGITS |
static Map<Integer,String> |
SQL_TYPE
Maps SQL types from
Types to clear text types. |
| Constructor and Description |
|---|
SqlUtil() |
| Modifier and Type | Method and Description |
|---|---|
static int |
getColumnType(ResultSet resultSet,
ResultSetMetaData resultSetMetaData,
int i,
Map<Integer,Integer> typeCache)
Gets type of column from result-set.
|
static int |
getColumnType(ResultSet resultSet,
ResultSetMetaData resultSetMetaData,
String columnName,
Map<String,Integer> typeCache)
Gets type of column from result-set.
|
static String |
mappedSchema(Map<String,String> schemaMapping,
String tableName)
Replaces schema of qualified table name according to a schema-map.
|
static Set<Table> |
readTableList(CsvFile tableFile,
DataModel dataModel,
Map<String,String> sourceSchemaMapping)
Reads a table-list from CSV-file.
|
static String |
replaceAlias(String condition,
String alias)
Replaces the alias T with given alias in a SQL-condition.
|
static String |
replaceAliases(String condition,
String aliasA,
String aliasB)
Replaces the aliases A and B with given aliases in a SQL-condition.
|
static String |
resolvePseudoColumns(String condition,
int today,
int birthdayOfSubject,
boolean reversed,
boolean inDeleteMode)
Resolves the pseudo-columns in a restriction condition.
|
static String |
resolvePseudoColumns(String condition,
String entityAAlias,
String entityBAlias,
int today,
int birthdayOfSubject,
boolean inDeleteMode)
Resolves the pseudo-columns in a restriction condition.
|
static String |
resolvePseudoColumns(String condition,
String entityAAlias,
String entityBAlias,
int today,
int birthdayOfSubject,
String birthdayColumnName,
boolean inDeleteMode)
Resolves the pseudo-columns in a restriction condition.
|
static String |
reversRestrictionCondition(String condition)
Change alias A to B and B to A in a SQL-condition.
|
static String |
splitDMLStatement(String sql,
int maxLength)
Splits a DML statement into several lines with limited length.
|
public static final List<String> JAILER_TABLES
public static final List<String> JAILER_MH_TABLES
public static final String LETTERS_AND_DIGITS
public static String reversRestrictionCondition(String condition)
condition - the conditionpublic static String replaceAliases(String condition, String aliasA, String aliasB)
condition - the conditionaliasA - alias for AaliasB - alias for Bpublic static String replaceAlias(String condition, String alias)
condition - the conditionalias - alias for Tpublic static String resolvePseudoColumns(String condition, String entityAAlias, String entityBAlias, int today, int birthdayOfSubject, boolean inDeleteMode)
condition - the conditionentityAAlias - alias for entity table joined with AentityBAlias - alias for entity table joined with BbirthdayOfSubject - birthday of subjecttoday - todayinDeleteMode - public static String resolvePseudoColumns(String condition, String entityAAlias, String entityBAlias, int today, int birthdayOfSubject, String birthdayColumnName, boolean inDeleteMode)
condition - the conditionentityAAlias - alias for entity table joined with AentityBAlias - alias for entity table joined with BbirthdayOfSubject - birthday of subjecttoday - todaybirthdayColumnName - name of the column which holds the birthday of an entity ('birthday' or 'orig_birthday')inDeleteMode - public static String resolvePseudoColumns(String condition, int today, int birthdayOfSubject, boolean reversed, boolean inDeleteMode)
condition - the conditionbirthdayOfSubject - birthday of subjecttoday - todayreversed - inDeleteMode - public static Set<Table> readTableList(CsvFile tableFile, DataModel dataModel, Map<String,String> sourceSchemaMapping)
dataModel - to get tables fromtableFile - the file containing the listpublic static String mappedSchema(Map<String,String> schemaMapping, String tableName)
schemaMapping - the mappingtableName - the table namepublic static int getColumnType(ResultSet resultSet, ResultSetMetaData resultSetMetaData, int i, Map<Integer,Integer> typeCache) throws SQLException
resultSet - result-seti - column indextypeCache - for caching typesTypesSQLExceptionpublic static int getColumnType(ResultSet resultSet, ResultSetMetaData resultSetMetaData, String columnName, Map<String,Integer> typeCache) throws SQLException
resultSet - result-setcolumnName - column nametypeCache - for caching typesSQLException