import pymysql

class PySql:

def __init__(self):

# 參數(shù)內(nèi)容可以從配置文件中讀取

? ? ? ? self.conn = pymysql.connect(host='',

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? user='',

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? password='',

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? db='',

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? port='',

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? charset='utf8', # 這里編碼只能寫為utf8

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? cursorclass=pymysql.cursors.DictCursor# 執(zhí)行sql語句的結(jié)果為字典類型

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? )

????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()