批量操作数据库：

    1. class DbConnect:
    2.     def __init__(self, db_name):
    3.         # 初始化数据库
    4.         self.db_name = db_name
    5.         self.cursor = None
    6.         self.connect = None
    8.     def _connect_mysql(self):
    9.         """连接数据库"""
    10.         self.connect = pymysql.connect(host="rm-bm*****",
    11.                                        user="press",
    12.                                        db=self.db_name,
    13.                                        password="4v******",
    14.                                        charset='utf8',
    15.                                        # autocommit=True,
    16.                                        cursorclass=pymysql.cursors.DictCursor)
    18.         # 使用cursor()方法获取操作游标
    19.         self.cursor = self.connect.cursor()
    21.     def close_mysql(self):
    22.         """关闭数据库"""
    23.         self.cursor.close()
    24.         self.connect.close()
    26.     def select(self, data):
    27.         """SQL 查询语句"""
    28.         self.cursor.execute(data)
    29.         results = self.cursor.fetchall()
    30.         return results
    32.     def execute(self, sql_data, args):
    33.         """SQL 删除、提交、修改语句"""
    34.         self._connect_mysql()
    35.         try:
    36.             # 执行SQL语句
    37.             self.cursor.executemany(sql_data, args)
    38.             # 提交修改
    39.             self.connect.commit()
    40.         except BaseException as error:
    41.             # 发生错误时回滚
    42.             self.connect.rollback()
    43.             print(error)

    数据库协作数据：

    1. db = DbConnect('workclub')
    2. coll_db = DbConnect('coll_service')
    3. start_work_id = *****
    4. work_sql = []
    5. coll_work = []
    6. coll_work_user = []
    7. # 插入协作作品
    8. sql = "INSERT INTO `ide_work` (`id`,`user_id`,`type`,`status`,`hidden_flag`,`name`,`cover_url`,`preview_url`,`ide_type`,`stage_type`,`published_at`,`updated_at`,`created_at`) " \
    9.       "VALUES (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s);"
    11. # 插入协作作品信息
    12. coll_work_sql = "INSERT INTO `coll_service`.`tbl_collaborate_work` (`work_id`,`work_type`,`author_id`,`work_status`,`del_flag`,`create_time`,`update_time`) " \
    13.                 "VALUES (%s,%s,%s,%s,%s,%s,%s); "
    14. coll_work_user_sql = "INSERT INTO `coll_service`.`tbl_collaborate_work_user` (`work_id`,`coll_user_id`,`work_type`,`del_flag`,`create_time`,`update_time`) " \
    15.                      "VALUES (%s,%s,%s,%s,%s,%s);"
    17. for i in range(1, 500):
    18.     work_sql.append((start_work_id + i, 275127340, 1, 1, 0, '新的作品press-' + str(i), '',
    19.                      'https://dev-cdn',
    20.                      1, 1, 0, 1626175844, 1626175844))
    21.     coll_work.append((start_work_id + i, 1, 275127340, 1, 1, '2021-07-13 16:31:58', '2021-07-13 16:31:58'))
    22.     coll_work_user.append((start_work_id + i, 275127340, 1, 1, '2021-07-13 16:31:58', '2021-07-13 16:31:58'))
    24. db.execute(sql, work_sql)
    25. coll_db.execute(coll_work_sql, coll_work)
    26. coll_db.execute(coll_work_user_sql, coll_work_user)
    27. db.close_mysql()
    28. coll_db.close_mysql()