chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

fixed format

Browse Source
This commit is contained in:
agapple
2019-03-28 10:19:53 +08:00
parent 99b34ff632
commit 20e7becfe9
1 changed files with 29 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
driver/src/test/java/com/alibaba/otter/canal/parse/driver/mysql/MysqlConnectorTest.java
View File

@@ -3,26 +3,51 @@ package com.alibaba.otter.canal.parse.driver.mysql;
import java.io.IOException; import java.io.IOException;
import java.net.InetSocketAddress; import java.net.InetSocketAddress;
import org.junit.Assert;
import org.junit.Test;
import com.alibaba.otter.canal.parse.driver.mysql.packets.server.ResultSetPacket; import com.alibaba.otter.canal.parse.driver.mysql.packets.server.ResultSetPacket;
public class MysqlConnectorTest { public class MysqlConnectorTest {
public static void main(String args[]) { @Test
MysqlConnector connector = new MysqlConnector(new InetSocketAddress("yddb01.mysql.database.chinacloudapi.cn", public void testQuery() {
3306), "ps-admin01@yddb01", "1qaz3edc");
MysqlConnector connector = new MysqlConnector(new InetSocketAddress("127.0.0.1", 3306), "xxxxx", "xxxxx");
try { try {
connector.connect(); connector.connect();
MysqlQueryExecutor executor = new MysqlQueryExecutor(connector); MysqlQueryExecutor executor = new MysqlQueryExecutor(connector);
ResultSetPacket result = executor.query("show variables like '%char%';"); ResultSetPacket result = executor.query("show variables like '%char%';");
System.out.println(result); System.out.println(result);
result = executor.query("select * from test.test1");
System.out.println(result);
} catch (IOException e) { } catch (IOException e) {
e.printStackTrace(); Assert.fail(e.getMessage());
} finally { } finally {
try { try {
connector.disconnect(); connector.disconnect();
} catch (IOException e) { } 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());
}
}
}
} }