openstack/cinder
Code Issues Proposed changes

Merge "Add column only when it doesn't exist"

Browse Source
This commit is contained in:
Zuul 2018-10-26 17:20:37 +00:00 committed by Gerrit Code Review
commit 90550d0b53
6 changed files with 18 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
cinder/db/sqlalchemy/migrate_repo/versions/088_add_replication_info_to_cluster.py
View File

@ -28,7 +28,9 @@ def upgrade(migrate_engine):
active_backend_id = Column('active_backend_id', String(length=255)) active_backend_id = Column('active_backend_id', String(length=255))
frozen = Column('frozen', Boolean, nullable=False, default=False, frozen = Column('frozen', Boolean, nullable=False, default=False,
server_default=expression.false()) server_default=expression.false())
if not hasattr(clusters.c, 'replication_status'):
clusters.create_column(replication_status) clusters.create_column(replication_status)
clusters.create_column(frozen) if not hasattr(clusters.c, 'frozen'):
clusters.create_column(active_backend_id) clusters.create_column(frozen)
if not hasattr(clusters.c, 'active_backend_id'):
clusters.create_column(active_backend_id)

3
cinder/db/sqlalchemy/migrate_repo/versions/089_add_cluster_name_image_cache.py
View File

@ -24,4 +24,5 @@ def upgrade(migrate_engine):
image_cache = Table('image_volume_cache_entries', meta, autoload=True) image_cache = Table('image_volume_cache_entries', meta, autoload=True)
cluster_name = Column('cluster_name', String(255), nullable=True) cluster_name = Column('cluster_name', String(255), nullable=True)
image_cache.create_column(cluster_name) if not hasattr(image_cache.c, 'cluster_name'):
image_cache.create_column(cluster_name)

3
cinder/db/sqlalchemy/migrate_repo/versions/090_add_race_preventer_to_workers.py
View File

@ -24,4 +24,5 @@ def upgrade(migrate_engine):
workers = Table('workers', meta, autoload=True) workers = Table('workers', meta, autoload=True)
race_preventer = Column('race_preventer', Integer, nullable=False, race_preventer = Column('race_preventer', Integer, nullable=False,
default=0, server_default=text('0')) default=0, server_default=text('0'))
race_preventer.create(workers, populate_default=True) if not hasattr(workers.c, 'race_preventer'):
race_preventer.create(workers, populate_default=True)

3
cinder/db/sqlalchemy/migrate_repo/versions/099_add_connection_info_to_attachment.py
View File

@ -19,4 +19,5 @@ def upgrade(migrate_engine):
# Add connection_info column to attachment table # Add connection_info column to attachment table
attachment = Table('volume_attachment', meta, autoload=True) attachment = Table('volume_attachment', meta, autoload=True)
connection_info = Column('connection_info', Text) connection_info = Column('connection_info', Text)
attachment.create_column(connection_info) if not hasattr(attachment.c, 'connection_info'):
attachment.create_column(connection_info)

6
cinder/db/sqlalchemy/migrate_repo/versions/103_message_action_detail_column.py
View File

@ -19,5 +19,7 @@ def upgrade(migrate_engine):
messages = Table('messages', meta, autoload=True) messages = Table('messages', meta, autoload=True)
detail_id = Column('detail_id', String(10), nullable=True) detail_id = Column('detail_id', String(10), nullable=True)
action_id = Column('action_id', String(10), nullable=True) action_id = Column('action_id', String(10), nullable=True)
messages.create_column(detail_id) if not hasattr(messages.c, 'detail_id'):
messages.create_column(action_id) messages.create_column(detail_id)
if not hasattr(messages.c, 'action_id'):
messages.create_column(action_id)

3
cinder/db/sqlalchemy/migrate_repo/versions/117_add_encryption_key_id_to_backups.py
View File

@ -20,4 +20,5 @@ def upgrade(migrate_engine):
backups = Table('backups', meta, autoload=True) backups = Table('backups', meta, autoload=True)
encryption_key_id = Column('encryption_key_id', String(length=36)) encryption_key_id = Column('encryption_key_id', String(length=36))
backups.create_column(encryption_key_id) if not hasattr(backups.c, 'encryption_key_id'):
backups.create_column(encryption_key_id)