U dª/eØ ã@sDddlmZddlmZddlmZddlmZGdd„deƒZ dS) é)ÚClient)Údefinesé)ÚCursor)ÚInterfaceErrorcsxeZdZdZddejejejejf‡fdd„ Z dd„Z dd„Z d d „Z d d „Z d d„Zdd„Zdd„Zddd„Z‡ZS)Ú Connectiona) Creates new Connection for accessing ClickHouse database. Connection is just wrapper for handling multiple cursors (clients) and do not initiate actual connections to the ClickHouse server. See parameters description in :data:`~clickhouse_driver.connection.Connection`. Nc sNg|_||_||_||_||_||_||_||_d|_d|_ t t |ƒ  ¡dS)NF) ÚcursorsÚdsnÚuserÚpasswordÚhostÚportÚdatabaseÚconnection_kwargsÚ is_closedÚ_hostsÚsuperrÚ__init__)Úselfr r r r r rÚkwargs©Ú __class__©úF/tmp/pip-unpacked-wheel-mds_o03w/clickhouse_driver/dbapi/connection.pyrszConnection.__init__cCsd t|ƒ|j¡S)Nz,)ÚformatÚidr©rrrrÚ__repr__"sÿzConnection.__repr__cCs|S©NrrrrrÚ __enter__(szConnection.__enter__cCs | ¡dSr)Úclose)rÚexc_typeÚexc_valÚexc_tbrrrÚ__exit__+szConnection.__exit__cCs<|jdk rt |j¡St|jf|j|j|j|jdœ|j—ŽS)z1 :return: a new Client instance. N)r r r r) r rZfrom_urlr r r r rrrrrrÚ _make_client.s   þþzConnection._make_clientcCs|jD] }| ¡qd|_dS)aM Close the connection now. The connection will be unusable from this point forward; an :data:`~clickhouse_driver.dbapi.Error` (or subclass) exception will be raised if any operation is attempted with the connection. The same applies to all cursor objects trying to use the connection. TN)rr r)rÚcursorrrrr 9s  zConnection.closecCsdS©zB Do nothing since ClickHouse has no transactions. NrrrrrÚcommitFszConnection.commitcCsdSr'rrrrrÚrollbackLszConnection.rollbackcCsX|jrtdƒ‚| ¡}|jdkr,|jj|_n |j|j_|ps