MCPcopy Create free account
hub / github.com/actiontech/dtle / findCurrentTable

Method findCurrentTable

driver/mysql/binlog/binlog_reader.go:1688–1697  ·  view source on GitHub ↗
(maybeSchema *common.SchemaContext, tableName string)

Source from the content-addressed store, hash-verified

1686}
1687
1688func (b *BinlogReader) findCurrentTable(maybeSchema *common.SchemaContext, tableName string) *common.TableContext {
1689 if maybeSchema == nil {
1690 return nil
1691 }
1692 table, ok := maybeSchema.TableMap[tableName]
1693 if !ok {
1694 return nil
1695 }
1696 return table
1697}
1698
1699func (b *BinlogReader) findTableConfig(maybeSchemaConfig *common.DataSource, tableName string) *common.Table {
1700 if nil == maybeSchemaConfig {

Callers 3

handleQueryEventMethod · 0.95
addFKChildrenMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected