Merge "Fix error of tacker-db-manage postgresql migration"

This commit is contained in:
Zuul 2024-12-19 01:19:04 +00:00 committed by Gerrit Code Review
commit c5094e7e13
3 changed files with 8 additions and 11 deletions

View File

@ -35,11 +35,10 @@ def _migrate_duplicate_names(table):
meta = sa.MetaData()
conn = op.get_bind()
engine = conn.engine
meta.create_all(bind=engine)
t = sa.Table(table, meta, autoload_with=engine)
meta.create_all(bind=conn)
t = sa.Table(table, meta, autoload_with=conn)
session = sa.orm.Session(bind=engine)
session = sa.orm.Session(bind=conn)
#with session.begin(subtransactions=True):
with session.begin():
dup_names = session.query(t.c.name).group_by(

View File

@ -38,9 +38,8 @@ down_revision = 'f958f58e5daa'
def _migrate_data(table, column_name):
meta = sa.MetaData()
conn = op.get_bind()
engine = conn.engine
meta.create_all(bind=engine)
t = sa.Table(table, meta, autoload_with=engine)
meta.create_all(bind=conn)
t = sa.Table(table, meta, autoload_with=conn)
for r in conn.execute(t.select()):
stmt = t.update().where(t.c.id == r.id).values(

View File

@ -35,11 +35,10 @@ def _migrate_duplicate_vnf_package_vnfd_id(table):
meta = sa.MetaData()
conn = op.get_bind()
engine = conn.engine
meta.create_all(bind=engine)
t = sa.Table(table, meta, autoload_with=engine)
meta.create_all(bind=conn)
t = sa.Table(table, meta, autoload_with=conn)
session = sa.orm.Session(bind=engine)
session = sa.orm.Session(bind=conn)
with session.begin():
dup_vnfd_ids = session.query(t.c.vnfd_id).group_by(
t.c.vnfd_id).having(sa.func.count() > 1).all()