o h,$@sBddlZddlZddlZdZddZGdddeZGddded ZGd d d eeZ Gd d d e Z Gddde Z GdddZ Gddde eZ Gddde eZGddde eZGddde ZGddde ZGddde eZGdddeZGd d!d!eZGd"d#d#eZGd$d%d%eZGd&d'd'eZdS)(N) PostgresErrorFatalPostgresErrorUnknownPostgresErrorInterfaceErrorInterfaceWarningPostgresLogMessageClientConfigurationErrorInternalClientErrorOutdatedSchemaCacheError ProtocolErrorUnsupportedClientFeatureErrorTargetServerAttributeNotMatchedUnsupportedServerFeatureErrorcCs|j}|dkp |dS)Nasyncpgzasyncpg.) __module__ startswith)clsmodnamerl/var/www/html/construction_image-detection-poc/venv/lib/python3.10/site-packages/asyncpg/exceptions/_base.py_is_asyncpg_classsrcseZdZiZiddddddddd d d d d ddddddddddddddddddd d!d"d#d$iZfd%d&Zed'd(ZZS))PostgresMessageMetaSseverityV severity_enCsqlstateMmessageDdetailHhintPpositionpinternal_positionqinternal_queryWcontexts schema_namet table_namec column_nameddata_type_namenconstraint_nameFserver_source_filenameLserver_source_lineRserver_source_functionc st||||}|j|jkr!|dkr!|jD]}t||dqt|r7tj|j}t ||r7t d || d}|durX|j |}|durStd ||j||j |<|S)NPostgresMessagez exception class redefinition: {}rz={} has duplicate SQLSTATE code, which isalready defined by {})super__new__r _field_mapvaluessetattrrsysmoduleshasattr RuntimeErrorformatget _message_map TypeError__name__) mclsnamebasesdctrfmodcodeexisting __class__rrr>2s*     zPostgresMessageMeta.__new__cCs|j|tSN)rHrGr)rKrQrrrget_message_class_for_sqlstateIsz2PostgresMessageMeta.get_message_class_for_sqlstate) rJr __qualname__rHr?r> classmethodrV __classcell__rrrSrrsT      rc@s:eZdZeddZeddZed ddZdd ZdS) r<cCs|d}t||S)Nr)rGtyperV)rfieldsrrrr_get_error_classPs z PostgresMessage._get_error_classcCs>d|i}t|j}|D]\}}||}|r|||<q |S)Nquery)rZr?itemsrG)rr[r]rN field_mapkvfieldrrr_get_error_dictUs  zPostgresMessage._get_error_dictNc Cs|||}||}|dd}|jdko t|o |ddk}|r.tj|j}|j}d}|jdvo6t|}|rJ|dd} | t d 7} | |d<|||fS) NrFeatureNotSupportedErrorr;RevalidateCachedQueryzQcached statement plan is invalid due to a database schema or configuration change)DuplicatePreparedStatementErrorInvalidSQLStatementNameErrorr#a NOTE: pgbouncer with pool_mode set to "transaction" or "statement" does not support prepared statements properly. You have two options: * if you are using pgbouncer for connection pooling to a single server, switch to the connection pool functionality provided by asyncpg, it is a much better option for this purpose; * if you have no option of avoiding the use of pgbouncer, then you can set statement_cache_size to 0 when creating the asyncpg connection object. ) rcr\rGrJrrBrCrInvalidCachedStatementErrortextwrapdedent) rr[r]rNexcclsris_icse exceptionsis_prepared_stmt_errorr#rrr_make_constructorcs(         z!PostgresMessage._make_constructorcCs6i}t|jD]}t||}|dur|||<q |SrU)rZr?r@getattr)selfrNrOvalrrras_dicts zPostgresMessage.as_dictrU)rJrrWrXr\rcrprtrrrrr<Ns    8r<) metaclassc@s&eZdZdZddZedddZdS)rz#Base class for all Postgres errors.cC:|jd}|jr|d|j7}|jr|d|j7}|SNrz DETAIL: {}z HINT: {}argsr!rFr#rrmsgrrr__str__ zPostgresError.__str__NcCs*|||\}}}||}|j||SrU)rp__dict__update)rr[r]rlrrNexrrrnews zPostgresError.newrU)rJrrW__doc__r|rXrrrrrrs  rc@eZdZdZdS)rz9A fatal error that should result in server disconnection.NrJrrWrrrrrrrc@r)rz'An error with an unknown SQLSTATE code.Nrrrrrrrrc@s$eZdZdddddZddZdS)InterfaceMessageNr!r#cCs||_||_dSrUr)rrr!r#rrr__init__s zInterfaceMessage.__init__cCrvrwrxrzrrrr|r}zInterfaceMessage.__str__)rJrrWrr|rrrrrs rc@s(eZdZdZdddddZddZdS)rz/An error caused by improper use of asyncpg API.NrcC tj|||dt||dSNr)rr Exceptionrrr{r!r#rrrrzInterfaceError.__init__cCst|||j|jd|jSr)rZr!r#with_traceback __traceback__rzrrrwith_msgszInterfaceError.with_msg)rJrrWrrrrrrrrs rc@r)rz1An error caused by improper client configuration.Nrrrrrrrrc@r) DataErrorz'An error caused by invalid query input.Nrrrrrrrrc@r)r z,Requested feature is unsupported by asyncpg.Nrrrrrr rr c@r)rz6Requested feature is unsupported by PostgreSQL server.Nrrrrrrrrc@s eZdZdZdddddZdS)rz3A warning caused by an improper use of asyncpg API.NrcCrr)rr UserWarningrrrrrrzInterfaceWarning.__init__)rJrrWrrrrrrrsrc@r)r z/All unexpected errors not classified otherwise.Nrrrrrr rr c@r)r zBUnexpected condition in the handling of PostgreSQL protocol input.Nrrrrrr rr c@r)r zECould not find a host that satisfies the target attribute requirementNrrrrrr rr cs*eZdZdZddddfdd ZZS)r zEA value decoding error caused by a schema change before row fetching.N)schema data_typer%cs"t|||_||_||_dSrU)r=rr-r3r%)rrr{rrr%rSrrrs  z!OutdatedSchemaCacheError.__init__)rJrrWrrrYrrrSrr sr c@s.eZdZdZddZddZed ddZdS) rz+A base class for non-error server messages.cCsdt|j|jS)Nz{}: {})rFrZrJr)rrrrrr|szPostgresLogMessage.__str__cCstdt|j)Nzinstances of {} are immutable)rIrFrZrJ)rrrLrsrrr __setattr__szPostgresLogMessage.__setattr__NcCs~|||\}}}|turt}|tur(|dp|d}|r(|dkr(tj}t|tt fr4||}n|}|j ||S)NrrWARNING) rprrrGupperrPostgresWarning issubclass BaseExceptionWarningr~r)rr[r]rl message_textrNrr{rrrrs  zPostgresLogMessage.newrU)rJrrWrr|rrXrrrrrrs r)rrBrj__all__rrZrr<rrrrrr ValueErrorrrr rrrr r r r rrrrrs,4W