使用Flask-SQLALchemy操作MySQL数据库

1、简介

Flask-SQLAlchemy 是一个 Flask 扩展,简化了在 Flask程序中使用SQLAlchemy 的操作。SQLAlchemy 是一个很强大的关系型数据库框架,支持多种数据库后台。 SQLAlchemy 提供了高层 ORM,也提供了使用数据库原生 SQL 的低层功能。

2、安装

$ pip install flask-sqlalchemy

3、配置连接mysql

$ vim models.py

from flask importFlask

from flask_script import Manager

from flask_sqlalchemy import SQLAlchemy

app =Flask(__name__)

app.config[‘SQLALCHEMY_DATABASE_URI‘] = ‘mysql://kevin:[email protected]/kevin‘

app.config[‘SQLALCHEMY_COMMIT_ON_TEARDOWN‘] = True

manager = Manager(app)

db = SQLAlchemy(app)

if __name__ ==‘__main__‘:

manager.run()

4、定义模型

$ vim models.py(只列出修改部分)

db = SQLAlchemy(app)

class Role(db.Model):

__tablename__ = ‘roles‘

id = db.Column(db.Integer,primary_key=True)

name = db.Column(db.String(255),unique=True)

users = db.relationship(‘User‘,backref=‘role‘)

def __repr__(self):

return ‘<Role %r>‘ %self.name

class User(db.Model):

__tablename__ = ‘users‘

id = db.Column(db.Integer,primary_key=True)

username = db.Column(db.String(255),unique=True,index=True)

password = db.Column(db.String(255))

role_id = db.Column(db.Integer,db.ForeignKey(‘roles.id‘))

def __repr__(self):

return ‘<User %r>‘ %self.username

类变量 __tablename__ 定义在数据库中使用的表名。如果没有定义 __tablename__, Flask-SQLAlchemy 会使用模版名的小写作为表名。

不需要定义__init__或__repr__,如果没有定义,SQLAlchemy会自动创建__init__方法。如果定义了,定义的字段名会成为此方法所接收的关键字参数名。

5、数据库操作

5.1、创建表

创建数据库,方法是使用db.create_all()函数。如果数据库表已经存在于数据库中,那么 db.create_all()不会重新创建或者更新这个表。

查看数据库

mysql> use kevin

Database changed

mysql> show tables;

Empty set (0.00sec)

创建

$ python models.py shell

>>> from models import db

>>>db.create_all()

查看

mysql> show tables;

+-----------------+

| Tables_in_kevin |

+-----------------+

| roles           |

| users           |

+-----------------+

2 rows in set (0.00sec)

5.2、插入数据

>>> from  models import Role,User

>>>admin_role = Role(name=‘Admin‘)

>>>mod_role = Role(name=‘Moderator‘)

>>>user_role = Role(name=‘User‘)

>>>user_kevin = User(username=‘kevin‘,role=admin_role)

>>>user_susan = User(username=‘susan‘,role=user_role)

>>>user_david = User(username=‘david‘,role=user_role)

现在这些对象只存在于Python 中,还未写入数据库。因此 id 尚未赋值。

>>>print(admin_role.id)

None

>>>print(mod_role.id)

None

>>>print(user_role.id)

None

通过数据库会话管理对数据库所做的改动,在 Flask-SQLAlchemy 中,会话由 db.session表示。准备把对象写入数据库之前,先要将其添加到会话中。

>>>db.session.add(admin_role)

>>>db.session.add(mod_role)

>>>db.session.add(user_role)

>>>db.session.add(user_kevin)

>>>db.session.add(user_susan)

>>>db.session.add(user_david)

可以简写为:

>>>db.session.add_all([admin_role,mod_role,user_role,user_kevin,user_susan,user_david])

为了把对象写入数据库,要调用 commit() 方法提交会话。

>>>db.session.commit()

再次查看id属性,它们已经赋值了,表里也有数据了。

>>>print(admin_role.id)

1

>>>print(mod_role.id)

2

>>>print(user_role.id)

3

mysql> select * from roles;

+----+-----------+

| id | name      |

+----+-----------+

|  1 | Admin    |

|  2 | Moderator |

|  3 | User     |

+----+-----------+

3 rows in set (0.00sec)

mysql> select * from users;

+----+----------+----------+---------+

| id | username |password | role_id |

+----+----------+----------+---------+

|  1 | kevin   | NULL     |       1 |

|  2 | susan   | NULL     |       3 |

|  3 | david   | NULL     |       3 |

+----+----------+----------+---------+

3 rows in set (0.00sec)

5.3、修改数据

在数据库会话上调用 add() 方法也能更新模型。下面把 "Admin" 角色重命名为 "Administrator"。

>>>admin_role.name = ‘Adminitrator‘

>>>db.session.add(admin_role)

>>>db.session.commit()

>>>print(admin_role.name)

Adminitrator

5.4、删除数据

数据库会话还有个 delete() 方法。下面是把 "Moderator" 角色从数据库中删除。

>>>db.session.delete(mod_role)

>>>db.session.commit()

mysql> select name from roles where name=‘Moderator‘;

Empty set (0.00sec)

5.5、查询数据

Flask-SQLAlchemy 为每个模型类都提供了query 对象。最基本的模型查询是取回对应表中的所有记录。

>>>Role.query.all()

[<Roleu‘Adminitrator‘>, <Role u‘User‘>]

>>>User.query.all()

