fixed desc table case insensitive

alibaba · Dec 26, 2022 · 9d0a372 · 9d0a372
1 parent 41a2a87
commit 9d0a372
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/TableMetaCache.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/TableMetaCache.java
@@ -31,12 +31,12 @@
  */
 public class TableMetaCache {
 
-    public static final String              COLUMN_NAME    = "Field";
-    public static final String              COLUMN_TYPE    = "Type";
-    public static final String              IS_NULLABLE    = "Null";
-    public static final String              COLUMN_KEY     = "Key";
-    public static final String              COLUMN_DEFAULT = "Default";
-    public static final String              EXTRA          = "Extra";
+    public static final String              COLUMN_NAME    = "field";
+    public static final String              COLUMN_TYPE    = "type";
+    public static final String              IS_NULLABLE    = "null";
+    public static final String              COLUMN_KEY     = "key";
+    public static final String              COLUMN_DEFAULT = "default";
+    public static final String              EXTRA          = "extra";
     private MysqlConnection                 connection;
     private boolean                         isOnRDS        = false;
     private boolean                         isOnPolarX     = false;
@@ -125,7 +125,7 @@ public static List<FieldMeta> parseTableMetaByDesc(ResultSetPacket packet) {
         Map<String, Integer> nameMaps = new HashMap<>(6, 1f);
         int index = 0;
         for (FieldPacket fieldPacket : packet.getFieldDescriptors()) {
-            nameMaps.put(fieldPacket.getName(), index++);
+            nameMaps.put(StringUtils.lowerCase(fieldPacket.getName()), index++);
         }
 
         int size = packet.getFieldDescriptors().size();