小调整。

iquanzhan · Sep 15, 2023 · 15c85fe · 15c85fe
1 parent 70d6d43
commit 15c85fe
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/rm-datasource/src/main/java/io/seata/rm/datasource/sql/struct/cache/DmTableMetaCache.java b/rm-datasource/src/main/java/io/seata/rm/datasource/sql/struct/cache/DmTableMetaCache.java
@@ -118,10 +118,10 @@ protected void processIndexes(TableMeta tableMeta, ResultSet rs) throws SQLExcep
 
     protected void processPrimaries(TableMeta tableMeta, ResultSet rs) throws SQLException {
         while (rs.next()) {
-            String pkName = rs.getString("PK_NAME");
+            String pkColName = rs.getString("COLUMN_NAME");
             for (IndexMeta i : tableMeta.getAllIndexes().values()) {
                 i.getValues().stream()
-                        .filter(c -> pkName.equals(c.getColumnName()))
+                        .filter(c -> pkColName.equals(c.getColumnName()))
                         .forEach(c -> i.setIndextype(IndexType.PRIMARY));
             }
         }

diff --git a/...atasource/src/test/java/io/seata/rm/datasource/sql/struct/cache/DmTableMetaCacheTest.java b/...atasource/src/test/java/io/seata/rm/datasource/sql/struct/cache/DmTableMetaCacheTest.java
@@ -73,7 +73,7 @@ public void getTableMetaTest() throws SQLException {
 
         Assertions.assertNotNull(tableMeta);
 
-        tableMeta = tableMetaCache.getTableMeta(proxy.getPlainConnection(), "\"dt1\"", proxy.getResourceId());
+        tableMeta = tableMetaCache.getTableMeta(proxy.getPlainConnection(), "dt1", proxy.getResourceId());
 
         Assertions.assertNotNull(tableMeta);
     }