目標:
封裝乙個模組
功能,呼叫模組,可以快捷的操作pymysql 的相關功能
分析:pymysql並不是一匯入就可以用的
使用之前要做一些事情
(考慮:把使用前必做的事情,放到初始化的init方法中)
更進一步
pymysql在使用之前,得先
1,連線mysql,獲得連線物件
2,通過連線物件,獲得游標物件
實際,是有兩種執行sql語句的方案
1,一種是直接執行
查詢的時候,不需要做其它操作,讓游標直接查就可以了
2,先執行,再提交
增,刪,改操作的時候,不僅僅是游標物件執行sql語句,連線物件還得向上提交一下才可以。
附:封裝好的**
""" 資料庫模組 """
import pymysql
class dbschool:
def __init__(self):
self.conn = self.get_conn() # 連線物件
self.cursor = self.get_cursor() # 游標物件
def get_conn(self):
""" 獲取連線物件 """
conn = pymysql.connect(
host="127.0.0.1",
port=3306,
user="root",
passwd="root",
db="python2019",
charset="utf8"
)return conn
def get_cursor(self):
"""獲取游標物件"""
# cursor = none
cursor = self.conn.cursor(cursor=pymysql.cursors.dictcursor)
return cursor
def select_all(self, sql):
"""查詢全部
:param sql: 查詢語句
:return: [{},{}]
"""self.cursor.execute(sql)
return self.cursor.fetchall()
def select_one(self, sql):
"""查詢乙個
:param sql: 查詢語句
:return: {}
"""self.cursor.execute(sql)
return self.cursor.fetchone()
def commit_data(self, sql):
"""提交資料
:param sql:
:return:
"""self.cursor.execute(sql)
self.conn.commit()
print("表連線物件,提交成功")
def __del__(self):
self.cursor.close()
self.conn.close()
db = dbschool()
pymysql 封裝呼叫
import pymysql class skq def init self config 建立連線 self.connection pymysql.connect config def add self,dict,table 執行sql語句 try with self.connection.cur...
對pymysql的簡單封裝
coding utf 8 usr bin python import pymysql class mysql 對pymysql的簡單封裝 def init self,host,user,pwd,db self.host host self.user user self.pwd pwd self.db...
基礎類封裝 pymysql庫操作mysql封裝
1 import pymysql 2from lib.logger import logger 3from warnings import filterwarnings 4 filterwarnings ignore category pymysql.warning 忽略mysql警告資訊56 cl...