o EDi@sXddlZddlmZmZddlmZmZmZddZddZ dd Z d d Z d d Z dS)N)islicetee)urlparseparse_qsunquoteccst|ttfr+d}||||}|r)t|V||7}||||}|sdSdSt|}tt||}|rF|Vtt||}|s8dSdS)Nr) isinstancelisttupleiterr)seqniitemitrW/var/www/Datamplify/venv/lib/python3.10/site-packages/clickhouse_driver/util/helpers.pychunkss   rcCs t|\}}t|dt||S)N)rnextzip)iterableabrrrpairwises   rc#sb|D]}t|ttfstdt|qfdd|D} dd|D}t|s-dS|Vq )Nz7Unsupported column type: {}. list or tuple is expected.csg|]}t|qSr)r.0columnr rr 'z!column_chunks..TcSsg|]}t|gqSr)rrrrrr+r)rrr TypeErrorformattypeany)columnsr rgrrrr column_chunkss r%cCsBt|tr|}|dvrdS|dvrdStd|t|S)N)trueyesonyt1T)falsenooffr f0FzString is not true/false: %r)rstrstriplower ValueErrorbool)objrrrasbool2s   r7c Cst|}i}i}|j}|jdur|j|d<|jddd}|r#||d<|jdur/t|j|d<|jdur;t|j|d<|jd krDd |d <hd }hd }t |j  D]\}}|r]t |s^qS|d}|dkrz| }||vrs|||<qSt|||<qS|d krt|||<qS|dkrt|||<qS|dkrt|||<qS|dkr|||<qS||vrt|||<qS|dkrt|||<qS|dkrt|||<qS|dkrzt|||<WqSty|d} t| dt| dt| df||<YqSw|dkrt|||<qS|dkr t|||<qS|dkrt|||<qS|dkr#tt|||<qS|dvr-|||<qS|dkr7||d<qS|||<qS|rC||d<||fS)a Parses url into host and kwargs suitable for further Client construction. Return host and kwargs. For example:: clickhouse://[user:password]@localhost:9000/default clickhouses://[user:password]@localhost:9440/default Three URL schemes are supported: * clickhouse:// creates a normal TCP socket connection * clickhouses:// creates a SSL wrapped TCP socket connection Any additional querystring arguments will be passed along to the Connection class's initializer. Nport/databaseuserpassword clickhousesTsecure>lz4zstdlz4hc>connect_timeoutsend_receive_timeoutsync_request_timeoutr compression use_numpy round_robin client_namecompress_block_sizesettings_is_important tcp_keepalive,client_revisionverifycheck_hostname ssl_version)ca_certscipherskeyfilekeypasscertfileserver_hostname alt_hostssettings)rhostnamer8pathreplaceusernamerr>schemerqueryitemslenr3r7floatintr4splitgetattrssl) urlr[kwargshostr]compression_algstimeoutsnamevaluepartsrrr parse_url>s                   rq) rh itertoolsrr urllib.parserrrrrr%r7rqrrrrs