iFddlmZmZmZmZddlmZddlmZddl m Z m Z m Z ddl m Z ddlmZddlmZdd lmZGd d e ZGd de ZGdde ZdefdZdS))AnyCallableOptionalUnion)utils) BaseMetaClass) PipelineImplPipelineOpImplPipelineOpResultImpl)defaults)PipelineOpType)_Error) FetchInfoc~eZdZdZdZedefdZedefdZ edefdZ ede fdZ ede edffd Zedefd Zedefd Zede fd Zede fd Zede edffdZede edffdZdS) PipelineOpc@|jj}d|d|jjdS)N) __class__ _public_nameop_typenameselfcls_names a/var/www/html/Pagina-Ingenieria-Requisitos/venv/lib/python3.11/site-packages/oracledb/pipeline.py__repr__zPipelineOp.__repr__,s*>.:8::dl&7::::ct|j}tt}||_||_|S)zu Internal method used for creating a result object that is returned when running a pipeline. )r _implPipelineOpResult__new__ _operation)rimplresults r_create_resultzPipelineOp._create_result0s; $DJ//!))*:;;   rreturnc|jjS)z This read-only attribute returns the array size that will be used when fetching query rows with :meth:`Pipeline.add_fetchall()`. For all other operations, the value returned is *0*. )r! arraysizers rr*zPipelineOp.arraysize;sz##rc|jjS)z Returns whether or not to fetch columns of type ``NUMBER`` as ``decimal.Decimal`` values for a query. )r!fetch_decimalsr+s rr-zPipelineOp.fetch_decimalsDs z((rc|jjS)zK Returns whether or not to fetch LOB locators for a query. )r! fetch_lobsr+s rr/zPipelineOp.fetch_lobsLs z$$rc|jjS)z This read-only attribute returns the keyword parameters to the stored procedure or function being called by the operation, if applicable. )r!keyword_parametersr+s rr1zPipelineOp.keyword_parametersSs z,,rNc|jjS)z This read-only attribute returns the name of the stored procedure or function being called by the operation, if applicable. )r!rr+s rrzPipelineOp.name[ zrc|jjS)z This read-only attribute returns the number of rows to fetch when performing a query of a specific number of rows. For all other operations, the value returned is *0*. )r!num_rowsr+s rr5zPipelineOp.num_rowscsz""rc4t|jjS)zf This read-only attribute returns the type of operation that is taking place. )rr!rr+s rrzPipelineOp.op_typels dj0111rc|jjS)z This read-only attribute returns the parameters to the stored procedure or function or the parameters bound to the statement being executed by the operation, if applicable. )r! parametersr+s rr8zPipelineOp.parameterstsz$$rc|jjS)z This read-only attribute returns the return type of the stored function being called by the operation, if applicable. )r! return_typer+s rr:zPipelineOp.return_type}s z%%rc|jjS)z This read-only attribute returns the row factory callable function to be used in a query executed by the operation, if applicable. )r! rowfactoryr+s rr<zPipelineOp.rowfactorys z$$rc|jjS)zx This read-only attribute returns the statement being executed by the operation, if applicable. )r! statementr+s rr>zPipelineOp.statements z##r)__name__ __module__ __qualname__rr'propertyintr*boolr-r/rr1rstrrr5rrr8r:rr<r>rrrr*s;;;   $3$$$X$))))X)%D%%%X% -C---X-eCI&X#####X#2222X2%C%%%X%&S&&&X&%E(D.1%%%X%$5d+$$$X$$$rr) metaclassceZdZdZedeeedffdZedee dffdZ ede fdZ ede fdZedeedffdZedee dffd ZdS) r"cJ|jj}d|d|jjjdS)Nrz for operation of type r)rr operationrrrs rrzPipelineOpResult.__repr__s/>. O O O1G1L O O O rr(NcJ|jjd|jjDSdS)z This read-only attribute is a list of FetchInfo objects. This attribute will be *None* for operations that do not return rows. Nc6g|]}tj|SrF)r _from_impl).0is r z,PipelineOpResult.columns..s#OOOI(++OOOr)r!fetch_metadatar+s rcolumnszPipelineOpResult.columnss0 : $ 0OOTZ5NOOO O 1 0rc|jjS)z This read-only attribute returns the error that occurred when running this operation. If no error occurred, then the value *None* is returned. )r!errorr+s rrTzPipelineOpResult.errorszrc|jS)zu This read-only attribute returns the PipelineOp operation object that generated the result. )r$r+s rrJzPipelineOpResult.operations rc|jjS)z This read-only attribute returns the return value of the called PL/SQL function, if a function was called for the operation. )r! return_valuer+s rrWzPipelineOpResult.return_values z&&rc|jjS)z This read-only attribute returns the rows that were fetched by the operation, if a query was executed. )r!rowsr+s rrYzPipelineOpResult.rowsr3rc|jjS)z This read-only attribute returns any warning that was encountered when running this operation. If no warning was encountered, then the value *None* is returned. )r!warningr+s rr[zPipelineOpResult.warningsz!!r)r?r@rArrBrlistrrRrrTrrJrrWrYr[rFrrr"r"s;   PtI45PPPXP uVT\*   X :X'c'''X'eD$J'X"vt|,"""X"""rr"ceZdZdZdZ ddededeee e fdee de f d Z ddedeee e fdee de fd Zde fd Z dd edeee e e fde fd Zd edee efde fdZ dd edeee e e fdeedeedeedeede fdZ dd edeee e e fdeedeedeedeede fdZ dd edeee e e fdeedeedeede f dZede e fdZdS)PipelinecZ|jj}d|dt|jjdS)Nrz with z operations>)rrlenr! operationsrs rrzPipeline.__repr__s2>.K8KK3tz'<#=#=KKKKrc|jj|tt}||_|j||S)z Internal method for adding an PipelineOpImpl instance to the list of operations, creating an associated PipelineOp instance to correspond to it. )r!raappendrr# _operations)rop_implops r_add_opzPipeline._add_opsS $$W---    + + ### rNrr:r8r1r(ctj||ttj||||}||S)a Adds an operation to the pipeline that calls a stored PL/SQL function with the given parameters and return type. The created PipelineOp object is also returned from this function. When the Pipeline is executed, the PipelineOpResult object that is returned for this operation will have the :attr:`~PipelineOpResult.return_value` attribute populated with the return value of the PL/SQL function if the call completes successfully. )rrr:r8r1)rverify_stored_proc_argsr r CALL_FUNCrg)rrr:r8r1res r add_callfunczPipeline.add_callfuncsR$ %j2DEEE ",#!1    ||G$$$rctj||ttj|||}||S)z Adds an operation that calls a stored procedure with the given parameters. The created PipelineOp object is also returned from this function. )rrr8r1)rrir r CALL_PROCrg)rrr8r1res r add_callproczPipeline.add_callprocsO %j2DEEE ",!1     ||G$$$rc`ttj}||S)z; Adds an operation that performs a commit. )r)r rCOMMITrg)rres r add_commitzPipeline.add_commits)!)>???||G$$$rr>cdttj||}||S)a^ Adds an operation that executes a statement with the given parameters. The created PipelineOp object is also returned from this function. Do not use this for queries that return rows. Instead use :meth:`Pipeline.add_fetchall()`, :meth:`Pipeline.add_fetchmany()`, or :meth:`Pipeline.add_fetchone()`. rr>r8)r rEXECUTErgrr>r8res r add_executezPipeline.add_executes8!"*!    ||G$$$rcdttj||}||S)a/ Adds an operation that executes a SQL statement once using all bind value mappings or sequences found in the sequence parameters. This can be used to insert, update, or delete multiple rows in a table. It can also invoke a PL/SQL procedure multiple times. The created PipelineOp object is also returned from this function. The ``parameters`` parameter can be a list of tuples, where each tuple item maps to one bind variable placeholder in ``statement``. It can also be a list of dictionaries, where the keys match the bind variable placeholder names in ``statement``. If there are no bind values, or values have previously been bound, the ``parameters`` value can be an integer specifying the number of iterations. rs)r r EXECUTE_MANYrgrus radd_executemanyzPipeline.add_executemany/s8(!"/!    ||G$$$rr*r<r/r-c | tj}ttj||||||}||S)a Adds an operation that executes a query and returns all of the rows from the result set. The created PipelineOp object is also returned from this function. When the Pipeline is executed, the PipelineOpResult object that is returned for this operation will have the :attr:`~PipelineOpResult.rows` attribute populated with the list of rows returned by the query. The default value for ``arraysize`` is :attr:`oracledb.defaults.arraysize `. Internally, this operation's :attr:`Cursor.prefetchrows` size is set to the value of the explicit or default ``arraysize`` parameter value. The ``fetch_lobs`` parameter specifies whether to return LOB locators or ``str``/``bytes`` values when fetching LOB columns. The default value is :data:`oracledb.defaults.fetch_lobs `. The ``fetch_decimals`` parameter specifies whether to return ``decimal.Decimal`` values when fetching columns of type ``NUMBER``. The default value is :data:`oracledb.defaults.fetch_decimals `. N)rr>r8r*r<r/r-)r r*r r FETCH_ALLrg)rr>r8r*r<r/r-res r add_fetchallzPipeline.add_fetchallJsSD   *I ",!!!)   ||G$$$rr5c | tj}ttj||||||}||S)a Adds an operation that executes a query and returns up to the specified number of rows from the result set. The created PipelineOp object is also returned from this function. When the Pipeline is executed, the PipelineOpResult object that is returned for this operation will have the :attr:`~PipelineOpResult.rows` attribute populated with the list of rows returned by the query. The default value for ``num_rows`` is the value of :attr:`oracledb.defaults.arraysize `. Internally, this operation's :attr:`Cursor.prefetchrows` size is set to the value of the explicit or default ``num_rows`` parameter, allowing all rows to be fetched in one round-trip. Since only one fetch is performed for a query operation, consider adding a ``FETCH NEXT`` clause to the statement to prevent the database processing rows that will never be fetched. The ``fetch_lobs`` parameter specifies whether to return LOB locators or ``str``/``bytes`` values when fetching LOB columns. The default value is :data:`oracledb.defaults.fetch_lobs `. The ``fetch_decimals`` parameter specifies whether to return ``decimal.Decimal`` values when fetching columns of type ``NUMBER``. The default value is :data:`oracledb.defaults.fetch_decimals `. N)rr>r8r5r<r/r-)r r*r r FETCH_MANYrg)rr>r8r5r<r/r-res r add_fetchmanyzPipeline.add_fetchmanyysSN  )H "-!!!)   ||G$$$rcjttj|||||}||S)a7 Adds an operation that executes a query and returns the first row of the result set if one exists (or *None*, if no rows exist). The created PipelineOp object is also returned from this function. When the Pipeline is executed, the PipelineOpResult object that is returned for this operation will have the :attr:`~PipelineOpResult.rows` attribute populated with this row if the query is performed successfully. Internally, this operation's :attr:`Cursor.prefetchrows` and :attr:`Cursor.arraysize` sizes will be set to *1*. Since only one fetch is performed for a query operation, consider adding a ``WHERE`` condition or using a ``FETCH NEXT`` clause in the statement to prevent the database processing rows that will never be fetched. The ``fetch_lobs`` parameter specifies whether to return LOB locators or ``str``/``bytes`` values when fetching LOB columns. The default value is :data:`oracledb.defaults.fetch_lobs `. The ``fetch_decimals`` parameter specifies whether to return ``decimal.Decimal`` values when fetching columns of type ``NUMBER``. The default value is :data:`oracledb.defaults.fetch_decimals `. )rr>r8r<r/r-)r r FETCH_ONErg)rr>r8r<r/r-res r add_fetchonezPipeline.add_fetchonesBF!",!!!)    ||G$$$rc|jS)zo This read-only attribute returns the list of operations associated with the pipeline. )rdr+s rrazPipeline.operationss r)NN)N)NNNNN)NNNN)r?r@rArrgrErrrr\tupledictrrkrnrqrvrCryrrDr|rrrBrarFrrr^r^s^LLL    48-1 %%%%U4;/0 % %TN %  %%%%>48-1 %%%U4;/0%%TN %  %%%%(%J%%%%:>%%%U4#456%  %%%%(%%$)$%  %%%%<:>#')-%))--%-%-%U4#456-%C= -% X& -% TN -%!-% -%-%-%-%d:>"&)-%))-2%2%2%U4#4562%3- 2% X& 2% TN 2%!2% 2%2%2%2%n:>)-%))- +%+%+%U4#456+%X& +% TN +% ! +% +%+%+%+%Z D,   X   rr^r(cxtt}t|_g|_|S)zl Creates a pipeline object which can be used to process a set of operations against a database. )r^r#r r!rd)pipelines rcreate_pipeliners/ ))H!^^HNH OrN)typingrrrrrbaser base_implr r r r enumsrerrorsr fetch_inforrr"r^rrFrrrs|>211111111111IIIIIIIIII!!!!!!!!!!!!i$i$i$i$i$=i$i$i$i$X9"9"9"9"9"9"9"9"9"xN N N N N N N N N br