s/Uc@sdZddlZddlmZddlmZmZmZmZmZm Z m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-ddl.m/Z/ddl0Z0ddl1Z1ddl2m3Z3ddl4m5Z5dd l6m7Z7dd l8m9Z9m:Z:dd l;m<Z<m=Z=dd l>m?Z?dd l@mAZAmBZBmCZCmDZDmEZEmFZFmGZGddlHmIZIddlJmKZKddlLmMZMddlNmOZOddlPZPddlQmRZRyddlSmTZTWneUk rsnXedZVdejWfdYZXeXZYeEreZZ[ndZ\dZ]eAdZ^eAdeAdfZ_dZ`ejdddZaeajbdeYZceOeajdZeejjfZfdddZgdegdZhdZid Zjd!Zkd"Zld#Zmd$ZnejjojbdeYZpejjqjbdeYZrd%Zsd&Ztd'Zud(Zvd)Zwd*Zxd+Zyd,Zzd-Z{d.Z|d/Z}d0Z~eBr/d1Zn d2Zd3Zd4ZeAd5ZeAd6Zd7Ze"dZeAd6Zd8Zd9Zd:fd;YZeBreje_DneAd<ZeAd=ZeAd>ZeAd?ZeAd@ZeAdAZeAdBZeAdCZeAdDZeAdEZeAdFZeAdGZeAdHZeAdIZeAdJZeAdKZeAdLZeAdMZeAdNZeAdOZeAdPZeAdQZeAdBZeAdOZeAd>ZeAdRZeAdCZeAdSZeAdDZee"dTZee"dTZee"dTZee"dTZeAd>ZeAdQZeAd>ZeAdDZeAdUZeAdCZeAdOZeAdQZeAdRZeAdVZeAdWZeAdXZeAdYZeAd=ZeAdZZeAdAZeAdBZd[Zeee?eeGd\eZeGd]egd^Zd_efd`YZdaefdbYZidcdd6dedf6dgdh6didj6Ziedk6edl6dmdn6dodp6dqdr6dsdt6dudv6dwdx6dydz6d{d|6d}d~6dd6dd6dd6dd6dd6dd6dd6dd6dd6dd6dd6dd6dd6dd6dd6dd6dd6dd6dd6ZdZdZdZdZdZdZdS(sMathieu FenniakiN(t timedeltai(*tIntervaltmin_int2tmax_int2tmin_int4tmax_int4tmin_int8tmax_int8tByteatNotSupportedErrortProgrammingErrort InternalErrortIntegrityErrortOperationalErrort DatabaseErrortInterfaceErrortErrortArrayContentNotHomogenousErrortArrayContentEmptyErrort!ArrayDimensionsNotConsistentErrortArrayContentNotSupportedErrortWarningti_unpackt ii_unpackt iii_unpackth_packtd_unpacktq_unpacktd_packtf_unpacktq_packti_packth_unpackt dii_unpackt qii_unpackt ci_unpackt bh_unpackt ihihih_unpackt cccc_unpacktii_packtiii_packtdii_packtqii_pack(twarn(tpack(tmd5(tDecimal(tdequet defaultdict(tcounttislice(tmap(tbtPY2t integer_typestnexttPRE_26t text_typetu(texc_info(tUUID(tdeepcopy(ttimegm(t LooseVersion(tloadsitUTCcBs#eZdZdZdZRS(cCstS(N(tZERO(tselftdt((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt utcoffsetFscCsdS(NRA((RCRD((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyttznameIscCstS(N(RB(RCRD((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pytdstLs(t__name__t __module__RERFRG(((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRADs  t tALTERtCREATEc sGd}d}d}d}d}t}t}gg} tdtd} |} d} xt|D]\} }| dt|kr|| d}nd}| |krY|dkr| j|| dkr|} qV|} q|d kr| j||} q|d kr3|d kr3| jt| q|d kr[|d kr[| jdq|dkr|d kr|} jdq|dkr|dkr|dkr|} jdq|d!krI|dkrId}|rt}| j|qV|dkrt}qV|dkr:|} | jt| qVt dq| j|n| |kr|dkr| j||rt}q|dkrt}q|} q|d"kr |dkr |rt}| j|q|dkrt}qt d|dq| j|n| |kr|d krI|} | j|q|d#kr|dkr|r}t}| j|q|dkrt}qt d|dq| j|nJ| |krc|dkr| dkr| j||} q|d$krS|dkrS|r't}| j|q`|dkr<t}q`t d|dq| j|n| |kr|dkr,dc|7<|dks|j r|dkr|} y?j ddd}| jdt |dd=Wq)t k r%| jdt tq)Xqq|dkr| dkr|dkr|} y?j ddd}| jdt |dd=Wqt k r| jdt tqXq|dkrqdc|7ost'tEt"tqmarkt?tnumerict:RMtnamedttpyformatt%t(tformattss*Only %s and %% are supported in the query.s'%s:' not supported in a quoted string within the query strings\s;' not supported in a quoted string within the query string.it_t)s()cSs|S(N((tvals((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt make_argsscstfdDS(Nc3s|]}|VqdS(N((t.0tp(Ra(sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pys s(ttuple(Ra(t placeholders(RasC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRbs(sformatRZ(RZsformat(RZsformat(RZsformat(snumericsqmarksformat(tFalseR3R1tNonet enumeratetlentappendR7tTrueRtisalnumtindexRNt ValueErrortjoin(tstyletquerytOUTSIDEt INSIDE_SQt INSIDE_QIt INSIDE_ESt INSIDE_PNtin_quote_escapetin_param_escapet output_queryt param_idxtstatetprev_ctitctnext_ctpidxRb((RfsC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pytconvert_paramstyle\s          $                        %  '   $      ittzinfoii?cCsyt||d}yttd|SWnJtk rt|tkrNtjjS|tkrdtjjSt dnXdS(Nit microsecondsi( RtEPOCHRt OverflowErrortINFINITY_MICROSECONDStdatetimetmaxtMINUS_INFINITY_MICROSECONDStminR;(tdatatoffsettlengthtmicros((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyttimestamp_recv_integers     cCsttt||dS(Ni(tutcfromtimestampt EPOCH_SECONDSR(RRR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyttimestamp_recv_floatscCsg|tjjkrt}nB|tjjkr6t}n'tt|jtd|j }t |S(Ng.A( RRRRRtintR>t timetupleRt microsecondR(tvR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyttimestamp_send_integer!s  $cCs"tt|j|jdtS(Ng.A(RR>RRR(R((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyttimestamp_send_float-scCst|jtjddS(NR(Rt astimezonetutctreplaceRh(R((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyttimestamptz_send_integer1scCst|jtjddS(NR(RRRRRh(R((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyttimestamptz_send_float7scCsmt||d}yttd|SWn>tk rh|tkrHtS|tkrXtStdnXdS(NiRi( RtEPOCH_TZRRRtDATETIME_MAX_TZRtDATETIME_MIN_TZR;(RRRR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyttimestamptz_recv_integerDs   cCst|||jdtS(NR(RRR(RRR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyttimestamptz_recv_floatQscCsr|j}y|t|jd7}Wntk r7nXy |j}Wntk r^d}nXt||j|S(Ng.Ai(RRtsecondstAttributeErrortmonthsR*tdays(RRR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pytinterval_send_integerUs     cCsp|jdd}y||j7}Wntk r5nXy |j}Wntk r\d}nXt||j|S(Ng@@i(RRRRR)R(RRR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pytinterval_send_floatds    cCs`t||\}}}|dkrLt|d\}}tj|||St|||SdS(Nig.A(R"tdivmodRRR(RRRRRRRR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pytinterval_recv_integerss  cCsnt||\}}}|dkrLt|d\}}tj|||Stt|dd||SdS(Nig.Ai(R!RRRRR(RRRRRRtsecsR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pytinterval_recv_float|s  cCst||dS(Ni(R(RRR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt int8_recvscCst||dS(Ni(R (RRR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt int2_recvscCst||dS(Ni(R(RRR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt int4_recvscCst||dS(Ni(R(RRR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt float4_recvscCst||dS(Ni(R(RRR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt float8_recvscCs|S(N((R((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt bytea_sendscCst||||!S(N(R(RRR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt bytea_recvscCs||||!S(N((RRR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRscCs|jS(N(tbytes(R((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt uuid_sendscCstd||||!S(NR(R<(RRR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt uuid_recvsstcCs|r tStS(N(tTRUEtFALSE(R((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt bool_sendscCstS(N(tNULL(R((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt null_sendscCst||||!S(N(R(RRR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pytint_instCursorcBseZdZdZedZedZedZdZdddZ dZ dZ dd Z d Zd Zd Zd ZddZdZRS(s<A cursor object is returned by the :meth:`~Connection.cursor` method of a connection. It has the following attributes and methods: .. attribute:: arraysize This read/write attribute specifies the number of rows to fetch at a time with :meth:`fetchmany`. It defaults to 1. .. attribute:: connection This read-only attribute contains a reference to the connection object (an instance of :class:`Connection`) on which the cursor was created. This attribute is part of a DBAPI 2.0 extension. Accessing this attribute will generate the following warning: ``DB-API extension cursor.connection used``. .. attribute:: rowcount This read-only attribute contains the number of rows that the last ``execute()`` or ``executemany()`` method produced (for query statements like ``SELECT``) or affected (for modification statements like ``UPDATE``). The value is -1 if: - No ``execute()`` or ``executemany()`` method has been performed yet on the cursor. - There was no rowcount associated with the last ``execute()``. - At least one of the statements executed as part of an ``executemany()`` had no row count associated with it. - Using a ``SELECT`` query statement on PostgreSQL server older than version 9. - Using a ``COPY`` query statement on PostgreSQL server version 8.1 or older. This attribute is part of the `DBAPI 2.0 specification `_. .. attribute:: description This read-only attribute is a sequence of 7-item sequences. Each value contains information describing one result column. The 7 items returned for each column are (name, type_code, display_size, internal_size, precision, scale, null_ok). Only the first two values are provided by the current implementation. This attribute is part of the `DBAPI 2.0 specification `_. cCsF||_d|_d|_d|_t|_d|_t|_ dS(Nii( t_ct arraysizeRhtpst _row_countR/t _cached_rowst portal_nameRgtportal_suspended(RCt connection((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt__init__s      cCstddd|jS(Ns'DB-API extension cursor.connection usedt stackleveli(R+R(RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRscCs|jS(N(R(RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pytrowcountscCs |jS(N(t_getDescription(RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRP sc Cs{|jdkrdS|jd}t|dkr6dSg}x8|D]0}|j|d|ddddddfqCW|S(Ntrow_descitnamettype_oid(RRhRjRk(RCRtcolumnstcol((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyR s  (cCszyf|jjj||_|jj rR|jj rR|jj|ddn|jj|||Wn]tk r|jdkrt dq|jj dkrt dqt dnXWd|jjj XdS(seExecutes a database operation. Parameters may be provided as a sequence, or as a mapping, depending upon the value of :data:`pg8000.paramstyle`. This method is part of the `DBAPI 2.0 specification `_. :param operation: The SQL statement to execute. :param args: If :data:`paramstyle` is ``qmark``, ``numeric``, or ``format``, this argument should be an array of parameters to bind into the statement. If :data:`paramstyle` is ``named``, the argument should be a dict mapping of parameters. If the :data:`paramstyle` is ``pyformat``, the argument value may be either an array or a mapping. :param stream: This is a pg8000 extension for use with the PostgreSQL `COPY `_ command. For a COPY FROM the parameter must be a readable file-like object, and for COPY TO it must be writable. .. versionadded:: 1.9.11 sbegin transactions Cursor closedsconnection is closediN( Rt_locktacquiretstreamtin_transactiont autocommittexecuteRhRRt_sockR;trelease(RCt operationtargsR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRs  cCs\g}x.|D]&}|j|||j|jq Wd|krIdn t||_dS(s1Prepare a database operation, and then execute it against all parameter sequences or mappings provided. This method is part of the `DBAPI 2.0 specification `_. :param operation: The SQL statement to execute :param parameter_sets: A sequence of parameters to execute the statement with. The values in the sequence should be sequences or mappings of parameters, the same as the args argument of the :meth:`execute` method. iN(RRkRtsum(RCRt param_setst rowcountst parameters((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt executemanyHs  cCs_yt|SWnJtk r"dStk r>tdntk rZtdnXdS(s Fetch the next row of a query result set. This method is part of the `DBAPI 2.0 specification `_. :returns: A row as a sequence of field values, or ``None`` if no more rows are available. s#attempting to use unexecuted cursorN(R7t StopIterationRht TypeErrorR R(RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pytfetchone]s    cCsPy,tt||dkr!|jn|SWntk rKtdnXdS(sFetches the next set of rows of a query result. This method is part of the `DBAPI 2.0 specification `_. :param size: The number of rows to fetch when called. If not provided, the :attr:`arraysize` attribute value is used instead. :returns: A sequence, each entry of which is a sequence of field values making up a row. If no more rows are available, an empty sequence will be returned. s#attempting to use unexecuted cursorN(ReR2RhRRR (RCtnum((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt fetchmanyps ) cCs2yt|SWntk r-tdnXdS(s$Fetches all remaining rows of a query result. This method is part of the `DBAPI 2.0 specification `_. :returns: A sequence, each entry of which is a sequence of field values making up a row. s#attempting to use unexecuted cursorN(ReRR (RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pytfetchalls  cCs d|_dS(sCloses the cursor. This method is part of the `DBAPI 2.0 specification `_. N(RhR(RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pytclosescCs|S(soA cursor object is iterable to retrieve the rows from a query. This is a DBAPI 2.0 extension. ((RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt__iter__scCsdS(sThis method is part of the `DBAPI 2.0 specification `_, however, it is not implemented by pg8000. N((RCtsizes((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt setinputsizesscCsdS(sThis method is part of the `DBAPI 2.0 specification `_, however, it is not implemented by pg8000. N((RCtsizetcolumn((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt setoutputsizescCs*zy!|jjj|jjSWntk r|jr|jj||jjt |jj |jj ||js|jj |qny|jjSWqtk r |j dkrtdq t|j ddkrtdq tqXnXWd|jjjXdS(NsA query hasn't been issued.Ris no result set(RRRRtpopleftt IndexErrorRt send_EXECUTEt_writetSYNC_MSGt_flushthandle_messagest close_portalRRhR RjRR(RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt__next__s*     N(RHRIt__doc__RtpropertyRRt descriptionRRhRRRRRRRRRR(((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRs 3  ,        tNtRtStKtZtTRRtDtCt1t2t3R^tntttARtdtGtHtBtPRdtXitMtqtWtFtLtIcCstd|jtDS(Ncss&|]}|dd!|dfVqdS(iiN((RcR^((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pys s(tdicttsplitt NULL_BYTE(R((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pytdata_into_dictss[] 'us{}itMulticastDelegatecBs5eZdZdZdZdZdZRS(cCs g|_dS(N(t delegates(RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRscCs|j||S(N(tadd(RCtdelegate((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt__iadd__s cCs|jj|dS(N(RRk(RCR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRscCs|jj||S(N(Rtremove(RCR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt__isub__!scOs%x|jD]}|||q WdS(N(R(RCRtkwargsR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt__call__%s(RHRIRRRRR(((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRs     t ConnectioncBseZdZedZedZedZedZedZedZ edZ edZ ed Z d Z ee Zd Zd Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!dZ"dZ#dZ$d Z%d!Z&d"Z'd#Z(d$Z)d%Z*d&Z+d'Z,d(Z-d)Z.d*Z/d+Z0d,Z1d-Z2d.Z3d/Z4d0Z5e6d1Z7e6d2Z8d3Z9RS(4s2 A connection object is returned by the :func:`pg8000.connect` function. It represents a single physical connection to a PostgreSQL database. .. attribute:: Connection.notifies A list of server-side notifications received by this database connection (via the LISTEN/NOTIFY PostgreSQL commands). Each list element is a two-element tuple containing the PostgreSQL backend PID that issued the notify, and the notification name. PostgreSQL will only send notifications to a client between transactions. The contents of this property are generally only populated after a commit or rollback of the current transaction. This list can be modified by a client application to clean out notifications as they are handled. However, inspecting or modifying this collection should only be done while holding the :attr:`notifies_lock` lock in order to guarantee thread-safety. This attribute is not part of the DBAPI standard; it is a pg8000 extension. .. versionadded:: 1.07 .. attribute:: Connection.notifies_lock A :class:`threading.Lock` object that should be held to read or modify the contents of the :attr:`notifies` list. This attribute is not part of the DBAPI standard; it is a pg8000 extension. .. versionadded:: 1.07 .. attribute:: Connection.autocommit Following the DB-API specification, autocommit is off by default. It can be turned on by setting this boolean pg8000-specific autocommit property to True. .. versionadded:: 1.9 .. exception:: Connection.Error Connection.Warning Connection.InterfaceError Connection.DatabaseError Connection.InternalError Connection.OperationalError Connection.ProgrammingError Connection.IntegrityError Connection.DataError Connection.NotSupportedError All of the standard database exception types are accessible via connection instances. This is a DBAPI 2.0 extension. Accessing any of these attributes will generate the warning ``DB-API extension connection.DatabaseError used``. cCs |jtS(N(t _getErrorR(RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRPiscCs |jtS(N(R!R(RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRPjscCs |jtS(N(R!R(RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRPkscCs |jtS(N(R!R(RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRPlscCs |jtS(N(R!R (RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRPmscCs |jtS(N(R!R (RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRPnscCs |jtS(N(R!R (RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRPoscCs |jtS(N(R!R (RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRPpscCs |jtS(N(R!R (RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRPrsidcCstd|jdd|S(Ns#DB-API extension connection.%s usedRi(R+RH(RCterror((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyR!|sc!s d_tdtdtdtdtdtdtdf_tj_|dkrytjd _ Wqt k rytjd _ Wqt k rt d qXqXn |_ t j t rj jd_ n|_t_d_td _d _d _y|dkrv|dk rvtjtjtj_nT|dk rttdst dntjtjtj_n td|dkr|dk rjj||fn|dk rjj|n|rzy~jjddl }jj!t"ddjj#d} | tdkr|j$j_n t dWnt%k rt dnXWdjj&Xnjj'dd_(Wn7tj)k r(jj*t dt+dnXj(j,_-j(j._/t0r_j(j1_2nj(j3_2d_4t5_6t5_7t5_8j7j97_7fd} fd} fd} fd} t:t;t<t=t>dt>d it?d!6fd"}fd#}fd$}t@rfd%d&}fd'}n'fd(d)}fd*}fd+}fd,}fd-}fd.}tfd/i&tA|fd06tAtBfd16tAfd26tAtCfd36tAtDfd46tE|fd56tAtFfd66tAfd76tEtGfd86tEtGfd96tE|fd:6tAtHfd;6tAtIfd<6tAfd=6tEfd>6tA|fd?6tA|fd@6tA|fdA6tA|fdB6tA|fdC6tA|fdD6tA|fdE6tA|fdF6tA|fdG6tA|fdH6tAfdI6tAfdJ6tE|fdK6tE|fdL6tAtJfdM6tAtKfdN6tAtLfdO6tE|fdP6tA|fdQ6tE|fdR6tAfdS6tAtMfdT6tE|fdU6_Ni dtAtOftPd6d0tAtQftR6d=tE| ftS6d<tAtTftU6d=tE| ftV6dKtE| ftWjX6dLtE| ftWjY6dMtAtZfdM6dNtAt[fdN6dOtAt\ftWj]6dOtAt\ft^6dRtE|ft?6dTtAt_ft`6_aijbtWjW6jctd6jcte6_ft@rLd1tAtgfjath`_. (R(RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRxscCs<z'|jj|j|jddWd|jjXdS(sCommits the current database transaction. This function is part of the `DBAPI 2.0 specification `_. tcommitN(RRRRRhR(RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRs cCs<z'|jj|j|jddWd|jjXdS(sRolls back the current database transaction. This function is part of the `DBAPI 2.0 specification `_. trollbackN(RRRRRhR(RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRs cCs~y>|jt|j|jj|jjd|_Wn9tk r]tdnt k rytdnXdS(Nsconnection is closed( Rt TERMINATE_MSGRRRRRhRRRo(RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRs       cCs0z|jj|jWd|jjXdS(sCloses the database connection. This function is part of the `DBAPI 2.0 specification `_. N(RRRR(RC((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRs cCs|jjstt|d}|dkr4nT|dkr|jdkr^tdn|jt|jj dt |j n|dkrEt dj t|d}|jdkrtdnt d tt|jj d|jjj d|jj d}|jt|t |j nC|dkrntdt|dntdt|ddS(NiisGserver requesting password authentication, but no password was providedRiRYisKserver requesting MD5 password authentication, but no password was providedR-iiiii sAuthentication method s not supported by pg8000.s not recognized by pg8000.(iiiiii (RRRRR{RhRt _send_messagetPASSWORDR0RRR4RpR&R-Rxt hexdigestRN(RCRRt auth_codetsalttpwd((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRs8       %      cCs|tk|_dS(N(tIDLER(RCRR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRscCs ||_dS(N(R(RCRR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRscCs)|jdkr|jdS|jdSdS(NiZi(RRhR(RCtvalue((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRs cCsg}x|D]}t|}y|j|j|Wq tk ry|j|j||Wqtk rtdttddqXq Xq W|S(Nstype isnot mapped to pg type(RRkRRyRR RNR;(RCRRtparamsRttyp((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt make_paramss    c Cst|d}d}xt|D]}|||jt|!}|t|d7}ttdt||}||d <|d 7}|jd j ||j |d\|d <|d(sRtpg8000_statement_RRcss|]}|dVqdS(iN((RcRO((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pys 3st param_funcscss|]}|dVqdS(iN((RcRO((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pys 7siisconnection is closedc3s$|]}j|ddVqdS(RiN(RF(Rctf(RC(sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pys _scss|]}|dVqdS(RN((RcR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pys ast input_funcst!thtbind_1tbind_2tpg8000_portal_sWith autocommit on, it's not possible to retrieve more rows than the pg8000 cache size, as the portal is closed when the transaction is closed.((0RhRYRR}RyRRReRRNR~R0RRR?R1RRjRRtPARSEtDESCRIBEt STATEMENTRRRRRRR;RR,RtclearRRRtportal_name_binR t_row_cache_size_bint execute_msgRJRtBINDRRRR(RCRRRaRtcacheRRbRRtkeyRtstatement_nametstatement_name_bint param_fcsRRtfct send_funct output_fctretvalR((RCsC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRs         )   ."             cCsyH|j||jtt|d|j||jtWnbtk rttddkrtdqtdntk rtdnXdS(Niiswrite to closed filesconnection is closed( RRRjt FLUSH_MSGRoRNR;RR(RCRR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRs    cCs t|_|jt|jdS(N(RgRRtEXECUTER(RCR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRs cCsdS(N((RCtmsgR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRscCs|d jt}|d}||jkrit|d}|jdkrW||_qi|j|7_n|tkrx)|jD]}|j|djqWndS(NiiR(Rt BINARY_SPACERsRRt DDL_COMMANDSR}R(RCRRRRtcommandt row_counttk((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRs   cCsd}g}xq|jdD]b}t||d}|d7}|dkrY|jdq|j||||||7}qW|jj|dS(NiRiii(RRRkRhR(RCRRtdata_idxtrowRtvlen((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRs  cCsd}|_ySxL|tkr^t|jd\}}|j||j|d|qWWn|jnX|jdk r|jndS(Nii(RhR"RR#RRR(RCRRR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRs ) cCs?|jtt|j|jt|j|j|dS(N(RtCLOSEtPORTALRRRRR(RCR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRs  cCst|}|j|dS(N(RR(RCRRR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRs cCs|jt}|| ||dd!}}|tdkrj|jdj}tj|||_n$|tdkr|tdkr%dtt f|j dt arr_transR0(RBR;R~Rtar(RR(sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyR>|s    (tarray_find_first_elementRhRRt issubclassR6RlR:RRRgRRRRRRRRRRtpg_array_typesRyRNR ( RCRt first_elementtint2_oktint4_oktint8_okRt array_oidRR>((RRRsC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyR+s\           cCs |||fS(s)Create a Transaction IDs (only global_transaction_id is used in pg) format_id and branch_qualifier are not used in postgres global_transaction_id may be any string identifier supported by postgres returns a tuple (format_id, global_transaction_id, branch_qualifier)((RCt format_idtglobal_transaction_idtbranch_qualifier((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pytxidscCs/||_|jr+|j|jddndS(s.Begins a TPC transaction with the given transaction ID xid. This method should be called outside of a transaction (i.e. nothing may have executed since the last .commit() or .rollback()). Furthermore, it is an error to call .commit() or .rollback() within the TPC transaction. A ProgrammingError is raised, if the application calls .commit() or .rollback() during an active TPC transaction. This function is part of the `DBAPI 2.0 specification `_. sbegin transactionN(R|RRRRh(RCRL((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt tpc_begins  cCs.d|jdf}|j|j|ddS(sPerforms the first phase of a transaction started with .tpc_begin(). A ProgrammingError is be raised if this method is called outside of a TPC transaction. After calling .tpc_prepare(), no statements can be executed until .tpc_commit() or .tpc_rollback() have been called. This function is part of the `DBAPI 2.0 specification `_. sPREPARE TRANSACTION '%s';iN(R|RRRh(RCR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt tpc_prepares cCs|dkr|j}n|dkr3tdnzV|j}t|_||jkr~|j|jd|dfdn |jWd||_Xd|_dS(s%When called with no arguments, .tpc_commit() commits a TPC transaction previously prepared with .tpc_prepare(). If .tpc_commit() is called prior to .tpc_prepare(), a single phase commit is performed. A transaction manager may choose to do this if only a single resource is participating in the global transaction. When called with a transaction ID xid, the database commits the given transaction. If an invalid transaction ID is provided, a ProgrammingError will be raised. This form should be called outside of a transaction, and is intended for use in recovery. On return, the TPC transaction is ended. This function is part of the `DBAPI 2.0 specification `_. s.Cannot tpc_commit() without a TPC transaction!sCOMMIT PREPARED '%s';iN( RhR|R RRlt tpc_recoverRRR(RCRLtprevious_autocommit_mode((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt tpc_commits        cCs|dkr|j}n|dkr3tdnzV|j}t|_||jkr~|j|jd|dfdn |jWd||_Xd|_dS(sDWhen called with no arguments, .tpc_rollback() rolls back a TPC transaction. It may be called before or after .tpc_prepare(). When called with a transaction ID xid, it rolls back the given transaction. If an invalid transaction ID is provided, a ProgrammingError is raised. This form should be called outside of a transaction, and is intended for use in recovery. On return, the TPC transaction is ended. This function is part of the `DBAPI 2.0 specification `_. s9Cannot tpc_rollback() without a TPC prepared transaction!sROLLBACK PREPARED '%s';iN( RhR|R RRlRORRR(RCRLRP((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyt tpc_rollbacks        cCsjzY|j}t|_|j}|jdg|D]}|jd|dd^q5SWd||_XdS(sReturns a list of pending transaction IDs suitable for use with .tpc_commit(xid) or .tpc_rollback(xid). This function is part of the `DBAPI 2.0 specification `_. s!select gid FROM pg_prepared_xactsiRYN(RRlRRRL(RCRPtcursR(((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyROs    .(:RHRIRRRRRRR R R R R t_row_cache_sizeRRR!RRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRLRMRNRhRQRRRO(((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyR *sn<           #   :            - a    ' $iiiiiiiit mule_internalteuc_twtgb2312teuc_cntis8859_5t iso_8859_5tis8859_6t iso_8859_6tis8859_7t iso_8859_7tis8859_8t iso_8859_8tkoi8_rtkoi8s iso8859-1tlatin1t iso8859_2tlatin2t iso8859_3tlatin3t iso8859_4tlatin4t iso8859_9tlatin5t iso8859_10tlatin6t iso8859_13tlatin7t iso8859_14tlatin8t iso8859_15tlatin9Rt sql_asciitcp886twin866tcp874twin874tcp1250twin1250tcp1251twin1251tcp1252twin1252tcp1253twin1253tcp1254twin1254tcp1255twin1255tcp1256twin1256tcp1257twin1257tcp1258twin1258sutf-8RVccsoxht|D]Z\}}t|trYx<t|D]\}}}|||fVq5Wq |||fVq WdS(N(RiRzRIR6(RBR~RR;ti2tv2((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyR6Os cCs+x$t|D]}|dk r |Sq WdS(N(R:Rh(RBR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyRAXs ccsHxA|D]9}t|tr;x!t|D] }|Vq)Wq|VqWdS(N(RzRIR:(RBRR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyR:_s   cCs|d}t|trt|}t|}xG|D]?}t|}t||ksh||kr8tdq8q8W|g}|j||Sx,|D]$}t|trtdqqWgSdS(Nisarray dimensions not consistent(RzRIRjR7RR?(RBtv0treq_lentreq_inner_lengthsRt inner_lengthsR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyR7hs"        cCs+x$t|D]}|dkr tSq WtS(N(R:RhRlRg(RBR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyR8~s cCsO|d}t|tr>t|g}|jt|n t|gS|S(Ni(RzRIRjR?R9(RBRR((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyR9s   (t __author__RRRYRRRRRRRRR R R R R RRRRRRRRRRRRRRRRRRR R!R"R#R$R%R&R'R(R)R*twarningsR+RRttstructR,thashlibR-tdecimalR.t collectionsR/R0t itertoolsR1R2t six.movesR3tsixR4R5R6R7R8R9R:tsysR;tuuidR<tcopyR=tcalendarR>Rvtdistutils.versionR?tjsonR@RRBRRARRIRRfRR"R#RRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRR tFLUSHtSYNCRRt TERMINATER*RRRRRR+RRRtRESPONSE_DETAILt RESPONSE_HINTtRESPONSE_POSITIONtRESPONSE__POSITIONtRESPONSE__QUERYtRESPONSE_WHEREt RESPONSE_FILEt RESPONSE_LINEtRESPONSE_ROUTINERtIDLE_IN_TRANSACTIONtIDLE_IN_FAILED_TRANSACTIONRRRJRRhR?tobjectRR RCR1R6RAR:R7R8R9(((sC/var/www/c4bv.valis/web2py-ge-R-2.10.3/gluon/contrib/pg8000/core.pyts`    4                                                                                 ;