spider_work/jihuanshe_spider/add_sql.py

# -*- coding: utf-8 -*-
# Author : Charley
# Python : 3.10.8
# Date   : 2025/3/19 11:53
from loguru import logger

from mysq_pool import MySQLConnectionPool

sql_pool = MySQLConnectionPool(log=logger)
start = 576577
# end = start + 200000
ll = [pid for pid in range(start, 1000001)]
# print(ll)
sql_pool.insert_all("insert into jhs_task (product_id) values (%s)", ll)

# sql_exists_flag = """SELECT EXISTS (SELECT 1 FROM jhs_shop_record WHERE seller_user_id = %s) AS exists_flag"""
# exists_flag = sql_pool.select_one(sql_exists_flag, (425,))
# exists_flag = exists_flag[0]
# print(exists_flag)
# if exists_flag == 1:
#     print(111111111111)
# else:
#     print(222222222222)