时间:2021-05-22
批量插入
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.rowcount 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): """根据ID更新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=(%s) WHERE id=(%s)" try: # cursor.execute() cursor.executemany(sql, update_list) # 批量插入 mysql_db.commit() cursor.close() print('数据库更新成功') except Exception as e: mysql_db.rollback() print('数据库更新失败') print(e) my_list = []my_list.append(('v1', 'v2', 'v3', 'id'))update_by_id(my_list)以上就是python pymysql库的常用操作的详细内容,更多关于python pymysql库的资料请关注其它相关文章!
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
1、安装pymysql库如果你想要使用python操作MySQL数据库,就必须先要安装pymysql库,这个库的安装很简单,直接使用pipinstallpymy
本文实例讲述了python数据库操作mysql:pymysql、sqlalchemy常见用法。分享给大家供大家参考,具体如下:相关内容:使用pymysql直接操
Python操作MySQL详解及实例使用Python进行MySQL的库主要有三个,Python-MySQL(更熟悉的名字可能是MySQLdb),PyMySQL和
本文我们为大家介绍Python3使用PyMySQL连接数据库,并实现简单的增删改查。什么是PyMySQL?PyMySQL是在Python3.x版本中用于连接My
本文实例讲述了Python实现连接MySql数据库及增删改查操作。分享给大家供大家参考,具体如下:在本文中介绍Python3使用PyMySQL连接数据库,并实现