1c5f54d4aa34 -> 4250dfa822a4 (head),Feed: Countries 312c1d408043 -> 1c5f54d4aa34,Feed: Continents 41984a51dbb2 -> 312c1d408043,Basic Structure <base> -> 41984a51dbb2,Init Alembic
当我启动一个新的干净的数据库并尝试运行迁移时,我收到一个错误：
vagrant@precise32:/vagrant$python manage.py db upgrade ... sqlalchemy.exc.ProgrammingError: (ProgrammingError) relation "continent" does not exist ...
如果我要求Flask-Migrate运行所有迁移,但是最后一次,它可以运行.如果之后我再次运行升级命令,它就可以工作 – 也就是说,它完全升级我的数据库而不需要对代码进行任何单一更改：
vagrant@precise32:/vagrant$python manage.py db upgrade 312c1d408043 INFO [alembic.migration] Context impl PostgresqlImpl. INFO [alembic.migration] Will assume transactional DDL. INFO [alembic.migration] Running upgrade -> 41984a51dbb2,Init Alembic INFO [alembic.migration] Running upgrade 41984a51dbb2 -> 312c1d408043,Basic Structure vagrant@precise32:/vagrant$python manage.py db upgrade INFO [alembic.migration] Context impl PostgresqlImpl. INFO [alembic.migration] Will assume transactional DDL. INFO [alembic.migration] Running upgrade 312c1d408043 -> 1c5f54d4aa34,Feed: Continents INFO [alembic.migration] Running upgrade 1c5f54d4aa34 -> 4250dfa822a4,Feed: Countries
TL; DR
上次迁移(Feed：Countries)对前一个(Feed：Continents)提供的表运行查询.如果我有大陆表创建和馈送,脚本应该工作.但事实并非如此.
为什么我必须在此之间停止迁移过程以在另一个命令中重新启动它？我真的不明白这一点.是否有一些命令Alembic在一系列迁移后执行？有任何想法吗？
以防万一
我的模型定义如下：
class Country(db.Model):
__tablename__ = 'country'
id = db.Column(db.Integer,primary_key=True)
alpha2 = db.Column(db.String(2),index=True,unique=True)
title = db.Column(db.String(140))
continent_id = db.Column(db.Integer,db.ForeignKey('continent.id'))
continent = db.relationship('Continent',backref='countries')
def __repr__(self):
return '<Country #{}: {}>'.format(self.id,self.title)
class Continent(db.Model):
__tablename__ = 'continent'
id = db.Column(db.Integer,unique=True)
title = db.Column(db.String(140))
def __repr__(self):
return '<Continent #{}: {}>'.format(self.id,self.title)
非常感谢,
正如@Miguel在评论中所说,这里有最后两次迁移的升级方法：
饲料：大陆
def upgrade():
csv_path = app.config['BASEDIR'].child('migrations','csv','en')
csv_file = csv_path.child('continents.csv')
with open(csv_file) as file_handler:
csv = list(reader(file_handler))
csv.pop(0)
data = [{'alpha2': c[0].lower(),'title': c[1]} for c in csv]
op.bulk_insert(Continent.__table__,data)
Feed：国家/地区(取决于上一次迁移的表格)
def upgrade():
# load countries iso3166.csv and build a dictionary
csv_path = app.config['BASEDIR'].child('migrations','en')
csv_file = csv_path.child('iso3166.csv')
countries = dict()
with open(csv_file) as file_handler:
csv = list(reader(file_handler))
for c in csv:
countries[c[0]] = c[1]
# load countries-continents from country_continent.csv
csv_file = csv_path.child('country_continent.csv')
with open(csv_file) as file_handler:
csv = list(reader(file_handler))
country_continent = [{'country': c[0],'continent': c[1]} for c in csv]
# loop
data = list()
for item in country_continent:
# get continent id
continent_guess = item['continent'].lower()
continent = Continent.query.filter_by(alpha2=continent_guess).first()
# include country
if continent is not None:
country_name = countries.get(item['country'],False)
if country_name:
data.append({'alpha2': item['country'].lower(),'title': country_name,'continent_id': continent.id})
我正在使用的CSV基本上遵循以下模式：
continents.csv
... AS,"Asia" EU,"Europe" NA,"north America" ...
iso3166.csv
... CL,"Chile" CM,"Cameroon" CN,"China" ...
_country_continent.csv_
... US,NA UY,SA UZ,AS ...
因此Feed：Continents提供大陆表,Feed：Countries提供国家/地区表.但它必须查询大陆表,以便在国家和大陆之间建立适当的联系.
更新2：来自Reddit的一些人已经提供了解释和解决方法
我问了the same question on Reddit,而themathemagician说：
I’ve run into this before,and the issue is that the migrations don’t
execute individually,but instead alembic batches all of them (or all
of them that need to be run) and then executes the sql. This means
that by the time the last migration is trying to run,the tables don’t
actually exist yet so you can’t actually make queries. Doing06009
This isn’t the most elegant solution (and that was for Postgres,the
command may be different for other dbs),but it worked for me. Also,
this isn’t actually an issue with Flask-Migrate as much as an issue
with alembic,so if you want to Google for more info,search for
alembic. Flask-Migrate is just a wrapper around alembic that works
with Flask-Script easily.
解决方法
我自己没试过,但是Alembic 0.6.5引入了一个transaction_per_migration选项,可以解决这个问题.这是env.py中configure()调用的一个选项.如果您使用默认配置文件,因为Flask-Migrate会创建它们,那么您可以在迁移/ env.py中修复此问题：
def run_migrations_online():
"""Run migrations in 'online' mode.
# ...
context.configure(
connection=connection,target_Metadata=target_Metadata,transaction_per_migration=True # <-- add this
)
# ...
另请注意,如果您还计划运行脱机迁移,则需要以相同方式修复run_migrations_offline()中的configure()调用.
尝试一下,让我知道它是否解决了这个问题.
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
