Flask连接数据库

     

from flask import Flask,jsonify,request
import json
from flask_cors import *
import pymysql

app = Flask(__name__)

import contextlib

@contextlib.contextmanager

def mysql(host='192.168.0.122', port=3306, user='root', passwd='我的数据库密码', db='text1',charset='utf8'):
　　conn = pymysql.connect(host=host, port=port, user=user, passwd=passwd, db=db, charset=charset)
　　cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
 　try:
   　　yield cursor
　　finally:
 　　  conn.commit()
　　　　cursor.close()
　　　　conn.close()

 @app.route('/aaa', methods=['GET','POST'])
 @cross_origin()
 def aaa():
    data= request.args.get("data")#获取前台json数据
    temp = json.loads(data)#将json转为字典
    id=temp['id']#获取相应的值
    with mysql() as cursor:
        print(cursor)
         row_count = cursor.execute("select * from users where id=%s", (id))
        row_1 = cursor.fetchone()
         return "successCallback"+"("+json.dumps(row_1)+")"
 
     conn.commit()
     cursor.close()
     conn.close()
 
 if __name__ == "__main__":
     app.run(
     host = '0.0.0.0',
     port = 7777,
    debug = True
)

from sqlalchemy import create_engine,text
from sqlalchemy.orm import sessionmaker

#定义数据库属性
hostname = '127.0.0.1'
port = '3306'
database = 'dbname'
username = 'root'
pwd = 'pwd'
dburl = 'mysql + mysqldb://{}:{}@{}:{}/{}'.format(username,pwd,hostname,port,database)

#创建数据库连接对象
engine = create_engine(dburl,echo=True)
Session = sessionmaker(bind=engine)
session = Session()
session.execute('insert test values ('abc','123')')
session.commmit()
session.close()