o /h@sddlmZddlmZmZmZmZmZddlm Z ddl m Z m Z m Z ddlmZddlmZmZddlmZdd lmZdd lmZd d lmZmZeeefZGd ddeZdS)) annotations)AnyDictOptionalUnioncast) deprecated)Headers QueryParamsTimeout)BasePostgrestClient) DEFAULT_POSTGREST_CLIENT_HEADERS DEFAULT_POSTGREST_CLIENT_TIMEOUT) CountMethod SyncClient) __version__)SyncRequestBuilderSyncRPCFilterRequestBuilderc@seZdZdZdeeddd3ddZ d4d5ddZd6ddZd7ddZ d7ddZ d8ddZ d8dd Z e d!d"ed#d9d%d&Z ' ( (d:d;d1d2Zd'S)<SyncPostgrestClientzPostgREST client.publicTschemaheaderstimeoutverifybase_urlstrrrDict[str, str]rUnion[int, float, Timeout]rboolreturnNonecCs(tj||||||dtt|j|_dS)Nr)r __init__rrsession)selfrrrrrr(O/var/www/html/govbot/env/lib/python3.10/site-packages/postgrest/_sync/client.pyr%s zSyncPostgrestClient.__init__rcCst||||dddS)NT)rrrrfollow_redirectshttp2r)r'rrrrr(r(r)create_session+sz"SyncPostgrestClient.create_sessioncCs|SNr(r'r(r(r) __enter__;szSyncPostgrestClient.__enter__cCs |dSr-)aclose)r'exc_typeexctbr(r(r)__exit__>s zSyncPostgrestClient.__exit__cCs|jdS)z&Close the underlying HTTP connections.N)r&r0r.r(r(r)r0AszSyncPostgrestClient.aclosetableSyncRequestBuilder[_TableT]cCstt|jd|S)zPerform a table operation. Args: table: The name of the table Returns: :class:`AsyncRequestBuilder` /)r_TableTr&r'r5r(r(r)from_EszSyncPostgrestClient.from_cC ||SzAlias to :meth:`from_`.r:r9r(r(r)r5Os zSyncPostgrestClient.tablez0.2.0z1.0.0zUse self.from_() insteadrcCr;r<r=r9r(r(r) from_tableSs zSyncPostgrestClient.from_tableNFfuncparamsdictcountOptional[CountMethod]headget SyncRPCFilterRequestBuilder[Any]cCsR|rdn|rdnd}|rtdd|int}tt|jd|||t|dS)aPerform a stored procedure call. Args: func: The name of the remote procedure to run. params: The parameters to be passed to the remote procedure. count: The method to use to get the count of rows returned. head: When set to `true`, `data` will not be returned. Useful if you only need the count. get: When set to `true`, the function will be called with read-only access mode. Returns: :class:`AsyncRPCFilterRequestBuilder` Example: .. code-block:: python await client.rpc("foobar", {"arg": "value"}).execute() .. versionchanged:: 0.10.9 This method now returns a :class:`AsyncRPCFilterRequestBuilder`. .. versionchanged:: 0.10.2 This method now returns a :class:`AsyncFilterRequestBuilder` which allows you to filter on the RPC's resultset. HEADGETPOSTPreferzcount=z/rpc/)json)r rrr&r )r'r?r@rBrDrEmethodrr(r(r)rpcXs zSyncPostgrestClient.rpc) rrrrrr rr!rr"r#r$)T) rrrr rr!rr"r#r)r#r)r#r$)r5rr#r6)r5rr#r)NFF) r?rr@rArBrCrDr"rEr"r#rF)__name__ __module__ __qualname____doc__rrr%r,r/r4r0r:r5rrr>rMr(r(r(r)rs(      rN) __future__rtypingrrrrr deprecationrhttpxr r r base_clientr constantsrrtypesrutilsrversionrrequest_builderrrrr8rr(r(r(r)s