buff1.0/buff/other/test.py

import re
from traceback import print_tb

import requests as req
import time,random,numpy as np
from datetime import datetime
from exceptiongroup import catch
import argparse
import mysql.connector
from numpy.ma.core import argsort
from selenium.webdriver.common.devtools.v85.system_info import ProcessInfo
import json

try:
    # 创建mysql连接
    conn = mysql.connector.connect(
        host = "121.40.50.77",
        user = "root",
        password = "Root@123456",
        database = "ry-vue"
    )
    goods_id_list=[]
    # 创建游标对象
    cursor = conn.cursor()
    # 执行SQL查询
    cursor.execute("SELECT goods_id,goods_info from sys_buff_goods where deal_flag ='0' limit 0 , 10 for update")
    # 获取所有记录列表
    results = cursor.fetchall()
    if len(results) == 0:
        print('信息不存在')
        exit()
    for row in results:
        goods_id_list.append(row[0])

    print(goods_id_list)
    # 使用join()将列表转换为逗号分隔的字符串
    placeholders = ', '.join(['%s'] * len(goods_id_list))
    print(placeholders)
    # 编写UPDATE语句
    update_query = f"UPDATE sys_buff_goods SET deal_flag ='1' WHERE goods_id in ({placeholders})"
    # 执行UPDATE语句
    cursor.execute(update_query, goods_id_list)
    time.sleep(30)
    conn.commit()
    # 关闭游标和连接
    cursor.close()
    conn.close()
except Exception as e:
    print('获取选品账号信息--失败',e)
    exit()