Python連線Mysql

1.安裝對應的庫

使用Python連線Mysql資料庫需要安裝相應的庫

以管理員身份執行cmd,輸入命令

pip install mysql.connector

安裝完成後建立
test.py
寫入
import mysql.connector
儲存後執行
python test.py
用以測試模組庫是否安裝完成，如果不報錯，說明安裝完成

2.進行連線測試

編寫connectTest.py檔案
檔案內容：

import mysql.connector


connect = mysql.connector.connect(
 host="127.0.0.1",# 資料庫主機地址
 user="root",# 資料庫使用者名稱
 passwd="root",# 資料庫密碼
 database="mysql" # 要連線的資料庫
)
#關閉連線
connect.close()

執行檔案python connectTest.py如果沒有報錯提示說明連線成功，如果報錯提示

說明連線失敗，請檢查賬戶、密碼以及資料庫是否正確，檢視資料庫是否開機

3.執行sql命令

3.1建立表

import mysql.connector


connect = mysql.connector.connect(
 host="127.0.0.1",# 資料庫密碼
 database="test" 		# 要連線的資料庫
)

#資料庫建表指令
sql = """CREATE TABLE `test`.`testtable` (
  `id` int NOT NULL,`name` varchar(255) NULL,`age` int NULL,`address` varchar(255) NULL,PRIMARY KEY (`id`)
  );"""
#獲取資料庫操作遊標
myCursor=connect.cursor()
#執行sql語句
myCursor.execute(sql)
#提交給資料庫執行命令
connect.commit()

connect.close()

執行後會建立一個名為testtabe的表

3.2插入資料

import mysql.connector


connect = mysql.connector.connect(
 host="127.0.0.1",# 資料庫密碼
 database="test"   # 要連線的資料庫
)

# 資料庫插入指令,待定字元無論是數值還是文字，都需要用%s
sql = "INSERT INTO `test`.`testtable`(`id`,`name`,`age`,`address`) VALUES (%s,%s,%s)"

var = (1,'windSnowLi',20,'中國')


# 獲取資料庫操作遊標
myCursor = connect.cursor()
try:
 # 執行sql語句
 myCursor.execute(sql,var)
 # 提交給資料庫執行命令
 connect.commit()
except :
 #回滾，以防出現錯誤
 connect.rollback()

connect.close()

隨後檢查資料庫

3.3查詢語句

import mysql.connector


connect = mysql.connector.connect(
 host="127.0.0.1",# 資料庫密碼
 database="test"   # 要連線的資料庫
)

# 資料庫查詢指令
sql = "select * from testtable"


# 獲取資料庫操作遊標
myCursor = connect.cursor()
try:
 # 執行sql語句
 myCursor.execute(sql)
 results = myCursor.fetchall()
 print(results)
except :
 print("查詢失敗")

connect.close()

3.4更新資料

import mysql.connector


connect = mysql.connector.connect(
 host="127.0.0.1",# 資料庫密碼
 database="test"   # 要連線的資料庫
)

# 資料庫更新指令
sql = "UPDATE `test`.`testtable` SET `id` = 2,`name` = 'mirror',`age` = 19,`address` = '祖國' WHERE `id` = 1"

# 獲取資料庫操作遊標
myCursor = connect.cursor()
try:
 # 執行sql語句
 myCursor.execute(sql)
 # 提交給資料庫執行命令
 connect.commit()
except :
 #回滾，以防出現錯誤
 connect.rollback()

connect.close()

3.5刪除資料

import mysql.connector


connect = mysql.connector.connect(
 host="127.0.0.1",# 資料庫密碼
 database="test"   # 要連線的資料庫
)

# 資料庫刪除指令
sql = "DELETE FROM `test`.`testtable` WHERE `id` = 1"

# 獲取資料庫操作遊標
myCursor = connect.cursor()
try:
 # 執行sql語句
 myCursor.execute(sql)
 # 提交給資料庫執行命令
 connect.commit()
except :
 #回滾，以防出現錯誤
 connect.rollback()

connect.close()

4.說明

sql語句中如果有待定字元，則都可以通過

sql = "INSERT INTO `test`.`testtable`(`id`,'中國')

這種方式拼接，不過執行時需要
myCursor.execute(sql,var)將引數也同步傳入

到此這篇關於Python連線Mysql進行增刪改查的示例程式碼的文章就介紹到這了,更多相關Python連線Mysql增刪改查內容請搜尋我們以前的文章或繼續瀏覽下面的相關文章希望大家以後多多支援我們！