批量插入
import pymysql
def insert_to_mysql(to_db_list):
mysql_db = pymysql.connect(host="host_ip", port=3306, user="username", password="password",
程式設計客棧 database="db", charset="utf8")
cursor = mysql_db.cursor()
sql = "insert into `your_db`.`your_table`(`colum1`, `colum2`, `colum3`) values (%s,%s,%s)"
try:
# cursor.execute()
cursor.executemany(sql, to_db_list) # 批量插入
effect_rows = cursor.rowcou程式設計客棧nt
mysql_db.commit()
cursor.close()
print('資料庫新增成功，插入 {}條資料'.format(effect_rows))
return effect_rows
except exception as e:
mysql_db.rollback()
print('資料庫執行失敗')
print(e)
return 0
my_list =
my_list.append(('v1', 'v2', 'v3'))
cnt = insert_to_mysql(my_list)
查詢def get_id_name():
cursor = mysql_db.cursor()
sql = "select id, name from `your_db`.`table`"
cursor.execute(sql)
res = cursor.fetchall()
# print(res)
return res
my_list = get_id_name()
for index in range(len(my_list)):
print(my_list[index][0]) # id
print(my_list[index][1]) # name
更新def update_by_id(update_list):
"""根據idvuimjzxh更新col1, col2, col3
list 依次為 col1, col2, col3, id
:param update_list:
:return:
"""cursor = mysql_db.cursor()
sql = "update `your_db`.`table` set col1=(%s),col2=(%s),col3=(%vuimjzxhs) where id=(%s)"
try:
# cursor.execute()
cursor.executemany(sql, update_list) # 批量插入
mysql_db.commit()
cursor.close()
print('資料庫更新成功')
except exception as e:
mysql_
print('資料庫更新失敗')
print(e)
my_list =
my_list.append(('v1', 'v2', 'v3', 'id'))
update_by_id(my_list)
Python PyMySQL運算元據庫
之前用的python2，連線mysql用的是mysqldb。現在換成python3.x了，由於 mysqldb 模組還不支援 python3.x，所以 python3.x 如果想連線mysql需要安裝 pymysql模組，以下將介紹pymysql的安裝及常用操作。pip install pymysq...
python pymysql基礎使用
方法 conn.基本使用 import pymysql conn pymysql.connect host 你的資料庫位址 user 使用者名稱 password 密碼 database 資料庫名 charset utf8 cursor conn.cursor sql create table us...
Python,pymysql簡單使用。
基本操作 1 匯入pymysql import pymysql 2 連線資料庫 conn pymysql.connect host localhost user root passwd root db ere charset utf8 務必注意各等號前面的內容！charset引數可避免中文亂碼 3 ...