mysql分库迁移

-- 创建用户数据库和表
CREATE DATABASE user_db;
USE user_db;
CREATE TABLE users (
    id INT PRIMARY KEY,
    name VARCHAR(255),
    email VARCHAR(255)
);

-- 创建订单数据库和表
CREATE DATABASE order_db;
USE order_db;
CREATE TABLE orders (
    id INT PRIMARY KEY,
    user_id INT,
    amount DECIMAL(10, 2)
);

import mysql.connector

def insert_user(user):
    conn = mysql.connector.connect(user='user', password='password', host='localhost', database='user_db')
    cursor = conn.cursor()
    query = "INSERT INTO users (id, name, email) VALUES (%s, %s, %s)"
    cursor.execute(query, (user['id'], user['name'], user['email']))
    conn.commit()
    cursor.close()
    conn.close()

def insert_order(order):
    conn = mysql.connector.connect(user='order', password='password', host='localhost', database='order_db')
    cursor = conn.cursor()
    query = "INSERT INTO orders (id, user_id, amount) VALUES (%s, %s, %s)"
    cursor.execute(query, (order['id'], order['user_id'], order['amount']))
    conn.commit()
    cursor.close()
    conn.close()