Python MySQL insert文を実行するサンプル
環境
Python3.9.7
Windows 11 Pro
操作方法
1.ライブラリmysql-connector-pythonインストール
pip install mysql-connector-python
2.テーブルを作成する
CREATE TABLE `usertbl` (
`uid` int NOT NULL AUTO_INCREMENT,
`name` varchar(20) COLLATE utf8mb4_general_ci NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci
CREATE TABLE `usertbl` (
`uid` int NOT NULL AUTO_INCREMENT,
`name` varchar(20) COLLATE utf8mb4_general_ci NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci
CREATE TABLE `usertbl` ( `uid` int NOT NULL AUTO_INCREMENT, `name` varchar(20) COLLATE utf8mb4_general_ci NOT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci
3.Insert構文を実行します
import mysql.connector
# 接続情報
conn = mysql.connector.connect(
host="localhost", port="3306", user="root", password="pwd12345"
)
# 接続状況確認
if conn.is_connected():
try:
# 再接続設定
conn.ping(reconnect=True)
# autocommit禁止
conn.autocommit = False
# カーソル作成
cr = conn.cursor()
# DB選択
cr.execute("use cft;")
# insertを実行
cr.execute("INSERT INTO usertbl (name) VALUES ('yamada')")
cr.execute("INSERT INTO usertbl (name) VALUES (%s)", ('oosaki',))
# コミット
conn.commit()
except mysql.connector.Error as e:
# ロールバック
conn.rollback()
print(e)
finally:
# クローズ
cr.close()
conn.close()
else:
exit()
import mysql.connector
# 接続情報
conn = mysql.connector.connect(
host="localhost", port="3306", user="root", password="pwd12345"
)
# 接続状況確認
if conn.is_connected():
try:
# 再接続設定
conn.ping(reconnect=True)
# autocommit禁止
conn.autocommit = False
# カーソル作成
cr = conn.cursor()
# DB選択
cr.execute("use cft;")
# insertを実行
cr.execute("INSERT INTO usertbl (name) VALUES ('yamada')")
cr.execute("INSERT INTO usertbl (name) VALUES (%s)", ('oosaki',))
# コミット
conn.commit()
except mysql.connector.Error as e:
# ロールバック
conn.rollback()
print(e)
finally:
# クローズ
cr.close()
conn.close()
else:
exit()
import mysql.connector # 接続情報 conn = mysql.connector.connect( host="localhost", port="3306", user="root", password="pwd12345" ) # 接続状況確認 if conn.is_connected(): try: # 再接続設定 conn.ping(reconnect=True) # autocommit禁止 conn.autocommit = False # カーソル作成 cr = conn.cursor() # DB選択 cr.execute("use cft;") # insertを実行 cr.execute("INSERT INTO usertbl (name) VALUES ('yamada')") cr.execute("INSERT INTO usertbl (name) VALUES (%s)", ('oosaki',)) # コミット conn.commit() except mysql.connector.Error as e: # ロールバック conn.rollback() print(e) finally: # クローズ cr.close() conn.close() else: exit()