(ph SrSSKJr SSKrSSKJrJr SSKJr SSK J r SSK J r SS KJr SS KJr SS KJr S S KJr \(aSSKJr "SS5r"SS\\ \ 5r"SS\\\ 5r"SS\5rg)z# CockroachDB-specific connections. ) annotationsN)Any TYPE_CHECKING)errors)Row) Connection) AdaptersMap)ConnectionInfo)AsyncConnection)adapters)PGconncp\rSrSr%S\S'S\S'\S Sj5r\S Sj5r\SSj5r SS jr S r g )_CrdbConnectionMixinzAdaptersMap | None _adaptersrpgconnc[U[[45(a URn[ UR S55$)zC Return `!True` if the server connected to `!conn` is CockroachDB. s crdb_version) isinstancer r rboolparameter_status)clsconns J/var/www/html/venv/lib/python3.13/site-packages/psycopg/crdb/connection.pyis_crdb_CrdbConnectionMixin.is_crdbs5 dZ9 : :;;DD))/:;;cdUR(d[[5UlUR$N)rr rselfs rr_CrdbConnectionMixin.adapters&s~~(2DN~~rc,[UR5$r )CrdbConnectionInforr!s rinfo_CrdbConnectionMixin.info.s!$++..rcpURUR5(a[R"S5eg)Nz/CockroachDB doesn't support prepared statements)rreNotSupportedErrorr!s r _check_tpc_CrdbConnectionMixin._check_tpc2s, << $ $%%&WX X %r)rN)rz/Connection[Any] | AsyncConnection[Any] | PGconnreturnr)r-r )r-r%)r-None) __name__ __module__ __qualname____firstlineno____annotations__ classmethodrpropertyrr&r+__static_attributes__rrrrsM!! N<<//Yrrc\rSrSrSrSrSrg)CrdbConnection7z5 Wrapper for a connection to a CockroachDB database. psycopg.crdbr7Nr/r0r1r2__doc__r6r7rrr9r97 Jrr9c\rSrSrSrSrSrg)AsyncCrdbConnection?z< Wrapper for an async connection to a CockroachDB database. r;r7Nr<r7rrr@r@?r>rr@cX\rSrSrSrSr\S Sj5r\S Sj5r\S Sj5r Sr g) r%GzN `~psycopg.ConnectionInfo` subclass to get info about a CockroachDB database. r;cg)N CockroachDBr7r!s rvendorCrdbConnectionInfo.vendorNsrcURS5nU(d[R"S5eURU5nUc[R"SU<35eU$)zv Return the CockroachDB server version connected. Return a number in the PostgreSQL format (e.g. 21.2.10 -> 210210). crdb_versionz''crdb_version' parameter status not setz)couldn't parse CockroachDB version from: )rr) InternalErrorparse_crdb_versionInterfaceError)r"sververs rserver_version!CrdbConnectionInfo.server_versionRsZ$$^4//"KL L%%d+ ;""%Nth#WX X rc[R"SU5nU(dg[URS55S-[URS55S--[URS55-$)Nz\bv(\d+)\.(\d+)\.(\d+)r i'rd)researchintgroup)r"rMms rrK%CrdbConnectionInfo.parse_crdb_versioncsW II/ 61771:&QWWQZ3)>>QWWQZPPrr7N)r-str)r-rV)rMrZr-z int | None) r/r0r1r2r=r5rFrOr4rKr6r7rrr%r%GsJ J  QQrr%)r= __future__rrTtypingrrrr)rowsr connectionr _adapters_mapr _connection_infor connection_asyncr _typesrpq.abcrrr9r@r%r7rrresq # %#'-.YY> ):c?  .0D "Q"Qr