o ED©iá ã@s8ddlmZddlmZGdd„deeƒZd dd„ZdS) é)Ú Immutable)Ú FromClausecsheZdZdZdZdZdZdZd‡fdd„ Ze dd „ƒZ e d d „ƒZ e d d „ƒZ dd„Z ddd„Z‡ZS)Ú ArrayJoinz'Represents ClickHouse ARRAY JOIN clauseÚ array_joinTFNcs,tƒ ¡||_||_||_||_d|_dS)a#Initialize ARRAY JOIN clause Args: left: The left side (table or subquery) array_column: The array column to join alias: Optional alias for the joined array elements is_left: If True, use LEFT ARRAY JOIN instead of ARRAY JOIN N)ÚsuperÚ__init__ÚleftÚ array_columnÚaliasÚis_leftÚ _is_clone_of)Úselfrr r r ©Ú __class__©úe/var/www/Datamplify/venv/lib/python3.10/site-packages/clickhouse_connect/cc_sqlalchemy/sql/clauses.pyrs  zArrayJoin.__init__cCs|jS)z%Return the selectable for this clause©r©r rrrÚ selectableszArrayJoin.selectablecCs|jgS)zJHide the left table from the FROM clause since it's part of the ARRAY JOINrrrrrÚ _hide_froms#ózArrayJoin._hide_fromscCs|jjS)z4Return all FROM objects referenced by this construct)rÚ _from_objectsrrrrr(rzArrayJoin._from_objectscKs$|j |j¡}|j ¡|_||_|S)zReturn a copy of this ArrayJoin)rÚ__new__Ú__dict__Úcopyr )r ÚkwÚcrrrÚ_clone-s zArrayJoin._clonecKs@dd„}|dur |}||jfi|¤Ž|_||jfi|¤Ž|_dS)zÖCopy internal state for cloning This ensures that when queries are cloned (e.g., for subqueries, unions, or CTEs), the left FromClause and array_column references are properly deep-cloned. c[s|S©Nr)ÚelemÚkwargsrrrÚ_default_clone:sz1ArrayJoin._copy_internals.._default_cloneN)rr )r Úclonerr!rrrÚ_copy_internals4s zArrayJoin._copy_internals©NFr)Ú__name__Ú __module__Ú __qualname__Ú__doc__Ú__visit_name__Ú_is_from_containerÚnamed_with_columnÚ_is_joinrÚpropertyrrrrr#Ú __classcell__rrrrrs   rNFcCst||||ƒS)aªCreate an ARRAY JOIN clause Args: left: The left side (table or subquery) array_column: The array column to join alias: Optional alias for the joined array elements is_left: If True, use LEFT ARRAY JOIN instead of ARRAY JOIN Returns: ArrayJoin: An ArrayJoin clause element Example: from clickhouse_connect.cc_sqlalchemy.sql.clauses import array_join # Basic ARRAY JOIN query = select(table).select_from(array_join(table, table.c.tags)) # LEFT ARRAY JOIN with alias query = select(table).select_from( array_join(table, table.c.tags, alias='tag', is_left=True) ) )r)rr r r rrrrFsrr$)Úsqlalchemy.sql.baserÚsqlalchemy.sql.selectablerrrrrrrÚs @