python 操作mysql数据库简单封装

1
2
import pymysql
from pymysql.cursors import DictCursor

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
class MySqlUtils:
def __init__(self, host=None, port=0, user=None, passwd=None, db=None,
charset='utf8'):
self.conn = pymysql.connect(host=host,
port=port,
user=user,
passwd=passwd,
# password也可以
db=db,
#数据库名称
charset=charset,
# 如果查询有中文需要指定数据库编码
cursorclass=DictCursor) #返回字典
self.cursor = self.conn.cursor()
def query(self, sql, args=None, fetchall=True):
self.cursor.execute(sql, args=args)
if fetchall:
#默认查询所有数据
res = self.cursor.fetchall()
else:
res = self.cursor.fetchone()
return res
def close_db(self):#关闭游标、连接
self.cursor.close()
self.conn.close()

1
2
3
def query_name(self, name):
self.cursor.execute("select * from 表名 where name = %s", args=[name, ])
return self.cursor.fetchall()

1
mysql_utils.query_name(name="xxx")就可以了，省得每次都要写一遍sql