python使用PyMysql連接MySQL實現增刪改查

文章目錄

• • 一、安裝PyMysql：
  • • • 1.方式一：使用命令行
      • 2.方式二：通過PyCharm編譯器
  • 二、操作MySQL數據庫步驟
  • • • 1. 使用import導入相應的類
      • 2.獲得數據庫的連接
      • 3.創建游標對象
      • 4.執行SQL語句
      • 5.關閉數據庫連接
  • 三、案例
  • • • 1. 查詢單條數據
      • 2. 查詢多條數據
      • 3.創建數據庫表
      • 4.插入記錄

一、安裝PyMysql：

1.方式一：使用命令行

打開cmd輸入以下代碼：

pip install PyMysql

2.方式二：通過PyCharm編譯器

如果使用的時開發工具：pycharm，可以直接進入setting 輸入Project interperter裡面去下載,點擊加號就可以去下載對應的依賴包l了

二、操作MySQL數據庫步驟

1. 使用import導入相應的類

import pymysql

提示：可以使用以下方法消除Pycharm編譯器裡面的警告（導入即可，要換行）

import warnings
warnings.filterwarnings("ignore")

2.獲得數據庫的連接

db = pymysql.connect("主機IP地址", "用戶名", "密碼", "需要連接的數據庫名")

3.創建游標對象

cursor = db.cursor()

4.執行SQL語句

 cursor.execute("SQL語句")

5.關閉數據庫連接

db.close()

三、案例

幾個函數：

1. 查詢單條數據

def findAll():
# 1.打開數據庫連接
db = pymysql.connect("localhost", "root", "root", "student")
# 2.創建游標對象
cursor = db.cursor()
# 執行SQL查詢
cursor.execute("select * from user")
# 獲得單條數據
dataOne = cursor.fetchone()
# 關閉數據庫連接
db.close()

2. 查詢多條數據

def findAll():
# 1.打開數據庫連接
db = pymysql.connect("localhost", "root", "root", "student")
# 2.創建游標對象
cursor = db.cursor()
# 查詢所有的記錄
cursor.execute("select * from user")
dataAll = cursor.fetchall()
print(dataAll)
# 關閉數據庫連接
db.close()

3.創建數據庫表

注意：創建之前先判斷表名知否存在，如果存在會報異常

def createTable():
db = pymysql.connect("localhost", "root", "root", "student")
cursor = db.cursor()
# 創建表SQL
sql = """create table student(sno varchar(12),name varchar(12))"""
# 執行創建表操作
cursor.execute(sql)
db.close()

4.插入記錄

def insert():
print("執行：insert...")
db = pymysql.connect("localhost", "root", "root", "student")
cursor = db.cursor()
sql = """insert into student(sno,name)values('2018010211','張小飛')"""
try:
# 執行操作
cursor.execute(sql)
# 提交事務
db.commit()
# 換回影響條數
count = cursor.rowcount
print(count)
print("提交成功")
except:
# 發生錯誤時回滾
db.rollback()
print("出現異常...")
db.close()

提示：其余操作只需要修改下SQL語句即可