Function rowToBytes

server/doltgres_handler.go:786–829

(ctx *sql.Context, s sql.Schema, row sql.Row, formatCodes []int16)

}

func rowToBytes(ctx *sql.Context, s sql.Schema, row sql.Row, formatCodes []int16) ([][]byte, error) {
	if len(row) == 0 {
		return nil, nil
	}
	if len(s) == 0 {
		// should not happen
		return nil, errors.Errorf("received empty schema")
	}
	formatCodes, err := extendFormatCodes(len(row), formatCodes)
	if err != nil {
		return nil, err
	}
	o := make([][]byte, len(row))
	for i, v := range row {
		if v == nil {
			o[i] = nil
		} else if formatCodes[i] == 1 {
			switch d := s[i].Type.(type) {
			case *pgtypes.DoltgresType:
				o[i], err = d.CallSend(ctx, v)
				if err != nil {
					return nil, err
				}
			default:
				cast := pgexprs.NewGMSCast(expression.NewLiteral(v, d))
				v, err = cast.Eval(ctx, nil)
				if err != nil {
					return nil, err
				}
				o[i], err = cast.DoltgresType(ctx).CallSend(ctx, v)
				if err != nil {
					return nil, err
				}
			}
		} else {
			val, err := s[i].Type.SQL(ctx, []byte{}, v) // We use []byte{} as there's a distinction between nil and empty
			if err != nil {
				return nil, err
			}
			o[i] = val.ToBytes()
		}
	}
	return o, nil
}