python 封裝pymysql的思路步驟

2021-09-26 03:45:03 字數 1590 閱讀 7962

目標:

封裝乙個模組

功能,呼叫模組,可以快捷的操作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...