refactor: code-optimization (#1885)

* refactor: code-optimization

* fix: restoring code style

* fix: gofmt
This commit is contained in:
guangwu
2023-05-23 17:54:51 +08:00
committed by GitHub
parent 2389d47c34
commit 54e4747dbc
12 changed files with 22 additions and 29 deletions

View File

@ -66,13 +66,13 @@ func (db *Database) OnRow(e *canal.RowsEvent) error {
for i, row := range e.Rows {
for j, item := range row {
if i%2 == 0 {
if isChar[j] == true {
if isChar[j] {
oldColumnValue[j] = fmt.Sprintf("%s", item)
} else {
oldColumnValue[j] = fmt.Sprintf("%d", item)
}
} else {
if isChar[j] == true {
if isChar[j] {
if item == nil {
newColumnValue[j] = nil
} else {
@ -103,7 +103,7 @@ func (db *Database) OnRow(e *canal.RowsEvent) error {
db.engine.Exec("BEGIN")
for _, row := range e.Rows {
for j, item := range row {
if isChar[j] == true {
if isChar[j] {
oldColumnValue[j] = fmt.Sprintf("%s", item)
} else {
oldColumnValue[j] = fmt.Sprintf("%d", item)
@ -128,7 +128,7 @@ func (db *Database) OnRow(e *canal.RowsEvent) error {
db.engine.Exec("BEGIN")
for _, row := range e.Rows {
for j, item := range row {
if isChar[j] == true {
if isChar[j] {
if item == nil {
newColumnValue[j] = nil
} else {