U Wi@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@seZdZdZdeedddddddd d d d Zd,ddddd dddZddddZd dddZ d dddZ dddddZ dddddZ e dded dd!dd"d#Zd-dd&d'ddd(d)d*d+Zd$S).SyncPostgrestClientzPostgREST client.publicTschemaheaderstimeoutverifystrzDict[str, str]zUnion[int, float, Timeout]boolNone)base_urlrrrrreturncCs(tj||||||dtt|j|_dS)Nr)r __init__rrsession)selfr!rrrrr&\/home/afrizal/public_html/fastapi/venv/lib/python3.8/site-packages/postgrest/_sync/client.pyr#s zSyncPostgrestClient.__init__r)r!rrrr"cCst||||dddS)NT)r!rrrZfollow_redirectsZhttp2r)r%r!rrrr&r&r'create_session+sz"SyncPostgrestClient.create_session)r"cCs|SNr&r%r&r&r' __enter__;szSyncPostgrestClient.__enter__cCs |dSr))aclose)r%exc_typeexctbr&r&r'__exit__>szSyncPostgrestClient.__exit__cCs|jdS)z&Close the underlying HTTP connections.N)r$r,r*r&r&r'r,AszSyncPostgrestClient.aclosezSyncRequestBuilder[_TableT])tabler"cCstt|jd|S)zPerform a table operation. Args: table: The name of the table Returns: :class:`AsyncRequestBuilder` /)r_TableTr$r%r1r&r&r'from_EszSyncPostgrestClient.from_cCs ||SzAlias to :meth:`from_`.r5r4r&r&r'r1OszSyncPostgrestClient.tablez0.2.0z1.0.0zUse self.from_() insteadrcCs ||Sr6r7r4r&r&r' from_tableSszSyncPostgrestClient.from_tableNFdictzOptional[CountMethod]z SyncRPCFilterRequestBuilder[Any])funcparamscountheadgetr"cCsR|rdn |rdnd}|r*tdd|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. HEADGETPOSTZPreferzcount=z/rpc/)json)r rrr$r )r%r:r;r<r=r>methodrr&r&r'rpcXszSyncPostgrestClient.rpc)T)NFF)__name__ __module__ __qualname____doc__rrr#r(r+r0r,r5r1rrr8rDr&r&r&r'rs&  rN) __future__rtypingrrrrr deprecationrZhttpxr r r Z base_clientr constantsrrtypesrutilsrversionrZrequest_builderrrrr3rr&r&r&r's