Method matchTable

driver/mysql/binlog/binlog_reader.go:1319–1359

(patternTBS []*common.DataSource, schemaName string, tableName string)

}

func (b *BinlogReader) matchTable(patternTBS []*common.DataSource, schemaName string, tableName string) bool {
	if schemaName == "" {
		return false
	}

	for _, pdb := range patternTBS {
		if pdb.TableSchema == "" && pdb.TableSchemaRegex == "" { // invalid pattern
			continue
		}
		if pdb.TableSchema != "" && pdb.TableSchema != schemaName {
			continue
		}
		if pdb.TableSchemaRegex != "" {
			reg := regexp.MustCompile(pdb.TableSchemaRegex)
			if !reg.MatchString(schemaName) {
				continue
			}
		}

		if tableName == "" || len(pdb.Tables) == 0 { // match all tables within the db if length of pdb.Tables is 0
			return true
		}

		for _, ptb := range pdb.Tables {
			if ptb.TableName == "" && ptb.TableRegex == "" { // invalid pattern
				continue
			}
			if ptb.TableName != "" && ptb.TableName == tableName {
				return true
			}
			if ptb.TableRegex != "" {
				reg := regexp.MustCompile(ptb.TableRegex)
				if reg.MatchString(tableName) {
					return true
				}
			}
		}
		return false
	}
	return false
}

func (b *BinlogReader) Close() error {
	b.logger.Debug("BinlogReader.Close")