optimize get tablemeta

apache · zjinlei · Dec 16, 2019 · Sep 17, 2019 · Sep 17, 2019 · Sep 18, 2019
commit b1f27d91ca686b7066ed4b8474e354a2888377b4
diff --git a/rm-datasource/src/main/java/io/seata/rm/datasource/AbstractConnectionProxy.java b/rm-datasource/src/main/java/io/seata/rm/datasource/AbstractConnectionProxy.java
@@ -114,7 +114,7 @@ public PreparedStatement prepareStatement(String sql) throws SQLException {
         SQLRecognizer sqlRecognizer = SQLVisitorFactory.get(sql, dbType);
         if (sqlRecognizer != null && sqlRecognizer.getSQLType() == SQLType.INSERT) {
             TableMeta tableMeta = TableMetaCacheAdapter.getTableMeta(dbType, getDataSourceProxy(), sqlRecognizer.getTableName(), false);
-            targetPreparedStatement = getTargetConnection().prepareStatement(sql, new String[]{ pkName });
+            targetPreparedStatement = getTargetConnection().prepareStatement(sql, new String[]{ tableMeta.getPkName() });
         } else {
             targetPreparedStatement = getTargetConnection().prepareStatement(sql);
         }