| 1658 | } |
| 1659 | |
| 1660 | func (e *Extractor) CheckAndApplyLowerCaseTableNames() { |
| 1661 | if e.lowerCaseTableNames != mysqlconfig.LowerCaseTableNames0 { |
| 1662 | lowerConfigItem := func(configItem []*common.DataSource) { |
| 1663 | for _, d := range configItem { |
| 1664 | g.LowerString(&d.TableSchema) |
| 1665 | g.LowerString(&d.TableSchemaRename) |
| 1666 | if d.TableSchemaRegex != "" { |
| 1667 | d.TableSchemaRegex = "(?i)" + d.TableSchemaRegex |
| 1668 | } |
| 1669 | for _, table := range d.Tables { |
| 1670 | g.LowerString(&table.TableName) |
| 1671 | g.LowerString(&table.TableRename) |
| 1672 | if table.TableRegex != "" { |
| 1673 | table.TableRegex = "(?i)" + table.TableRegex |
| 1674 | } |
| 1675 | } |
| 1676 | } |
| 1677 | } |
| 1678 | lowerConfigItem(e.mysqlContext.ReplicateDoDb) |
| 1679 | lowerConfigItem(e.mysqlContext.ReplicateIgnoreDb) |
| 1680 | } |
| 1681 | } |