一区二区三区在线-一区二区三区亚洲视频-一区二区三区亚洲-一区二区三区午夜-一区二区三区四区在线视频-一区二区三区四区在线免费观看

服務器之家：專注于服務器技術及軟件下載分享
分類導航

Mysql|Sql Server|Oracle|Redis|MongoDB|PostgreSQL|Sqlite|DB2|mariadb|Access|數據庫技術|

服務器之家 - 數據庫 - Mysql - 使用python連接mysql數據庫之pymysql模塊的使用

使用python連接mysql數據庫之pymysql模塊的使用

2020-12-03 15:24三國小夢 Mysql

這篇文章主要介紹了使用python連接mysql數據庫之pymysql模塊的使用，本文給大家介紹的非常詳細，具有一定的參考借鑒價值,需要的朋友可以參考下

安裝pymysql

pip install pymysql

2|0使用pymysql

2|1使用數據查詢語句

查詢一條數據fetchone()

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
from pymysql import *
 
conn = connect(
  host='127.0.0.1',
  port=3306, user='root',
  password='123456',
  database='itcast',
  charset='utf8')
 
# 創建游標
c = conn.cursor()
# 執行sql語句
c.execute("select * from student")
# 查詢一行數據
result = c.fetchone()
print(result)
# 關閉游標
c.close()
# 關閉數據庫連接
conn.close()
"""
(1, '張三', 18, b'\x01')
"""

查詢多條數據fetchall()

?
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
26
from pymysql import *
 
conn = connect(
  host='127.0.0.1',
  port=3306, user='root',
  password='123456',
  database='itcast',
  charset='utf8')
 
# 創建游標
c = conn.cursor()
# 執行sql語句
c.execute("select * from student")
# 查詢多行數據
result = c.fetchall()
for item in result:
  print(item)
# 關閉游標
c.close()
# 關閉數據庫連接
conn.close()
"""
(1, '張三', 18, b'\x01')
(2, '李四', 19, b'\x00')
(3, '王五', 20, b'\x01')
"""

更改游標的默認設置，返回值為字典

?
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
26
from pymysql import *
 
conn = connect(
  host='127.0.0.1',
  port=3306, user='root',
  password='123456',
  database='itcast',
  charset='utf8')
 
# 創建游標，操作設置為字典類型
c = conn.cursor(cursors.DictCursor)
# 執行sql語句
c.execute("select * from student")
# 查詢多行數據
result = c.fetchall()
for item in result:
  print(item)
# 關閉游標
c.close()
# 關閉數據庫連接
conn.close()
"""
{'id': 1, 'name': '張三', 'age': 18, 'sex': b'\x01'}
{'id': 2, 'name': '李四', 'age': 19, 'sex': b'\x00'}
{'id': 3, 'name': '王五', 'age': 20, 'sex': b'\x01'}
"""

返回一條數據時也是一樣的。返回字典或者時元組看個人需要。

2|2使用數據操作語句

執行增加、刪除、更新語句的操作其實是一樣的。只寫一個作為示范。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
from pymysql import *
 
conn = connect(
  host='127.0.0.1',
  port=3306, user='root',
  password='123456',
  database='itcast',
  charset='utf8')
 
# 創建游標
c = conn.cursor()
# 執行sql語句
c.execute("insert into student(name,age,sex) values (%s,%s,%s)",("小二",28,1))
# 提交事務
conn.commit()
# 關閉游標
c.close()
# 關閉數據庫連接
conn.close()

和查詢語句不同的是必須使用commit()提交事務，否則操作就是無效的。

3|0編寫數據庫連接類

普通版

MysqlHelper.py

?
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
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
from pymysql import connect,cursors
 
class MysqlHelper:
  def __init__(self,
         host="127.0.0.1",
         user="root",
         password="123456",
         database="itcast",
         charset='utf8',
         port=3306):
    self.host = host
    self.port = port
    self.user = user
    self.password = password
    self.database = database
    self.charset = charset
    self._conn = None
    self._cursor = None
 
  def _open(self):
    # print("連接已打開")
    self._conn = connect(host=self.host,
               port=self.port,
               user=self.user,
               password=self.password,
               database=self.database,
               charset=self.charset)
    self._cursor = self._conn.cursor(cursors.DictCursor)
 
  def _close(self):
    # print("連接已關閉")
    self._cursor.close()
    self._conn.close()
 
  def one(self, sql, params=None):
    result: tuple = None
    try:
      self._open()
      self._cursor.execute(sql, params)
      result = self._cursor.fetchone()
    except Exception as e:
      print(e)
    finally:
      self._close()
    return result
 
  def all(self, sql, params=None):
    result: tuple = None
    try:
      self._open()
      self._cursor.execute(sql, params)
      result = self._cursor.fetchall()
    except Exception as e:
      print(e)
    finally:
      self._close()
    return result
 
  def exe(self, sql, params=None):
    try:
      self._open()
      self._cursor.execute(sql, params)
      self._conn.commit()
    except Exception as e:
      print(e)
    finally:
      self._close()

