python3怎么用sqlalchemy操作mysql · 常用笔记

# python3怎么用sqlalchemy操作mysql ``` <pre class="calibre15">``` 第一步 python需要安装pymysql mysqldb不可用于python3 第二步使用 url链接链接字符串 dialect+driver://username:password@host:port/database 在config中写配置 # 增加： article1 = Article(title='aaa',content='bbb') db.session.add(article1) # 事务 db.session.commit() # 查 # select * from article where article.title='aaa'; article1 = Article.query.filter(Article.title == 'aaa').first() print 'title:%s' % article1.title print 'content:%s' % article1.content 3. 改： ``` # 改： # 1\. 先把你要更改的数据查找出来 article1 = Article.query.filter(Article.title == 'aaa').first() # 2\. 把这条数据，你需要修改的地方进行修改 article1.title = 'new title' # 3\. 做事务的提交 db.session.commit() # 删 # 1\. 把需要删除的数据查找出来 article1 = Article.query.filter(Article.content == 'bbb').first() # 2\. 把这条数据删除掉 db.session.delete(article1) # 3\. 做事务提交 db.session.commit() ``` ### Flask-SQLAlchemy外键及其关系： 1. 外键： ``` class User(db.Model): __tablename__ = 'user' id = db.Column(db.Integer,primary_key=True,autoincrement=True) username = db.Column(db.String(100),nullable=False) class Article(db.Model): __tablename__ = 'article' id = db.Column(db.Integer, primary_key=True, autoincrement=True) title = db.Column(db.String(100),nullable=False) content = db.Column(db.Text,nullable=False) author_id = db.Column(db.Integer,db.ForeignKey('user.id')) author = db.relationship('User',backref=db.backref('articles')) ``` 2. `author = db.relationship('User',backref=db.backref('articles'))`解释： * 给`Article`这个模型添加一个`author`属性，可以访问这篇文章的作者的数据，像访问普通模型一样。 * `backref`是定义反向引用，可以通过`User.articles`访问这个模型所写的所有文章。 3. 多对多： * 多对多的关系，要通过一个中间表进行关联。 * 中间表，不能通过`class`的方式实现，只能通过`db.Table`的方式实现。 * 设置关联：`tags = db.relationship('Tag',secondary=article_tag,backref=db.backref('articles'))`需要使用一个关键字参数`secondary=中间表`来进行关联。 * 访问和数据添加可以通过以下方式进行操作： * 添加数据： ``` article1 = Article(title='aaa') article2 = Article(title='bbb') tag1 = Tag(name='111') tag2 = Tag(name='222') article1.tags.append(tag1) article1.tags.append(tag2) article2.tags.append(tag1) article2.tags.append(tag2) db.session.add(article1) db.session.add(article2) db.session.add(tag1) db.session.add(tag2) db.session.commit() ``` * 访问数据： ``` article1 = Article.query.filter(Article.title == 'aaa').first() tags = article1.tags for tag in tags: print tag.name ``` ### Flask-Script的介绍与安装： 1. Flask-Script：Flask-Script的作用是可以通过命令行的形式来操作Flask。例如通过命令跑一个开发版本的服务器、设置数据库，定时任务等。 2. 安装：首先进入到虚拟环境中，然后`pip install flask-script`来进行安装。 3. 如果直接在主`manage.py`中写命令，那么在终端就只需要`python manage.py command_name`就可以了。 4. 如果把一些命令集中在一个文件中，那么在终端就需要输入一个父命令，比如`python manage.py db init`。 5. 例子： ``` from flask_script import Manager from flask_script_demo import app from db_scripts import DBManager manager = Manager(app) # 和数据库相关的操作，我都放在一起 @manager.command def runserver(): print '服务器跑起来了!!!!!' manager.add_command('db',DBManager) if __name__ == '__main__': manager.run() ``` 6. 有子命令的例子： ``` #encoding: utf-8 from flask_script import Manager DBManager = Manager() @DBManager.command def init(): print '数据库初始化完成' @DBManager.command def migrate(): print '数据表迁移成功' ``` ### 分开`models`以及解决循环引用： 1. 分开models的目的：为了让代码更加方便的管理。 2. 如何解决循环引用：把`db`放在一个单独的文件中，切断循环引用的线条就可以了。 ### Flask-Migrate的介绍与安装： 1. 介绍：因为采用`db.create_all`在后期修改字段的时候，不会自动的映射到数据库中，必须删除表，然后重新运行`db.craete_all`才会重新映射，这样不符合我们的需求。因此flask-migrate就是为了解决这个问题，她可以在每次修改模型后，可以将修改的东西映射到数据库中。 2. 首先进入到你的虚拟环境中，然后使用`pip install flask-migrate`进行安装就可以了。 3. 使用`flask_migrate`必须借助`flask_scripts`，这个包的`MigrateCommand`中包含了所有和数据库相关的命令。 4. `flask_migrate`相关的命令： * `python manage.py db init`：初始化一个迁移脚本的环境，只需要执行一次。 * `python manage.py db migrate`：将模型生成迁移文件，只要模型更改了，就需要执行一遍这个命令。 * `python manage.py db upgrade`：将迁移文件真正的映射到数据库中。每次运行了`migrate`命令后，就记得要运行这个命令。 5. 注意点：需要将你想要映射到数据库中的模型，都要导入到`manage.py`文件中，如果没有导入进去，就不会映射到数据库中。 6. `manage.py`的相关代码： ``` from flask_script import Manager from migrate_demo import app from flask_migrate import Migrate,MigrateCommand from exts import db from models import Article # init # migrate # upgrade # 模型 -> 迁移文件 -> 表 manager = Manager(app) # 1\. 要使用flask_migrate，必须绑定app和db migrate = Migrate(app,db) # 2\. 把MigrateCommand命令添加到manager中 manager.add_command('db',MigrateCommand) if __name__ == '__main__': manager.run() ``` ``` ```