o hYg@sddlmZddlZddlZddlmZddlmZddlmZddlmZddlm Z ddlm Z dd lm Z dd lm Z dd lm Z dd lmZdd lmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlm Z ddl!m"Z"ddl#m$Z$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/dd&l0m1Z1d'd(l2m3Z3d'd)l4m5Z5d'd*l6m7Z7d'd+l6m8Z8d'd,l9m:Z:d'd-l9m;Z;d'd.l3mZ>dd1lm?Z?dd2l@mAZAdd3lBmCZCdd4lDmEZEdd5lFmGZGdd6lFmHZHdd7lmIZIdd8lmJZJdd9lmKZKdd:lLmMZMdd;lLmNZNddlRmSZSd'd?lTmUZUd'd@lVmWZWeXeYZZGdAdBdBe1Z[GdCdDdDe(Z\e*e/dEdpdLdMZ]e*e\dEdqdNdOZ^e*e)dEdrdQdRZ_e*e.dEdsdTdUZ`e;adVe:adVdWe7jbcdXGdYdZdZe7jbZde5jefeddtd^d_Zge5jhfedudddeZidvdfdgZjdwdjdkZkdxdndoZldS)y) annotationsN)Any)cast)Dict)List)Optional)Sequence)Tuple) TYPE_CHECKING)Union)Column)literal_column)Numeric)text)types)BIGINT)ExcludeConstraint)INTEGER) CreateIndex) operators) ColumnClause) TextClause)UnaryExpression)FunctionElement)NULLTYPE) alter_column) alter_table) AlterColumn) ColumnComment)compiles)format_column_name)format_table_name) format_type)IdentityColumnDefault) RenameTable) DefaultImpl)util)render)ops) schemaobj)BatchOperations) Operations) sqla_compat)Literal)Index)UniqueConstraint)ARRAY) PGDDLCompiler)HSTORE)JSON)JSONB) ClauseElement) ColumnElement) quoted_name)MetaData)Table) TypeEngine)_ServerDefault)AutogenContext)_f_name)MigrationContextcseZdZdZdZejddhfZd]d d Zd dZddZ          d^d_fd%d& Z d'd(Z d)d*Z d`d-d.Z dad1d2Zdbd6d7Zdcd8d9Zddds  zAPostgresqlImpl.correct_for_autogen_constraints..)remover.sqla_2_skip_functional_indexes)rRconn_unique_constraints conn_indexesmetadata_unique_constraintsmetadata_indexesdoubled_constraintsixrIrIrTcorrect_for_autogen_constraintss z.PostgresqlImpl.correct_for_autogen_constraintsexpr remove_suffixcCs|dddd}|jdur||jjdd}|r@|ddkr@|ddkr@|d d}|r@|ddkr@|ddks,d |vrKtd d|}|r[||r[|dt| }|S) N"r^r_.r()rz::z (::[\w ]+\w))lowerreplacerLrXrgrhendswithlen)rRrDrrrIrIrT_cleanup_index_exprs  z"PostgresqlImpl._cleanup_index_exprexpr7cCsd}t|tr[|jdur|j}nF|j}t|jtr|jj}nd}|dur8|tjkr.d} |S|tjkr5d} |S|tjkrG|tjkrGd} |S|tjkrS|tjkrSd} |St|ts|S)Nr^z ascz nulls lastz asc nulls lastz nulls first) rdrmodifierelementrasc_op nullslast_opdesc_op nullsfirst_op)rRr to_removeopinner_oprIrIrT_default_modifierss:         z!PostgresqlImpl._default_modifiersitemUnion[Index, UniqueConstraint]Tuple[Any, ...]cCs|jdrdSdS)Npostgresql_nulls_not_distinct)nulls_not_distinctrI)dialect_kwargsrK)rRrrIrIrT _dialect_sig6s zPostgresqlImpl._dialect_sigcs$tfddjDS)Nc3sD|]}jgt|tr|dfn ||fRVqdS)r^N)rrdre_compile_elementr)rerDrRrIrT @s   z2PostgresqlImpl.create_index_sig..)tuple expressionsr)rRrDrIrrTcreate_index_sig?s   zPostgresqlImpl.create_index_sigconstr1cCs"ttdd|jD||S)NcSsg|]}|jqSrI)rX)rrSrIrIrT Psz?PostgresqlImpl.create_unique_constraint_sig..)rsortedcolumnsr)rRrrIrIrTcreate_unique_constraint_sigLs z+PostgresqlImpl.create_unique_constraint_sigreflected_optionsDict[str, Any]kindcCs*|di}|ds|dd|S)Ndialect_optionsrH)rKcopyr)rRrroptionsrIrIrT adjust_reflected_dialect_optionsSs  z/PostgresqlImpl.adjust_reflected_dialect_optionsrcCs|j|jddddjS)NTF) literal_binds include_table)dialectcompile_kwargs)compilerstring)rRrrIrIrTr\s zPostgresqlImpl._compile_elementis_server_defaultboolis_indexc s0|r t|ts |}tj|f||d|S)zdRender a SQL expression that is typically a server default, index expression, etc. )rr)rdr self_grouprrender_ddl_sql_expr)rRrrrrErrIrTrbsz"PostgresqlImpl.render_ddl_sql_exprr<autogen_contextr>Union[str, Literal[False]]cCsFt|j}|ds dSt|d|jr!t|d|j}|||SdS)Nzsqlalchemy.dialects.postgresqlFz_render_%s_type)rf __module__ startswithhasattr__visit_name__getattr)rRrzrmodmethrIrIrT render_typeys   zPostgresqlImpl.render_typer4cCttt||ddS)N text_typez(.+?\(.*text_type=)rrer)_render_type_w_subtyperRrzrrIrIrT_render_HSTORE_type z"PostgresqlImpl._render_HSTORE_typer2cCr)N item_typez(.+?\()rrrIrIrT_render_ARRAY_typerz!PostgresqlImpl._render_ARRAY_typer5cCrN astext_typez(.+?\(.*astext_type=)rrrIrIrT_render_JSON_typerz PostgresqlImpl._render_JSON_typer6cCrrrrrIrIrT_render_JSONB_typerz!PostgresqlImpl._render_JSONB_type)rDr0rErrFrG) NFNNNNNNNN)rtrerurervrwrbrxrXryrzr{r|ryr}rwr~r{rrrrwrrwrErrFrG)rDr0rrerrerFre)rr7rFre)rrrFr)rDr0rFr)rr1rFr)rrrrerFr)rr7rFre)FF) rr7rrrrrErrFre)rzr<rr>rFr)rzr4rr>rFre)rzr2rr>rFre)rzr5rr>rFre)rzr6rr>rFre)__name__r __qualname__ __dialect__transactional_ddlr& type_synonymsrUr]rsrrrrrrrrrrrrrrrr __classcell__rIrIrrTrALsJ  /4&   "      rAcseZdZd fdd ZZS) rrXrerurzr<rFrGc s8|dd}tj||fi|t||_||_dS)Nr)rr__init__rO to_instancerzr)rRrXrurzrErrrIrTrs   zPostgresqlColumnType.__init__)rXrerurerzr<rFrG)rrrrrrIrIrrTrsrrBrr%compilerr3rFrecKs"dt||j|jt||jdfS)Nz%s RENAME TO %s)rrtr|r"new_table_namerrrErIrIrTvisit_rename_tables rcKsDdt||j|jt||jdt||j|jrd|jfSdfS)Nz %s %s %s %szTYPE %szUSING %sr^)rrtr|rrur#rzrrrIrIrTvisit_column_types rrcKsJd}|jdur|j|jtnd}|jt||j|jt ||j |dS)Nz9COMMENT ON COLUMN {table_name}.{column_name} IS {comment}NULL)rtrucomment) r sql_compilerrender_literal_valuerOStringformatr"rtr|r!ru)rrrEddlrrIrIrTvisit_column_comments    r r$c Ksdt||j|jt||jf}|jdur|d7}|S|jdur.|d7}|||j7}|S|j |j|j\}}}|j}t |D]&}|dkrS|d|j rNdnd7}qA|d| t jd i|t||i7}qA|S) Nz%s %s z DROP IDENTITYzADD alwayszSET GENERATED %s ALWAYSz BY DEFAULTzSET %s rI)rrtr|rrurrvisit_identity_columnimpl_compare_identity_defaultrr get_identity_optionsr.Identityr)rrrErdiff_identityattrrIrIrTrs0       rcreate_exclude_constraintbatch_create_exclude_constraintexclude_constraintc@s^eZdZdZdZ   d'd(ddZed)ddZ d*d+ddZed,d"d#Z ed-d%d&Z dS).CreateExcludeConstraintOpz0Represent a create exclude constraint operation.excludeNconstraint_namesqla_compat._ConstraintNamertUnion[str, quoted_name]elementsIUnion[Sequence[Tuple[str, str]], Sequence[Tuple[ColumnClause[Any], str]]]where)Optional[Union[ColumnElement[bool], str]]r|ry_orig_constraintOptional[ExcludeConstraint]rFrGcKs.||_||_||_||_||_||_||_dSrV)rrtr r"r|r$rE)rRrrtr r"r|r$rErIrIrTrs  z"CreateExcludeConstraintOp.__init__r\rc CsDt|}||j|jdd|jDtd|j|j||j|j|j d S)NcSsg|] \}}}||fqSrIrI)rrrXrrIrIrTr/sz=CreateExcludeConstraintOp.from_constraint..zColumnElement[bool] | None)r"r|r$ deferrable initiallyr) r._table_for_constraintrX _render_exprsrr"r|r&r'r)clsr\constraint_tablerIrIrTfrom_constraint's  z)CreateExcludeConstraintOp.from_constraintmigration_contextOptional[MigrationContext]cCsx|jdur|jSt|}|j|j|jd}t|j|j|j d|j }|j D] \}}}| t |tq'|||S)N)r|)rXr")r$r+ SchemaObjectsrLrtr|rr rr"rEr)rNr rappend_constraint)rRr- schema_objtexclrrXoperrIrIrT to_constraint;s&    z'CreateExcludeConstraintOp.to_constraint operationsr-rerrEOptional[Table]cOs||||fi|}||S)aIssue an alter to create an EXCLUDE constraint using the current migration context. .. note:: This method is Postgresql specific, and additionally requires at least SQLAlchemy 1.0. e.g.:: from alembic import op op.create_exclude_constraint( "user_excl", "user", ("period", "&&"), ("group", "="), where=("group != 'some group'"), ) Note that the expressions work the same way as that of the ``ExcludeConstraint`` object itself; if plain strings are passed, quoting rules must be applied manually. :param name: Name of the constraint. :param table_name: String name of the source table. :param elements: exclude conditions. :param where: SQL expression or SQL string with optional WHERE clause. :param deferrable: optional bool. If set, emit DEFERRABLE or NOT DEFERRABLE when issuing DDL for this constraint. :param initially: optional string. If set, emit INITIALLY when issuing DDL for this constraint. :param schema: Optional schema name to operate within. )invoke)r*r6rrtr rErrIrIrTrQs+ z3CreateExcludeConstraintOp.create_exclude_constraintr,cOs.|jj|d<|||jj|fi|}||S)a3Issue a "create exclude constraint" instruction using the current batch migration context. .. note:: This method is Postgresql specific, and additionally requires at least SQLAlchemy 1.0. .. seealso:: :meth:`.Operations.create_exclude_constraint` r|)rr|rtr8)r*r6rr rErrIrIrTrs  z9CreateExcludeConstraintOp.batch_create_exclude_constraint)NNN)rrrtrr r!r"r#r|ryr$r%rFrG)r\rrFrrV)r-r.rFr) r6r-rrertrer rrErrFr7)r6r,rrer rrEr) rrr__doc__constraint_typer classmethodr,r5rrrIrIrIrTrs     -rrr>rcCst||ddS)NT)alter)_exclude_constraintr5)rrrIrIrT_add_exclude_constraintsr>r\rnamespace_metadatar:cCs&td||}|dur |St||dS)NrF)r)_user_defined_renderr=)r\rr?renderedrIrIrT!_render_inline_exclude_constraints  rBcCs|j}|dur |ddS)Nz*from sqlalchemy.dialects import postgresqlz postgresql.)importsadd)rrCrIrIrT_postgresql_autogenerate_prefixs rEr<rcs*gj}jrdtjfjrdtjfjr,dtjf|s@|r@jjr@dt jjf|sQj rQdt j ffdd}|rt t j g}|ss|t t jj g7}| |dtd |d S|}d td |d S) Nr&r'rr|rXcsNfddjD}jdur|dtj|ddD|S)Ncs$g|]\}}}dt||fqS)z(%s, %r))_render_potential_column)rsqltextrXopstring)rrIrTrszC_exclude_constraint..do_expr_where_opts..zwhere=%scSsg|] \}}d||fqS)z%s=%rrI)rkvrIrIrTrs)r)r"appendr)_render_potential_exprextend)argsrr\optsrIrTdo_expr_where_optss  z/_exclude_constraint..do_expr_where_optsz-%(prefix)screate_exclude_constraint(%(args)s)z, )prefixrNz%%(prefix)sExcludeConstraint(%(args)s)) _has_batchr&rKrer'rrLr|r)_identrX_render_gen_namereprrM_alembic_autogenerate_prefixjoinrE)r\rr< has_batchrQrNrIrOrTr=s<  r=valueGUnion[ColumnClause[Any], Column[Any], TextClause, FunctionElement[Any]]cCsJt|tr|jr d}nd}|t||jdStj||t|ttfdS)Nz"%(prefix)sliteral_column(%(name)r)z%(prefix)scolumn(%(name)r))rRrX) wrap_in_text) rdr is_literalr)_sqlalchemy_autogenerate_prefixrXrLrr)rZrtemplaterIrIrTrFs  rF)rr%rr3rFre)rrrr3rFre)rrrr3rFre)rr$rr3)rr>rrrFre)r\rrr>r?r:rFre)rr>rFre)r\rrr>r<rrFre)rZr[rr>rFre)m __future__rloggingrgtypingrrrrrrr r r sqlalchemyr r rrrrOsqlalchemy.dialects.postgresqlrrrsqlalchemy.schemarsqlalchemy.sqlrsqlalchemy.sql.elementsrrrsqlalchemy.sql.functionsrsqlalchemy.typesrbaserrrrr r!r"r#r$r%rr&r^r( autogenerater)r6r*r+operations.baser,r-r.r/r0r1$sqlalchemy.dialects.postgresql.arrayr2#sqlalchemy.dialects.postgresql.baser3%sqlalchemy.dialects.postgresql.hstorer4#sqlalchemy.dialects.postgresql.jsonr5r6r7r8r9sqlalchemy.sql.schemar:r;sqlalchemy.sql.type_apir<r=autogenerate.apir>autogenerate.renderr?runtime.migrationr@ getLoggerrrrArrrr rregister_operationAddConstraintOpregister_add_constraintr renderers dispatch_forr>_constraint_renderersrBrEr=rFrIrIrIrTs                                                              e    "      <