Function ExecuteQuery

tests/integration/compare.go:71–117

ExecuteQuery executes a query and returns the result

(db *sql.DB, query string)

// ExecuteQuery executes a query and returns the result
func ExecuteQuery(db *sql.DB, query string) (*QueryResult, error) {
	rows, err := db.Query(query)
	if err != nil {
		return &QueryResult{Error: err}, nil
	}
	defer func() { _ = rows.Close() }()

	columns, err := rows.Columns()
	if err != nil {
		return nil, fmt.Errorf("failed to get columns: %w", err)
	}

	var result [][]interface{}
	for rows.Next() {
		// Use sql.RawBytes to completely avoid driver parsing issues
		rawValues := make([]sql.RawBytes, len(columns))
		valuePtrs := make([]interface{}, len(columns))
		for i := range rawValues {
			valuePtrs[i] = &rawValues[i]
		}

		if err := rows.Scan(valuePtrs...); err != nil {
			return nil, fmt.Errorf("failed to scan row: %w", err)
		}

		// Convert RawBytes to appropriate types
		values := make([]interface{}, len(columns))
		for i := range rawValues {
			if rawValues[i] == nil {
				values[i] = nil
			} else {
				values[i] = parseValue(string(rawValues[i]))
			}
		}

		result = append(result, values)
	}

	if err := rows.Err(); err != nil {
		return nil, fmt.Errorf("row iteration error: %w", err)
	}

	return &QueryResult{
		Columns: columns,
		Rows:    result,
	}, nil
}

// parseValue attempts to parse a string value into an appropriate Go type
func parseValue(s string) interface{} {