Function convertRowsToRecords

server/plpgsql/interpreter_logic.go:380–411

convertRowsToRecords iterates overs |rows| and converts each field in each row into a RecordValue. |schema| is specified for type information.

(schema sql.Schema, rows []sql.Row)

// convertRowsToRecords iterates overs |rows| and converts each field in each row
// into a RecordValue. |schema| is specified for type information.
func convertRowsToRecords(schema sql.Schema, rows []sql.Row) ([][]pgtypes.RecordValue, error) {
	records := make([][]pgtypes.RecordValue, 0, len(rows))
	for _, row := range rows {
		record := make([]pgtypes.RecordValue, len(row))
		for i, field := range row {
			t := schema[i].Type
			doltgresType, ok := t.(*pgtypes.DoltgresType)
			if !ok {
				// non-Doltgres types are still used in analysis, but we only support disk serialization
				// for Doltgres types, so we must convert the GMS type to the nearest Doltgres type here.
				// TODO: this conversion isn't fully accurate. expression.GMSCast has additional logic in
				//       its Eval() method to handle types more exactly and also handles converting the
				//       value to ensure it is well formed for the returned DoltgresType. We can't
				//       currently use GMSCast directly here though, because of a dependency cycle, so
				//       that conversion logic needs to be extracted into a package both places can import.
				var err error
				doltgresType, err = pgtypes.FromGmsTypeToDoltgresType(t)
				if err != nil {
					return nil, err
				}
			}

			record[i] = pgtypes.RecordValue{
				Value: field,
				Type:  doltgresType,
			}
		}
		records = append(records, record)
	}

	return records, nil
}

// applyNoticeOptions adds the specified |options| to the |noticeResponse|.
func applyNoticeOptions(ctx *sql.Context, noticeResponse *pgproto3.NoticeResponse, options map[string]string) error {