导入包
连接数据库
- # 建立与MySQL数据库的连接
- conn = pymysql.connect(host='ip', user='账号', password='密码', db='数据库名')
- cursor = conn.cursor()
-
- # 关闭游标和数据库连接
- cursor.close()
- conn.close()
复制代码 批量插入数据
- # 执行truncate table语句
- cursor.execute("TRUNCATE TABLE 表名")
- try:
- # 批量插入数据的SQL语句
- sql = "INSERT INTO 表名 (consumer_group_name,topic_name, parameter_name,parameter_value) VALUES (%s, %s, %s, %s)"
- # 执行批量插入操作
- cursor.executemany(sql, consumergroup_info_list)
- # 提交事务
- conn.commit()
- print("数据插入成功!")
- except Exception as e:
- # 发生错误时回滚事务
- conn.rollback()
- print("数据插入失败:", e)
复制代码 免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。 |