使用 Flask SQLAlchemy 从 SQLite 切换到 MySQL

我有一个网站,我已经与 FlaskSQLAlchemy 和 SQLite 建立,并需要切换到 MySQL。我已经迁移了数据库本身,并让它在 MySQL 下运行,但是

  1. 不知道如何连接到 MySQL 数据库(即 SQLALCHEMY_DATABASE_URI应该是什么)和
  2. 目前还不清楚我现有的 SQLAlchemySQLite 代码是否可以使用 MySQL。

我怀疑(1)是相当简单的,只需要显示如何映射,例如,我在 MySQL 数据库工具中使用的连接对话框的内容到一个适当格式的 URL。但是我很担心(2) ,我假设 SQLAlchemy 提供了一个抽象层,所以 简单的 SQLAlchemy 代码,如

from flask import Flask
from flask.ext.sqlalchemy import SQLAlchemy


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




class User(db.Model):
id = db.Column(db.Integer, primary_key=True)
username = db.Column(db.String(80), unique=True)
email = db.Column(db.String(120), unique=True)


def __init__(self, username, email):
self.username = username
self.email = email


def __repr__(self):
return '<User %r>' % self.username


admin = User('admin', 'admin@example.com')


db.session.add(admin)


User.query.all()


User.query.filter_by(username='admin').first()

除了对数据库 URI 进行适当的修改之外,wold 不需要做任何修改就可以工作; 但是用于在 MySQL 中使用 SQLAlchemy 的 我找到的例子似乎使用了一个完全不同的 API。

我可以(2)迁移我的 Flask SQLAlchemy 代码,通过简单地更改数据库 URI 来使用 MySQL 数据库吗?

107243 次浏览

您指出的教程展示了使用 SQLAlchemy 连接到 MySQL 的正确方法。下面是您的代码,只有很小的变化:

我假设您的 MySQL 服务器运行在 Flask 运行的同一台机器上,并且数据库名称为 db _ name。如果您的服务器不是同一台机器,请将服务器 IP 代替 localhost

from flask import Flask
from flask.ext.sqlalchemy import SQLAlchemy


app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://username:password@localhost/db_name'
db = SQLAlchemy(app)




class User(db.Model):
id = db.Column(db.Integer, primary_key=True)
username = db.Column(db.String(80), unique=True)
email = db.Column(db.String(120), unique=True)


def __init__(self, username, email):
self.username = username
self.email = email


def __repr__(self):
return '<User %r>' % self.username


admin = User('admin', 'admin@example.com')


db.create_all() # In case user table doesn't exists already. Else remove it.


db.session.add(admin)


db.session.commit() # This is needed to write the changes to database


User.query.all()


User.query.filter_by(username='admin').first()

我碰巧遇到了 SQLAlchemy(mqsqldb)使用的默认驱动程序,在我的虚拟环境中没有为我编译。因此,我选择了一个具有完整的 python 实现 pymysql的 MySQL 驱动程序。使用 pip install pymysql安装后,SQLALCHEMY _ DATABASE _ URI 将更改为:

app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://username:password@localhost/db_name'

使用像 SQLAlchemy 这样的 ORM 的目的是,在大多数情况下,您可以使用不同的数据库,只需要很少或根本不需要更改。所以,我的答案是肯定的。您应该能够使用 sqlite 代码使用上面代码中映射的 URI 来处理 MySQL。

当时接受的答案是正确的,但是 import 语句中的语法已经被弃用。

这个:

from flask.ext.sqlalchemy import SQLAlchemy

应改为:

import flask_sqlalchemy

由于有关数据库连接的问题往往会获得流量,并且相关性会保持很长时间,因此值得记录在案。

不推荐使用 烧瓶版本1.0更新日志,它实际上在示例中使用了这个模块:

Ext-直接按名称导入扩展名,而不是按名称导入扩展名 通过 flask.ext 名称空间 Sqltancy 变成 import flask _ sqltancy。