Răsfoiți Sursa

优化逻辑

穿云 4 luni în urmă
părinte
comite
af4fbb6526

+ 1 - 1
dbsyncer-connector/dbsyncer-connector-base/src/test/java/ConnectionTest.java

@@ -445,7 +445,7 @@ public class ConnectionTest {
 
     private DatabaseConfig createMysqlConfig() {
         DatabaseConfig config = new DatabaseConfig();
-        config.setUrl("jdbc:mysql://127.0.0.1:3305/test?rewriteBatchedStatements=true&useUnicode=true&characterEncoding=UTF8&serverTimezone=Asia/Shanghai&useSSL=false&verifyServerCertificate=false&autoReconnect=true&failOverReadOnly=false");
+        config.setUrl("jdbc:mysql://127.0.0.1:3305/test?rewriteBatchedStatements=true&useUnicode=true&characterEncoding=UTF8&serverTimezone=Asia/Shanghai&useSSL=false&verifyServerCertificate=false&autoReconnect=true&failOverReadOnly=false&tinyInt1isBit=false");
         config.setUsername("root");
         config.setPassword("123");
         config.setDriverClassName("com.mysql.cj.jdbc.Driver");

+ 6 - 0
dbsyncer-connector/dbsyncer-connector-mysql/src/main/java/org/dbsyncer/connector/mysql/schema/support/MySQLShortType.java

@@ -56,6 +56,12 @@ public final class MySQLShortType extends ShortType {
             Boolean b = (Boolean) val;
             return (short) (b ? 1 : 0);
         }
+        if (val instanceof byte[]) {
+            byte[] bytes = (byte[]) val;
+            if (bytes.length > 1) {
+                return (short) bytes[1];
+            }
+        }
         return throwUnsupportedException(val, field);
     }