Skip to content

Commit c99aaa4

Browse files
committed
remove comments
1 parent 2bb7cb9 commit c99aaa4

File tree

1 file changed

+0
-9
lines changed

1 file changed

+0
-9
lines changed

go/logic/applier.go

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -636,17 +636,12 @@ func (this *Applier) ApplyIterationInsertQuery() (chunkSize int64, rowsAffected
636636
}
637637

638638
sqlResult, err := func() (gosql.Result, error) {
639-
/*tx, err := this.db.Begin()*/
640639
var conn *gosql.Conn
641640
conn, err = this.db.Conn(context.Background())
642641
if (conn == nil || err != nil) {
643642
fmt.Sprintf("failed to get connection")
644643
return nil, err
645644
}
646-
// if _, err := conn.ExecContext(context.Background(), "SET @@SESSION.sql_log_bin=0"); err != nil {
647-
// fmt.Sprintf("failed to disable binary logs")
648-
// return nil, err
649-
// }
650645
tx, err := conn.BeginTx(context.Background(), nil)
651646
if err != nil {
652647
return nil, err
@@ -666,10 +661,6 @@ func (this *Applier) ApplyIterationInsertQuery() (chunkSize int64, rowsAffected
666661
if err := tx.Commit(); err != nil {
667662
return nil, err
668663
}
669-
// if _, err := conn.ExecContext(context.Background(), "SET @@SESSION.sql_log_bin=1"); err != nil {
670-
// fmt.Sprintf("failed to enable binary logs")
671-
// return nil, err
672-
// }
673664
conn.Close()
674665
return result, nil
675666
}()

0 commit comments

Comments
 (0)