sqlalchemy批量添加數據－數據源是json（小算法）

 

需求：

想要寫１個增加case的接口

問題：

sqlalchemy添加case的方式，只能是１條數據１條數據的插入，像這樣：

　 ro2 = Role(name='user') 2  db.session.add_all([ro1]) 3     db.session.commit()

我希望的效果是這樣的：

我傳入一個字典{'name':'lisa'}，然后自動轉化成name=‘lisa’這樣的格式

接口的參數是一組dict類型的數據，每一組數據即視為１條case，通過程序將json傳過來的數據對號入座

a=[{'name':'lisa'},{'name':'bob'}]

case=[]
for i in a: #i={'name':'lisa'}
    name=i['name'] #name='lisa'

    obj = Role(name=name)#obj=<Role 'lisa'>
    case.append(obj)
print(case)#[<Role 'lisa'>, <Role 'bob'>]
db.session.add_all(case)
db.session.commit()

 

 

完整的代碼如下：

#!/usr/bin/python
# -*- coding: utf-8 -*-

from flask import Flask  5 from flask_sqlalchemy import SQLAlchemy  6 
app = Flask(__name__)  8 
# 設置連接數據庫的URL
app.config['SQLALCHEMY_DATABASE_URI'] ='mysql+mysqlconnector://root:admin123456@10.1.71.32:3306/test'

# 設置每次請求結束后會自動提交數據庫的改動
app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN'] = True 14 app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True 15 
# 查詢時顯示原始SQL語句
app.config['SQLALCHEMY_ECHO'] = False 18 db = SQLAlchemy(app) 19 

class Role(db.Model): 22     __tablename__ = 'roles'
    id = db.Column(db.Integer, primary_key=True) 24     name = db.Column(db.String(64)) 25 
    def __repr__(self): 27         return '<Role %r>' % self.name 28 

#數據源-要批量添加的case數據 list套dict
a=[{'name':'lisa'},{'name':'bob'}] 32 
case=[] 34 for i in a: #i={'name':'lisa'}
    name=i['name'] #name='lisa'

    obj = Role(name=name)#obj=<Role 'lisa'>
 case.append(obj) 39 print(case)#[<Role 'lisa'>, <Role 'bob'>]
db.session.add_all(case) 41 db.session.commit()

結果：可以循環插入多條數據