devbox
盐析白兔
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Flask-数据库-SQLAlchemy_flask sqlalchemy

作者：盐析白兔 | 2024-04-29 07:28:24

赞

踩

flask sqlalchemy

SQLAlchemy是flask的扩展，是一个功能强大的OR映射器，支持多种数据库后台，可以将类的对象映射至数据库表。

使用这个工具，可以创建数据库，创建表，并为数据库添加数据，进行查询操作等。

参考：Flask SQLAlchemy - Flask 教程 | BootWiki.com

创建实例 

 app=Flask(__name__)  #创建Flask实例

 app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:///students.sqlite3'#设置数据库URL

app.config[]可以为Flask实例添加一些配置。

这个配置指明当前文件夹下students.sqlite3数据库文件作为数据库访问的URL，这个数据库文件当前可以不存在，在程序运行时create。

在Flask-SQLAlchemy中，数据库使用URL指定。几种最流行的数据库引擎使用的URL格式

 

 

app.config['SECRET_KEY'] = "random string"

 这个配置设置了secret_key，用于session，在学习session的时候已经知道，服务器加密会话数据时需要一个secret_key，至于这里为什么要用到session，在后面会说到。

db=SQLAlchemy(app) 创建一个SQLAlchemy类的对象。 该对象包含ORM操作的辅助函数。 它还提供了一个使用其声明用户定义模型的父级模型类。

类和模型 

模型这个术语表示应用使用的持久化实体。在ORM中，模型一般是一个Python类，类中的属性对应于数据库表中的列。

定义一个类（students模型），继承Model模型。这个类和数据库的表对应，类的属性分别对应表的字段。

class students(db.Model):
    id = db.Column('student_id', db.Integer, primary_key=True)
    name = db.Column(db.String(100))
    city = db.Column(db.String(50))
    addr = db.Column(db.String(200))
    pin = db.Column(db.String(10))
    def __init__(self,name,city,addr,pin):


        self.name=name
        self.city=city
        self.addr=addr
        self.pin=pin

db.Column类构造函数的第一个参数是数据库列和模型属性的类型 

常用的类型

 

db.Column的其余参数指定属性的配置选项

常用的SQLAlchemy配置选项 

 

通过属性定义，也为表添加了字段。id为主键。

db.create_all()

使用这个语句，执行创建数据库操作。

CRUD操作 

 SQLAlchemy的Session对象管理ORM对象的所有持久性操作。

db.session.add(模型对象) - 将一条记录插入到映射表中   准备把对象写入数据库之前，要先将其添加到会话中
db.session.delete(模型对象) - 从表中删除记录
模型.query.all() - 从表中检索所有记录(对应于SELECT查询)。

db.session.commit()提交修改  为了把对象写入数据库，我们要调用commit()方法提交会话

可以使用filter属性将筛选器应用于检索到的记录集。例如，要在students表中检索city ='Haikou'的记录，请使用以下语句 

Students.query.filter_by(city = 'Haikou').all()

 

 

 

 

数据库会话db.session和Flask的session对象没有关系。数据库会话也称为事务， 能保证数据库的一致性。提交操作使用原子方式把会话中的对象全部写入数据库。如果在写入会话的过程中发生了错误，那么整个会话都会失效。如果你始终把相关改动放在会话中提交，就能避免因部分更新导致的数据库不一致。

实战

实现一个添加学生信息并展示信息的小应用。

点击添加学生，打开添加学生页面，提交信息后，展示所有学生信息列表。

http://localhost:5000/

http://localhost:5000/new

 

http://localhost:5000/ 

这个应用，一共有两个页面，一个展示所有信息show_all.html，一个添加学生信息new.html。

在展示所有信息页面，首先显示闪现消息flash，当没有闪现消息的时候不显示。添加学生链接至new页面，最下方读取数据库数据并显示，数据库无数据时不显示数据。

show_all.html如下

  1. <html>
  2. <head>
  3. <meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
  4. <title>Flask示例</title>
  5. </head>
  6.    <body>
  7.  
  8.       <h1>
  9.          Flask
  10.             SQLAlchemy示例
  11.       </h1>
  12.  
  13.       <hr/>
  14.       {%- for message in get_flashed_messages() %}
  15.          {{ message }}
  16.       {%- endfor %}
  17.  
  18.       <h1>(<a href = "{{ url_for('new') }}">添加学生
  19.          </a>)</h1>
  20.  
  21.       <table>
  22.          <thead>
  23.             <tr>
  24.                <th>姓名</th>
  25.                <th>城市</th>
  26.                <th>地址</th>
  27.                <th>Pin</th>
  28.             </tr>
  29.          </thead>
  30.  
  31.          <tbody>
  32.             {% for student in students %}
  33.                <tr>
  34.                   <td>{{ student.name }}</td>
  35.                   <td>{{ student.city }}</td>
  36.                   <td>{{ student.addr }}</td>
  37.                   <td>{{ student.pin }}</td>
  38.                </tr>
  39.             {% endfor %}
  40.          </tbody>
  41.       </table>
  42.  
  43.    </body>
  44. </html>
  45.  
  46.

