IilNSSKrSSKJr SSKJrJr SSKJrJ r SSK J r "SS\5r \R"\ 5S5r"S S \5r\R"\5S 5rSS jrSS jrSSjr"SS\ \5r\R"\5S5rSSjrg)N)compiler) DDLElementPrimaryKeyConstraint) ClauseElement Executable) get_columnsc\rSrSrSSjrSrg) CreateView cfU(aU(a [S5eXlX lX0lX@lg)Nz4Cannot use CREATE OR REPLACE with materialized views) ValueErrorname selectable materializedreplace)selfrrrrs ;/venv/lib/python3.13/site-packages/sqlalchemy_utils/view.py__init__CreateView.__init__ s( GST T $( )rrrrN)FF__name__ __module__ __qualname____firstlineno__r__static_attributes__rrr r srr c SRUR(aSOSUR(aSOSURRR UR 5URRURSS95$)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  rc\rSrSrSSjrSrg)DropViewc(XlX lX0lgN)rrcascade)rrrr1s rrDropView.__init__s ( r)r1rrN)FTrrrrr-r-srr-c SRUR(aSOSURRR UR 5UR (aS5$S5$)NzDROP {}VIEW IF EXISTS {} {}r rCASCADE)r"rr#r$r%rr1r(s rcompile_drop_materialized_viewr5$sX ( / /"//R,,227<<@__  +- rc bUc/nUc[R"5nUc0n[U5Vs/sH\n[R"URUR UR URUR5URS9PM^ snU-n[R"X/UQ70UD6n[[U5Vs/sHofRPM sn5(d:UR[[U5Vs/sHofRPM sn65 U$s snfs snfs snf)N)key primary_key) saMetaDatarColumnrtypegetr8Tableanyappend_constraintr) rrindexesmetadataaliaseskwargscargstables rcreate_table_from_selectablerH-s;;=Z( )A FF FF AFFAFF+  )   D HHT 5d 5f 5E {:'>?'>! '>? @ @  ;z3J"K3Ja663J"K L  L @"KsA#D"D'D, c ^[UUUSUS9m[RRUS[ XSS95 [RR US5U4Sj5n[RRUS[ USS95 T$)a8Create 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)rrrArBrC after_createT)rcN>TRHnURU5 M gr0rAcreatetarget connectionr*idxrGs rcreate_indexes0create_materialized_view..create_indexesr==C JJz "!r before_droprHr9eventlistenr listens_forr-)rrrBrArCrRrGs @rcreate_materialized_viewrZMs. )   EHHOO4$7 XX(N3#4#HHOOD) Lrc ^[UUSS9m[RRUS[ XUS95 [RR US5U4Sj5n[RRUS[ XS95 T$)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) # sqlalchemy 1.3: # 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)rrrBrJ)rcN>TRHnURU5 M gr0rLrNs rrR#create_view..create_indexesrTrrU)r1rV)rrrBcascade_on_droprrRrGs @r create_viewr_sV )  E HHOO4W5 XX(N3#4#HHOO/ Lrc\rSrSrSrSrSrg)RefreshMaterializedViewTcXlX lgr0)r concurrently)rrrds rr RefreshMaterializedView.__init__s  (rrdrN)rrrr inherit_cacherrrrrraras M)rracSRUR(aSOSURRR UR 5S9$)Nz.REFRESH MATERIALIZED VIEW {concurrently}{name}z CONCURRENTLY rrf)r"rdr#r$r%r)r)rs r!compile_refresh_materialized_viewrisF ; B B(/(<(<_"    1 1 7 7 E C rcXUR5 UR[X55 g)a+Refreshes 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)flushexecutera)sessionrrds rrefresh_materialized_viewrns MMO OO+D?@r)NNN)NN)TF)F) sqlalchemyr9sqlalchemy.extrsqlalchemy.schemarrsqlalchemy.sql.expressionrrsqlalchemy_utils.functionsrr compilesr+r-r5rHrZr_rarirnrrrrus#>?2 :z 8    H   /l  AH)j-) *+, Ar