[<Useru‘kevin‘>, <User u‘susan‘>, <User u‘david‘>]

使用过滤器可以配置 query 对象进行更精确的数据库查询。下面这个例子查找角色为"User" 的所有用户

>>>User.query.filter_by(role=user_role).all()

[<Useru‘susan‘>, <User u‘david‘>]

filter_by() 等过滤器在 query 对象上调用,返回一个更精确的 query 对象。多个过滤器可以一起调用,直到获得所需结果。完整的列表参见 SQLAlchemy 文档。

由于个人技术所限有不足之处还请各位指出。可以通过以下两个群找到笔者。

北京linux运维求职招聘群:153677549

Linux运维开发群:298324302

时间: 2024-10-12 12:32:10

使用Flask-SQLALchemy操作MySQL数据库的相关文章

flask + pymysql操作Mysql数据库

安装flask-sqlalchemy.pymysql模块 pip install flask-sqlalchemy pymysql 安装Mysql数据库 from flask.ext.sqlalchemy import SQLAlchemy from flask import Flask '''配置数据库''' app = Flask(__name__) app.config['SECRET_KEY'] ='hard to guess' # 这里登陆的是root用户,要填上自己的密码,MySQL

Python3:sqlalchemy对mysql数据库操作,非sql语句

Python3:sqlalchemy对mysql数据库操作,非sql语句 # python3 # author lizm # datetime 2018-02-01 10:00:00 # -*- coding: utf-8 -*- ''' 数据起始日期:2015-05-08 数据库:mysql ''' import requests from bs4 import BeautifulSoup import json import pymysql import datetime import ti

使用pandas操作MySQL数据库

转载(有添加.修改)作者:但盼风雨来_jc链接:https://www.jianshu.com/p/238a13995b2b來源:简书著作权归作者所有.商业转载请联系作者获得授权,非商业转载请注明出处. 本次分享将介绍如何在Python中使用Pandas库实现MySQL数据库的读写.首先我们需要了解点ORM方面的知识 ORM技术   对象关系映射技术,即ORM(Object-Relational Mapping)技术,指的是把关系数据库的表结构映射到对象上,通过使用描述对象和数据库之间映射的元数

python操作mysql数据库

连接数据库 输入值 存入数据库 关闭 import string import mysql.connector conn=mysql.connector.connect(user='root',password='test',database='dalian',use_unicode=True) cursor=conn.cursor() a=raw_input('enter an id: ') b=raw_input('enter a name: ') while(a!='quit' or b!

Windows下安装MySQLdb, Python操作MySQL数据库的增删改查

这里的前提是windows上已经安装了MySQL数据库,且配置完毕,能正常建表能操作.在此基础上只需安装MySQL-python-1.2.4b4.win32-py2.7.exe就ok了,只有1M多.这个有点类似jdbc里的那个jar包. 下载链接:http://sourceforge.net/projects/mysql-python/ , 百度云盘 :http://pan.baidu.com/s/1dDgnfpR 密码:7bna 接着import MySQLdb就能使用了,下面给出测试代码:

使用python操作mysql数据库

这是我之前使用mysql时用到的一些库及开发的工具,这里记录下,也方便我查阅. python版本: 2.7.13 mysql版本: 5.5.36 几个python库 1.mysql-connector-python 是MySQL官方的Python驱动 https://dev.mysql.com/doc/connector-python/en/ 安装: pip install mysql-connector 示例代码: https://github.com/mike-zhang/pyExample

【php】php操作MySQL数据库

一.操作步骤: 1. 连接MySQL数据库并判断是否连接成功2. 选择数据库3. 设置字符集4. 准备SQL语句5. 向MySQL服务发送SQL语句6. 解析处理结果集7. 释放结果集,关闭数据库连接 二.常用操作: 1. mysqli_connect();--连接数据库,并返回一个连接资源 格式: mysql_connect(主机名,用户,密码); --其中参数可选,若不写则参考php.ini中默认配置 2. mysqli_error(); --获取刚刚(最后)执行数据库操作的错误信息 3.

python3操作MySQL数据库

安装PyMySQL 下载地址:https://pypi.python.org/pypi/PyMySQL 1.把操作Mysql数据库封装成类,数据库和表先建好 import pymysql.cursors # ======== Setting linked test databases =========== host = '192.168.17.123' user = 'root' password = '123456' db='polls' # ======== MySql base oper

c语言操作mysql数据库

c语言操作Mysql数据库,主要就是为了实现对数据库的增.删.改.查等操作,操作之前,得先连接数据库啊,而连接数据库主要有两种方法.一.使用mysql本身提供的API,在mysql的安装目录中可可以看到大量的头文件.lib文件.dll文件,这说明mysql原生就支持了c语言,操作起来相当简单.二.使用win32 api(这里只探讨windows平台),主要是ODBC. ODBC API 接口是(Open Database Connectivity)开放式数据库接口,它建立了一组规范,并提供了一组

PHP操作MySQL数据库的相关函数

首先,要分清SQL语句的类型: SQL语句的分类 (1)DDL:Data Define Language,数据定义语言--定义表的列结构 CREATE.DROP.ALTER.TRUNCATE (2)DML:Data Manipulate Language,数据操作语言--操作表的记录行 INSERT.DELETE.UPDATE (3)DQL:Data Query Language,数据查询语言--不影响表的行和列 SELECT (4)DCL:Data Control Language,数据控制语