使用FlaskSQLAlchemy将csv、json格式数据插入mysql数据库

一、获取Flask、SQLAlchemy实例&＃xff0c;绑定Flask实例

db &＃61; SQLAlchemy()
db.init_app(app)


其中app来自工厂函数

def create_app(app):app &＃61; Flask(__name__)app.config.from_object(Config)config_extensions(app)return app


二、插入csv文件中的数据

数据文件&＃xff1a;mysql.csv&＃xff08;h3c套一提供数据&＃xff09;

1.声明orm关系映射

# -*- coding:utf-8 -*-
# Created by ZhaoWen on 2020/10/25from app.models import dbclass Tbl_hotel_test(db.Model):__tablename__ &＃61; &＃39;tbl_hotel_test&＃39;seq &＃61; db.Column(db.String(30),primary_key&＃61;True) #SEQhotel_name &＃61; db.Column(db.String(100)) #酒店名称country &＃61; db.Column(db.String(50)) #国家province &＃61; db.Column(db.String(50)) #省份city &＃61; db.Column(db.String(50)) #城市business_district &＃61; db.Column(db.String(100)) #商圈start &＃61; db.Column(db.String(30)) #星级department &＃61; db.Column(db.String(50)) #业务部门rooms &＃61; db.Column(db.Integer) #房间数字photos &＃61; db.Column(db.Integer) #图片数score &＃61; db.Column(db.DECIMAL(15,12)) #评分content &＃61; db.Column(db.Integer) #评论数city_avg_night &＃61; db.Column(db.DECIMAL(6,2)) #城市平均实住间夜hotel_total_order &＃61; db.Column(db.Integer) #酒店总订单hotel_total_night &＃61; db.Column(db.Integer) # 酒店总间夜hotel_right_order &＃61; db.Column(db.Integer) # 酒店实住订单hotel_right_night &＃61; db.Column(db.Integer) # 酒店实住间夜hotel_direct_order &＃61; db.Column(db.Integer) #酒店直销订单hotel_direct_night &＃61; db.Column(db.Integer) #酒店直销间夜hotel_direct_right_order &＃61; db.Column(db.Integer) #酒店直销实住订单hotel_direct_right_night &＃61; db.Column(db.Integer) #酒店直销实住间夜hotel_direct_refuse_order &＃61; db.Column(db.Integer) #酒店直销拒单hotel_direct_refuse_pie &＃61; db.Column(db.String(20)) #酒店直销拒单率city_direct_order &＃61; db.Column(db.Integer) #城市直销订单city_direct_Refuse_pie &＃61; db.Column(db.String(20)) #城市直销拒单率directcity_issmall &＃61; db.Column(db.Integer) #拒单率是否小于等于直销城市均值


2.插入数据

&＃64;main_print.route(&＃39;/addData&＃39;)
def main_add():print(&＃39;开始插入&＃39;)with open(&＃39;app/static/data/mysql.csv&＃39;,&＃39;r&＃39;,encoding&＃61;&＃39;utf-8&＃39;) as f:reader &＃61; csv.reader(f)if reader !&＃61; None:for i in reader:hotel &＃61; Tbl_hotel_test(seq&＃61;i[0],hotel_name&＃61;i[1],country&＃61;i[2],province&＃61;i[3],city&＃61;i[4],business_district&＃61;i[5],start&＃61;i[6],department&＃61;i[7],rooms&＃61;i[8],photos&＃61;i[9],score&＃61;i[10],content&＃61;i[11],city_avg_night&＃61;i[12],hotel_total_order&＃61;i[13],hotel_total_night&＃61;i[14],hotel_right_order&＃61;i[15],hotel_right_night&＃61;i[16],hotel_direct_order&＃61;i[17],hotel_direct_night&＃61;i[18],hotel_direct_right_order&＃61;i[19],hotel_direct_right_night&＃61;i[20],hotel_direct_refuse_order&＃61;i[21],hotel_direct_refuse_pie&＃61;i[22],city_direct_order&＃61;i[23],city_direct_Refuse_pie&＃61;i[24],directcity_issmall&＃61;i[25])db.session.add(hotel)# return render_template(&＃39;/test/test-data.html&＃39;,reader &＃61; reader)db.session.commit()return render_template(&＃39;/test/sucess.html&＃39;,content&＃61;&＃39;插入成功&＃39;)return &＃39;&＃39;


