Pārlūkot izejas kodu

fixed issue #284 , add slave_uuid

agapple 8 gadi atpakaļ
vecāks
revīzija
b2a5f482ee

+ 10 - 0
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlConnection.java

@@ -213,6 +213,16 @@ public class MysqlConnection implements ErosaConnection {
             }
         }
 
+        try {
+            // 参考:https://github.com/alibaba/canal/issues/284
+            // mysql5.6需要设置slave_uuid避免被server kill链接
+            update("set @slave_uuid=uuid()");
+        } catch (Exception e) {
+            if (!StringUtils.contains(e.getMessage(), "Unknown system variable")) {
+                logger.warn(ExceptionUtils.getFullStackTrace(e));
+            }
+        }
+
         try {
             // mariadb针对特殊的类型,需要设置session变量
             update("SET @mariadb_slave_capability='" + LogEvent.MARIA_SLAVE_CAPABILITY_MINE + "'");