import pymysql #数据库查询 class QuerySqlData(object): def __init__(self): self.conn = pymysql.connect( host='ip', port=3306, user='#', passwd='#', db='#', charset='utf8') # 建立链接 def find_table(self,sql,bid): cursor = self.conn.cursor() # 建立链接 try: cursor.execute(sql, bid) # 执行SQL results = cursor.fetchall(); # 返回查询数据 self.conn.commit() # 提交,否则没法保存新建或者修改的数据 except: print("数据链接错误-find_table") finally: cursor.close() # 关闭游标 self.conn.close() # 关闭链接 return resultsif __name__ == '__main__': querySqlData = QuerySqlData() value = {"userid":"aa"} a = querySqlData.find_table('SELECT * from t_user u where u.userid=%(userid)s',value) print(a)