1.增删改查封装类MysqlHelper.py
import pymysql as ps class MysqlHelper:
def __init__(self, host, user, password, database, charset):
self.host = host
self.user = user
self.password = password
self.database = database
self.charset = charset
self.db = None
self.curs = None
# 数据库连接
def open(self):
self.db = ps.connect(host=self.host, user=self.user, password=self.password,database=self.database, charset=self.charset)
self.curs = self.db.cursor()
# 数据库关闭
def close(self):
self.curs.close()
self.db.close()
# 数据增删改
def cud(self, sql, params):
self.open()
try:
self.curs.execute(sql, params)
self.db.commit()
print("ok")
except :
print('cud出现错误')
self.db.rollback()
self.close()
# 数据查询
def find(self, sql, params):
self.open()
try:
result = self.curs.execute(sql, params)
self.close()
print("ok")
return result
except:
print('find出现错误')
2.数据查询（引入封装类）
from MysqlHelper import MysqlHelper
mh = MysqlHelper('localhost', 'root', '', 'test', 'utf8')
sql = "select * from user where name=%s"
print(mh.find(sql, '小明'))
3.数据修改（引入封装类）
from MysqlHelper import MysqlHelper
mh = MysqlHelper('localhost', 'root', '', 'test', 'utf8')
sql = "insert into user(name,password) values(%s,%s)"
mh.cud(sql, ('小光', ''))