本文我們為大家介紹 Python3 使用 PyMySQL 連接數據庫，并實現簡單的增刪改查。

什么是 PyMySQL？

PyMySQL 是在 Python3.x 版本中用于連接 MySQL 服務器的一個庫，Python2中則使用mysqldb。

PyMySQL 遵循 Python 數據庫 API v2.0 規范，并包含了 pure-Python MySQL 客戶端庫。

PyMySQL 安裝

在使用 PyMySQL 之前，我們需要確保 PyMySQL 已安裝。

PyMySQL 下載地址：https://github.com/PyMySQL/PyMySQL。

如果還未安裝，我們可以使用以下命令安裝最新版的 PyMySQL：

$ pip install PyMySQL

如果你的系統不支持 pip 命令，可以使用以下方式安裝：

1、使用 git 命令下載安裝包安裝(你也可以手動下載)：

$ git clone https://github.com/PyMySQL/PyMySQL

$ cd PyMySQL/

$ python3 setup.py install

2、數據庫操作實例，直接上代碼。

import pymysql

import datainfo

import time

#獲取參數

host = datainfo.host

username = datainfo.username

password = datainfo.password

database = datainfo.db

print()

#測試數據庫連接

def testconnect():

#打開數據庫鏈接

db = pymysql.connect(host,username,password,database)

#使用cursor() 方法創建一個游標對象 cursor

cursor = db.cursor()

#使用execute()方法執行SQL查詢

cursor.execute("select version()")

#使用fetchone ()獲取單條數據

data = cursor.fetchone()

print(data)

db.close()

#插入數據庫

def InsertDate():

#打開數據庫鏈接

db = pymysql.connect(host,username,password,database,charset='utf8')

#使用cursor() 方法創建一個游標對象 cursor

cursor = db.cursor()

create_time = time.strftime('%Y-%m-%d %H:%M:%S')

update_time = time.strftime('%Y-%m-%d %H:%M:%S')

start_time = time.strftime('%Y-%m-%d %H:%M:%S')

end_time = time.strftime('%Y-%m-%d %H:%M:%S')

remark = "測試插入信息"

print("開始")

#Sql 插入語句

sql = "insert into demo(start_time,end_time,creat_time,update_time,remark) " \

"VALUES ('%s','%s','%s','%s','%s')"\

%(start_time,end_time,create_time,update_time,remark)

try:

#執行sql

print("執行插入")

tt = cursor.execute(sql)

print(tt)

db.commit()

except UnicodeEncodeError as e :

#發生錯誤時回滾

print(e)

db.rollback()

db.close()

#查詢操作

def selectData():

db = pymysql.connect(host, username, password, database, charset='utf8')

# 使用cursor() 方法創建一個游標對象 cursor

cursor = db.cursor()

sql = "select * from demo where id >='%d'" %(1)

try:

#執行sql

print("執行查詢")

cursor.execute(sql)

results = cursor.fetchall()

for row in results:

id = row[0]

start_time = row[1]

end_time = row[2]

create_time = row[3]

update_time = row[4]

remark = row[5]

#打印結果

print("id = %d,start_time=%s,end_time=%s,create_time=%s,update_time=%s,remark=%s" %(id,start_time,end_time,create_time,update_time,remark))

db.commit()

except UnicodeEncodeError as e :

#發生錯誤時回滾

print(e)

db.close()

#更新操作

def update_data():

db = pymysql.connect(host, username, password, database, charset='utf8')

# 使用cursor() 方法創建一個游標對象 cursor

cursor = db.cursor()

update_time = time.strftime('%Y-%m-%d %H:%M:%S')

sql = "update demo set update_time ='%s' where id >='%d' " %(update_time,1)

try:

#執行sql

print("執行更新")

cursor.execute(sql)

db.commit()

except UnicodeEncodeError as e :

#發生錯誤時回滾

print(e)

db.rollback()

db.close()

#刪除操作

def delete_Date():

db = pymysql.connect(host, username, password, database, charset='utf8')

# 使用cursor() 方法創建一個游標對象 cursor

cursor = db.cursor()

sql = "delete from demo where id

try:

#執行sql

print("執行刪除")

cursor.execute(sql)

db.commit()

except UnicodeEncodeError as e :

#發生錯誤時回滾

print(e)

db.rollback()

db.close()

if __name__ == '__main__':

testconnect()

InsertDate()

selectData()

update_data()

delete_Date()

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持聚米學院。

總結

以上是生活随笔為你收集整理的mysql适配器_MySQL适配器PyMySQL详解的全部內容，希望文章能夠幫你解決所遇到的問題。

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