該類封裝了fetchone、fetchall、execute，省去了數據庫連接的打開和關閉和游標的打開和關閉。
下面的代碼是調用該類的小示例：

?
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
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
from MysqlHelper import *
 
mysqlhelper = MysqlHelper()
ret = mysqlhelper.all("select * from student")
for item in ret:
  print(item)
"""
{'id': 1, 'name': '張三', 'age': 18, 'sex': b'\x01'}
{'id': 2, 'name': '李四', 'age': 19, 'sex': b'\x00'}
{'id': 3, 'name': '王五', 'age': 20, 'sex': b'\x01'}
{'id': 5, 'name': '小二', 'age': 28, 'sex': b'\x01'}
{'id': 6, 'name': '娃哈哈', 'age': 28, 'sex': b'\x01'}
{'id': 7, 'name': '娃哈哈', 'age': 28, 'sex': b'\x01'}
"""
上下文管理器版
mysql_with.py
 
from pymysql import connect, cursors
 
class DB:
  def __init__(self,
         host='localhost',
         port=3306,
         db='itcast',
         user='root',
         passwd='123456',
         charset='utf8'):
    # 建立連接
    self.conn = connect(
      host=host,
      port=port,
      db=db,
      user=user,
      passwd=passwd,
      charset=charset)
    # 創建游標，操作設置為字典類型
    self.cur = self.conn.cursor(cursor=cursors.DictCursor)
 
  def __enter__(self):
    # 返回游標
    return self.cur
 
  def __exit__(self, exc_type, exc_val, exc_tb):
    # 提交數據庫并執行
    self.conn.commit()
    # 關閉游標
    self.cur.close()
    # 關閉數據庫連接
    self.conn.close()

如何使用：

?
1
2
3
4
5
6
7
8
9
10
from mysql_with import DB
 
with DB() as db:
  db.execute("select * from student")
  ret = db.fetchone()
  print(ret)
 
"""
{'id': 1, 'name': '張三', 'age': 18, 'sex': b'\x01'}
"""

總結

以上所述是小編給大家介紹的使用python連接mysql數據庫之pymysql模塊的使用，希望對大家有所幫助，如果大家有任何疑問歡迎給我留言，小編會及時回復大家的！

原文鏈接：https://www.cnblogs.com/lxy0/archive/2019/09/01/11441723.html

延伸 · 閱讀

精彩推薦
主站蜘蛛池模板： 青青精品视频 | 调教禽兽| 精品久久久久久久久免费影院 | 岛国片免费看 | 男男视频18免费网站 | 日本高清在线精品一区二区三区 | 日本xxxxx69hd日本 | 国产aaaaa一级毛片 | 欧美同性猛男野外gay免费 | 国产成人cao在线 | 91最新国产 | 麻豆视频免费在线观看 | 青草久久精品亚洲综合专区 | 青草视频在线观看免费网站 | 国产免费视频 | 日本老头4569gay | 午夜国产精品 | 亚洲干综合 | 99在线在线视频免费视频观看 | 午夜伦伦电影理论片大片 | 日本免费在线 | 91精品综合久久久久久五月天 | 国产欧美日韩视频在线观看一区二区 | 16男男gaygays | 特黄特色大片免费视频播放 | 欧美va在线 | 日本视频在线观看播放 | 好姑娘完整版在线观看中文 | 高清欧美不卡一区二区三区 | 免费精品在线 | 久久99re热在线播放7 | 激情小说欧美图片 | 亚洲天堂免费看 | 消息称老熟妇乱视频一区二区 | 亚洲国产成人综合 | 国产精品第一区揄拍 | 国产日韩欧美在线一二三四 | 嫩草影院地址一地址二 | 香蕉tv亚洲专区在线观看 | 亚洲国产精品网 | 国产精品日韩欧美一区二区 |