mysql批量替换工具

import mysql.connector

def batch_replace(table_name, column_name, old_value, new_value):
    try:
        # 连接数据库
        conn = mysql.connector.connect(user='your_username', password='your_password',
                                       host='your_host', database='your_database')
        cursor = conn.cursor()

        # 构建批量替换SQL语句
        sql = f"UPDATE {table_name} SET {column_name} = %s WHERE {column_name} = %s"
        values = [(new_value, old_value)] * 1000  # 假设每次处理1000条数据

        # 执行批量替换操作
        cursor.executemany(sql, values)
        conn.commit()

        print(f"Successfully replaced {len(values)} records in {table_name}.{column_name}")

    except mysql.connector.Error as err:
        print(f"Error: {err}")
    finally:
        if conn.is_connected():
            cursor.close()
            conn.close()

# 示例调用
batch_replace('your_table', 'your_column', 'old_text', 'new_text')