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

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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
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)

1
2
3
4
5
6
7
8
9
10
(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