0.安裝

pip install pymysql

1.打開數據庫連接

import pymysql

db = pymysql.connect(host="數據庫地址",

user="用戶名",

password="密碼",

port="端口",

database="數據庫名",

charset='utf8')

2.創建游標

cursor = db.cursor()

3.操作數據庫

3.1創建表

# 如果數據表已經存在使用execute()方法刪除表。

cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")

# 創建數據表SQL語句

sql = """CREATE TABLE EMPLOYEE (

id int(7) NOT NULL auto_increment,

FIRST_NAME CHAR(20) NOT NULL,

LAST_NAME CHAR(20),

AGE INT,

SEX CHAR(1),

INCOME FLOAT,primary key(id))ENGINE=InnoDB DEFAULT CHARSET=utf8"""

cursor.execute(sql)

3.2添加

# SQL 插入語句

sql = """INSERT INTO EMPLOYEE(FIRST_NAME,

LAST_NAME, AGE, SEX, INCOME)

VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""

try:

cursor.execute(sql)

# 提交到數據庫執行

db.commit()

except:

# 發生錯誤時回滾

db.rollback()

3.3查詢

# SQL 查詢語句

sql = "SELECT * FROM EMPLOYEE WHERE INCOME > {}".format(1000)

try:

# 執行SQL語句

cursor.execute(sql)

# 獲取所有記錄列表

results = cursor.fetchall()

for row in results:

fname = row[0]

lname = row[1]

age = row[2]

sex = row[3]

income = row[4]

# 打印結果

print("fname={},lname={},age={},sex={},income={}".format(fname, lname, age, sex, income))

except:

print("Error: unable to fecth data")

fetchone(): 獲取單條數據，返回結果行元組，若無結果，返回null；

rowcount：獲取下一個查詢結果集，是一個對象；

fetchall()：獲取多條數據元組；若無結果，返回()。

備注：在MySQL中是NULL，而在Python中則是None。

3.4修改

# SQL 更新語句

sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '{}'".format('M')

try:

cursor.execute(sql)

# 提交到數據庫執行

db.commit()

except:

# 發生錯誤時回滾

db.rollback()

3.5刪除

# SQL 刪除語句

sql = "DELETE FROM EMPLOYEE WHERE AGE > {}".format(20)

try:

cursor.execute(sql)

# 提交到數據庫執行

db.commit()

except:

# 發生錯誤時回滾

db.rollback()

4.關閉游標與數據庫連接

cursor.close()

db.close()

總結

以上是生活随笔為你收集整理的python mysql数据库_Python3中操作MySQL数据库的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。