flask_sqlalchemy批量插入mysql

测试代码

#!/usr/bin/python

# -*- coding: utf-8 -*-

from datetime import datetime

from flask_sqlalchemy import SQLAlchemy

from flask import Flask

app = Flask(__name__)

'''配置数据库'''

app.config['SECRET_KEY'] = 'dns'#一个字符串，密码。也可以是其他如加密过的

#在此登录的是root用户，要填上密码如123456，MySQL默认端口是3306。并填上创建的数据库名如test

app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://root:123456@192.168.5.41/test'

#设置下方这行code后，在每次请求结束后会自动提交数据库中的变动

app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN'] = True

app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True

db = SQLAlchemy(app)#实例化数据库对象，它提供访问Flask-SQLAlchemy的所有功能

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)

    def __init__(self, username, email):

        self.username = username

        self.email = email

    def __repr__(self):

        return '<User %r>' % self.username

if __name__ == '__main__':

    db.drop_all()

    db.create_all()

    fourth_time = datetime.utcnow()

    db.session.execute(

        User.__table__.insert(),

        [{"username": 'name=' + str(i), "email": 'email=' + str(i)} for i in range(20000)]

    )

    db.session.commit()

    five_time = datetime.utcnow()

    print((five_time - fourth_time).total_seconds())

执行结果

从结果来看性能还是不错的

参考

http://www.manongjc.com/detail/8-fjqznbdwcmthgru.html