Function prepareTransformation

backend/plugin/parser/mysql/backup.go:72–112

(databaseName, statement string, dbMetadata *model.DatabaseMetadata)

}

func prepareTransformation(databaseName, statement string, dbMetadata *model.DatabaseMetadata) ([]StatementInfo, error) {
	list, err := SplitSQL(statement)
	if err != nil {
		return nil, errors.Wrap(err, "failed to split sql")
	}

	var result []StatementInfo
	for i, item := range list {
		if len(item.Text) == 0 || item.Empty {
			continue
		}

		parsed, err := ParseMySQLOmni(item.Text)
		if err != nil {
			return nil, errors.Wrap(err, "failed to parse sql")
		}
		if parsed == nil || len(parsed.Items) == 0 {
			continue
		}

		for _, node := range parsed.Items {
			tables, err := ExtractTables(databaseName, node, item.Text, i, dbMetadata)
			if err != nil {
				return nil, errors.Wrap(err, "failed to extract tables")
			}
			for _, table := range tables {
				result = append(result, StatementInfo{
					Offset:        table.Offset,
					Statement:     table.Statement,
					Node:          table.Node,
					Table:         table.Table,
					StartPosition: item.Start,
					EndPosition:   item.End,
					FullSQL:       item.Text,
				})
			}
		}
	}

	return result, nil
}

// ExtractTables extracts table references from a DML statement.
func ExtractTables(databaseName string, node ast.Node, fullSQL string, offset int, dbMetadata *model.DatabaseMetadata) ([]StatementInfo, error) {