使用 Flask-Sqlalchemy 动态创建/更新/删除表答案

【问题标题】：Create/Update/Delete Tables Dynamically With Flask-Sqlalchemy使用 Flask-Sqlalchemy 动态创建/更新/删除表
【发布时间】：2015-09-17 20:01:57
【问题描述】：

python、flask 和 sqlalchemy 的新手。请帮忙。

我正在用烧瓶写一个小应用程序。我将一些模型定义为：

class Field(db.Model):
    __tablename__ = 'fields'

    id = db.Column(db.Integer, db.Sequence('FIELDS_SEQ'), primary_key=True)
    name = db.Column(db.String(120), nullable=False)
    position = db.Column(db.Integer)

    # a field has only one type
    type_id = db.Column(db.Integer, db.ForeignKey(FieldType.id))

    # a field only belongs to one table
    table_info_id = db.Column(db.Integer, db.ForeignKey('tables_info.id'), unique=True)

    _create_db_sequence('FIELDS_SEQ')


class TableInfo(db.Model):
    __tablename__ = 'tables_info'

    id = db.Column(db.Integer, db.Sequence('TABLES_INFO_SEQ'), primary_key=True)
    name = db.Column(db.String(120), unique=True, nullable=False)

    # a table can have a lot of fields
    fields = db.relationship(Field, backref='table_info', lazy='joined')

    # a table only belongs to one department
    department_id = db.Column(db.Integer, db.ForeignKey('departments.id'))

    _create_db_sequence('TABLES_INFO_SEQ')

所以我有一个表单来收集 TableInfo 的 name 属性。现在，我如何动态地 - 在运行时 - 创建一个空表，其 name 属性仅具有一个列定义 (id)。创建表后，我将使用另一个表单来收集字段/列名。同样，我想动态地将这些列添加到表中。由于此表及其列不会基于上述预定义模型，我如何在运行时以应用程序可以与之交互的方式创建表和列？我读到flask-sqlalchemy 使用声明性基础，它需要在创建映射表之前定义模型。我可以在 flask-sqlalchemy 环境中动态创建表吗？谢谢。

【问题讨论】：

看起来您的表结构可能过于复杂。虽然这是可以理解的，但您可能有一个用例，您需要更多的列在运行中，虽然我确信这将通过 SQL alchemy 实现，但它最终将成为一个 hacky 或非 ORM 解决方案。您可能会更轻松地研究允许动态动态创建列的 no-sql 解决方案。
@F Boucaut 不幸的是，我现在只能使用 Oracle。您能否详细说明如何通过 sqlalchemy 实现这一点？

标签： python flask flask-sqlalchemy

【解决方案1】：

我也有类似的问题。我更改了我的 model.py 并想升级我的数据库。

这是我为升级它所做的。我不知道这是否是正确的做法，但它确实有效。

我创建了一个文件 manage.py

import os
from flask import Flask
from dictiofquestions import dico
from flask_sqlalchemy import SQLAlchemy
from flask_script import Manager
from flask_migrate import Migrate, MigrateCommand
from core import db
from Models import Questions

app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:////tmp/test.db'
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = 'True'

db.init_app(app)
migrate = Migrate(app, db)

manager = Manager(app)
manager.add_command('db', MigrateCommand)


if __name__ == "__main__":
    manager.run()

别忘了这条线app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = 'True'

这是我的文件 core.py

from flask_sqlalchemy import SQLAlchemy
db = SQLAlchemy()

还有我的models.py

from core import db

class Questions(db.Model):
    id = db.Column(db.Integer, primary_key=True)
    question = db.Column(db.String(200), unique=True)
    resp1 = db.Column(db.String(80), unique=False)
    resp2 = db.Column(db.String(80), unique=False)
    resp3 = db.Column(db.String(80), unique=False)
    resp4 = db.Column(db.String(80), unique=False)
    valideresp = db.Column(db.String(5), unique=False)
    categorie = db.Column(db.String(50), unique=False)

    def __init__(self, question, resp1, resp2, resp3, resp4, valideresp, categorie):
        self.question = question
        self.resp1 = resp1
        self.resp2 = resp2
        self.resp3 = resp3
        self.resp4 = resp4
        self.valideresp = valideresp
        self.categorie = categorie

    def __repr__(self):
        return '<Questions %r>' % self.question

在我的控制台中输入命令：

python manage.py db init
python manage.py db migrate
python manage.py db upgrade

就像我可以在需要时使用这 3 个命令升级我的数据库。如果您需要更多信息，我认为您可以访问此页面。 https://flask-migrate.readthedocs.io/en/latest/

【讨论】：