Method updateTableMeta

driver/mysql/binlog/binlog_reader.go:1393–1434

gno, query: for debug use

(currentSchema string, table *common.Table, realSchema string, tableName string,
	gno int64, query string)

// gno, query: for debug use
func (b *BinlogReader) updateTableMeta(currentSchema string, table *common.Table, realSchema string, tableName string,
	gno int64, query string) (*common.TableContext, error) {

	var err error

	if b.maybeSqleContext == nil {
		b.logger.Debug("ignore updating table meta", "schema", realSchema, "table", tableName)
		return nil, nil
	}

	columns, fkParent, err := base.GetTableColumnsSqle(b.maybeSqleContext, realSchema, tableName)
	if err != nil {
		b.logger.Warn("updateTableMeta: cannot get table info after ddl.", "err", err,
			"realSchema", realSchema, "tableName", tableName, "gno", gno, "query", query)
		return nil, err
	}
	b.logger.Debug("binlog_reader. new columns.",
		"schema", realSchema, "table", tableName, "columns", columns.String())

	//var table *config.Table

	if table == nil {
		// a new table (it might be in all db copy since it is not ignored).
		table = common.NewTable(realSchema, tableName)
		table.TableType = "BASE TABLE"
	}
	table.OriginalTableColumns = columns
	table.ColumnMap, err = mysqlconfig.BuildColumnMapIndex(table.ColumnMapFrom, table.OriginalTableColumns.Ordinals)
	if err != nil {
		return nil, err
	}

	schemaContext := b.findCurrentSchema(realSchema)
	tableCtx, err := common.NewTableContext(table)
	if err != nil {
		return nil, err
	}
	schemaContext.TableMap[table.TableName] = tableCtx
	b.addFKChildren(currentSchema, fkParent, realSchema, tableName)

	return tableCtx, nil
}

func (b *BinlogReader) updateCurrentReplicateDoDb(schemaName string, tableName string) error {
	if schemaName == "" {