ó (È\c@sŒdZddlmZmZmZddlZddlmZejeƒde fd„ƒYƒZ ejeƒde fd „ƒYƒZ dS( s2Implement the Base class for Driver and Connectioniÿÿÿÿ(tABCMetatabstractmethodtabstractpropertyNi(tDriverRegistryt BaseDrivercBsYeZdZed„ƒZed„ƒZed„ƒZed„ƒZed„ƒZ RS(s§ class BaseDriver(object): This is a base class for different server types. Inherit this class to implement different type of database driver implementation. (For PostgreSQL/EDB Postgres Advanced Server, we will be using psycopg2) Abstract Properties: -------- ---------- * Version (string): Current version string for the database server * libpq_version (string): Current version string for the used libpq library Abstract Methods: -------- ------- * get_connection(*args, **kwargs) - It should return a Connection class object, which may/may not be connected to the database server. * release_connection(*args, **kwargs) - Implement the connection release logic * gc() - Implement this function to release the connections assigned in the session, which has not been pinged from more than the idle timeout configuration. cCsdS(N((tcls((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pytVersion5scCsdS(N((R((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pyt libpq_version9scOsdS(N((tselftargstkwargs((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pytget_connection=scOsdS(N((RR R ((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pytrelease_connectionAscCsdS(N((R((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pytgcEs( t__name__t __module__t__doc__RRRRR R R (((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pyRs  tBaseConnectioncBsyeZdZdZdZdZdZdZdZdZ dZ e d„ƒZ e ded „ƒZe ded „ƒZe ded „ƒZe ded „ƒZe ded „ƒZe ded„ƒZe d„ƒZe d„ƒZe d„ƒZe d„ƒZe d„ƒZe d„ƒZe d„ƒZe eed„ƒZe d„ƒZe d„ƒZe dd„ƒZ RS(sß class BaseConnection(object) It is a base class for database connection. A different connection drive must implement this to expose abstract methods for this server. General idea is to create a wrapper around the actual driver implementation. It will be instantiated by the driver factory basically. And, they should not be instantiated directly. Abstract Methods: -------- ------- * connect(**kwargs) - Define this method to connect the server using that particular driver implementation. * execute_scalar(query, params, formatted_exception_msg) - Implement this method to execute the given query and returns single datum result. * execute_async(query, params, formatted_exception_msg) - Implement this method to execute the given query asynchronously and returns result. * execute_void(query, params, formatted_exception_msg) - Implement this method to execute the given query with no result. * execute_2darray(query, params, formatted_exception_msg) - Implement this method to execute the given query and returns the result as a 2 dimensional array. * execute_dict(query, params, formatted_exception_msg) - Implement this method to execute the given query and returns the result as an array of dict (column name -> value) format. * def async_fetchmany_2darray(records=-1, formatted_exception_msg=False): - Implement this method to retrieve result of asynchronous connection and polling with no_result flag set to True. This returns the result as a 2 dimensional array. If records is -1 then fetchmany will behave as fetchall. * connected() - Implement this method to get the status of the connection. It should return True for connected, otherwise False * reset() - Implement this method to reconnect the database server (if possible) * transaction_status() - Implement this method to get the transaction status for this connection. Range of return values different for each driver type. * ping() - Implement this method to ping the server. There are times, a connection has been lost, but - the connection driver does not know about it. This can be helpful to figure out the actual reason for query failure. * _release() - Implement this method to release the connection object. This should not be directly called using the connection object itself. NOTE: Please use BaseDriver.release_connection(...) for releasing the connection object for better memory management, and connection pool management. * _wait(conn) - Implement this method to wait for asynchronous connection to finish the execution, hence - it must be a blocking call. * _wait_timeout(conn, time) - Implement this method to wait for asynchronous connection with timeout. This must be a non blocking call. * poll(formatted_exception_msg, no_result) - Implement this method to poll the data of query running on asynchronous connection. * cancel_transaction(conn_id, did=None) - Implement this method to cancel the running transaction. * messages() - Implement this method to return the list of the messages/notices from the database server. * rows_affected() - Implement this method to get the rows affected by the last command executed on the server. iiiiigš™™™™™É?i †cKsdS(N((RR ((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pytconnect¯scCsdS(N((Rtquerytparamstformatted_exception_msg((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pytexecute_scalar³scCsdS(N((RRRR((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pyt execute_async¸scCsdS(N((RRRR((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pyt execute_void½scCsdS(N((RRRR((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pytexecute_2darrayÂscCsdS(N((RRRR((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pyt execute_dictÇsiÿÿÿÿcCsdS(N((RtrecordsR((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pytasync_fetchmany_2darrayÌscCsdS(N((R((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pyt connectedÑscCsdS(N((R((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pytresetÕscCsdS(N((R((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pyttransaction_statusÙscCsdS(N((R((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pytpingÝscCsdS(N((R((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pyt_releaseáscCsdS(N((Rtconn((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pyt_waitåscCsdS(N((RR"ttime((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pyt _wait_timeoutéscCsdS(N((RRt no_result((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pytpollíscCsdS(N((R((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pytstatus_messageñscCsdS(N((R((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pyt rows_affectedõscCsdS(N((Rtconn_idtdid((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pytcancel_transactionùsN(!RRRtASYNC_OKtASYNC_READ_TIMEOUTtASYNC_WRITE_TIMEOUTtASYNC_NOT_CONNECTEDtASYNC_EXECUTION_ABORTEDt ASYNC_TIMEOUTtASYNC_WAIT_TIMEOUTtASYNC_NOTICE_MAXLENGTHRRtNonetFalseRtTrueRRRRRRRRR R!R#R%R'R(R)R,(((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pyRJsRZ( RtabcRRRtsixtregistryRt add_metaclasstobjectRR(((s8/usr/share/pgadmin4/web/pgadmin/utils/driver/abstract.pyt s 6