Skip to content

Commit ea20076

Browse files
tanpenggoodtanpenggood
authored
fix: rowChange typo (#3593)
1 parent 2550d8e commit ea20076

File tree

4 files changed

+25
-25
lines changed

4 files changed

+25
-25
lines changed

‎example/src/main/java/com/alibaba/otter/canal/example/BaseCanalClientTest.java‎

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -132,14 +132,14 @@ protected void printEntry(List<Entry> entrys) {
132132
}
133133

134134
if (entry.getEntryType() == EntryType.ROWDATA) {
135-
RowChange rowChage = null;
135+
RowChange rowChange = null;
136136
try {
137-
rowChage = RowChange.parseFrom(entry.getStoreValue());
137+
rowChange = RowChange.parseFrom(entry.getStoreValue());
138138
} catch (Exception e) {
139139
throw new RuntimeException("parse event has an error , data:" + entry.toString(), e);
140140
}
141141

142-
EventType eventType = rowChage.getEventType();
142+
EventType eventType = rowChange.getEventType();
143143

144144
logger.info(row_format,
145145
new Object[] { entry.getHeader().getLogfileName(),
@@ -148,13 +148,13 @@ protected void printEntry(List<Entry> entrys) {
148148
String.valueOf(entry.getHeader().getExecuteTime()), simpleDateFormat.format(date),
149149
entry.getHeader().getGtid(), String.valueOf(delayTime) });
150150

151-
if (eventType == EventType.QUERY || rowChage.getIsDdl()) {
152-
logger.info("ddl : " + rowChage.getIsDdl() + " , sql ----> " + rowChage.getSql() + SEP);
151+
if (eventType == EventType.QUERY || rowChange.getIsDdl()) {
152+
logger.info("ddl : " + rowChange.getIsDdl() + " , sql ----> " + rowChange.getSql() + SEP);
153153
continue;
154154
}
155155

156-
printXAInfo(rowChage.getPropsList());
157-
for (RowData rowData : rowChage.getRowDatasList()) {
156+
printXAInfo(rowChange.getPropsList());
157+
for (RowData rowData : rowChange.getRowDatasList()) {
158158
if (eventType == EventType.DELETE) {
159159
printColumn(rowData.getBeforeColumnsList());
160160
} else if (eventType == EventType.INSERT) {
@@ -217,7 +217,7 @@ public void setConnector(CanalConnector connector) {
217217

218218
/**
219219
* 获取当前Entry的 GTID信息示例
220-
*
220+
*
221221
* @param header
222222
* @return
223223
*/
@@ -235,7 +235,7 @@ public static String getCurrentGtid(CanalEntry.Header header) {
235235

236236
/**
237237
* 获取当前Entry的 GTID Sequence No信息示例
238-
*
238+
*
239239
* @param header
240240
* @return
241241
*/
@@ -253,7 +253,7 @@ public static String getCurrentGtidSn(CanalEntry.Header header) {
253253

254254
/**
255255
* 获取当前Entry的 GTID Last Committed信息示例
256-
*
256+
*
257257
* @param header
258258
* @return
259259
*/

‎parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinlogDumpTest.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -47,23 +47,23 @@ public boolean sink(List<Entry> entrys, InetSocketAddress remoteAddress, String
4747
}
4848

4949
if (entry.getEntryType() == EntryType.ROWDATA) {
50-
RowChange rowChage = null;
50+
RowChange rowChange = null;
5151
try {
52-
rowChage = RowChange.parseFrom(entry.getStoreValue());
52+
rowChange = RowChange.parseFrom(entry.getStoreValue());
5353
} catch (Exception e) {
5454
throw new RuntimeException("ERROR ## parser of eromanga-event has an error , data:"
5555
+ entry.toString(), e);
5656
}
5757

58-
EventType eventType = rowChage.getEventType();
58+
EventType eventType = rowChange.getEventType();
5959
System.out.println(String.format("================> binlog[%s:%s] , name[%s,%s] , eventType : %s",
6060
entry.getHeader().getLogfileName(),
6161
entry.getHeader().getLogfileOffset(),
6262
entry.getHeader().getSchemaName(),
6363
entry.getHeader().getTableName(),
6464
eventType));
6565

66-
for (RowData rowData : rowChage.getRowDatasList()) {
66+
for (RowData rowData : rowChange.getRowDatasList()) {
6767
if (eventType == EventType.DELETE) {
6868
print(rowData.getBeforeColumnsList());
6969
} else if (eventType == EventType.INSERT) {

‎parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlDumpTest.java‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -59,28 +59,28 @@ public boolean sink(List<Entry> entrys, InetSocketAddress remoteAddress, String
5959
continue;
6060
}
6161

62-
RowChange rowChage = null;
62+
RowChange rowChange = null;
6363
try {
64-
rowChage = RowChange.parseFrom(entry.getStoreValue());
64+
rowChange = RowChange.parseFrom(entry.getStoreValue());
6565
} catch (Exception e) {
6666
throw new RuntimeException("ERROR ## parser of eromanga-event has an error , data:"
6767
+ entry.toString(), e);
6868
}
6969

70-
EventType eventType = rowChage.getEventType();
70+
EventType eventType = rowChange.getEventType();
7171
System.out.println(String.format("================> binlog[%s:%s] , name[%s,%s] , eventType : %s",
7272
entry.getHeader().getLogfileName(),
7373
entry.getHeader().getLogfileOffset(),
7474
entry.getHeader().getSchemaName(),
7575
entry.getHeader().getTableName(),
7676
eventType));
7777

78-
if (eventType == EventType.QUERY || rowChage.getIsDdl()) {
79-
System.out.println(" sql ----> " + rowChage.getSql());
78+
if (eventType == EventType.QUERY || rowChange.getIsDdl()) {
79+
System.out.println(" sql ----> " + rowChange.getSql());
8080
}
8181

82-
printXAInfo(rowChage.getPropsList());
83-
for (RowData rowData : rowChage.getRowDatasList()) {
82+
printXAInfo(rowChange.getPropsList());
83+
for (RowData rowData : rowChange.getRowDatasList()) {
8484
if (eventType == EventType.DELETE) {
8585
print(rowData.getBeforeColumnsList());
8686
} else if (eventType == EventType.INSERT) {

‎parse/src/test/java/com/alibaba/otter/canal/parse/inbound/mysql/RdsLocalBinlogDumpTest.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -53,23 +53,23 @@ public boolean sink(List<Entry> entrys, InetSocketAddress remoteAddress, String
5353
}
5454

5555
if (entry.getEntryType() == EntryType.ROWDATA) {
56-
RowChange rowChage = null;
56+
RowChange rowChange = null;
5757
try {
58-
rowChage = RowChange.parseFrom(entry.getStoreValue());
58+
rowChange = RowChange.parseFrom(entry.getStoreValue());
5959
} catch (Exception e) {
6060
throw new RuntimeException("ERROR ## parser of eromanga-event has an error , data:"
6161
+ entry.toString(), e);
6262
}
6363

64-
EventType eventType = rowChage.getEventType();
64+
EventType eventType = rowChange.getEventType();
6565
System.out.println(String.format("================> binlog[%s:%s] , name[%s,%s] , eventType : %s",
6666
entry.getHeader().getLogfileName(),
6767
entry.getHeader().getLogfileOffset(),
6868
entry.getHeader().getSchemaName(),
6969
entry.getHeader().getTableName(),
7070
eventType));
7171

72-
for (RowData rowData : rowChage.getRowDatasList()) {
72+
for (RowData rowData : rowChange.getRowDatasList()) {
7373
if (eventType == EventType.DELETE) {
7474
print(rowData.getBeforeColumnsList());
7575
} else if (eventType == EventType.INSERT) {

0 commit comments

Comments
 (0)