| 52 | } |
| 53 | |
| 54 | func TransformDMLToSelect(_ context.Context, _ base.TransformContext, statement string, sourceDatabase string, targetDatabase string, tablePrefix string) ([]base.BackupStatement, error) { |
| 55 | statementInfoList, err := prepareTransformation(sourceDatabase, statement) |
| 56 | if err != nil { |
| 57 | return nil, errors.Wrap(err, "failed to prepare transformation") |
| 58 | } |
| 59 | |
| 60 | return generateSQL(statementInfoList, targetDatabase, tablePrefix) |
| 61 | } |
| 62 | |
| 63 | func generateSQL(statementInfoList []statementInfo, targetDatabase string, tablePrefix string) ([]base.BackupStatement, error) { |
| 64 | groupByTable := make(map[string][]statementInfo) |