o 8cxF@sdZddlZddlmZddlmZddlmZddlmZdd lm Z d d Z d d Z      dddZ ddZ GdddeZGdddeZdS)zXProvide the 'autogenerate' feature which can produce migration operations automatically.N)inspect)compare)render)util)opscCst||}|jS)a Compare a database schema to that given in a :class:`~sqlalchemy.schema.MetaData` instance. The database connection is presented in the context of a :class:`.MigrationContext` object, which provides database connectivity as well as optional comparison functions to use for datatypes and server defaults - see the "autogenerate" arguments at :meth:`.EnvironmentContext.configure` for details on these. The return format is a list of "diff" directives, each representing individual differences:: from alembic.migration import MigrationContext from alembic.autogenerate import compare_metadata from sqlalchemy.schema import SchemaItem from sqlalchemy.types import TypeEngine from sqlalchemy import (create_engine, MetaData, Column, Integer, String, Table, text) import pprint engine = create_engine("sqlite://") with engine.begin() as conn: conn.execute(text(''' create table foo ( id integer not null primary key, old_data varchar, x integer )''')) conn.execute(text(''' create table bar ( data varchar )''')) metadata = MetaData() Table('foo', metadata, Column('id', Integer, primary_key=True), Column('data', Integer), Column('x', Integer, nullable=False) ) Table('bat', metadata, Column('info', String) ) mc = MigrationContext.configure(engine.connect()) diff = compare_metadata(mc, metadata) pprint.pprint(diff, indent=2, width=20) Output:: [ ( 'add_table', Table('bat', MetaData(bind=None), Column('info', String(), table=), schema=None)), ( 'remove_table', Table(u'bar', MetaData(bind=None), Column(u'data', VARCHAR(), table=), schema=None)), ( 'add_column', None, 'foo', Column('data', Integer(), table=)), ( 'remove_column', None, 'foo', Column(u'old_data', VARCHAR(), table=None)), [ ( 'modify_nullable', None, 'foo', u'x', { 'existing_server_default': None, 'existing_type': INTEGER()}, True, False)]] :param context: a :class:`.MigrationContext` instance. :param metadata: a :class:`~sqlalchemy.schema.MetaData` instance. .. seealso:: :func:`.produce_migrations` - produces a :class:`.MigrationScript` structure based on metadata comparison. )produce_migrations upgrade_opsas_diffs)contextmetadatamigration_scriptrN/var/www/html/gps/gps/lib/python3.10/site-packages/alembic/autogenerate/api.pycompare_metadatas [ rcCs8t||d}tjdtgtgd}t|||S)aProduce a :class:`.MigrationScript` structure based on schema comparison. This function does essentially what :func:`.compare_metadata` does, but then runs the resulting list of diffs to produce the full :class:`.MigrationScript` object. For an example of what this looks like, see the example in :ref:`customizing_revision`. .. seealso:: :func:`.compare_metadata` - returns more fundamental "diff" data from comparing a schema. )r Nrev_idr downgrade_ops)AutogenContextrMigrationScript UpgradeOps DowngradeOpsr_populate_migration_script)r r autogen_contextrrrrr ms  r sa.op.Frc Csd||||d}|durddlm}ddlm} |j| d}t||d} t|| _t t || S) zRender Python code given an :class:`.UpgradeOps` or :class:`.DowngradeOps` object. This is a convenience function that can be used to test the autogenerate output of a user-defined :class:`.MigrationScript` structure. )sqlalchemy_module_prefixalembic_module_prefix render_itemrender_as_batchNr)MigrationContextr)DefaultDialect)dialect)opts) runtime.migrationr!sqlalchemy.engine.defaultr" configurersetimportsr_indent_render_cmd_body) up_or_down_oprrr r)rmigration_contextr$r!r"rrrrrender_python_codes      r.cCsDt|}tg}t||tjd||d}t|||dS)z6legacy, used by test_autogen_composition at the momentNr) rrrr_produce_net_changesrreverser _render_python_into_templatevars)r template_argsrr rrrr_render_migration_diffss  r3c@seZdZdZdZ dZ dZ dZ dZ dddZ e j ddZ e jdd Zd d Zd d ZeZe j ddZe j ddZdS)rzSMaintains configuration and state that's specific to an autogenerate operation.NTc Cs|r|dur|jrtd|dur|j}|dur|ddn||_}|r<|dur<|dur<|jdur)rBnametype_ parent_namesrMrKfnrrrrun_name_filters=s"     zAutogenContext.run_name_filterscCs&|jD] }||||||sdSqdS)aRun the context's object filters and return True if the targets should be part of the autogenerate operation. This method should be run for every kind of object encountered within an autogenerate operation, giving the environment the chance to filter what objects should be included in the comparison. The filters here are produced directly via the :paramref:`.EnvironmentContext.configure.include_object` parameter. FT)r=)rBobject_rOrP reflected compare_torRrrrrun_object_filters_s z!AutogenContext.run_object_filterscCs&g}t|jD]}||jq|S)aaReturn an aggregate of the :attr:`.MetaData.sorted_tables` collection(s). For a sequence of :class:`.MetaData` objects, this concatenates the :attr:`.MetaData.sorted_tables` collection for each individual :class:`.MetaData` in the order of the sequence. It does **not** collate the sorted tables collections. )rto_listr extend sorted_tables)rBresultmrrrrZrs zAutogenContext.sorted_tablescCs^i}t|jD]$}t|t|j}|r&tddddt|D| |jq|S)aReturn an aggregate of the :attr:`.MetaData.tables` dictionaries. The :attr:`.MetaData.tables` collection is a dictionary of table key to :class:`.Table`; this method aggregates the dictionary across multiple :class:`.MetaData` objects into one dictionary. Duplicate table keys are **not** supported; if two :class:`.MetaData` objects contain the same table key, an exception is raised. z9Duplicate table keys across multiple MetaData objects: %sz, css|]}d|VqdS)z"%s"Nr).0keyrrr sz4AutogenContext.table_key_to_table..) rrXr r( intersectiontables ValueErrorjoinsortedupdate)rBr[r\ intersectrrrtable_key_to_tables z!AutogenContext.table_key_to_table)NNT)__name__ __module__ __qualname____doc__r r@r#r)r-rFrmemoized_propertyrI contextlibcontextmanagerrJrSrW run_filtersrZrgrrrrrs2  8  " rc@sLeZdZdZ dddZddZddZd d Zd d Zd dZ ddZ dS)RevisionContextz^Maintains configuration and state that's specific to a revision file generation operation.NcCs2||_||_||_||_d|i|_|g|_dS)Nconfig)rqscript_directory command_argsprocess_revision_directivesr2_default_revisiongenerated_revisions)rBrqrrrsrtrrrrFszRevisionContext.__init__c Csi}|jD] \}}|||qt|ddr0|j}t|_|jr)|j|jt ||||j j |j |j fd|j|j|j|j|jd|S)N _needs_renderFT)refreshheadsplice branch_labels version_path depends_on)r2items setdefaultgetattr_last_autogen_contextr(r)rerr1rrgenerate_revisionrmessageryrz branch_labelr|r})rBrr2kvrrrr _to_scripts0  zRevisionContext._to_scriptcC|||ddS)NT_run_environmentrBrevr-rrrrun_autogeneratez RevisionContext.run_autogeneratecCr)NFrrrrrrun_no_autogeneraterz#RevisionContext.run_no_autogeneratec Cs"|r!|jdr tdt|j|t|jdkr!td|jd}|jd}|jd}t|dd sF||j d_ ||j d_ d |_ n|jtjg|d |jtjg|d t||d |_}|rmt|||jrx||||j|jd}|r||||j|jD]}d |_ qdS)Nsqlz7Using --sql with --autogenerate does not make any senseheadsz"Target database is not up to date. upgrade_tokendowngrade_tokenrwFT)r)r)rCrt)rsrr8r(rr get_revisionsr$rvrupgrade_ops_listrdowngrade_ops_listrrw _upgrade_opsr<rr_downgrade_opsrrrrrrt) rBrr-rCrrrrhookrrrrsV             z RevisionContext._run_environmentc Cs^tj|jdp t|jdtgtg|jd|jd|jd|jd|jdd }|S) Nrrryrzrr|r}) rrr rryrzrr|r})rrrsrrrr)rBoprrrrus z!RevisionContext._default_revisionccs|jD]}||VqdSrG)rvr)rBgenerated_revisionrrrgenerate_scriptss z RevisionContext.generate_scriptsrG) rhrirjrkrFrrrrrurrrrrrps 2 rp)rrFrNN)rkrm sqlalchemyrrrr operationsrrr r.r3objectrrprrrrs(     _ &Y