import pymysql
class MysqlOperation():
def __init__(self, host, user, pwd, port, db):
self.host = host
self.user = user
self.password = pwd
self.port = port
self.dbname = db
self.conn = None # 連接
self.cur = None # 游標
def open(self):
# 創建連接
self.conn = pymysql.connect(host=self.host, user=self.user, password=self.password, port=self.port,
db=self.dbname, charset='utf8') # 創建連接
self.cur = self.conn.cursor() # 創建游標
def select(self, sql):
'''查詢數據'''
self.cur.execute(sql) # 查詢數據
return self.cur.fetchall() # 獲取結果
def execute(self, sql):
'''執行sql'''
try:
# 執行SQL語句
self.cur.execute(sql)
# 提交事務到數據庫執行
self.conn.commit() # 事務是訪問和更新數據庫的一個程序執行單元
except BaseException as f:
print(f)
self.conn.rollback()
# 返回受影響行數
return self.cur.rowcount
def executemany(self, sql, params):
'''
批量插入數據
:param sql: 插入數據模版, 需要指定列和可替換字符串個數
:param params: 插入所需數據,列表嵌套元組[(1, '張三', '男'),(2, '李四', '女'),]
:return: 影響行數
'''
try:
# sql = "INSERT INTO USER VALUES (%s,%s,%s,%s)" # insert 模版
# params = [(2, 'fighter01', 'admin', 'sanpang'),
# (3, 'fighter02', 'admin', 'sanpang')] # insert數據,
self.cur.executemany(sql, params)
except BaseException as f:
print(f)
self.conn.rollback()
return self.cur.rowcount
def __enter__(self):
self.open()
return self
def __exit__(self, exc_type, exc_val, exc_tb):
'''退出時關閉游標關閉連接'''
self.cur.close()
self.conn.close()
obj = MysqlOperation(host='127.0.0.1', user='root', pwd='123456', port=3306, db='wlj_db') # 對象
with obj as obj:
result = obj.executemany('''INSERT INTO student(gender, class_id, 分) VALUES ('男', '2', '王五');''')
print(result)