对于的视图函数如下

  1. @app.route('/')
  2. def show_all():
  3.     return render_template('show_all.html',students=students.query.all())

添加学生信息页面new.html，也会显示flash，下放展示一个表单，点击提交按钮后，表单数据以post方式提交给服务器，并使用视图函数new接收表单数据进行处理。对表单数据进行校验，不满足校验显示flash，满足校验，则向数据库添加数据，并重定向至展示信息页面。

new.html页面如下：

  1.  
  2. <head>
  3. <meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
  4. <title>Flask示例</title>
  5. </head>
  6.  
  7.     <h3>添加学生信息</h3>
  8.       <hr/>
  9.  
  10.       {%- for category, message in get_flashed_messages(with_categories = true) %}
  11.          <div class = "alert alert-danger">
  12.             {{ message }}
  13.          </div>
  14.       {%- endfor %}
  15.  
  16.       <form action = "/new" method = "post">
  17.          <label for = "name">姓名</label><br>
  18.          <input type = "text" name = "name" placeholder = "Name" /><br>
  19.          <label for = "email">城市</label><br>
  20.          <input type = "text" name = "city" placeholder = "city" /><br>
  21.          <label for = "addr">地址</label><br>
  22.           <textarea name = "addr" placeholder = "addr"></textarea><br>
  23.          <label for = "PIN">邮编</label><br>
  24.          <input type = "text" name = "pin" placeholder = "pin" /><br>
  25.          <input type = "submit" value = "提交" />
  26.       </form>
  27.  
  28.    </body>
  29. </html>
  30.  
  31.  
  32.

 对于视图函数如下

  1. @app.route('/new',methods=['GET','POST'])
  2. def new():
  3.  
  4.     if request.method=='POST':
  5.         if not request.form['name']or not request.form['city']or not request.form['addr']:
  6.             flash('Please enter all the fields','error') #如果有一个没填写，闪现消息
  7.         else:
  8.             student = students(request.form['name'], request.form['city'], request.form['addr'], request.form['pin'])
  9.             print(student)
  10.             db.session.add(student)#把数据添加到数据库
  11.             db.session.commit()#提交数据
  12.             flash('Record was successfully added')#闪现消息添加成功
  13.             return  redirect(url_for('show_all')) #一个函数可以有两个return
  14.     return render_template('new.html') #点击添加按钮，渲染new.html页面

最后附上程序入口，运行程序，即可访问。

  1. if __name__ == '__main__':
  2.     db.create_all()
  3.     app.run(debug=True)

完整代码：

  1. from flask_sqlalchemy import SQLAlchemy
  2. from flask import Flask,render_template,request,flash,redirect,url_for
  3. app=Flask(__name__)
  4. app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:///students.sqlite3'#设置数据库URL
  5. #创建一个SQLAlchemy类的对象。 该对象包含ORM操作的辅助函数。 它还提供了一个使用其声明用户定义模型的父级模型类。
  6. app.config['SECRET_KEY'] = "random string"
  7.  
  8.  
  9.  
  10.  
  11. db=SQLAlchemy(app)
  12. class students(db.Model):
  13.     id = db.Column('student_id', db.Integer, primary_key=True)
  14.     name = db.Column(db.String(100))
  15.     city = db.Column(db.String(50))
  16.     addr = db.Column(db.String(200))
  17.     pin = db.Column(db.String(10))
  18.     def __init__(self,name,city,addr,pin):
  19.  
  20.  
  21.         self.name=name
  22.         self.city=city
  23.         self.addr=addr
  24.         self.pin=pin
  25.  
  26.  
  27.  
  28. @app.route('/')
  29. def show_all():
  30.     db.create_all()
  31.     return render_template('show_all.html',students=students.query.all())
  32.  
  33.  
  34. @app.route('/new',methods=['GET','POST'])
  35. def new():
  36.  
  37.     if request.method=='POST':
  38.         if not request.form['name']or not request.form['city']or not request.form['addr']:
  39.             flash('Please enter all the fields','error') #如果有一个没填写，闪现消息
  40.         else:
  41.             student = students(request.form['name'], request.form['city'], request.form['addr'], request.form['pin'])
  42.             print(student)
  43.             db.session.add(student)#把数据添加到数据库
  44.             db.session.commit()#提交数据
  45.             flash('Record was successfully added')#闪现消息添加成功
  46.             return  redirect(url_for('show_all')) #一个函数可以有两个return
  47.     return render_template('new.html') #点击添加按钮，渲染new.html页面
  48.  
  49. if __name__ == '__main__':
  50.     db.create_all()
  51.     app.run(debug=True)

 总结：文本学习了Flask数据库相关扩展SQLAlchemy的使用，并实现了一个添加并展示学生信息的应用。


 

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/盐析白兔/article/detail/506593
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号