import pymysql
class PySql:
def __init__(self):
# 参数内容可以从配置文件中读取
self.conn = pymysql.connect(host='',
user='',
password='',
db='',
port='',
charset='utf8', # 这里编码只能写为utf8
cursorclass=pymysql.cursors.DictCursor# 执行sql语句的结果为字典类型
)
self.cur =self.conn.cursor()
def do_sql_one(self,sql,args=None):
self.cur.execute(sql,args=(args,))
return self.cur.fetchone()
def do_sql_all(self,sql,args=None):
self.cur.execute(sql, args=(args,))
return self.cur.fetchall()
def do_sql(self,sql,args=None,is_all=False):
self.cur.execute(sql, args=(args,))
if is_all:
return self.cur.fetchall()
else:
return self.cur.fetchone()
def close_sql(self):
self.cur.close()
self.conn.close()
