#Dg d dl mZ d dlZd dlmZ d dlmZ d dlmZ d dlmZ d dlmZ d dlm Z d d lm
Z
d d
lm Z d d lm Z d d l
mZ d
dlmZ d
dlmZ ddlmZ ddlmZ e rZd dlmZ d dlmZ d dlmZ d dlmZ d dlmZ ddl m Z ddl m Z ddl m Z ddl m!Z! dd l"m#Z# dd l"m$Z$ dd l"m%Z% dd l&m'Z' dd l(m)Z) dd!l(m*Z* dGd(Z+dHd*Z, dIdJd>Z-dKdBZ. G dC dD Z/ G dE dF Z0dS )L ) annotationsN)Any)Callable)Dict)Iterator)Optional)Sequence)Set)
TYPE_CHECKING)Union)inspect )compare)render )util)ops)
Connection)Dialect) Inspector)MetaData)
SchemaItem)Config) DowngradeOps)MigrationScript)
UpgradeOps)NameFilterParentNames)NameFilterType) RenderItemFnMigrationContext)Script)ScriptDirectorycontextr! metadatar returnr c T t | | }|j S )aB
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 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(),
Column("info", String(), table=),
schema=None,
),
),
(
"remove_table",
Table(
"bar",
MetaData(),
Column("data", VARCHAR(), table=),
schema=None,
),
),
(
"add_column",
None,
"foo",
Column("data", Integer(), table=),
),
[
(
"modify_nullable",
None,
"foo",
"x",
{
"existing_comment": None,
"existing_server_default": False,
"existing_type": INTEGER(),
},
True,
False,
)
],
(
"remove_column",
None,
"foo",
Column("old_data", VARCHAR(), table=),
),
]
: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)r$ r% migration_scripts j/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/alembic/autogenerate/api.pycompare_metadatar- + s* r *'8<< ' 0 0 2 22 r c t | | }t j dt j g t j g }t j || |S )a Produce 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)AutogenContextr r r r r _populate_migration_script)r$ r% autogen_contextr+ s r, r( r( sh $ %Wx@@@O*N2&&&r** &8HIII r. sa.op.F
up_or_down_op Union[UpgradeOps, DowngradeOps]sqlalchemy_module_prefixstralembic_module_prefixrender_as_batchboolimports
Sequence[str] render_itemOptional[RenderItemFn]migration_contextOptional[MigrationContext]user_module_prefix
Optional[str]c |||||d}|%ddl m} ddlm}
| j |
}t || } t
| | _ t j t j
| | S ) a* Render 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.
:param up_or_down_op: :class:`.UpgradeOps` or :class:`.DowngradeOps` object
:param sqlalchemy_module_prefix: module prefix for SQLAlchemy objects
:param alembic_module_prefix: module prefix for Alembic constructs
:param render_as_batch: use "batch operations" style for rendering
:param imports: sequence of import symbols to add
:param render_item: callable to render items
:param migration_context: optional :class:`.MigrationContext`
:param user_module_prefix: optional string prefix for user-defined types
.. versionadded:: 1.11.0
)r; r= rB r> rF Nr r r )DefaultDialect)dialect)opts) runtime.migrationr! sqlalchemy.engine.defaultrI configurer3 setr@ r _indent_render_cmd_body) r9 r; r= r> r@ rB rD rF rK r! rI r5 s r, render_python_coderR s : %=!6"* 0 D 888888<<<<<< 6 , 6"N$$
%%6TBBBO !'llO >
?? r.
template_argsDict[Any, Any]Nonec t | }t j g }t j || t j d|| }t j ||| dS )z6legacy, used by test_autogen_composition at the momentNr0 ) r3 r r r _produce_net_changesr reverser _render_python_into_templatevars)r$ rS r5 r) r+ s r, _render_migration_diffsrZ s
%W--O.$$K +>>>* !))++ +)= r. c e Zd ZU dZdZded< dZded< dZded< dZd ed
< dZ d ed < d(d)dZ
e j d*d Z
ej d+d Zd,d Zd-d%ZeZe j d& Ze j d' ZdS ).r3 zSMaintains configuration and state that's specific to an
autogenerate operation.NOptional[MetaData]r% zOptional[Connection]
connectionzOptional[Dialect]rJ zSet[str]r@ r! rD TrK Optional[dict] autogenerater? r& rU c n |r ||j rt j d ||j }|| dd n|x| _ }|r,|*|(|j !t j d|j j z | dd }| dd }g }g }|r| | |r| | || _ || _
|| _ | j "| j j | _
| j j | _ t | _ || _ d| _ d S )Nz^autogenerate can't use as_sql=True as it prevents querying the database for schema informationtarget_metadatazCan't proceed with --autogenerate option; environment script %s does not provide a MetaData object or sequence of objects to the context.include_object include_nameF)as_sqlr CommandErrorrK getr% scriptenv_py_locationappend_object_filters
_name_filtersrD bindr] rJ rO r@
_has_batch) selfrD r% rK r_ rb rc object_filters name_filterss r, __init__zAutogenContext.__init__G s~
!-!( . #6
<$)D 2:1ADHH& - - -x
!-!(4#K %+;=
"2D99xx55 2 ! !. 1 1 1 . - - - - )!2 ! - " 4 9DO 19DLuu $( %r. r c V | j t d t | j S )NzHcan't return inspector as this AutogenContext has no database connection)r] TypeErrorr
rn s r, inspectorzAutogenContext.inspector s3 ? "<
t'''r. Iterator[None]c # . K d| _ d V d| _ d S )NTF)rm rt s r,
_within_batchz AutogenContext._within_batch s!
r. namerG type_r parent_namesr c d|v r;|dk r|}n| dd }|r|d }|r |d||d< n||d< | j D ]} |||| s dS dS ) a Run the context's name filters and return True if the targets
should be part of the autogenerate operation.
This method should be run for every kind of name encountered within the
reflection side of an autogenerate operation, giving the environment
the chance to filter what names should be reflected as database
objects. The filters here are produced directly via the
:paramref:`.EnvironmentContext.configure.include_name` parameter.
schema_nametable
table_nameN.schema_qualified_table_nameFT)rf rk )rn ry rz r{ r r} fns r, run_name_filtersz AutogenContext.run_name_filters s L ( ( !
) - -lD A A
M *= 9 M# "
CL!>??
CML!>?$ B2dE<00
uu
4r. object_r reflected
compare_toOptional[SchemaItem]c > | j D ]} |||||| s dS dS )a Run 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)rj )rn r ry rz r r r s r, run_object_filtersz!AutogenContext.run_object_filters sC $ & B2gtUIzBB
uu
4r. c v g }t j | j D ] }| |j |S )ai Return 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.
)r to_listr% extend
sorted_tables)rn resultms r, r z AutogenContext.sorted_tables s@ dm,, + +A MM!/ * * * *
r. c
Z i }t j | j D ]}t | t |j }|rz4AutogenContext.table_key_to_table.. s& K K## K K K K K Kr. )
r r r% rO intersectiontables
ValueErrorjoinsortedupdate)rn r r intersects r, table_key_to_tablez!AutogenContext.table_key_to_table s dm,, $ $AF 00QX ??I
+yy K K 9J9J K K KKKM
MM!( # # # #
r. )NNT)
rD r! r% r\ rK r^ r_ r? r& rU )r& r )r& rv )ry rG rz r r{ r r& r? ) r r ry rG rz r r r? r r r& r? )__name__
__module__ __qualname____doc__r% __annotations__r] rJ r@ rD rq r memoized_propertyru
contextlibcontextmanagerrx r r run_filtersr r r8 r. r, r3 r3 sp $(H''''" (,J++++ "&G%%%% G +/....N
(, # ! :& :& :& :& :&x
( ( ( (
$ $ $ $L 0 %K
r. r3 c N e Zd ZdZ d d d
Zd dZd!dZd!dZd"dZd#dZ d$d Z
dS )%RevisionContextz^Maintains configuration and state that's specific to a revision
file generation operation.Nconfigr script_directoryr# command_argsDict[str, Any]process_revision_directivesOptional[Callable]r& rU c || _ || _ || _ || _ d|i| _ | g| _ d S )Nr )r r r r rS _default_revisiongenerated_revisions)rn r r r r s r, rq zRevisionContext.__init__ sQ 0 (+F( f
%)$:$:$<$<#= r. r+ r Optional[Script]c
| j }t |dd rV| j }t |_ |j r |j |j t j ||| |j J | j
j |j |j fd|j
|j |j |j |j d|S )N
_needs_renderFT)refreshheadsplice
branch_labels version_path
depends_on)rS copygetattr_last_autogen_contextrO r@ r r rY r1 r generate_revisionmessager r branch_labelr r )rn r+ rS r5 s r,
_to_scriptzRevisionContext._to_script s )-(:(?(?(A(A
#_e < <
" 8O '*eeO # '
I '../?/GHHH 3 !1=
&2226t$6 # $
!&#**7)6'2
r. revtuplerD r! c 4 | ||d d S )NT_run_environmentrn r rD s r, run_autogeneratez RevisionContext.run_autogenerate/ s#
c#4d;;;;;r. c 4 | ||d d S )NFr r s r, run_no_autogeneratez#RevisionContext.run_no_autogenerate4 s#
c#4e<<<< > > > >"
<< < < <
= = = =
62 62 62 62p
6 6 6 6 6 6r. r )r$ r! r% r r& r )r$ r! r% r r& r )r6 r7 Fr8 NNN)r9 r: r; r< r= r< r> r? r@ rA rB rC rD rE rF rG r& r< )r$ r! rS rT r& rU )1
__future__r r typingr r r r r r r
r r
sqlalchemyr
r r r
operationsr sqlalchemy.enginer r r sqlalchemy.sql.schemar r r r operations.opsr r r runtime.environmentr r r rL r! script.baser" r# r- r( rR rZ r3 r r8 r. r, r s " " " " " " .,,,,,,))))))++++++......000000 ------000000++++++;;;;;;444444222222444444$$$$$$------z3 z3 z3 z3z B %*!& ! *.48(,0 0 0 0 0f *j j j j j j j jZF6 F6 F6 F6 F6 F6 F6 F6 F6 F6r.