#-*- encoding: utf-8 -*-
#第一种mongodb入库
# from pymongo import *
# import json
# conn = MongoClient(‘127.0.0.1‘,27017)
# db = conn.p2p
# content = open(‘static/data/text.json‘,‘r‘,encoding=‘utf-8‘,errors=‘ignore‘)
# data = json.load(content)
# db.order.insert(data)
# print(db.order.count())
# 第二种SQLALCHEMY入库mysql
# import json
# from flask import Flask
# from flask_sqlalchemy import SQLAlchemy
# app = Flask(__name__)
# app.config.from_pyfile("config.ini")
# db = SQLAlchemy(app)
# class Product(db.Model):
# __tablename__= ‘product‘
# id = db.Column(db.Integer,primary_key=True)
# name = db.Column(db.String(200))
# price = db.Column(db.Integer)
# @app.route("/")
# def index():
# content = open(‘static/data/test.json‘,‘r‘,encoding=‘utf-8‘,errors=‘ignore‘)
# data = json.load(content)
# for i in data:
# ret = Product(name=i[‘name‘],price = i[‘price‘])
# db.session.add(ret)
# return "入库成功"
# if __name__ == "__main__":
# app.run()
#第三种 原生sql 入库mysql
# import json
# from pymysql import *
# conn = connect(host="127.0.0.1",port=3306,user=‘root‘,password=‘mysql‘,database="myflask",charset="utf8")
# cur = conn.cursor()
# content = open(‘static/data/text.json‘,‘r‘,encoding=‘utf-8‘,errors=‘ignore‘)
# data = json.load(content)
# for i in data:
# cur.execute("insert into order values(0,‘"+i[‘name‘]+"‘,‘"+i[‘price‘]+"‘)")
# conn.commit
