python类create_unique_constraint()的实例源码

def upgrade():
    # ### commands auto generated by Alembic - please adjust! ###
    op.create_unique_constraint('uq_dataset_problem_idtable_name_entity_id', 'dataset', ['problem_id', 'table_name', 'entity_id'])
    op.drop_constraint('uq_dataset_table_name_entity_id', 'dataset', type_='unique')
    # ### end Alembic commands ###

def downgrade():
    # ### commands auto generated by Alembic - please adjust! ###
    op.create_unique_constraint('uq_dataset_table_name_entity_id', 'dataset', ['table_name', 'entity_id'])
    op.drop_constraint('uq_dataset_problem_idtable_name_entity_id', 'dataset', type_='unique')
    # ### end Alembic commands ###

def upgrade():
    op.create_unique_constraint('uq_dataset_label_probability_data_id_label_id', 'dataset_label_probability', ['data_id', 'label_id'])

def upgrade():
    # ### commands auto generated by Alembic - please adjust! ###
    op.create_unique_constraint(None, 'law_group', ['name'])
    op.create_unique_constraint(None, 'law_status', ['name'])
    # ### end Alembic commands ###

def upgrade():
    # ### commands auto generated by Alembic - please adjust! ###
    op.drop_table('email_mailing_list')
    op.drop_table('email')
    op.add_column('mailing_list', sa.Column('url', sa.String(length=50), nullable=True))
    op.create_unique_constraint(None, 'mailing_list', ['url'])
    # ### end Alembic commands ###

def upgrade():
    # ### commands auto generated by Alembic - please adjust! ###
    op.create_unique_constraint('_cluster_name_uc', 'user', ['cluster_id', 'name'])
    # ### end Alembic commands ###

def upgrade():
    # ### commands auto generated by Alembic - please adjust! ###
    op.create_unique_constraint('_node_mountpoint_what_uc', 'mountpoint', ['node_id', 'what'])
    op.create_unique_constraint('_node_mountpoint_where_uc', 'mountpoint', ['node_id', 'where'])
    # ### end Alembic commands ###

def upgrade():
    ### commands auto generated by Alembic - please adjust! ###
    op.add_column(
        'reference_set',
        sa.Column('next_tiledb_column_offset', sa.BigInteger(), nullable=False, default=0))
    op.add_column(
        'reference', 
        sa.Column('tiledb_column_offset', sa.BigInteger(), nullable=True))
    op.alter_column('reference', 'length', existing_type=sa.BIGINT(), nullable=False)
    op.alter_column('reference', 'name', existing_type=sa.TEXT(), nullable=False)
    op.create_unique_constraint('unique_name_per_reference_set_constraint', 'reference', 
        ['reference_set_id', 'name'])
    op.create_index('unique_reference_set_id_offset_idx', 'reference', 
        ['reference_set_id', 'tiledb_column_offset'], 
        unique=True)
    op.drop_column('reference', 'offset')
    # Trigger on reference insertion
    op.execute('''\
    CREATE OR REPLACE FUNCTION increment_next_column_in_reference_set_pgsql()
      RETURNS trigger AS $increment_next_column_in_reference_set_pgsql$
    BEGIN
      UPDATE reference SET tiledb_column_offset=(select next_tiledb_column_offset from reference_set where id=NEW.reference_set_id) where NEW.tiledb_column_offset IS NULL and id=NEW.id;
      UPDATE reference_set SET next_tiledb_column_offset=next_tiledb_column_offset+NEW.length WHERE id = NEW.reference_set_id;
      RETURN NEW;
    END;
    $increment_next_column_in_reference_set_pgsql$ LANGUAGE plpgsql;
    CREATE TRIGGER increment_next_column_in_reference_set AFTER INSERT ON reference
    FOR EACH ROW EXECUTE PROCEDURE increment_next_column_in_reference_set_pgsql();
    ''')
    ### end Alembic commands ###

def create_unique_constraint(self, name, local_cols, **kw):
        """Issue a "create unique constraint" instruction using the
        current batch migration context.

        The batch form of this call omits the ``source`` and ``schema``
        arguments from the call.

        .. seealso::

            :meth:`.Operations.create_unique_constraint`

        """
        kw['schema'] = self.impl.schema
        return super(BatchOperations, self).create_unique_constraint(
            name, self.impl.table_name, local_cols, **kw)

def downgrade():
    # ### commands auto generated by Alembic - please adjust! ###
    op.create_unique_constraint('sendmessage_to_key', 'sendmessage', ['to'])
    op.create_unique_constraint('sendmessage_state_key', 'sendmessage', ['state'])
    op.create_unique_constraint('sendmessage_message_key', 'sendmessage', ['message'])
    # ### end Alembic commands ###

def upgrade():
    op.create_unique_constraint(
        op.f('uq_txn_reconciles_ofx_account_id'),
        'txn_reconciles',
        ['ofx_account_id', 'ofx_fitid']
    )
    op.create_unique_constraint(
        op.f('uq_txn_reconciles_txn_id'),
        'txn_reconciles',
        ['txn_id']
    )

