使用脚本对mysql分表

import mysql.connector

# 连接数据库
db = mysql.connector.connect(
    host="localhost",
    user="yourusername",
    password="yourpassword",
    database="yourdatabase"
)
cursor = db.cursor()

# 创建新表
new_table_name = "table_1"
create_table_sql = f"""
CREATE TABLE {new_table_name} (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(255),
    age INT
)
"""
cursor.execute(create_table_sql)

# 分表逻辑
split_count = 4  # 分表数量
select_sql = "SELECT * FROM original_table"
cursor.execute(select_sql)
rows = cursor.fetchall()

for i, row in enumerate(rows):
    insert_sql = f"INSERT INTO {new_table_name} (name, age) VALUES (%s, %s)"
    cursor.execute(insert_sql, (row[1], row[2]))
    if (i + 1) % (len(rows) // split_count) == 0:
        db.commit()
        new_table_name = f"table_{(i // (len(rows) // split_count)) + 2}"
        create_table_sql = f"""
        CREATE TABLE {new_table_name} (
            id INT AUTO_INCREMENT PRIMARY KEY,
            name VARCHAR(255),
            age INT
        )
        """
        cursor.execute(create_table_sql)

db.commit()
cursor.close()
db.close()