]j%SrSSKJr SSKrSSKJrJrJrJrJ r J r SSK J r SSK JrJr SSKJr SS KJr SS KJr SS KJr \(aSS KJr SS KJr SSKJr SSKJr \R@RBr!\R@RDr"\R@RFr#\R@RHr$\"SSS9r%\"SSSS9r&"SS\ \&5r'"SS\ \&5r("SS\ \&5r)"SS\ \&5r*\+\S4r,S\-S'\.\/\4r0S\-S 'S-S!jr1S.S"jr2S/S#jr3\Rh"S$5S0S%j5r5S1S&jr6S2S'jr7S2S(jr8S3S)jr9S4S*jr:S5S+jr;S6S,jr Like `RowFactory`, taking either type of cursor as argument. cgrr )r!_BaseRowFactory__cursors r#r$BaseRowFactory.__call__Rsr&r N)rABaseCursor[Any, Any]r(r6r)r r&r#r>r>Ms Mr&r>.r DictRowc[$)zRow factory to represent rows as simple tuples. This is the default factory, used when `~psycopg.Connection.connect()` or `~psycopg.Connection.cursor()` are called without a `!row_factory` parameter. )tuple)cursors r# tuple_rowrHds  Lr&c@^[U5=mb SU4SjjnU$[$)z}Row factory to represent rows as dictionaries. The dictionary keys are taken from the column names of the returned columns. c.>[[TU55$rdictzip)valuesnamess r# dict_row_dict_row..dict_row_xsE6*+ +r&)rNr'r(zdict[str, Any] _get_names no_result)rGrPrOs @r#dict_rowrUqs* F##0 ,r&c^UR=m(aC[T5=nb5[UR/U4Sj[ U55Q76nUR $[ $)zRow factory to represent rows as `~collections.namedtuple`. The field names are taken from the column names of the returned columns, with some mangling to deal with invalid names. c3F># UHnTRU5v M g7fr)fname).0iress r# !namedtuple_row..s)O1#))A,,s!)pgresult _get_nfields_make_nt _encodingrange_makerT)rGnfieldsntr[s @r#namedtuple_rowrfsQ  S0A%AW$N f&& P)Og)O Pxxr&icF^[U4SjU55n[SU5$)Nc3X># UHn[URT55v M! g7fr)rdecode)rYnencs r#r\_make_nt..s"GA(#77s'*r)rFr )rkrOsnamess` r#r`r`s GG GF eV $$r&c^SU4SjjnU$)a=Generate a row factory to represent rows as instances of the class `!cls`. The class must support every output column name as a keyword parameter. :param cls: The class to return for each row. It must support the fields returned by the query as keyword arguments. :rtype: `!Callable[[Cursor],` `RowMaker`\[~T]] cD>^[U5=mb SUU4SjjnU$[$)Nc :>T"S0[[TU55D6$Nr rK)rNclsrOs r# class_row__2class_row..class_row_..class_row__s6T#eV"4566r&rNr'r(rrR)rGrsrOrrs @r# class_row_class_row..class_row_s-' 'E 4 7 7  r&)rGrCr( RowMaker[T]r )rrrvs` r# class_rowrys  r&c^SU4SjjnU$)zGenerate a row factory calling `!func` with positional parameters for every row. :param func: The function to call for each row. It must support the fields returned by the query as positional arguments. c>SU4SjjnU$)Nc>T"U6$rr )rNfuncs r# args_row__/args_row..args_row_..args_row__s = r&rur )curr~r}s r# args_row_args_row..args_row_s !r&)rBaseCursor[Any, T]r(rxr )r}rs` r#args_rowrs r&c^SU4SjjnU$)zGenerate a row factory calling `!func` with keyword parameters for every row. :param func: The function to call for each row. It must support the fields returned by the query as keyword arguments. cD>^[U5=mb SUU4SjjnU$[$)Nc :>T"S0[[TU55D6$rqrK)rNr}rOs r# kwargs_row__5kwargs_row..kwargs_row_..kwargs_row__s7d3uf#5677r&rurR)rGrrOr}s @r# kwargs_row_kwargs_row..kwargs_row_s-' 'E 4 8 8  r&)rGrr(rxr )r}rs` r# kwargs_rowrs  r&cUR=n(a1[U5=nb#US:a[R"S5eSSjnU$[$)zF Generate a row factory returning the first column as a scalar value. r zat least one column expectedc US$)Nrr rNs r# scalar_row_scalar_row..scalar_row_s !9 r&)rNr'r(r)r^r_eProgrammingErrorrT)rGr[rdrs r# scalar_rowrsP  S0A%AW$N Q;$$%CD D r&c.[R"S5e)zA `RowMaker` that always fail. It can be used as return value for a `RowFactory` called with no result. Note that the `!RowFactory` *will* be called with no result, but the resulting `!RowMaker` never should. z the cursor doesn't have a result)rInterfaceErrorrs r#rTrTs  = >>r&cUR=n(aS[U5=nbEURn[U5Vs/sH"oAR U5R U5PM$ sn$gs snfr)r^r_rarbrXri)rGr[rdrkrZs r#rSrSsf S0A%AW$N.3Gn .<IIaL   $n    s)A(cURnUR[:XdCUR[:Xd/UR[:XdUR[ :Xa U(aU$g)z Return the number of columns in a result, if it returns tuples else None Take into account the special case of results with zero columns. N)rdstatus TUPLES_OK SINGLE_TUPLE TUPLES_CHUNK COMMAND_OK)r[rds r#r_r_sI kkG i :: % :: % JJ* $r&)rGrCr(zRowMaker[TupleRow])rGrCr(zRowMaker[DictRow])rGrCr(zRowMaker[NamedTuple])rkstrrObytesr(ztype[NamedTuple])rrztype[T]r(BaseRowFactory[T])r}zCallable[..., T]r(r)rGrCr(z RowMaker[Any])rNr'r(r)rGrCr(zlist[str] | None)r[rr(z int | None)=r. __future__r functoolstypingrrrrrr collectionsr collections.abcr r rrr_compatr _encodingsrrGrpq.abcr _cursor_baser cursor_asyncr ExecStatusrrrrrrrr1r8r>rFr__annotations__rLrrDrHrUrf lru_cacher`ryrrrrTrSr_r r&r#rsZ #PP".- () ]] % % MM # # }})) }}))  C4 etZ8