pyhton如何連接mysql數(shù)據(jù)庫

1、導(dǎo)入模塊

2、打開數(shù)據(jù)庫連接

3、創(chuàng)建游標(biāo)對象cursor

如何用Python對數(shù)據(jù)庫中的數(shù)據(jù)進(jìn)行增刪改查

增

import pymysql

#連接數(shù)據(jù)庫

conn=pymysql.connect（host = ‘127.0.0.1’ # 連接名稱，默認(rèn)127.0.0.1

，user = ‘root’ # 用戶名

，passwd=‘password’ # 密碼

，port= 3306 # 端口，默認(rèn)為3306

，db=‘test’ # 數(shù)據(jù)庫名稱

，charset=‘utf8’ # 字符編碼

）

cur = conn.cursor（） # 生成游標(biāo)對象

#=插入語句===================

sql= “INSERT INTO student VALUES （‘p’，‘魏六’，‘17’）”

#===================================================

try：

cur.execute（sql1） # 執(zhí)行插入的sql語句

conn.commit（） # 提交到數(shù)據(jù)庫執(zhí)行

except：

coon.rollback（）# 如果發(fā)生錯誤則回滾

conn.close（） # 關(guān)閉數(shù)據(jù)庫連接

然后我們再運(yùn)行查詢語句

import mysql.connector

conn=mysql.connector.connect（host = ‘127.0.0.1’ # 連接名稱，默認(rèn)127.0.0.1

，user = ‘root’ # 用戶名

，passwd=‘password’ # 密碼

，port= 3306 # 端口，默認(rèn)為3306

，db=‘test’ # 數(shù)據(jù)庫名稱

，charset=‘utf8’ # 字符編碼

）

cur = conn.cursor（） # 生成游標(biāo)對象

sql=“select * from student ” # SQL語句

cur.execute（sql） # 執(zhí)行SQL語句

data = cur.fetchall（） # 通過fetchall方法獲得數(shù)據(jù)

for i in data［：］： # 打印輸出所有數(shù)據(jù)

print （i）

cur.close（） # 關(guān)閉游標(biāo)

conn.close（） # 關(guān)閉連接

執(zhí)行結(jié)果就是

（‘b’， ‘錢二’， ‘16’）

（‘c’， ‘張三’， ‘17’）

（‘d’， ‘李四’， ‘17’）

（‘e’， ‘王五’， ‘16’）

（‘a(chǎn)’， ‘趙大’， ‘16’）

（‘p’， ‘魏六’， ‘17’）

刪

import pymysql

#連接數(shù)據(jù)庫

conn=pymysql.connect（host = ‘127.0.0.1’ # 連接名稱，默認(rèn)127.0.0.1

，user = ‘root’ # 用戶名

，passwd=‘password’ # 密碼

，port= 3306 # 端口，默認(rèn)為3306

，db=‘test’ # 數(shù)據(jù)庫名稱

，charset=‘utf8’ # 字符編碼

）

cur = conn.cursor（） # 生成游標(biāo)對象

#=刪除語句===================

sql = “DELETE FROM student WHERE 學(xué)號 = “a”

#===================================================

try：

cur.execute（sql） # 執(zhí)行插入的sql語句

conn.commit（） # 提交到數(shù)據(jù)庫執(zhí)行

except：

coon.rollback（）# 如果發(fā)生錯誤則回滾

conn.close（） # 關(guān)閉數(shù)據(jù)庫連接

改

import pymysql

#連接數(shù)據(jù)庫

conn=pymysql.connect（host = ‘127.0.0.1’ # 連接名稱，默認(rèn)127.0.0.1

，user = ‘root’ # 用戶名

，passwd=‘password’ # 密碼

，port= 3306 # 端口，默認(rèn)為3306

，db=‘test’ # 數(shù)據(jù)庫名稱

，charset=‘utf8’ # 字符編碼

）

cur = conn.cursor（） # 生成游標(biāo)對象

#=刪除語句===================

sql =”UPDATE student SET 學(xué)員姓名 = ‘歐陽’ WHERE 學(xué)號 = ‘b’ “

#===================================================

try：

cur.execute（sql） # 執(zhí)行插入的sql語句

conn.commit（） # 提交到數(shù)據(jù)庫執(zhí)行

except：

coon.rollback（）# 如果發(fā)生錯誤則回滾

conn.close（） # 關(guān)閉數(shù)據(jù)庫連接

查

import pymysql

#連接數(shù)據(jù)庫

conn=pymysql.connect（host = ‘127.0.0.1’ # 連接名稱，默認(rèn)127.0.0.1

，user = ‘root’ # 用戶名

，passwd=‘password’ # 密碼

，port= 3306 # 端口，默認(rèn)為3306

，db=‘test’ # 數(shù)據(jù)庫名稱

，charset=‘utf8’ # 字符編碼

）

cur = conn.cursor（） # 生成游標(biāo)對象

#=刪除語句===================

sql=”select * from student “ # SQL語句

#====================================================

try：

cur.execute（sql） # 執(zhí)行插入的sql語句

data = cur.fetchall（）

for i in data［：］：

print （i）

conn.commit（） # 提交到數(shù)據(jù)庫執(zhí)行

except：

coon.rollback（）# 如果發(fā)生錯誤則回滾

conn.close（） # 關(guān)閉數(shù)據(jù)庫連接

整合自：Python學(xué)習(xí)網(wǎng)、CDA數(shù)據(jù)分析研究院

編輯：jq