def upgrade():
    """Upgrade the database to a newer revision."""
    # commands auto generated by Alembic - please adjust! ###
    op.add_column('analysis_requests', sa.Column('parent_id', sa.Integer(), nullable=True))
    op.add_column('worker_results', sa.Column('worker_id', sa.String(length=64), nullable=True))
    op.create_unique_constraint(None, 'worker_results', ['worker_id'])
    # end Alembic commands ###

def upgrade():
    """Upgrade the database to a newer revision."""
    # commands auto generated by Alembic - please adjust! ###
    op.create_table('stacks',
                    sa.Column('id', sa.Integer(), nullable=False),
                    sa.Column('is_ref_stack', sa.Boolean(), nullable=False),
                    sa.Column('stack_json', postgresql.JSONB(), nullable=False),
                    sa.PrimaryKeyConstraint('id'))
    op.add_column('similar_stacks', sa.Column('analysis', postgresql.JSONB()))
    op.add_column('similar_stacks', sa.Column('similar_stack_id', sa.Integer(), nullable=False))
    op.add_column('similar_stacks', sa.Column('similarity_value', sa.Float(), nullable=False))
    op.add_column('similar_stacks', sa.Column('stack_id', sa.Integer(), nullable=False))
    op.create_unique_constraint('sim_unique', 'similar_stacks', ['stack_id', 'similar_stack_id'])
    op.drop_constraint('similar_stacks_appstack_id_fkey', 'similar_stacks', type_='foreignkey')
    op.create_foreign_key(None, 'similar_stacks', 'stacks', ['stack_id'], ['id'])
    op.create_foreign_key(None, 'similar_stacks', 'stacks', ['similar_stack_id'], ['id'])
    op.drop_column('similar_stacks', 'dependency_list')
    op.drop_column('similar_stacks', 'appstack_id')
    op.drop_table('reference_stacks')
    op.drop_table('app_stacks')
    # end Alembic commands ###

def upgrade():
    """Upgrade the database to a newer revision."""
    # commands auto generated by Alembic - please adjust! ###
    op.create_unique_constraint(None, 'ecosystems', ['name'])
    # end Alembic commands ###

def upgrade():
    op.rename_table('knowledge_post_author', 'assoc_post_author')
    op.rename_table('knowledge_post_tags', 'assoc_post_tag')
    op.add_column('assoc_post_author', sa.Column('order', sa.Integer(), nullable=True))

    op.add_column('posts', sa.Column('uuid', sa.String(length=100), nullable=True))
    op.create_unique_constraint(None, 'posts', ['uuid'])

    op.add_column('pageviews', sa.Column('object_action', sa.String(length=100), nullable=True))
    op.add_column('pageviews', sa.Column('version', sa.String(length=100), nullable=True))

def upgrade():
    # ### commands auto generated by Alembic - please adjust! ###
    op.add_column('repository', sa.Column('external_id', sa.String(length=64), nullable=True))
    op.add_column('repository', sa.Column('provider', zeus.db.types.enum.StrEnum(), nullable=False))
    op.create_unique_constraint('unq_external_id', 'repository', ['provider', 'external_id'])
    # ### end Alembic commands ###

def upgrade():
    # ### commands auto generated by Alembic - please adjust! ###
    op.drop_constraint('unq_repo_name', 'repository', type_='unique')
    op.create_unique_constraint('unq_repo_name', 'repository', ['provider', 'owner_name', 'name'])
    # ### end Alembic commands ###

def downgrade():
    # ### commands auto generated by Alembic - please adjust! ###
    op.drop_constraint('unq_repo_name', 'repository', type_='unique')
    op.create_unique_constraint('unq_repo_name', 'repository', ['owner_name', 'name'])
    # ### end Alembic commands ###

def downgrade():
    # ### commands auto generated by Alembic - please adjust! ###
    op.add_column('filecoverage', sa.Column(
        'job_id', postgresql.UUID(), autoincrement=False, nullable=False))
    op.drop_constraint(None, 'filecoverage', type_='foreignkey')
    op.create_foreign_key('filecoverage_job_id_fkey', 'filecoverage', 'job', [
                          'job_id'], ['id'], ondelete='CASCADE')
    op.create_unique_constraint(
        'unq_job_filname', 'filecoverage', ['job_id', 'filename'])
    op.drop_constraint('unq_coverage_filname', 'filecoverage', type_='unique')
    op.drop_index(op.f('ix_filecoverage_build_id'), table_name='filecoverage')
    op.drop_column('filecoverage', 'build_id')
    # ### end Alembic commands ###

def downgrade():
    # ### commands auto generated by Alembic - please adjust! ###
    op.create_unique_constraint('unq_external_id', 'repository', ['provider', 'external_id'])
    op.create_unique_constraint('repository_url_key', 'repository', ['url'])
    op.create_unique_constraint('repository_name_key', 'repository', ['name'])
    op.drop_constraint('unq_repo_name', 'repository', type_='unique')
    op.drop_constraint('unq_repo_external_id', 'repository', type_='unique')
    op.drop_column('repository', 'owner_name')
    # ### end Alembic commands ###