From 9b2ad0eafdd40af08e915d05ae511ed1e5a88516 Mon Sep 17 00:00:00 2001
From: kangzhidong <kzd666@163.com>
Date: Wed, 20 Mar 2019 16:29:53 +0800
Subject: [PATCH] set utf8mb4 to support emoji

---
 .../otter/canal/client/adapter/rdb/RdbAdapter.java        | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/RdbAdapter.java b/client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/RdbAdapter.java
index b45ad4d9..75ddfbb0 100644
--- a/client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/RdbAdapter.java
+++ b/client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/RdbAdapter.java
@@ -2,10 +2,7 @@ package com.alibaba.otter.canal.client.adapter.rdb;
 
 import java.sql.Connection;
 import java.sql.SQLException;
-import java.util.LinkedHashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Properties;
+import java.util.*;
 import java.util.concurrent.ConcurrentHashMap;
 
 import javax.sql.DataSource;
@@ -123,6 +120,9 @@ public class RdbAdapter implements OuterAdapter {
         dataSource.setTimeBetweenEvictionRunsMillis(60000);
         dataSource.setMinEvictableIdleTimeMillis(300000);
         dataSource.setUseUnfairLock(true);
+        List<String> array = new ArrayList<>();
+        array.add("set names utf8mb4;");
+        dataSource.setConnectionInitSqls(array);
 
         try {
             dataSource.init();