Skip to content

Commit 4770cad

Browse files
author
eitam
committed
moved supportsSmartQuotes to after the data parse
1 parent 4429f9d commit 4770cad

File tree

1 file changed

+0
-9
lines changed

1 file changed

+0
-9
lines changed

canal/canal.go

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -509,16 +509,11 @@ func (c *Canal) GetColumnsCharsets() error {
509509
if err != nil {
510510
return fmt.Errorf("failed to generate charset query: %w", err)
511511
}
512-
513-
// ADD: Log what table we're processing
514-
log.Infof("Fetching charset mappings for %s.%s", dbName, tableName)
515-
516512
rows, err := db.QueryContext(c.ctx, query, dbName, tableName)
517513
if err != nil {
518514
return fmt.Errorf("error occurred while executing query: %s on db: %s on table: %s. error: %v",
519515
query, dbName, tableName, errors.Trace(err))
520516
}
521-
522517
// Ensure rows are closed after processing
523518
func() {
524519
defer rows.Close()
@@ -527,10 +522,6 @@ func (c *Canal) GetColumnsCharsets() error {
527522
}
528523
}()
529524

530-
// ADD: Log final map contents for this table
531-
log.Infof("Table %s charset map populated with %d entries: %+v",
532-
tableRegex, len(c.cfg.ColumnCharset[tableRegex]), c.cfg.ColumnCharset[tableRegex])
533-
534525
}
535526

536527
return nil

0 commit comments

Comments
 (0)