| 12345678910111213141516171819202122232425262728293031 |
- # -*- coding: utf-8 -*-
- # Author : Charley
- # Python : 3.10.8
- # Date : 2025/9/29 13:56
- from loguru import logger
- from mysql_pool import MySQLConnectionPool
- sql_pool = MySQLConnectionPool(log=logger)
- # data_list = []
- # for i in range(10000001,10700001):
- # data_list.append({"cert_id": i})
- #
- # print(len(data_list))
- # sql_pool.insert_many("pcg_task", data_list)
- """
- 数据去重
- """
- sql_cert_list = sql_pool.select_all("select cert_id from pcg_record")
- sql_cert_list = [i[0] for i in sql_cert_list]
- for i in sql_cert_list:
- # 更新task表中的state为1
- sql_pool.update_one_or_dict("pcg_task", {"state": 1}, {"cert_id": i})
- logger.success("------------------- 更新完成 -------------------")
|
