D6iW>ddlZddlmZddlmZmZddlmZm Z ddl m Z GddeZ eje dZGd d eZejed Z dd Zdd Z ddZGdde eZejedZddZy)N)compiler) DDLElementPrimaryKeyConstraint) ClauseElement Executable) get_columnsceZdZddZy) CreateViewcZ|r |r td||_||_||_||_y)Nz4Cannot use CREATE OR REPLACE with materialized views) ValueErrorname selectable materializedreplace)selfr rrrs X/home/azureuser/techstart-app/venv/lib/python3.12/site-packages/sqlalchemy_utils/view.py__init__zCreateView.__init__ s0 GST T $( N)FF__name__ __module__ __qualname__rrrr r srr c dj|jrdnd|jrdnd|jjj |j |jj|jdS)NzCREATE {}{}VIEW {} AS {}z OR REPLACE MATERIALIZED T) literal_binds) formatrrdialectidentifier_preparerquoter sql_compilerprocessrelementrkws r compile_create_materialized_viewr'sj % , ,  b"//R,,227<<@%%g&8&8%M  rceZdZddZy)DropViewc.||_||_||_yN)r rcascade)rr rr,s rrzDropView.__init__s ( rN)FTrrrrr)r)srr)c dj|jrdnd|jjj |j |j rdSdS)NzDROP {}VIEW IF EXISTS {} {}rrCASCADE)rrrr r!r r,r$s rcompile_drop_materialized_viewr/$sX ( / /"//R,,227<<@__  +- rc F|g}|tj}|i}t|Dcgc]]}tj|j|j |j |j|j|j_c}|z}tj||g|i|}tt|Dcgc]}|jc}s8|jtt|Dcgc]}|jc}|Scc}wcc}wcc}w)N)key primary_key) saMetaDatarColumnr typegetr2Tableanyappend_constraintr) r rindexesmetadataaliaseskwargscargstables rcreate_table_from_selectablerB-s;;= Z(    FFAFF AFFAFF ;     D HHT8 5d 5f 5E {:'>?! ? @  ;z3J"Ka166"K L  L @"KsA"DD7D c *t|||d|tjj|dt ||dtjj |dfd}tjj|dt |dS)ahCreate a view on a given metadata :param name: The name of the view to create. :param selectable: An SQLAlchemy selectable e.g. a select() statement. :param metadata: An SQLAlchemy Metadata instance that stores the features of the database being described. :param indexes: An optional list of SQLAlchemy Index instances. :param aliases: An optional dictionary containing with keys as column names and values as column aliases. Same as for ``create_view`` except that a ``CREATE MATERIALIZED VIEW`` statement is emitted instead of a ``CREATE VIEW``. N)r rr;r<r= after_createT)rcJjD]}|j|yr+r;createtarget connectionr&idxrAs rcreate_indexesz0create_materialized_view..create_indexesb"== #C JJz " #r before_droprBr3eventlistenr listens_forr))r rr<r;r=rLrAs @rcreate_materialized_viewrSEs" )   EHHOO.*T:D"QXX(N3#4#HHOOHmXd-NO Lrc &t||dtjj|dt |||tjj |dfd}tjj|dt ||S)aCreate a view on a given metadata :param name: The name of the view to create. :param selectable: An SQLAlchemy selectable e.g. a select() statement. :param metadata: An SQLAlchemy Metadata instance that stores the features of the database being described. :param cascade_on_drop: If ``True`` the view will be dropped with ``CASCADE``, deleting all dependent objects as well. :param replace: If ``True`` the view will be created with ``OR REPLACE``, replacing an existing view with the same name. The process for creating a view is similar to the standard way that a table is constructed, except that a selectable is provided instead of a set of columns. The view is created once a ``CREATE`` statement is executed against the supplied metadata (e.g. ``metadata.create_all(..)``), and dropped when a ``DROP`` is executed against the metadata. To create a view that performs basic filtering on a table. :: metadata = MetaData() users = Table('users', metadata, Column('id', Integer, primary_key=True), Column('name', String), Column('fullname', String), Column('premium_user', Boolean, default=False), ) premium_members = select(users).where(users.c.premium_user == True) create_view('premium_users', premium_members, metadata) metadata.create_all(engine) # View is created at this point N)r rr<rD)rcJjD]}|j|yr+rFrHs rrLz#create_view..create_indexesrMrrN)r,rO)r rr<cascade_on_droprrLrAs @r create_viewrWksR ) j4 EHHOO4W5 XX(N3#4#HHOOHmXdO-TU LrceZdZdZdZy)RefreshMaterializedViewTc ||_||_yr+)r concurrently)rr r[s rrz RefreshMaterializedView.__init__s (rN)rrr inherit_cacherrrrrYrYs M)rrYcdj|jrdnd|jjj |j S)Nz.REFRESH MATERIALIZED VIEW {concurrently}{name}z CONCURRENTLY r)r[r )rr[rr r!r )r%rs r!compile_refresh_materialized_viewr^sF ; B B(/(<(<_"    1 1 7 7 E C rcZ|j|jt||y)aCRefreshes an already existing materialized view :param session: An SQLAlchemy Session instance. :param name: The name of the materialized view to refresh. :param concurrently: Optional flag that causes the ``CONCURRENTLY`` parameter to be specified when the materialized view is refreshed. N)flushexecuterY)sessionr r[s rrefresh_materialized_viewrcs! MMO OO+D,?@r)NNN)NN)TF)F) sqlalchemyr3sqlalchemy.extrsqlalchemy.schemarrsqlalchemy.sql.expressionrrsqlalchemy_utils.functionsrr compilesr'r)r/rBrSrWrYr^rcrrrrjs#>?2:z8<@0#T  9x)j-)*+, Ar