from flask import Flask,request import json import pymssql #创建连接字符串 (sqlserver默认端口为1433) conn =pymssql.connect( server="db53.oaqi.com",#本地服务器 port="9167",#TCP端口 user="dev", password="Wy@2012!", database="fstask_new", charset = "CP936" #这里设置全局的GBK,如果设置的是UTF—8需要将数据库默认的GBK转化成UTF-8 ) if conn: print('连接数据库成功!')#测试是否连接上 app=Flask(__name__) @app.route("/test_1.0",methods=["GET","POST"]) def check(): # 默认返回内容 return_dict= {'status': False} get_data=request.args.to_dict() siteid=get_data.get('siteid') client=get_data.get('client') # 对参数进行操作 return_dict=tt(siteid,client) return json.dumps(return_dict, ensure_ascii=False) def tt(siteid,client): result_str="站点:%s 终端:%s" %(siteid,client) return result_str cur = conn.cursor() cur.callproc('p_fstask_new_siteid_client', ['4567','4567354']) result = cur.fetchall() for row in result: status = row[0] print('{0}'.format(status)) conn.close() if __name__ == '__main__': app.run(debug=True)
时间: 2024-02-14 14:34:20 浏览: 77
这段代码似乎是一个使用Flask搭建的Web应用程序,连接到了一个名为fstask_new的SQL Server数据库,并且使用pymssql库执行了一个名为p_fstask_new_siteid_client的存储过程。
在程序开始处,连接到了SQL Server数据库,并且定义了一个Flask应用程序。在程序的主要函数中,使用了Flask的路由装饰器@app.route(),当URL为/test_1.0时,执行check()函数。check()函数获取URL参数siteid和client,并将它们作为参数传递给tt()函数。tt()函数将参数拼接成一个字符串并返回。
在程序的后面,使用了pymssql库连接到SQL Server数据库,并使用存储过程p_fstask_new_siteid_client来查询数据。最后关闭了数据库连接,并启动了Flask应用程序。
需要注意的是,当调用存储过程时,参数必须以列表的形式传递。在这里,p_fstask_new_siteid_client存储过程需要两个参数,所以传递了一个包含两个元素的列表['4567','4567354']。另外,使用存储过程时也可以使用游标对象的execute()方法,不过需要把存储过程名和参数拼成一条SQL语句传递给execute()方法。
阅读全文