python中flask_sqlalchemy操作数据库的方法示例

php中文网 Python

本文摘自php中文网，作者不言，侵删。

本篇文章给大家带来的内容是关于python中flask_sqlalchemy操作数据库的方法示例，有一定的参考价值，有需要的朋友可以参考一下，希望对你有所帮助。

flask_sqlalchemy

使用对象关系映射（Object-Relational Mapper, ORM）框架，它将低层的数据库操作指令抽象成高层的面向对象操作。也就是说，如果我们直接使用数据库引擎，我们就要写 SQL 操作语句，但是，如果我们使用了 ORM 框架，我们对诸如表、文档此类的数据库实体就可以简化成对 Python 对象的操作

SQLAlchemy已经成为了python世界里面orm的标准，flask是一个轻巧的web框架，可以自由的使用orm，其中flask-sqlalchemy是专门为flask指定的插件。

在 Flask-SQLAlchemy 中，数据库使用 URL 指定。

1

MySQL -->  mysql://username:password@hostname/database

安装

1

pip install flask-sqlalchemy

对数据库操作

1. 如何创建数据库操作连接

1

2

3

4

5

6

7

8

9

10

11

12

from flask import Flask

from flask_sqlalchemy import SQLAlchemy

 

app = Flask(__name__)

db = SQLAlchemy(app)

app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://root:sheen@localhost/zaj_sql'

app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True

 

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)

为了创建初始数据库，调用 SQLAlchemy.create_all() 方法来创建表和数据库:

1

db.create_all()

您的数据库已经生成。现在来创建一些用户

1

2

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

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

但是它们还没有真正地写入到数据库中，因此让我们来确保它们已经写入到数据库中

1

2

3

db.session.add(admin)

db.session.add(guest)

db.session.commit()

2.创建关系型数据库表

SQLAlchemy 连接到关系型数据库，关系型数据最擅长的东西就是关系。因此，我们将创建一个使用两张相互关联的表的应用作为例子。
最为常见的关系就是一对多的关系。因为关系在它们建立之前就已经声明，您可以使用 字符串来指代还没有创建的类
关系使用 relationship() 函数表示。然而外键必须用类 sqlalchemy.schema.ForeignKey 来单独声明.

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

from datetime import datetime

from flask_bootstrap import Bootstrap

from flask_wtf import FlaskForm

from flask_sqlalchemy import SQLAlchemy

from flask import Flask

import pymysql

from sqlalchemy import desc

 

app = Flask(__name__)

db = SQLAlchemy(app)

app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://root:sheen@localhost/zaj_sql'

app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True

bootstrap = Bootstrap(app)

 

class User(db.Model):

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

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

    passwd = db.Column(db.String(100))

    add_time = db.Column(db.DATETIME,default=datetime.now())

    gender = db.Column(db.BOOLEAN,default=True)

    role_id = db.Column(db.INTEGER,db.ForeignKey('role.id'))

 

    def __repr__(self):

        return '<User:%s>' %(self.name)

 

class Role(db.Model):

    id = db.Column(db.INTEGER,autoincrement=True,primary_key=True)

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

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

    # 给Role模型添加users属性

    # backref 是定义反向引用

        def __repr__(self):

        return '<Role:%s>' % (self.name)

if __name__ =='__main__':

    # 1. 创建数据库表

    # db.drop_all()

    # db.create_all()

    # # 2. 创建role数据库表数据

    role_1 = Role(name='超级会员')

    role_2 = Role(name='普通会员')

 

    db.session.add(role_1)

    db.session.add(role_2)

 

    db.session.commit()

 

    # # # 3. 添加user表内数据，100个用户，50个为超级会员，50个为普通会员

    for i in range(1,13):

        if i%2 == 0:

            u = User(name='sheen'+str(i),passwd='sheen',role_id=1)

            db.session.add(u)

        else:

            u = User(name='star'+str(i),passwd='star',role_id=2)

            db.session.add(u)

    db.session.commit()

backref 是定义反向引用，可以通过User.role访问Role对象和属性。
788357229-5bd92e1c61ea0_articlex.png

751079151-5bd92e80e69bb_articlex.png

查询所有数据

1

2

print('角色',Role.query.all())

print('用户',User.query.all())

根据条件查询数据

1

2

3

4

# select * from tablename where xxx=xxxxx

print(User.query.filter_by(role_id=1).all())

print(Role.query.filter_by().all())

print(User.query.filter_by(role_id=2).all())

2472270871-5bd92fad4f013_articlex.png

对于找到的数据进行更新

1

2

3

4

5

6

print('进行数据更新',end='\n')

   u =User.query.filter_by(name='sheen2').first()

   print(u)

   u.passwd = '123'

   db.session.add(u)

   db.session.commit()

2049843908-5bd92f16a36c3_articlex.png

筛选数据方法2(filter),这种方法可以看见原生的sql语句

1

2

3

print('数据筛选', end='\n')

user = User.query.filter(User.role_id==1)

print(user)

2414030351-5bd93011bfe57_articlex.png

对于查询的信息进行显示限制

1

2

3

4

print('限制查询数据的显示', end='\n')

 

users = User.query.filter_by(role_id=1).limit(3).all()

print(users)

对于查询的信息进行排序输出(默认情况由小到大进行排序)， 如果想要由大到小： desc(User.add_time)

1

2

3

print('数据再处理', end='\n')

users = User.query.filter_by(role_id=1).order_by(desc(User.name)).all()

print(users)

多个过滤函数

1

2

3

4

5

print('多个过滤函数', end='\n')

    users = User.query.filter_by(role_id=1).order_by(desc(User.name)).limit(3).offset(1).all()

    print(users)

    users = User.query.filter_by(role_id=1).order_by(desc(User.name)).slice(1,4).all()

    print(users)

3448472066-5bd931d040a46_articlex.png

分页,第一个参数表示显示第几页数据，第二个参数表示每页显示多少条数据

1

2

3

4

5

6

print('分页显示', end='\n')

 

users = User.query.paginate(1,5)

print(users.items)

users = User.query.paginate(2, 5)

print(users.items)

402572791-5bd930b1e8485_articlex.png

以上就是python中flask_sqlalchemy操作数据库的方法示例的详细内容，更多文章请关注木庄网络博客！！

相关阅读 >>

介绍Python中星号变量的特殊用法

Python中format()格式输出的详细介绍（附代码）

Python对json的解析详解

Python pip是什么原理

Python中列表、元组、字典三者有什么区别

Python2.7和3.5有什么区别

Python基础操作汇总

Python如何把字符串倒序

Python中eval函数怎么用

Python如何做一个登录注册界面

更多相关阅读请进入《Python》频道 >>




标签：

打赏

取消

感谢您的支持，我会继续努力的!

扫码支持
扫码打赏，您说多少就多少

打开支付宝扫一扫，即可进行扫码打赏哦

分享从这里开始，精彩与您同在

相关推荐

评论

管理员已关闭评论功能...