快捷導(dǎo)航

Python操作MySQL的方法詳細(xì)解讀

更新時(shí)間：2023年11月02日 09:22:14 作者：觀止study

這篇文章主要介紹了Python操作MySQL的方法詳細(xì)解讀,在Python中,通過使用第三方庫:pymysql,完成對MySQL數(shù)據(jù)庫的操作,Python操作MySQL并不難,難點(diǎn)是如何編寫合適的SQL語句,需要的朋友可以參考下

一.安裝第三方庫

在Python中，通過使用第三方庫:pymysql,完成對MySQL數(shù)據(jù)庫的操作。

安裝指令:

pip install pymysql

二.在Python中使用

(1) 基本使用

導(dǎo)包-》建立連接-》進(jìn)行xx操作-》關(guān)閉連接：

# 1.導(dǎo)入操作包
from pymysql import Connection

# 2.獲取到MySQL數(shù)據(jù)庫的連接對象
conn = Connection(
    host='localhost',  # 主機(jī)名或IP地址
    port=3306,  # 端口號，默認(rèn)3306
    user='root',  # MySQL賬號
    password='root'  # MySQL密碼
)

# 打印MySQL版本信息
print(conn.get_server_info())

# 3.關(guān)閉到數(shù)據(jù)庫的連接
conn.close()

(2) 執(zhí)行建表SQL

導(dǎo)包-》建立連接-》獲取游標(biāo)對象-》選擇數(shù)據(jù)庫-》執(zhí)行相應(yīng)sql-》關(guān)閉連接：

from pymysql import Connection

# 獲取到MySQL數(shù)據(jù)庫的連接對象
conn = Connection(
    host='localhost',  # 主機(jī)名或IP地址
    port=3306,  # 端口號，默認(rèn)3306
    user='root',  # MySQL賬號
    password='root'  # MySQL密碼
)

"""
執(zhí)行非查詢性質(zhì)SQL
"""
# 獲取游標(biāo)對象(用于操作數(shù)據(jù)庫)
cursor = conn.cursor()
# 選擇要操作的數(shù)據(jù)庫
conn.select_db("db1")
# 使用游標(biāo)對象，執(zhí)行建表sql語句
cursor.execute("CREATE TABLE tb_user(id INT,name VARCHAR(8),age int)")

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

(3) 執(zhí)行查詢SQL

導(dǎo)包-》建立連接-》獲取游標(biāo)對象-》選擇數(shù)據(jù)庫-》執(zhí)行相應(yīng)sql-》獲取查詢數(shù)據(jù)，執(zhí)行xx操作-》關(guān)閉連接：

from pymysql import Connection

# 獲取到MySQL數(shù)據(jù)庫的連接對象
conn = Connection(
    host='localhost',  # 主機(jī)名或IP地址
    port=3306,  # 端口號，默認(rèn)3306
    user='root',  # MySQL賬號
    password='root'  # MySQL密碼
)

"""
執(zhí)行查詢性質(zhì)SQL
"""
# 獲取游標(biāo)對象(用于操作數(shù)據(jù)庫)
cursor = conn.cursor()
# 選擇要操作的數(shù)據(jù)庫
conn.select_db("db1")
# 使用游標(biāo)對象，執(zhí)行sql語句
cursor.execute("SELECT * FROM tb_user")
# 獲取查詢結(jié)果，返回元組對象
results: tuple = cursor.fetchall()
for result in results:
    print(result)

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

(4) 執(zhí)行插入SQL

導(dǎo)包-》建立連接-》獲取游標(biāo)對象-》選擇數(shù)據(jù)庫-》執(zhí)行相應(yīng)sql-》提交行為-》關(guān)閉連接：

from pymysql import Connection

# 獲取到MySQL數(shù)據(jù)庫的連接對象
conn = Connection(
    host='localhost',  # 主機(jī)名或IP地址
    port=3306,  # 端口號，默認(rèn)3306
    user='root',  # MySQL賬號
    password='root',  # MySQL密碼
    autocommit=True  # 設(shè)置自動提交(commit)
)

"""
執(zhí)行插入SQL
"""
# 獲取游標(biāo)對象(用于操作數(shù)據(jù)庫)
cursor = conn.cursor()
# 選擇要操作的數(shù)據(jù)庫
conn.select_db("db1")
# 使用游標(biāo)對象，執(zhí)行sql語句
cursor.execute("Insert into tb_user values(1,'hhy','250')")
# 確認(rèn)插入行為
# 如果在獲取連接對象時(shí)設(shè)置自動提交可以不用再寫。
conn.commit()

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

(5) 執(zhí)行修改SQL

導(dǎo)包-》建立連接-》獲取游標(biāo)對象-》選擇數(shù)據(jù)庫-》執(zhí)行相應(yīng)sql-》提交行為-》關(guān)閉連接：

from pymysql import Connection

# 獲取到MySQL數(shù)據(jù)庫的連接對象
conn = Connection(
    host='localhost',  # 主機(jī)名或IP地址
    port=3306,  # 端口號，默認(rèn)3306
    user='root',  # MySQL賬號
    password='root',  # MySQL密碼
    autocommit=True  # 設(shè)置自動提交(commit)
)

"""
執(zhí)行修改SQL
"""
# 獲取游標(biāo)對象(用于操作數(shù)據(jù)庫)
cursor = conn.cursor()
# 選擇要操作的數(shù)據(jù)庫
conn.select_db("db1")
# 使用游標(biāo)對象，執(zhí)行sql語句
cursor.execute("UPDATE tb_user set username='hhy' where username = 'fsp'")
# 確認(rèn)修改行為
# 如果在獲取連接對象時(shí)設(shè)置自動提交可以不用再寫。
conn.commit()

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

(6) 執(zhí)行刪除SQL

導(dǎo)包-》建立連接-》獲取游標(biāo)對象-》選擇數(shù)據(jù)庫-》執(zhí)行相應(yīng)sql-》提交行為-》關(guān)閉連接：

from pymysql import Connection

# 獲取到MySQL數(shù)據(jù)庫的連接對象
conn = Connection(
    host='localhost',  # 主機(jī)名或IP地址
    port=3306,  # 端口號，默認(rèn)3306
    user='root',  # MySQL賬號
    password='root',  # MySQL密碼
    autocommit=True  # 設(shè)置自動提交(commit)
)


"""
執(zhí)行刪除SQL
"""
# 獲取游標(biāo)對象(用于操作數(shù)據(jù)庫)
cursor = conn.cursor()
# 選擇要操作的數(shù)據(jù)庫
conn.select_db("db1")
# 使用游標(biāo)對象，執(zhí)行sql語句
cursor.execute("DELETE from tb_user WHERE username = 'hhy'")
# 確認(rèn)刪除行為
# 如果在獲取連接對象時(shí)設(shè)置自動提交可以不用再寫。
conn.commit()

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

(7) 小結(jié)

pymysql在執(zhí)行數(shù)據(jù)插入或其它產(chǎn)生數(shù)據(jù)更改的SQL語句時(shí)，默認(rèn)是需要提交更改的，即，需要通過代碼“確認(rèn)”這種更改行為。
如果不想手動commit確認(rèn)，可以在構(gòu)建連接對象的時(shí)候，設(shè)置自動commit的屬性。
查詢后，使用游標(biāo)對象.fetchall()可得到全部的查詢結(jié)果封裝入嵌套元組內(nèi)
可使用游標(biāo)對象.execute()執(zhí)行SQL語句