Method findCurrentSchema

driver/mysql/binlog/binlog_reader.go:1653–1663

(schemaName string)

	}
}
func (b *BinlogReader) findCurrentSchema(schemaName string) *common.SchemaContext {
	if schemaName == "" {
		return nil
	}
	schemaContext, ok := b.tables[schemaName]
	if !ok {
		return nil
	}

	return schemaContext
}

func (b *BinlogReader) findSchemaConfig(schemaConfigs []*common.DataSource, schemaName string) *common.DataSource {
	if schemaName == "" {