怎麼使用Python操作MySQL的各種功能

王林
發布: 2023-06-03 12:37:43
轉載
1468 人瀏覽過

連接MySQL

在Python中,我們可以使用pymysql函式庫來連接MySQL資料庫。

import pymysql

# 连接MySQL
conn = pymysql.connect(host='localhost', user='root', password='123456', database='test', charset='utf8')

# 获取游标
cursor = conn.cursor()

# 执行SQL语句
cursor.execute('SELECT * FROM users')

# 获取结果集
result = cursor.fetchall()
print(result)

# 关闭游标和连接
cursor.close()
conn.close()
登入後複製

以上程式碼中,我們先使用pymysql函式庫連接了MySQL資料庫,並且取得了遊標。然後,我們執行了一個簡單的SELECT語句,並且取得了結果集。最後,我們關閉了遊標和連線。

增刪改查

在MySQL中,我們可以使用INSERTDELETEUPDATESELECT 語句來完成增刪改查操作。在Python中,我們同樣可以使用pymysql函式庫來執行這些操作。

插入資料

import pymysql

# 连接MySQL
conn = pymysql.connect(host='localhost', user='root', password='123456', database='test', charset='utf8')

# 获取游标
cursor = conn.cursor()

# 插入数据
sql = "INSERT INTO users(username, password) VALUES (%s, %s)"
params = ('Tom', '123456')
cursor.execute(sql, params)

# 提交事务
conn.commit()

# 关闭游标和连接
cursor.close()
conn.close()
登入後複製

以上程式碼中,我們使用INSERT語句向users表中插入了一條資料。在執行execute方法時,我們可以使用佔位符%s來表示參數,然後在執行時傳入對應的參數。最後,我們提交了事務,並關閉了遊標和連線。

刪除資料

import pymysql

# 连接MySQL
conn = pymysql.connect(host='localhost', user='root', password='123456', database='test', charset='utf8')

# 获取游标
cursor = conn.cursor()

# 删除数据
sql = "DELETE FROM users WHERE id = %s"
params = (1,)
cursor.execute(sql, params)

# 提交事务
conn.commit()

# 关闭游标和连接
cursor.close()
conn.close()
登入後複製

以上程式碼中,我們使用DELETE語句刪除了users表中id為1的數據。在執行execute方法時,我們同樣使用了佔位符%s來表示參數。最後,我們提交了事務,並關閉了遊標和連線。

更新資料

import pymysql

# 连接MySQL
conn = pymysql.connect(host='localhost', user='root', password='123456', database='test', charset='utf8')

# 获取游标
cursor = conn.cursor()

# 更新数据
sql = "UPDATE users SET password = %s WHERE username = %s"
params = ('654321', 'Tom')
cursor.execute(sql, params)

# 提交事务
conn.commit()

# 关闭游标和连接
cursor.close()
conn.close()
登入後複製

以上程式碼中,我們使用UPDATE語句更新了users表中usernameTom的資料的密碼。在執行execute方法時,我們同樣使用了佔位符%s來表示參數。最後,我們提交了事務,並關閉了遊標和連線。

查詢資料

import pymysql

# 连接MySQL
conn = pymysql.connect(host='localhost', user='root', password='123456', database='test', charset='utf8')

# 获取游标
cursor = conn.cursor()

# 查询数据
sql = "SELECT * FROM users WHERE username = %s"
params = ('Tom',)
cursor.execute(sql, params)

# 获取结果集
result = cursor.fetchall()
print(result)

# 关闭游标和连接
cursor.close()
conn.close()
登入後複製

以上程式碼中,我們使用SELECT語句查詢了users表中usernameTom的數據。在執行execute方法時,我們同樣使用了佔位符%s來表示參數。最後,我們取得了結果集,並關閉了遊標和連線。

批次運算

在MySQL中,我們可以使用INSERTDELETEUPDATESELECT語句來批次操作資料。在Python中,我們同樣可以使用pymysql函式庫來批次操作資料。

批次插入資料

import pymysql

# 连接MySQL
conn = pymysql.connect(host='localhost', user='root', password='123456', database='test', charset='utf8')

# 获取游标
cursor = conn.cursor()

# 批量插入数据
sql = "INSERT INTO users(username, password) VALUES (%s, %s)"
params = [('Tom', '123456'), ('Jerry', '654321'), ('Alice', '111111')]
cursor.executemany(sql, params)

# 提交事务
conn.commit()

# 关闭游标和连接
cursor.close()
conn.close()
登入後複製

以上程式碼中,我們使用executemany方法批次插入了多條資料。在執行executemany方法時,我們使用了一個元組清單來表示多個參數。最後,我們提交了事務,並關閉了遊標和連線。

批次刪除資料

import pymysql

# 连接MySQL
conn = pymysql.connect(host='localhost', user='root', password='123456', database='test', charset='utf8')

# 获取游标
cursor = conn.cursor()

# 批量删除数据
sql = "DELETE FROM users WHERE id = %s"
params = [(1,), (2,), (3,)]
cursor.executemany(sql, params)

# 提交事务
conn.commit()

# 关闭游标和连接
cursor.close()
conn.close()
登入後複製

在以上程式碼中,我們使用executemany方法批次刪除了多條資料。在執行executemany方法時,我們同樣使用了一個元組列表來表示多個參數。最後,我們提交了事務,並關閉了遊標和連線。

批次更新資料

import pymysql

# 连接MySQL
conn = pymysql.connect(host='localhost', user='root', password='123456', database='test', charset='utf8')

# 获取游标
cursor = conn.cursor()

# 批量更新数据
sql = "UPDATE users SET password = %s WHERE username = %s"
params = [('123456', 'Tom'), ('654321', 'Jerry'), ('111111', 'Alice')]
cursor.executemany(sql, params)

# 提交事务
conn.commit()

# 关闭游标和连接
cursor.close()
conn.close()
登入後複製

以上是怎麼使用Python操作MySQL的各種功能的詳細內容。更多資訊請關注PHP中文網其他相關文章!

相關標籤:
來源:yisu.com
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板