代码：
class MySqlTools:
def __init__(self,host,user,password,database,port=3306,charset = "utf8"):
self.host = host
self.user = user
self.password = password
self.database = database
self.port = port
self.charset = charset
def __connet(self):
self.conn = None
self.cursor = None
self.conn = pymysql.connect(host=self.host,
user=self.user,
password=self.password,
database=self.database,
port=self.port,
charset=self.charset
)
self.cursor = self.conn.cursor()
def __cud(self,sql,params=[]):
"""
:param self:
:param sql:
:param params:
:return:
"""
try:
self.__connet()
self.cursor.execute(sql,params)
self.conn.commit()
except Exception as e:
print(e)
self.conn.rollback()
finally:
self.__close()
def __close(self):
"""
释放资源
:param self:
:return:
"""
if self.cursor:
self.cursor.close()
if self.conn:
self.conn.close()
def insert(self,sql,paeams = []):
"""
:param sql:
:param paeams:
:return:
"""
self.__cud(sql,params)
def update(self,sql,params = []):
"""
delete操作
:param sql:
:param params:
:return:
"""
self.__cud(sql,params)
def getOne(self,sql,params=[]):
"""
:param self:
:param sql:
:param params:
:return:
"""
result = None
try:
self.__connet()
self.cursor.execute(sql,paeams)
result =self.cursor.fetchall()
except Exception as e:
print(e)
finally:
self.__close()
return result
