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

fix: rowChange typo (#3593)

Browse Source
This commit is contained in:
tanpenggood
2021-10-09 15:23:36 +08:00
committed by GitHub
parent 2550d8eb65
commit ea20076a32
4 changed files with 25 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
example/src/main/java/com/alibaba/otter/canal/example/BaseCanalClientTest.java
View File

@@ -132,14 +132,14 @@ public class BaseCanalClientTest {
} }
if (entry.getEntryType() == EntryType.ROWDATA) { if (entry.getEntryType() == EntryType.ROWDATA) {
RowChange rowChage = null; RowChange rowChange = null;
try { try {
rowChage = RowChange.parseFrom(entry.getStoreValue()); rowChange = RowChange.parseFrom(entry.getStoreValue());
} catch (Exception e) { } catch (Exception e) {
throw new RuntimeException("parse event has an error , data:" + entry.toString(), e); throw new RuntimeException("parse event has an error , data:" + entry.toString(), e);
} }
EventType eventType = rowChage.getEventType(); EventType eventType = rowChange.getEventType();
logger.info(row_format, logger.info(row_format,
new Object[] { entry.getHeader().getLogfileName(), new Object[] { entry.getHeader().getLogfileName(),
@@ -148,13 +148,13 @@ public class BaseCanalClientTest {
String.valueOf(entry.getHeader().getExecuteTime()), simpleDateFormat.format(date), String.valueOf(entry.getHeader().getExecuteTime()), simpleDateFormat.format(date),
entry.getHeader().getGtid(), String.valueOf(delayTime) }); entry.getHeader().getGtid(), String.valueOf(delayTime) });
if (eventType == EventType.QUERY || rowChage.getIsDdl()) { if (eventType == EventType.QUERY || rowChange.getIsDdl()) {
logger.info("ddl : " + rowChage.getIsDdl() + " , sql ----> " + rowChage.getSql() + SEP); logger.info("ddl : " + rowChange.getIsDdl() + " , sql ----> " + rowChange.getSql() + SEP);
continue; continue;
} }
printXAInfo(rowChage.getPropsList()); printXAInfo(rowChange.getPropsList());
for (RowData rowData : rowChage.getRowDatasList()) { for (RowData rowData : rowChange.getRowDatasList()) {
if (eventType == EventType.DELETE) { if (eventType == EventType.DELETE) {
printColumn(rowData.getBeforeColumnsList()); printColumn(rowData.getBeforeColumnsList());
} else if (eventType == EventType.INSERT) { } else if (eventType == EventType.INSERT) {

8
parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinlogDumpTest.java
View File

@@ -47,15 +47,15 @@ public class LocalBinlogDumpTest {
} }
if (entry.getEntryType() == EntryType.ROWDATA) { if (entry.getEntryType() == EntryType.ROWDATA) {
RowChange rowChage = null; RowChange rowChange = null;
try { try {
rowChage = RowChange.parseFrom(entry.getStoreValue()); rowChange = RowChange.parseFrom(entry.getStoreValue());
} catch (Exception e) { } catch (Exception e) {
throw new RuntimeException("ERROR ## parser of eromanga-event has an error , data:" throw new RuntimeException("ERROR ## parser of eromanga-event has an error , data:"
+ entry.toString(), e); + entry.toString(), e);
} }
EventType eventType = rowChage.getEventType(); EventType eventType = rowChange.getEventType();
System.out.println(String.format("================> binlog[%s:%s] , name[%s,%s] , eventType : %s", System.out.println(String.format("================> binlog[%s:%s] , name[%s,%s] , eventType : %s",
entry.getHeader().getLogfileName(), entry.getHeader().getLogfileName(),
entry.getHeader().getLogfileOffset(), entry.getHeader().getLogfileOffset(),
@@ -63,7 +63,7 @@ public class LocalBinlogDumpTest {
entry.getHeader().getTableName(), entry.getHeader().getTableName(),
eventType)); eventType));
for (RowData rowData : rowChage.getRowDatasList()) { for (RowData rowData : rowChange.getRowDatasList()) {
if (eventType == EventType.DELETE) { if (eventType == EventType.DELETE) {
print(rowData.getBeforeColumnsList()); print(rowData.getBeforeColumnsList());
} else if (eventType == EventType.INSERT) { } else if (eventType == EventType.INSERT) {

14
parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlDumpTest.java
View File

@@ -59,15 +59,15 @@ public class MysqlDumpTest {
continue; continue;
} }
RowChange rowChage = null; RowChange rowChange = null;
try { try {
rowChage = RowChange.parseFrom(entry.getStoreValue()); rowChange = RowChange.parseFrom(entry.getStoreValue());
} catch (Exception e) { } catch (Exception e) {
throw new RuntimeException("ERROR ## parser of eromanga-event has an error , data:" throw new RuntimeException("ERROR ## parser of eromanga-event has an error , data:"
+ entry.toString(), e); + entry.toString(), e);
} }
EventType eventType = rowChage.getEventType(); EventType eventType = rowChange.getEventType();
System.out.println(String.format("================> binlog[%s:%s] , name[%s,%s] , eventType : %s", System.out.println(String.format("================> binlog[%s:%s] , name[%s,%s] , eventType : %s",
entry.getHeader().getLogfileName(), entry.getHeader().getLogfileName(),
entry.getHeader().getLogfileOffset(), entry.getHeader().getLogfileOffset(),
@@ -75,12 +75,12 @@ public class MysqlDumpTest {
entry.getHeader().getTableName(), entry.getHeader().getTableName(),
eventType)); eventType));
if (eventType == EventType.QUERY || rowChage.getIsDdl()) { if (eventType == EventType.QUERY || rowChange.getIsDdl()) {
System.out.println(" sql ----> " + rowChage.getSql()); System.out.println(" sql ----> " + rowChange.getSql());
} }
printXAInfo(rowChage.getPropsList()); printXAInfo(rowChange.getPropsList());
for (RowData rowData : rowChage.getRowDatasList()) { for (RowData rowData : rowChange.getRowDatasList()) {
if (eventType == EventType.DELETE) { if (eventType == EventType.DELETE) {
print(rowData.getBeforeColumnsList()); print(rowData.getBeforeColumnsList());
} else if (eventType == EventType.INSERT) { } else if (eventType == EventType.INSERT) {

8
parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/RdsLocalBinlogDumpTest.java
View File

@@ -53,15 +53,15 @@ public class RdsLocalBinlogDumpTest {
} }
if (entry.getEntryType() == EntryType.ROWDATA) { if (entry.getEntryType() == EntryType.ROWDATA) {
RowChange rowChage = null; RowChange rowChange = null;
try { try {
rowChage = RowChange.parseFrom(entry.getStoreValue()); rowChange = RowChange.parseFrom(entry.getStoreValue());
} catch (Exception e) { } catch (Exception e) {
throw new RuntimeException("ERROR ## parser of eromanga-event has an error , data:" throw new RuntimeException("ERROR ## parser of eromanga-event has an error , data:"
+ entry.toString(), e); + entry.toString(), e);
} }
EventType eventType = rowChage.getEventType(); EventType eventType = rowChange.getEventType();
System.out.println(String.format("================> binlog[%s:%s] , name[%s,%s] , eventType : %s", System.out.println(String.format("================> binlog[%s:%s] , name[%s,%s] , eventType : %s",
entry.getHeader().getLogfileName(), entry.getHeader().getLogfileName(),
entry.getHeader().getLogfileOffset(), entry.getHeader().getLogfileOffset(),
@@ -69,7 +69,7 @@ public class RdsLocalBinlogDumpTest {
entry.getHeader().getTableName(), entry.getHeader().getTableName(),
eventType)); eventType));
for (RowData rowData : rowChage.getRowDatasList()) { for (RowData rowData : rowChange.getRowDatasList()) {
if (eventType == EventType.DELETE) { if (eventType == EventType.DELETE) {
print(rowData.getBeforeColumnsList()); print(rowData.getBeforeColumnsList());
} else if (eventType == EventType.INSERT) { } else if (eventType == EventType.INSERT) {