kQj,LdZddlmZmZmZmZmZddlmZddl Z ddl Z ddl mZddlmZddlmZej&Zee j(e j*eeeeeffZ d ed e j0fd Zd eed ee j(fd ZGddZGddZgdZy)z4Handles to SQL queries running on a remote database.)AnyMappingOptionalSequenceUnion)UUIDN)LOOP)_lancedb)AsyncRecordBatchReadervaluereturnct|tjr0tj|j g|j St|tj r|j}t|tjrp|jdk(r$tj|jdS|jdk7rtd|jdtj|}t|tjr)tjj|t!|Stj|gS)z5One parameter as a one-element array of its own type.)typerr z>a numpy query parameter must be a scalar or a 1-D vector, got z dimensions) isinstancepaScalararrayas_pyr ChunkedArraycombine_chunksnpndarrayndimreshape ValueErrorArrayFixedSizeListArray from_arrayslen)r s P/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/lancedb/sql.py_parameter_arrayr"s%#xxejj99%)$$&%$ ::?88EMM!,- - ::?zzl+/ %"$$00E CC 88UG  parametersc |yt|tjr|}nt|tjr^|j j }t |dk(r|dn*tjjg|j}n(t|trltjj|jDcgc] }t|c}|jDcgc] }t|c}}nt|tr{t|tt fsetjj|Dcgc] }t|c}t#t |Dcgc]}t|dzc}}n!t%dt'|j(|j*dk7rt-d|j*|Scc}wcc}wcc}wcc}w)aNTurn ``parameters`` into the one-row batch a parameterized query sends. Scalars keep the type pyarrow infers for them (numpy scalars keep their dtype), a ``pyarrow.Scalar`` keeps its own type, and a 1-D numpy or pyarrow array becomes a ``FixedSizeList`` of its element type, which is what a vector column stores. Nr r)schema)namesz_query parameters must be a sequence, a mapping, or a one-row pyarrow RecordBatch or Table, not z.query parameters must be exactly one row, got )rr RecordBatchTabler to_batchesr from_pylistr&rrvaluesr"keysstrrbytesrange TypeErrorr__name__num_rowsr)r$batchbatchesr namepositions r!to_parameter_batchr84s*bnn- J )++-88:7|q  AJ++Bz7H7H+I  J (**2<2C2C2E F e $ F)3):;3t9;+  J )*Z#u2V**2< = e $ =5:3z?5KL3x!|$L+   115j1A1J1J0K M   ~~LsG+;G0 G5G: cNeZdZdZd dZedefdZdefdZ de fdZ d dZ y) AsyncQueryz@A handle to a submitted SQL query on an asynchronous connection.c||_yN_innerselfinners r!__init__zAsyncQuery.__init__c  r#rc.|jjSzAThe stable identifier scoped to the connection that submitted it.r>idr@s r!rGz AsyncQuery.idf{{~~r#cRK|jjd{S7w)-Get a point-in-time description of the query.N)r>describerHs r!rLzAsyncQuery.describeks[[))++++s '%'cdKt|jjd{S7w)a&Wait for the initial result stream and return its Arrow reader. Results are single-consumer. Calling this method more than once on the same query raises an error. Later batches are streamed as they become available without waiting for the full query to finish. N)r r>readerrHs r!rNzAsyncQuery.readeros&&DKK,>,>,@&@AA&@s #0. 0NcTK|jjd{y7wz"Request cancellation of the query.N)r>cancelrHs r!rQzAsyncQuery.cancelxskk  """s (&()rAz_lancedb.SqlQueryrN) r2 __module__ __qualname____doc__rBpropertyrrGQueryDescriptionrLr rNrQr#r!r:r:`sFJD, 0,B4B#r#r:cfeZdZdZdefdZedefdZde fdZ de jfdZ d d Zy) Queryz/Synchronous counterpart of :class:`AsyncQuery`.rAc||_yr<r=r?s r!rBzQuery.__init__rCr#rc.|jjSrErFrHs r!rGzQuery.idrIr#c\tj|jjS)rK)r runr>rLrHs r!rLzQuery.describesxx ,,.//r#ctj|jjfdfd}tj j j|S)a)Wait for the initial result stream and return a blocking reader. Results are single-consumer. Calling this method more than once on the same query raises an error. Later batches block only until they become available, without waiting for the full query to finish. cj tjjS#t$rYywxYwr<)r r^ __anext__StopAsyncIteration)rNsr! next_batchz Query.reader..next_batchs2 xx 0 0 233%  s "& 22c3>Kx}|x}yywr<rX)r4rcs r!r5zQuery.reader..batchess(&L(55 'L(55s)r r^r>rNrRecordBatchReader from_batchesr&)r@r5rcrNs @@r!rNz Query.readersK$++,,./   ##00 JJr#Nc^tj|jjyrP)r r^r>rQrHs r!rQz Query.cancels ##%&r#rR)r2rSrTrUr:rBrVrrGrWrLrrerNrQrXr#r!rZrZ}sR9jD0*0K,,K*'r#rZ)r:rZrWQueryParameters)rUtypingrrrrruuidrnumpyrpyarrowrlancedb.background_loopr r arrowr rWr(r)r.rhrr"r8r:rZ__all__rXr#r!rqs;::(),,(3-cARRSCBHH.))) bnn)X##:&'&'R Ir#