g/7ddlmZddlmZddlmZmZmZmZm Z ddl m Z m Z ddl mZddlmZmZmZmZmZmZmZmZmZmZmZddlmZmZdd lmZdd l m!Z!m"Z"ed Z#Gd d ee#Z$Gddee#Z%Gdde%e#Z&Gddee#e$e#Z'Gddee#e%e#Z(Gddee#e$e#Z)Gddee#Z*y)) annotations)JSONDecodeError)AnyGenericOptionalTypeVarUnion)Headers QueryParams)ValidationError) APIResponseBaseFilterRequestBuilderBaseRPCRequestBuilderBaseSelectRequestBuilder CountMethodSingleAPIResponse pre_delete pre_insert pre_select pre_update pre_upsert)APIErrorgenerate_default_error_message) ReturnMethod) SyncClientget_origin_and_cast_ReturnTc8eZdZ ddZddZy)SyncQueryRequestBuildercX||_||_||_||_||_||_yNsessionpath http_methodheadersparamsjsonselfr$r%r&r'r(r)s T/var/www/openai/venv/lib/python3.12/site-packages/postgrest/_sync/request_builder.py__init__z SyncQueryRequestBuilder.__init__/  &   c|jj|j|j|j|j |j } |jr|jdk7r|j}|j jddk(r|S|j jdr||##v-66D||''1Z?# ||'' 6$,,:J:J8:TT"$,,*:*:8*DD#'K"8,GGJJqvvx(( ,1668$! + >9!<= = >s,AD'AD'2D'D'' E+0E  !E+N)r$rr%strr&r>r'r r(r r)Union[dict, list]returnNone)r@zAPIResponse[_ReturnT]__name__ __module__ __qualname__r-r=r/r,r r sP        $>r/r c8eZdZ ddZddZy)SyncSingleRequestBuildercX||_||_||_||_||_||_yr"r#r*s r,r-z!SyncSingleRequestBuilder.__init__Vr.r/c|jj|j|j|j|j |j } d|jcxkrdkrnnttj|St|j #t$r}t|j |d}~wt$rtt|wxYw)zExecute the query. .. tip:: This is the last method called, after the query is built. Returns: :class:`SingleAPIResponse` Raises: :class:`APIError` If the API raised an error. r1i+N)r$r5r&r%r)r(r' status_coderrr9rr rrr+r:r<s r,r=z SyncSingleRequestBuilder.executefs LL    II;;LL !  >q}}++(2MMaPPqvvx(( ,1668$! + >9!<= = >s3B!B!! C%*C!C%Nr$rr%r>r&r>r'r r(r r)dictr@rA)r@zSingleAPIResponse[_ReturnT]rBrFr/r,rHrHUsP       >r/rHceZdZddZy)SyncMaybeSingleRequestBuildercd} ttj|}|stddddd|S#t$r)}|jrd|jvrYd}~yYd}~Ad}~wwxYw)NzThe result contains 0 rowszMissing response204z"Please check traceback of the codezPostgrest couldn't retrieve response, please check traceback of the code. Please create an issue in `supabase-community/postgrest-py` if needed.)messagecodehintdetails)rHrr=rrWrMs r,r=z%SyncMaybeSingleRequestBuilder.executesw  (2::4@A1!@ r   yy9QYYF s4 A&A!!A&N)r@z%Optional[SingleAPIResponse[_ReturnT]])rCrDrEr=rFr/r,rQrQsr/rQc0eZdZ ddZy)SyncFilterRequestBuilderc tttj||||tttj|||||||yr")rrrr-r r*s r,r-z!SyncFilterRequestBuilder.__init__P 4X>?HH '7F  3H=>GG '4gvt r/NrNrCrDrEr-rFr/r,rYrYsK            r/rYc0eZdZ ddZy)SyncRPCFilterRequestBuilderc tttj||||tttj|||||||yr")rrrr-rHr*s r,r-z$SyncRPCFilterRequestBuilder.__init__sP 4X>?HH '7F  4X>?HH '4gvt r/NrNr\rFr/r,r^r^sK            r/r^cbeZdZ ddZddZd dZif d dZd dZy) SyncSelectRequestBuilderc tttj||||tttj|||||||yr")rrrr-r r*s r,r-z!SyncSelectRequestBuilder.__init__r[r/cd|jd<tt|j|j|j|j |j |jS)zSpecify that the query will only return a single row in response. .. caution:: The API will raise an error if the query returned more than one row. !application/vnd.pgrst.object+jsonr3r'r&r)r(r%r$)r'rHrr&r)r(r%r$r+s r,singlezSyncSelectRequestBuilder.singlesQ "E X'1LL((;;LL   r/cd|jd<tt|j|j|j|j |j |jS)zRetrieves at most one row from the result. Result must be at most one row (e.g. using `eq` on a UNIQUE column), otherwise this will result in an error.rdr3re)r'rQrr&r)r(r%r$rfs r, maybe_singlez%SyncSelectRequestBuilder.maybe_singlesN!D X,X6LL((;;LL   r/c|jd}d}|dk(rd}n|dk(rd}n|dk(rd}|jd rd |jd d nd}|jj||d |d ||_tt|j |j |j|j|j|jS)Ntypeplainplphraseph web_searchwconfig()fts.re) r8r(addr rr'r&r)r%r$)r+columnqueryoptionstype_ type_part config_parts r, text_searchz$SyncSelectRequestBuilder.text_searchs F# G I h I l "I6=kk(6K'++h/02QS kkoof 3{m1UG.TU &x0LL((;;LL   r/cd|jd<tt|j|j|j |j|j |jS)zASpecify that the query must retrieve data as a single CSV string.r4r3r#)r'rHr>r$r%r&r(r)rfs r,csvzSyncSelectRequestBuilder.csvsN!+ X',LL((LL;;   r/NrN)r@z"SyncSingleRequestBuilder[_ReturnT])r@z'SyncMaybeSingleRequestBuilder[_ReturnT])ryr>rzr>r{zdict[str, Any]r@"SyncFilterRequestBuilder[_ReturnT])r@zSyncSingleRequestBuilder[str])rCrDrEr-rgrirrrFr/r,raras              BD  "% 0> + .  r/raceZdZddZddd ddZdej ddd ddZdej dd dd  dd Zdej d  dd Z dej d  ddZ y)SyncRequestBuilderc ||_||_yr")r$r%)r+r$r%s r,r-zSyncRequestBuilder.__init__s  r/Ncountheadczt|||d\}}}}tt|j|j||||S)zRun a SELECT query. Args: *columns: The names of the columns to fetch. count: The method to use to get the count of rows returned. Returns: :class:`SyncSelectRequestBuilder` r)rrarr$r%)r+rrcolumnsmethodr(r'r)s r,selectzSyncRequestBuilder.selectsB)3G5t(T%'1 LL$))VWfd  r/FTr returningupsertdefault_to_nullct|||||\}}}}tt|j|j||||S)aRun an INSERT query. Args: json: The row to be inserted. count: The method to use to get the count of rows returned. returning: Either 'minimal' or 'representation' upsert: Whether the query should be an upsert. default_to_null: Make missing fields default to `null`. Otherwise, use the default value for the column. Only applies for bulk inserts. Returns: :class:`SyncQueryRequestBuilder` r)rr rr$r%) r+r)rrrrrr(r's r,insertzSyncRequestBuilder.insert,sO,)3 + ) %'x0 LL$))VWfd  r/rlrrignore_duplicates on_conflictrct||||||\}}} }tt|j|j|| ||S)aRun an upsert (INSERT ... ON CONFLICT DO UPDATE) query. Args: json: The row to be inserted. count: The method to use to get the count of rows returned. returning: Either 'minimal' or 'representation' ignore_duplicates: Whether duplicate rows should be ignored. on_conflict: Specified columns to be made to work with UNIQUE constraint. default_to_null: Make missing fields default to `null`. Otherwise, use the default value for the column. This only applies when inserting new rows, not when merging with existing rows under `ignoreDuplicates: false`. This also only applies when doing bulk upserts. Returns: :class:`SyncQueryRequestBuilder` r)rr rr$r%) r+r)rrrrrrr(r's r,rzSyncRequestBuilder.upsertMsR2)3 /#+ ) %'x0 LL$))VWfd  r/rrc~t|||\}}}}tt|j|j||||S)aRun an UPDATE query. Args: json: The updated fields. count: The method to use to get the count of rows returned. returning: Either 'minimal' or 'representation' Returns: :class:`SyncFilterRequestBuilder` r)rrYrr$r%)r+r)rrrr(r's r,updatezSyncRequestBuilder.updatersI )3 ) % (1 LL$))VWfd  r/c|t||\}}}}tt|j|j||||S)zRun a DELETE query. Args: count: The method to use to get the count of rows returned. returning: Either 'minimal' or 'representation' Returns: :class:`SyncFilterRequestBuilder` r)rrYrr$r%)r+rrrr(r'r)s r,deletezSyncRequestBuilder.deletesF)3) %(1 LL$))VWfd  r/)r$rr%r>r@rA)rr>rOptional[CountMethod]rzOptional[bool]r@z"SyncSelectRequestBuilder[_ReturnT]) r)r?rrrrrboolrrr@!SyncQueryRequestBuilder[_ReturnT])r)r?rrrrrrrr>rrr@r)r)rOrrrrr@r)rrrrr@r) rCrDrEr-rrrepresentationrrrrrFr/r,rrsY(,#   %   ,  .(,"."="= $  %        + J(,"."="="' $# # % #  #  # # #  +# R(,"."="=   %    ,  8(,"."="=  %   ,  r/rN)+ __future__rr)rtypingrrrrr httpxr r pydanticr base_request_builderrrrrrrrrrrr exceptionsrrtypesrutilsrrrr rHrQrYr^rarrFr/r,rs" 99&$    B 3 : 5>gh/5>p.>wx0.>b$