flask使用模块flask_sqlalchemy来根据前端POST请求实现对本地数据库的增删改查（一）---增

75 阅读 0 评论 50 点赞

我是靠谱客的博主隐形纸鹤，最近开发中收集的这篇文章主要介绍flask使用模块flask_sqlalchemy来根据前端POST请求实现对本地数据库的增删改查（一）---增，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

本文主要介绍falsk使用模块flask_sqlalchemy来根据前端POST请求实现对本地数据库的增删改查（一）--------增

前言：

上篇文章已经写到了falsk模块flask_sqlalchemy配置本地数据库，也已经建好表与字段本文不在赘述。

如图所示建好的表needs,以及字段信息：

接下来我们根据postman 模拟前端请求对字段进行插入值的操作：

代码示例：

from flask import Flask, request, jsonify

app = Flask(__name__)

# 连接mysql数据库需要导入pymysql模块
import pymysql

pymysql.install_as_MySQLdb()

# 导入SQLAlchemy扩展：通过python对象操作数据库
from flask_sqlalchemy import SQLAlchemy

# #实例化SQLALchemy
# db = SQLAlchemy(app)

# 配置数据库的地址； 协议+用户名:密码@主机IP/数据库名称
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:root@localhost/flask?charset=utf8'
# 实时跟踪数据库的修改，不建议开启
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False

# 实例化SQLALchemy,实例化需要写在配置数据库之后
db = SQLAlchemy(app)


# 定义数据库模型
class need(db.Model):
    # 定义表名
    __tablename__ = 'needs'
    # 定义字段
    # primary_key=True 声明主键  unique=True 值唯一  nullable=False 非空
    # 默认主键（label_id）auto_increment 自增
    need_id = db.Column(db.Integer, primary_key=True, nullable=False)
    title = db.Column(db.String(16),  nullable=False)
    applicant_name = db.Column(db.String(16), nullable=False)
    applicant_number = db.Column(db.Integer, nullable=False)
    department = db.Column(db.String(16), nullable=False)
    business = db.Column(db.String(16), nullable=False)
    systemctl_number = db.Column(db.String(16), nullable=False)
    cause = db.Column(db.String(40), nullable=False)

 


# 对数据库进行插入操作
@app.route('/insert', methods=['POST'])
#表示前端访问地址为：http://192.168.56.99:5000/insert


def insert():
    js = request.get_json()
    Need_id = js['need_id']
    Title = js['title']
    Applicant_name = js['applicant_name']
    Applicant_number = js['applicant_number']
    Department = js['department']
    Business = js['business']
    System_number = js['system_number']
    Cause = js['cause']

    Test = need(need_id=Need_id, title=Title, applicant_name=Applicant_name, applicant_number=Applicant_number,
                department=Department, business=Business, systemctl_number=System_number, cause=Cause)

    # 上传提交插入的字段
    db.session.add(Test)
    db.session.commit()
    
   #此处设定请求后的返回值：
    return jsonify({"code": "0000", "msg": "请求成功"})



if __name__ == '__main__':
        # 删除所有表
      #db.drop_all()
      # 创建所有表
    db.create_all()
    app.run(host="192.168.56.99", debug=True)

接下来在服务器上运行此代码（此页面说明运行成功了）：

(venv) [root@localhost templates]# python project.py 
 * Serving Flask app "project" (lazy loading)
 * Environment: production
   WARNING: This is a development server. Do not use it in a production deployment.
   Use a production WSGI server instead.
 * Debug mode: on
 * Running on http://192.168.56.99:5000/ (Press CTRL+C to quit)
 * Restarting with stat
 * Debugger is active!
 * Debugger PIN: 320-648-074

那么我们就可以在postman上测试了：

请求选择post,输入地址，在Body的raw中写入请求的参数，返回格式选择为json即可。

请求示例：

{

    "need_id":20,

    "title":"申请hbase",

    "applicant_name":"frost",

    "applicant_number":"012345",

    "department":"大数据",

    "business":"测试",

    "system_number":"456",

    "cause":"申请hbase"

}