From 20e7becfe90b62e8f95bdaf870a8e4de5c8dc48c Mon Sep 17 00:00:00 2001
From: agapple <jianghang115@gmail.com>
Date: Thu, 28 Mar 2019 10:19:53 +0800
Subject: [PATCH] fixed format

---
 .../driver/mysql/MysqlConnectorTest.java      | 33 ++++++++++++++++---
 1 file changed, 29 insertions(+), 4 deletions(-)

diff --git a/driver/src/test/java/com/alibaba/otter/canal/parse/driver/mysql/MysqlConnectorTest.java b/driver/src/test/java/com/alibaba/otter/canal/parse/driver/mysql/MysqlConnectorTest.java
index 1af5d1e3..abcd1473 100644
--- a/driver/src/test/java/com/alibaba/otter/canal/parse/driver/mysql/MysqlConnectorTest.java
+++ b/driver/src/test/java/com/alibaba/otter/canal/parse/driver/mysql/MysqlConnectorTest.java
@@ -3,26 +3,51 @@ package com.alibaba.otter.canal.parse.driver.mysql;
 import java.io.IOException;
 import java.net.InetSocketAddress;
 
+import org.junit.Assert;
+import org.junit.Test;
+
 import com.alibaba.otter.canal.parse.driver.mysql.packets.server.ResultSetPacket;
 
 public class MysqlConnectorTest {
 
-    public static void main(String args[]) {
-        MysqlConnector connector = new MysqlConnector(new InetSocketAddress("yddb01.mysql.database.chinacloudapi.cn",
-            3306), "ps-admin01@yddb01", "1qaz3edc");
+    @Test
+    public void testQuery() {
+
+        MysqlConnector connector = new MysqlConnector(new InetSocketAddress("127.0.0.1", 3306), "xxxxx", "xxxxx");
         try {
             connector.connect();
             MysqlQueryExecutor executor = new MysqlQueryExecutor(connector);
             ResultSetPacket result = executor.query("show variables like '%char%';");
             System.out.println(result);
+            result = executor.query("select * from test.test1");
+            System.out.println(result);
         } catch (IOException e) {
-            e.printStackTrace();
+            Assert.fail(e.getMessage());
         } finally {
             try {
                 connector.disconnect();
             } catch (IOException e) {
+                Assert.fail(e.getMessage());
             }
         }
     }
 
+    // @Test
+    public void testUpdate() {
+
+        MysqlConnector connector = new MysqlConnector(new InetSocketAddress("127.0.0.1", 3306), "xxxxx", "xxxxx");
+        try {
+            connector.connect();
+            MysqlUpdateExecutor executor = new MysqlUpdateExecutor(connector);
+            executor.update("insert into test.test2(id,name,score,text_value) values(null,'中文1',10,'中文2')");
+        } catch (IOException e) {
+            Assert.fail(e.getMessage());
+        } finally {
+            try {
+                connector.disconnect();
+            } catch (IOException e) {
+                Assert.fail(e.getMessage());
+            }
+        }
+    }
 }