資料庫操作 pymysql 封裝處理（中級）

**如下：

import

pymysql
from pymysql.cursors import
dictcursor
class
dbhandler(object):
"""初始化資料庫
"""#
也可以繼承 connection 這裡沒有選擇繼承
def__init__
(self,
host=none, #
連線名 port=3306, #
埠 user=none, #
使用者名稱 password=none, #
密碼 charset=none, #
不能寫utf-8 在mysql裡面寫utf-8會報錯
database=none, #
資料庫庫名
cursorclass=dictcursor,
**kwargs):
self.connect =pymysql.connect(
host=host, #
連線名 port=port, #
埠 user=user, #
使用者名稱 password=password, #
密碼 charset=charset, #
不能寫utf-8 在mysql裡面寫utf-8會報錯
database=database, #
資料庫庫名
cursorclass=cursorclass, #
資料轉換成字典格式
**kwargs
)#建立游標物件 **主要**
self.cursor =self.connect.cursor()
def query_one(self, query, args=none):
"""查詢資料庫一條資料
:param query: 執行mysql語句
:param args: 與查詢語句一起傳遞的引數(給語句傳參) 元組、列表和字典
"""self.cursor.execute(query, args)
#將更改提交到資料庫
self.connect.commit()
return
self.cursor.fetchone()
def query_all(self, query, args=none):
"""查詢資料庫所有資料
:param query: 執行mysql語句
:param args: 與查詢語句一起傳遞的引數(給語句傳參) 元組、列表和字典
"""self.cursor.execute(query, args)
#將更改提交到資料庫
self.connect.commit()
return
self.cursor.fetchall()
def query(self, query, args=none, one=true):
"""主體查詢資料
:param query: 執行mysql語句
:param args: 與查詢語句一起傳遞的引數(給語句傳參) 元組、列表和字典
:param one: one是true 時候執行query_one, 否則執行query_all
"""if
one:
return
self.query_one(query, args)
return
self.query_all(query, args)
defclose(self):
"""關閉
:return:
"""#
關閉游標
self.cursor.close()
#斷開資料庫連線
self.connect.close()
if__name__ == '
__main__':
db =dbhandler(
host='
127.0.0.1
', #
連線名 port=3306, #
埠 user='
root
', #
使用者名稱 password='
root
', #
密碼 charset='
utf8
', #
不能寫utf-8 在mysql裡面寫utf-8會報錯
database='
pymysql_test'#
資料庫庫名
) 
# 查詢語句
sql = '
select * from authors
'sql1 = "
select * from authors where authorid = %s;
"print(db.query(sql, one=false))
print(db.query(query=sql1, args=[1]))

# 關閉連線

db.close()

pymysql 資料庫操作

參考文件 import pymysql dbparams conn pymysql.connect dbparams cursor conn.cursor sql select sname,sclass from student try cursor.execute sql 獲取查詢結果 data ...

python操作pymysql資料庫

首先需要匯入通過import pymysql匯入資料庫模組 已經建立好乙個資料庫test，資料庫中有乙個空表t，只有兩個欄位id int 5 name varchar 20 import pymysql conn pymysql.connect host 127.0.0.1 port 3306,us...

使用PyMySQL操作mysql資料庫

使用pymysql操作mysql資料庫 python版本 2.6或3.3 mysql版本 4.1 使用pip安裝，在命令列執行如下命令 1 pip install pymysql 其中的x.x是版本 目前可以獲取的最新版本是0.6.6 1 python setup.py install 建議使用pi...