3. 效果

三、插入json中的数据

1.ORM关系映射

# -*- coding:utf-8 -*-
# Created by ZhaoWen on 2020/10/25from app.models import db&＃39;&＃39;&＃39;
城市,公司全名,公司ID,公司简称,公司大小,公司所在商区,职位所属 ,教育要求,公司所属领域 ,职位ID,职位福利,职位名称,薪水,工作年限要求
&＃39;&＃39;&＃39;class Tbl_zp(db.Model):__tablename__ &＃61; &＃39;tbl_zp_test&＃39;id &＃61; db.Column(db.Integer,primary_key&＃61;True,autoincrement&＃61;True) #序号company_id &＃61; db.Column(db.Integer) # 公司idcity &＃61; db.Column(db.String(20)) # 城市conpany_name &＃61; db.Column(db.String(50)) # 公司全名conpany_simple_name &＃61; db.Column(db.String(20)) # 公司简称conpany_size &＃61; db.Column(db.String(20)) # 公司大小conpany_area &＃61; db.Column(db.String(50)) #公司所在商圈job_category &＃61; db.Column(db.String(20)) #职位所属分类school_level &＃61; db.Column(db.String(10)) #教育要求conpany_category &＃61; db.Column(db.String(20)) # 公司所属领域job_id &＃61; db.Column(db.String(20)) #职位idjob_get &＃61; db.Column(db.String(200)) # 职位福利job_name &＃61; db.Column(db.String(50)) # 职位名称job_salary &＃61; db.Column(db.String(20)) # 薪资job_year &＃61; db.Column(db.String(50)) #工作年限要求


2.插入数据

&＃64;main_print.route(&＃39;/addData2&＃39;)
def main_add2():print(&＃39;开始插入&＃39;)result &＃61; []with open(&＃39;app/static/data/zpdata.json&＃39;,encoding&＃61;&＃39;utf-8&＃39;) as f:result.append(json.load(f))if result !&＃61; None:for r in result:for i in r:&＃39;&＃39;&＃39;城市,公司全名,公司ID,公司简称,公司大小,公司所在商区,职位所属 ,教育要求,公司所属领域 ,职位ID,职位福利,职位名称,薪水,工作年限要求&＃39;&＃39;&＃39;try:zp &＃61; Tbl_zp(city&＃61;i[&＃39;城市&＃39;], conpany_name&＃61;i[&＃39;公司全名&＃39;], company_id&＃61;i[&＃39;公司ID&＃39;],conpany_simple_name&＃61;i[&＃39;公司简称&＃39;], conpany_size&＃61;i[&＃39;公司大小&＃39;], conpany_area&＃61;i[&＃39;公司所在商区&＃39;], job_category&＃61;i[&＃39;职位所属&＃39;],school_level&＃61;i[&＃39;教育要求&＃39;], conpany_category&＃61;i[&＃39;公司所属领域&＃39;], job_id&＃61;i[&＃39;职位ID&＃39;],job_get&＃61;i[&＃39;职位福利&＃39;],job_name&＃61;i[&＃39;职位名称&＃39;], job_salary&＃61;i[&＃39;薪水&＃39;], job_year&＃61;i[&＃39;工作年限要求&＃39;])db.session.add(zp)except:db.session.delete(zp)db.session.commit()# return render_template(&＃39;test/json-show.html&＃39;,result &＃61; result)return render_template(&＃39;/test/sucess.html&＃39;, content&＃61;&＃39;插入成功&＃39;)return &＃39;&＃39;


3.效果