optimize: oracle index (apache#1583)

Signed-off-by: slievrly <slievrly@163.com>
ggndnn · Sep 6, 2019 · 7696cd8 · 7696cd8
1 parent 6c7df96
commit 7696cd8
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/rm-datasource/src/main/java/io/seata/rm/datasource/sql/struct/TableMetaCacheOracle.java b/rm-datasource/src/main/java/io/seata/rm/datasource/sql/struct/TableMetaCacheOracle.java
@@ -170,9 +170,7 @@ private static TableMeta resultSetMetaToSchema(DatabaseMetaData dbmd, String tab
                     index.setAscOrDesc(rsIndex.getString("ASC_OR_DESC"));
                     index.setCardinality(rsIndex.getInt("CARDINALITY"));
                     index.getValues().add(col);
-                    if ("PRIMARY".equalsIgnoreCase(indexName)) {
-                        index.setIndextype(IndexType.PRIMARY);
-                    } else if (!index.isNonUnique()) {
+                    if (!index.isNonUnique()) {
                         index.setIndextype(IndexType.Unique);
                     } else {
                         index.setIndextype(IndexType.Normal);
@@ -183,7 +181,7 @@ private static TableMeta resultSetMetaToSchema(DatabaseMetaData dbmd, String tab
             }
 
             while (rsPrimary.next()) {
-                String pkIndexName = rsPrimary.getObject(6).toString();
+                String pkIndexName = rsPrimary.getString("PK_NAME");
                 if (tm.getAllIndexes().containsKey(pkIndexName)) {
                     IndexMeta index = tm.getAllIndexes().get(pkIndexName);
                     index.setIndextype(IndexType.PRIMARY);