Skip to content

Commit

Permalink
Merge branch '3.10' of https://github.com/JumpMind/symmetric-ds.git i…
Browse files Browse the repository at this point in the history 
…nto 3.10
  • Loading branch information
elong committed Dec 17, 2018
2 parents d5d0f58 + 3d7d9e6 commit 76a1675
Showing 1 changed file with 103 additions and 56 deletions.
159 changes: 103 additions & 56 deletions symmetric-jdbc/src/main/java/org/jumpmind/db/platform/oracle/OracleDdlReader.java
View file
Expand Up @@ -34,8 +34,10 @@
import java.util.Collection;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

Expand Down Expand Up @@ -152,7 +154,7 @@ protected Integer mapUnknownJdbcTypeForColumn(Map<String, Object> values) {
} else if (typeName != null && typeName.startsWith("BFILE")) {
return Types.VARCHAR;
} else if (typeName != null && typeName.startsWith("INTERVAL")) {
return Types.VARCHAR;
return Types.VARCHAR;
} else if (typeName != null && typeName.startsWith("ROWID")) {
return Types.VARCHAR;
} else {
Expand Down Expand Up @@ -336,37 +338,39 @@ protected Collection<IIndex> readIndices(Connection connection,

StringBuilder query = new StringBuilder();

query.append("SELECT a.INDEX_NAME, a.INDEX_TYPE, a.UNIQUENESS, b.COLUMN_NAME, b.COLUMN_POSITION FROM USER_INDEXES a, USER_IND_COLUMNS b WHERE ");
query.append("a.TABLE_NAME=? AND a.GENERATED=? AND a.TABLE_TYPE=? AND a.TABLE_NAME=b.TABLE_NAME AND a.INDEX_NAME=b.INDEX_NAME AND ");
query.append("a.INDEX_NAME NOT IN (SELECT DISTINCT c.CONSTRAINT_NAME FROM USER_CONSTRAINTS c WHERE c.CONSTRAINT_TYPE=? AND c.TABLE_NAME=a.TABLE_NAME");
query.append("SELECT a.INDEX_NAME, a.INDEX_TYPE, a.UNIQUENESS, b.COLUMN_NAME, b.COLUMN_POSITION FROM ALL_INDEXES a ");
query.append("JOIN ALL_IND_COLUMNS b ON a.table_name = b.table_name AND a.INDEX_NAME=b.INDEX_NAME ");
query.append("WHERE ");
query.append("a.TABLE_NAME = ? ");
query.append("AND a.GENERATED='N' ");
query.append("AND a.TABLE_TYPE='TABLE' ");
if (metaData.getSchemaPattern() != null) {
query.append(" AND c.OWNER LIKE ?) AND a.TABLE_OWNER LIKE ?");
} else {
query.append(")");
query.append("AND a.TABLE_OWNER = ?");
}

Map<String, IIndex> indices = new LinkedHashMap<String, IIndex>();
PreparedStatement stmt = null;

try {
Set<String> pkIndecies = readPkIndecies(connection, metaData.getSchemaPattern(), tableName);

stmt = connection.prepareStatement(query.toString());
stmt.setString(
1,
getPlatform().getDdlBuilder().isDelimitedIdentifierModeOn() ? tableName : tableName
.toUpperCase());
stmt.setString(2, "N");
stmt.setString(3, "TABLE");
stmt.setString(4, "P");
if (metaData.getSchemaPattern() != null) {
stmt.setString(5, metaData.getSchemaPattern().toUpperCase());
stmt.setString(6, metaData.getSchemaPattern().toUpperCase());
stmt.setString(2, metaData.getSchemaPattern().toUpperCase());
}

ResultSet rs = stmt.executeQuery();
Map<String, Object> values = new HashMap<String, Object>();

while (rs.next()) {
String name = rs.getString(1);
if (pkIndecies.contains(name)) { // Filter PK indexes from these results.
continue;
}
String type = rs.getString(2);
// Only read in normal oracle indexes
if (type.startsWith("NORMAL")) {
Expand Down Expand Up @@ -427,47 +431,90 @@ public String mapRow(Row row) {
}

public List<Trigger> getTriggers(final String catalog, final String schema,
final String tableName) throws SqlException {

List<Trigger> triggers = new ArrayList<Trigger>();

log.debug("Reading triggers for: " + tableName);
JdbcSqlTemplate sqlTemplate = (JdbcSqlTemplate) platform
.getSqlTemplate();

String sql = "SELECT * FROM ALL_TRIGGERS "
+ "WHERE TABLE_NAME=? and OWNER=?";
triggers = sqlTemplate.query(sql, new ISqlRowMapper<Trigger>() {
public Trigger mapRow(Row row) {
Trigger trigger = new Trigger();
trigger.setName(row.getString("TRIGGER_NAME"));
trigger.setSchemaName(row.getString("OWNER"));
trigger.setTableName(row.getString("TABLE_NAME"));
trigger.setEnabled(Boolean.valueOf(row.getString("STATUS")));
trigger.setSource("create ");
String triggerType = row.getString("TRIGGERING_EVENT");
if (triggerType.equals("DELETE")
|| triggerType.equals("INSERT")
|| triggerType.equals("UPDATE")) {
trigger.setTriggerType(TriggerType.valueOf(triggerType));
}
trigger.setMetaData(row);
return trigger;
}
}, tableName, schema);

for (final Trigger trigger : triggers) {
String name = trigger.getName();
String sourceSql = "select TEXT from all_source "
+ "where NAME=? order by LINE ";
sqlTemplate.query(sourceSql, new ISqlRowMapper<Trigger>() {
public Trigger mapRow(Row row) {
trigger.setSource(trigger.getSource()+"\n"+row.getString("TEXT"));;
return trigger;
}
}, name);
}

return triggers;
}
final String tableName) throws SqlException {

List<Trigger> triggers = new ArrayList<Trigger>();

log.debug("Reading triggers for: {}", tableName);
JdbcSqlTemplate sqlTemplate = (JdbcSqlTemplate) platform.getSqlTemplate();

String sql = "SELECT TRIGGER_NAME, OWNER, TABLE_NAME, STATUS, TRIGGERING_EVENT FROM ALL_TRIGGERS WHERE TABLE_NAME=? and OWNER=?";
triggers = sqlTemplate.query(sql, new ISqlRowMapper<Trigger>() {
public Trigger mapRow(Row row) {
Trigger trigger = new Trigger();
trigger.setName(row.getString("TRIGGER_NAME"));
trigger.setSchemaName(row.getString("OWNER"));
trigger.setTableName(row.getString("TABLE_NAME"));
trigger.setEnabled(Boolean.valueOf(row.getString("STATUS")));
trigger.setSource("create ");
String triggerType = row.getString("TRIGGERING_EVENT");
if (triggerType.equals("DELETE")
|| triggerType.equals("INSERT")
|| triggerType.equals("UPDATE")) {
trigger.setTriggerType(TriggerType.valueOf(triggerType));
}
trigger.setMetaData(row);
return trigger;
}
}, tableName, schema);

for (final Trigger trigger : triggers) {
String name = trigger.getName();
String sourceSql = "select TEXT from all_source where OWNER=? AND NAME=? order by LINE";

final StringBuilder buff = new StringBuilder();
buff.append(trigger.getSource());
sqlTemplate.query(sourceSql, new ISqlRowMapper<Trigger>() {
public Trigger mapRow(Row row) {
String line = row.getString("TEXT");
if (!line.endsWith("\n")) {
buff.append("\n");
}
buff.append(line);
return trigger;
}
}, schema, name);
trigger.setSource(buff.toString());
}

return triggers;
}

protected Set<String> readPkIndecies(Connection connection, String schema, String tableName) throws SQLException {
String QUERY = "SELECT INDEX_NAME FROM ALL_CONSTRAINTS c WHERE c.TABLE_NAME = ? AND CONSTRAINT_TYPE = 'P'";
if (schema != null) {
QUERY += " AND c.OWNER = ?";
}
ResultSet rs = null;
PreparedStatement stmt = null;
Set<String> values = new LinkedHashSet<String>();
try {
stmt = connection.prepareStatement(QUERY);
stmt.setString(
1,
getPlatform().getDdlBuilder().isDelimitedIdentifierModeOn() ? tableName : tableName
.toUpperCase());
if (schema != null) {
stmt.setString(2, schema.toUpperCase());
}

rs = stmt.executeQuery();

while (rs.next()) {
String pkIndexName = rs.getString(1);
values.add(pkIndexName);
}


} finally {
if (rs != null) {
rs.close();
}
if (stmt != null) {
stmt.close();
}

}
return values;
}
}

0 comments on commit 76a1675

Please sign in to comment.