mysql分表案例

import mysql.connector

def get_order_table_name(order_id):
    # 根据订单ID计算分表名称
    table_index = (order_id // 1000000) % 10
    return f"orders_{table_index}"

def insert_order(order_id, user_id, amount):
    table_name = get_order_table_name(order_id)
    conn = mysql.connector.connect(user='user', password='password', host='host', database='database')
    cursor = conn.cursor()
    query = f"INSERT INTO {table_name} (order_id, user_id, amount) VALUES (%s, %s, %s)"
    cursor.execute(query, (order_id, user_id, amount))
    conn.commit()
    cursor.close()
    conn.close()

def query_order(order_id):
    table_name = get_order_table_name(order_id)
    conn = mysql.connector.connect(user='user', password='password', host='host', database='database')
    cursor = conn.cursor()
    query = f"SELECT * FROM {table_name} WHERE order_id = %s"
    cursor.execute(query, (order_id,))
    result = cursor.fetchone()
    cursor.close()
    conn.close()
    return result