(schema string)
| 2035 | } |
| 2036 | |
| 2037 | func (b *BinlogReader) removeFKChildSchema(schema string) { |
| 2038 | for _, schemaContext := range b.tables { |
| 2039 | for _, tableContext := range schemaContext.TableMap { |
| 2040 | for k, _ := range tableContext.FKChildren { |
| 2041 | if k.Schema == schema { |
| 2042 | delete(tableContext.FKChildren, k) |
| 2043 | } |
| 2044 | } |
| 2045 | |
| 2046 | } |
| 2047 | } |
| 2048 | } |
| 2049 | |
| 2050 | func (b *BinlogReader) removeFKChild(childSchema string, childTable string) { |
| 2051 | for _, schemaContext := range b.tables { |