Pythonを使ってMySQLの各種機能を操作する方法

王林
リリース: 2023-06-03 12:37:43
転載
1470 人が閲覧しました

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 ステートメントを実行し、結果セットを取得しました。最後に、カーソルと接続を閉じます。

CRUD

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 内の username を更新します。 table to Tom のデータのパスワード。 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 内の username をクエリします。 Tom のデータのテーブル。 execute メソッドを実行するときは、パラメータを表すためにプレースホルダー %s も使用します。最後に、結果セットを取得し、カーソルと接続を閉じます。

バッチ操作

MySQL では、

INSERTDELETEUPDATE、および SELECT ステートメントを使用してデータをバッチで操作します。 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 中国語 Web サイトの他の関連記事を参照してください。

関連ラベル:
ソース:yisu.com
このウェブサイトの声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
最新の問題
人気のチュートリアル
詳細>
最新のダウンロード
詳細>
ウェブエフェクト
公式サイト
サイト素材
フロントエンドテンプレート