def upgrade():
op.execute(sa.schema.CreateSequence(sa.Sequence('pod_states_id_seq')))
op.add_column('pod_states', sa.Column('id', sa.Integer(), nullable=False,
server_default=sa.text("nextval('pod_states_id_seq'::regclass)")))
op.execute("ALTER TABLE pod_states DROP CONSTRAINT pod_states_pkey, "
"ADD CONSTRAINT pod_states_pkey PRIMARY KEY (id);")
op.add_column('container_states', sa.Column('exit_code', sa.Integer(), nullable=True))
op.add_column('container_states', sa.Column('pod_state_id', sa.Integer(), nullable=True))
op.add_column('container_states', sa.Column('reason', sa.Text(), nullable=True))
op.create_index('ix_pod_id_start_time', 'pod_states', ['pod_id', 'start_time'], unique=True)
op.create_foreign_key('container_states_pod_state_id_fkey', 'container_states',
'pod_states', ['pod_state_id'], ['id'])
upgrade_data()
op.alter_column('container_states', 'pod_state_id',
existing_type=sa.INTEGER(), nullable=False)
op.drop_constraint(u'container_states_pod_id_fkey', 'container_states',
type_='foreignkey')
op.drop_column('container_states', 'pod_id')
python类alter_column()的实例源码
2e00e70316c0_link_container_and_pod_states.py 文件源码
项目:kuberdock-platform
作者: cloudlinux
项目源码
文件源码
阅读 31
收藏 0
点赞 0
评论 0
18d04a76914f_billing_fixes.py 文件源码
项目:kuberdock-platform
作者: cloudlinux
项目源码
文件源码
阅读 34
收藏 0
点赞 0
评论 0
def upgrade():
op.alter_column('kubes', 'name', existing_type=sa.VARCHAR(length=64),
nullable=False)
op.create_index('one_default', 'kubes', ['is_default'], unique=True,
postgresql_where=sa.text(u'kubes.is_default IS true'))
op.drop_constraint(u'kubes_is_default_key', 'kubes', type_='unique')
op.alter_column('packages', 'name', existing_type=sa.VARCHAR(length=64),
nullable=False)
op.alter_column('packages', 'prefix', existing_type=sa.VARCHAR(),
nullable=False)
op.alter_column('packages', 'suffix', existing_type=sa.VARCHAR(),
nullable=False)
session = Session(bind=op.get_bind())
session.query(PackageKube).filter(sa.or_(
PackageKube.package_id.is_(None), PackageKube.kube_id.is_(None),
)).delete()
session.commit()
op.alter_column('package_kube', 'kube_id', existing_type=sa.INTEGER(),
nullable=False)
op.alter_column('package_kube', 'package_id', existing_type=sa.INTEGER(),
nullable=False)
def upgrade():
### commands auto generated by Alembic - please adjust! ###
op.create_table('comments',
sa.Column('id', sa.Integer(), nullable=False),
sa.Column('body', sa.Text(), nullable=True),
sa.Column('body_html', sa.Text(), nullable=True),
sa.Column('timestamp', sa.DateTime(), nullable=True),
sa.Column('disabled', sa.Boolean(), nullable=True),
sa.Column('author_id', sa.Integer(), nullable=True),
sa.Column('post_id', sa.Integer(), nullable=True),
sa.ForeignKeyConstraint(['author_id'], ['users.id'], ),
sa.ForeignKeyConstraint(['post_id'], ['posts.id'], ),
sa.PrimaryKeyConstraint('id')
)
op.create_index(op.f('ix_comments_timestamp'), 'comments', ['timestamp'], unique=False)
op.alter_column(u'statistic_visitor', 'referred',
existing_type=mysql.VARCHAR(collation=u'utf8_unicode_ci', length=128),
nullable=True,
existing_server_default=sa.text(u"''"))
### end Alembic commands ###
def upgrade():
### commands auto generated by Alembic - please adjust! ###
op.create_table('machine_statistic',
sa.Column('id', sa.Integer(), nullable=False),
sa.Column('type', sa.String(length=64), nullable=True),
sa.Column('timestamp', sa.String(length=64), nullable=True),
sa.Column('userid', sa.String(length=64), nullable=True),
sa.Column('netcode', sa.String(length=64), nullable=True),
sa.Column('login_time', sa.DateTime(), nullable=True),
sa.PrimaryKeyConstraint('id'),
sa.UniqueConstraint('id')
)
op.create_index(op.f('ix_machine_statistic_login_time'), 'machine_statistic', ['login_time'], unique=False)
op.alter_column(u'statistic_visitor', 'referred',
existing_type=mysql.VARCHAR(collation=u'utf8_unicode_ci', length=128),
nullable=True,
existing_server_default=sa.text(u"''"))
### end Alembic commands ###
def downgrade():
### commands auto generated by Alembic - please adjust! ###
op.alter_column(u'users', 'user_id',
existing_type=sa.VARCHAR(length=100),
nullable=True)
op.alter_column(u'users', 'updated_at',
existing_type=postgresql.TIMESTAMP(),
nullable=True)
op.alter_column(u'users', 'name',
existing_type=sa.VARCHAR(length=100),
nullable=True)
op.alter_column(u'users', 'last_name',
existing_type=sa.VARCHAR(length=200),
nullable=True)
op.alter_column(u'users', 'email',
existing_type=sa.VARCHAR(length=150),
nullable=True)
op.alter_column(u'users', 'created_at',
existing_type=postgresql.TIMESTAMP(),
nullable=True)
op.drop_table('request_referral')
### end Alembic commands ###
def upgrade():
# ### commands auto generated by Alembic - please adjust! ###
op.alter_column('channels', 'owner_id',
existing_type=sa.VARCHAR(),
nullable=False)
op.alter_column('disabled_channels', 'channel_id',
existing_type=sa.VARCHAR(),
nullable=False)
op.alter_column('disabled_channels', 'last_vk_post_id',
existing_type=sa.INTEGER(),
nullable=False)
op.alter_column('disabled_channels', 'owner_id',
existing_type=sa.VARCHAR(),
nullable=False)
op.alter_column('disabled_channels', 'vk_group_id',
existing_type=sa.VARCHAR(),
nullable=False)
# ### end Alembic commands ###
def downgrade():
# ### commands auto generated by Alembic - please adjust! ###
op.alter_column('disabled_channels', 'vk_group_id',
existing_type=sa.VARCHAR(),
nullable=True)
op.alter_column('disabled_channels', 'owner_id',
existing_type=sa.VARCHAR(),
nullable=True)
op.alter_column('disabled_channels', 'last_vk_post_id',
existing_type=sa.INTEGER(),
nullable=True)
op.alter_column('disabled_channels', 'channel_id',
existing_type=sa.VARCHAR(),
nullable=True)
op.alter_column('channels', 'owner_id',
existing_type=sa.VARCHAR(),
nullable=True)
# ### end Alembic commands ###
4cf8bc3edb66_rename_tenant_to_project.py 文件源码
项目:neutron-dynamic-routing
作者: openstack
项目源码
文件源码
阅读 22
收藏 0
点赞 0
评论 0
def upgrade():
"""Code reused from
Change-Id: I87a8ef342ccea004731ba0192b23a8e79bc382dc
"""
inspector = get_inspector()
data = get_data()
for table, column in data:
alter_column(table, column)
indexes = inspector.get_indexes(table)
for index in indexes:
if 'tenant_id' in index['name']:
recreate_index(index, table)
5446559aecf7_txnreconcile_txn_id_not_null.py 文件源码
项目:biweeklybudget
作者: jantman
项目源码
文件源码
阅读 22
收藏 0
点赞 0
评论 0
def upgrade():
# When making changes to a column that has a foreign key, we need to drop
# and then re-add the constraint
op.execute('DELETE FROM txn_reconciles WHERE txn_id IS NULL;')
op.execute('LOCK TABLES txn_reconciles WRITE, transactions WRITE;')
op.drop_constraint('fk_txn_reconciles_txn_id_transactions',
'txn_reconciles', type_='foreignkey')
op.alter_column(
'txn_reconciles',
'txn_id',
existing_type=mysql.INTEGER(display_width=11),
nullable=False
)
op.create_foreign_key('fk_txn_reconciles_txn_id_transactions',
'txn_reconciles', 'transactions', ['txn_id'], ['id'])
op.execute('UNLOCK TABLES;')
def upgrade():
### commands auto generated by Alembic - please adjust! ###
op.add_column('comments', sa.Column('goodsID', sa.Integer(), nullable=True))
op.alter_column('comments', 'commentatorID',
existing_type=mysql.INTEGER(display_width=11),
nullable=True)
op.drop_constraint('comments_ibfk_2', 'comments', type_='foreignkey')
op.create_foreign_key(None, 'comments', 'goods', ['goodsID'], ['goodID'])
op.drop_column('comments', 'goodID')
op.add_column('goods', sa.Column('address', sa.String(length=128), nullable=False))
op.add_column('goods', sa.Column('poster', sa.String(length=128), nullable=False))
op.add_column('goods', sa.Column('times', sa.Integer(), nullable=True))
op.alter_column('orders', 'createDate',
existing_type=mysql.DATETIME(),
nullable=False)
### end Alembic commands ###
def downgrade():
### commands auto generated by Alembic - please adjust! ###
op.alter_column('orders', 'createDate',
existing_type=mysql.DATETIME(),
nullable=True)
op.drop_column('goods', 'times')
op.drop_column('goods', 'poster')
op.drop_column('goods', 'address')
op.add_column('comments', sa.Column('goodID', mysql.INTEGER(display_width=11), autoincrement=False, nullable=False))
op.drop_constraint(None, 'comments', type_='foreignkey')
op.create_foreign_key('comments_ibfk_2', 'comments', 'goods', ['goodID'], ['goodID'])
op.alter_column('comments', 'commentatorID',
existing_type=mysql.INTEGER(display_width=11),
nullable=False)
op.drop_column('comments', 'goodsID')
### end Alembic commands ###
def change_task(self):
# Task in elixir did not generate a row_type for use as discriminator
self.schedule('alter', op.add_column, 'task', Column('row_type', String(40)))
# Task in elixir's queue_id was NULLABLE, but should not be (Tasks HAVE to be in a Queue now)
self.schedule('alter', op.alter_column, 'task', 'queue_id', nullable=True)
# Rename of relationship foreign key Task.reserved_by_id -> reserved_by_party_id
old_name = 'reserved_by_id'
new_name = 'reserved_by_party_id'
self.schedule('drop_fk', op.drop_constraint, '%s_%s_fk' % ('task', old_name), 'task')
self.schedule('alter', op.alter_column, 'task', old_name, new_column_name=new_name)
self.schedule('create_fk', op.create_foreign_key, fk_name('task', new_name, 'party'), 'task', 'party', [new_name], ['id'])
self.schedule('drop_pk', op.drop_index, ix_name('task', 'reserved_by_id'))
self.schedule('indexes', op.create_index, ix_name('task','reserved_by_party_id'), 'task', ['reserved_by_party_id'])
def upgrade():
# ### commands auto generated by Alembic - please adjust! ###
op.alter_column('dataset', 'collection_date',
existing_type=mysql.DATETIME(),
type_=sa.Text(),
existing_nullable=True)
op.alter_column('dataset', 'latitude',
existing_type=mysql.FLOAT(),
type_=sa.Text(),
existing_nullable=True)
op.alter_column('dataset', 'longitude',
existing_type=mysql.FLOAT(),
type_=sa.Text(),
existing_nullable=True)
op.alter_column('user', 'admin',
existing_type=mysql.TINYINT(display_width=1),
type_=sa.Boolean(),
existing_nullable=True)
# ### end Alembic commands ###
def downgrade():
# ### commands auto generated by Alembic - please adjust! ###
op.alter_column('user', 'admin',
existing_type=sa.Boolean(),
type_=mysql.TINYINT(display_width=1),
existing_nullable=True)
op.alter_column('dataset', 'longitude',
existing_type=sa.Text(),
type_=mysql.FLOAT(),
existing_nullable=True)
op.alter_column('dataset', 'latitude',
existing_type=sa.Text(),
type_=mysql.FLOAT(),
existing_nullable=True)
op.alter_column('dataset', 'collection_date',
existing_type=sa.Text(),
type_=mysql.DATETIME(),
existing_nullable=True)
# ### end Alembic commands ###
d9530a529b3f_add_timezone_awareness_for_datetime.py 文件源码
项目:hotface
作者: linhanqiuinc24
项目源码
文件源码
阅读 22
收藏 0
点赞 0
评论 0
def downgrade():
connection = op.get_bind()
if connection.engine.dialect.name != "sqlite":
# user/models.py
op.alter_column('users', 'date_joined', type_=sa.DateTime(), existing_type=flaskbb.utils.database.UTCDateTime(timezone=True), existing_nullable=True)
op.alter_column('users', 'lastseen', type_=sa.DateTime(), existing_type=flaskbb.utils.database.UTCDateTime(timezone=True), existing_nullable=True)
op.alter_column('users', 'birthday', type_=sa.DateTime(), existing_type=flaskbb.utils.database.UTCDateTime(timezone=True), existing_nullable=True)
op.alter_column('users', 'last_failed_login', type_=sa.DateTime(), existing_type=flaskbb.utils.database.UTCDateTime(timezone=True), existing_nullable=True)
# message/models.py
op.alter_column('conversations', 'date_created', type_=sa.DateTime(timezone=False), existing_type=flaskbb.utils.database.UTCDateTime(timezone=True), existing_nullable=True)
op.alter_column('messages', 'date_created', type_=sa.DateTime(timezone=False), existing_type=flaskbb.utils.database.UTCDateTime(timezone=True), existing_nullable=True)
# forum/models.py
op.alter_column('topicsread', 'last_read', type_=sa.DateTime(timezone=False), existing_type=flaskbb.utils.database.UTCDateTime(timezone=True), existing_nullable=True)
op.alter_column('forumsread', 'last_read', type_=sa.DateTime(timezone=False), existing_type=flaskbb.utils.database.UTCDateTime(timezone=True), existing_nullable=True)
op.alter_column('forumsread', 'cleared', type_=sa.DateTime(timezone=False), existing_type=flaskbb.utils.database.UTCDateTime(timezone=True), existing_nullable=True)
op.alter_column('reports', 'reported', type_=sa.DateTime(timezone=False), existing_type=flaskbb.utils.database.UTCDateTime(timezone=True), existing_nullable=True)
op.alter_column('reports', 'zapped', type_=sa.DateTime(timezone=False), existing_type=flaskbb.utils.database.UTCDateTime(timezone=True), existing_nullable=True)
op.alter_column('posts', 'date_created', type_=sa.DateTime(timezone=False), existing_type=flaskbb.utils.database.UTCDateTime(timezone=True), existing_nullable=True)
op.alter_column('posts', 'date_modified', type_=sa.DateTime(timezone=False), existing_type=flaskbb.utils.database.UTCDateTime(timezone=True), existing_nullable=True)
op.alter_column('topics', 'date_created', type_=sa.DateTime(timezone=False), existing_type=flaskbb.utils.database.UTCDateTime(timezone=True), existing_nullable=True)
op.alter_column('topics', 'last_updated', type_=sa.DateTime(timezone=False), existing_type=flaskbb.utils.database.UTCDateTime(timezone=True), existing_nullable=True)
op.alter_column('forums', 'last_post_created', type_=sa.DateTime(timezone=False), existing_type=flaskbb.utils.database.UTCDateTime(timezone=True), existing_nullable=True)
58e7f2fc7ff7_set_translations_not_null.py 文件源码
项目:dila
作者: socialwifi
项目源码
文件源码
阅读 35
收藏 0
点赞 0
评论 0
def upgrade():
# ### commands auto generated by Alembic - please adjust! ###
op.execute("UPDATE translated_string SET base_string='' WHERE base_string is NULL")
op.alter_column('translated_string', 'base_string',
existing_type=sa.TEXT(),
nullable=False)
op.execute("UPDATE translated_string SET comment='' WHERE comment is NULL")
op.alter_column('translated_string', 'comment',
existing_type=sa.TEXT(),
nullable=False)
op.execute("UPDATE translated_string SET context='' WHERE context is NULL")
op.alter_column('translated_string', 'context',
existing_type=sa.TEXT(),
nullable=False)
op.execute("UPDATE translated_string SET translation='' WHERE translation is NULL")
op.alter_column('translated_string', 'translation',
existing_type=sa.TEXT(),
nullable=False)
op.execute("UPDATE translated_string SET translator_comment='' WHERE translator_comment is NULL")
op.alter_column('translated_string', 'translator_comment',
existing_type=sa.TEXT(),
nullable=False)
# ### end Alembic commands ###
58e7f2fc7ff7_set_translations_not_null.py 文件源码
项目:dila
作者: socialwifi
项目源码
文件源码
阅读 26
收藏 0
点赞 0
评论 0
def downgrade():
# ### commands auto generated by Alembic - please adjust! ###
op.alter_column('translated_string', 'translator_comment',
existing_type=sa.TEXT(),
nullable=True)
op.alter_column('translated_string', 'translation',
existing_type=sa.TEXT(),
nullable=True)
op.alter_column('translated_string', 'context',
existing_type=sa.TEXT(),
nullable=True)
op.alter_column('translated_string', 'comment',
existing_type=sa.TEXT(),
nullable=True)
op.alter_column('translated_string', 'base_string',
existing_type=sa.TEXT(),
nullable=True)
# ### end Alembic commands ###
d59114c46ac4_change_constrains.py 文件源码
项目:fuel-nailgun-extension-iac
作者: openstack
项目源码
文件源码
阅读 28
收藏 0
点赞 0
评论 0
def upgrade():
table_prefix = context.config.get_main_option('table_prefix')
op.create_unique_constraint('_repo_name_unique',
table_prefix + 'repos',
['repo_name'])
op.alter_column(table_prefix + 'repos',
'user_key',
type_=sa.UnicodeText(),
existing_type=sa.String(255))
d59114c46ac4_change_constrains.py 文件源码
项目:fuel-nailgun-extension-iac
作者: openstack
项目源码
文件源码
阅读 28
收藏 0
点赞 0
评论 0
def downgrade():
table_prefix = context.config.get_main_option('table_prefix')
op.drop_constraint('_repo_name_unique',
table_prefix + 'repos')
op.alter_column(table_prefix + 'repos',
'user_key',
existing_type=sa.UnicodeText(),
type_=sa.String(255))
f4a5152337aa_reduce_size_of_email.py 文件源码
项目:BookCloud
作者: livro-aberto
项目源码
文件源码
阅读 24
收藏 0
点赞 0
评论 0
def upgrade():
# ### commands auto generated by Alembic - please adjust! ###
op.alter_column('user', 'email',
existing_type=mysql.VARCHAR(length=255),
type_=sa.String(length=75),
existing_nullable=False)
# ### end Alembic commands ###
f4a5152337aa_reduce_size_of_email.py 文件源码
项目:BookCloud
作者: livro-aberto
项目源码
文件源码
阅读 29
收藏 0
点赞 0
评论 0
def downgrade():
# ### commands auto generated by Alembic - please adjust! ###
op.alter_column('user', 'email',
existing_type=sa.String(length=75),
type_=mysql.VARCHAR(length=255),
existing_nullable=False)
# ### end Alembic commands ###
def upgrade():
### commands auto generated by Alembic - please adjust! ###
op.alter_column(
'inpatientadmission',
'visit_number',
new_column_name='external_identifier'
)
### end Alembic commands ###
def downgrade():
### commands auto generated by Alembic - please adjust! ###
op.alter_column(
'inpatientadmission',
'external_identifier',
new_column_name='visit_number'
)
### end Alembic commands ###
29353a1877ba_remove_featured_table.py 文件源码
项目:FRG-Crowdsourcing
作者: 97amarnathk
项目源码
文件源码
阅读 27
收藏 0
点赞 0
评论 0
def upgrade():
# First, create column and fill all records with default value.
# To avoid integrity error, the constraint non-nullable will be set after that
op.add_column('app', sa.Column('featured', sa.Boolean, default=False))
query = 'UPDATE "app" SET featured=false;'
op.execute(query)
op.alter_column('app', 'featured', nullable=False)
query = 'UPDATE "app" SET featured=true WHERE app.id IN (SELECT app_id FROM FEATURED);'
op.execute(query)
op.drop_table('featured')
ac115763654_remove_completed_column_from_project.py 文件源码
项目:FRG-Crowdsourcing
作者: 97amarnathk
项目源码
文件源码
阅读 25
收藏 0
点赞 0
评论 0
def downgrade():
op.add_column('project', sa.Column('completed', sa.Boolean, default=False))
query = 'UPDATE project SET completed=false;'
op.execute(query)
op.alter_column('project', 'completed', nullable=False)
update_completed = '''
WITH completed_tasks AS (
SELECT project.id, COUNT(task.id) as n_completed_tasks FROM project, task
WHERE task.state='completed' AND task.project_id=project.id
GROUP BY project.id
), total_tasks AS (
SELECT project.id, COUNT(task.id) as n_tasks FROM project, task
WHERE task.project_id=project.id
GROUP BY project.id
)
UPDATE project SET completed=true WHERE project.id IN (
SELECT total_tasks.id
FROM completed_tasks INNER JOIN total_tasks ON completed_tasks.id=total_tasks.id
);
'''
op.execute(update_completed)
# sql = sa.sql.text('''SELECT COUNT(task.id) AS n_completed_tasks FROM task
# WHERE task.project_id=:project_id AND task.state=\'completed\';''')
# sql = sa.sql.text('''SELECT COUNT(task.id) AS n_tasks FROM task
# WHERE task.project_id=:project_id''')
3620d7cac37b_table_constrains.py 文件源码
项目:FRG-Crowdsourcing
作者: 97amarnathk
项目源码
文件源码
阅读 24
收藏 0
点赞 0
评论 0
def upgrade():
# App table
op.alter_column('app', 'name', nullable=False)
op.alter_column('app', 'short_name', nullable=False)
op.alter_column('app', 'description', nullable=False)
op.alter_column('app', 'owner_id', nullable=False)
# Task
op.alter_column('task', 'app_id', nullable=False)
# TaskRun
op.alter_column('task_run', 'app_id', nullable=False)
op.alter_column('task_run', 'task_id', nullable=False)
3620d7cac37b_table_constrains.py 文件源码
项目:FRG-Crowdsourcing
作者: 97amarnathk
项目源码
文件源码
阅读 28
收藏 0
点赞 0
评论 0
def downgrade():
op.alter_column('app', 'name', nullable=True)
op.alter_column('app', 'short_name', nullable=True)
op.alter_column('app', 'description', nullable=True)
op.alter_column('app', 'owner_id', nullable=True)
# Task
op.alter_column('task', 'app_id', nullable=True)
# TaskRun
op.alter_column('task_run', 'app_id', nullable=True)
op.alter_column('task_run', 'task_id', nullable=True)
46c3f68e950a_add_table_constraints_to_user_locale_.py 文件源码
项目:FRG-Crowdsourcing
作者: 97amarnathk
项目源码
文件源码
阅读 22
收藏 0
点赞 0
评论 0
def upgrade():
query = 'UPDATE "user" SET locale=\'en\';'
op.execute(query)
op.alter_column('user', 'locale', nullable=False)
op.alter_column('user', 'privacy_mode', nullable=False)
25e478de8a63_big_int_for_oauth_id.py 文件源码
项目:FRG-Crowdsourcing
作者: 97amarnathk
项目源码
文件源码
阅读 27
收藏 0
点赞 0
评论 0
def upgrade():
op.alter_column('user', 'facebook_user_id', type_=sa.BigInteger)
op.alter_column('user', 'twitter_user_id', type_=sa.BigInteger)
25e478de8a63_big_int_for_oauth_id.py 文件源码
项目:FRG-Crowdsourcing
作者: 97amarnathk
项目源码
文件源码
阅读 29
收藏 0
点赞 0
评论 0
def downgrade():
op.alter_column('user', 'facebook_user_id', type_=sa.Integer)
op.alter_column('user', 'twitter_user_id', type_=sa.Integer)