#mysqlhelper.py另存即可

import?pymysql

class?dbhelper():
????def?__init__(self,host,port,user,passwd,db,charset="utf8"):
????????self.host=host
????????self.port=port
????????self.user=user
????????self.passwd=passwd
????????self.db=db
????????self.charset=charset
????#創(chuàng)建一個(gè)鏈接
????def?connection(self):
????????#創(chuàng)建連接
????????self.conn=pymysql.connect(host=self.host,port=self.port,
????????user=self.user,passwd=self.passwd,
????????db=self.db,charset=self.charset)
????????#創(chuàng)建游標(biāo)
????????self.cur=self.conn.cursor()
????#關(guān)閉鏈接
????def?closeconnection(self):
????????self.cur.close()
????????self.conn.close()
????#查詢一條語句
????def?getonedata(self,sql):
????????try:
????????????self.connection()
????????????self.cur.execute(sql)
????????????result=self.cur.fetchone()
????????????self.closeconnection()
????????except?Exception:
????????????print(Exception)
????????return?result
????#添加/修改/刪除
????def?executedata(self,sql):
????????try:
????????????self.connection()
????????????self.cur.execute(sql)
????????????self.conn.commit()
????????????self.closeconnection()
????????except?Exception:
????????????print(Exception)
????#批量插入
????def?executemanydata(self,sql,vals):
????????try:
????????????self.connection()
????????????self.cur.executemany(sql,vals)
????????????self.conn.commit()
????????????self.closeconnection()
????????except?Exception:
????????????print(Exception)