分布式架构数据库11.11活动

from mysql.connector import pooling

# 创建连接池
db_config = {
    "host": "shard1.example.com",
    "user": "user",
    "password": "password",
    "database": "mydatabase"
}
pool = pooling.MySQLConnectionPool(pool_name="mypool", pool_size=5, **db_config)

# 获取连接并执行查询
connection = pool.get_connection()
cursor = connection.cursor()
cursor.execute("SELECT * FROM orders WHERE user_id = %s", (user_id,))
result = cursor.fetchall()
cursor.close()
connection.close()

import psycopg2

# 连接到CockroachDB集群
conn = psycopg2.connect(
    host="localhost",
    database="mydb",
    user="root",
    password=""
)

# 开启事务
with conn.cursor() as cur:
    cur.execute("BEGIN")
    try:
        cur.execute("INSERT INTO orders (user_id, product_id) VALUES (%s, %s)", (1, 100))
        cur.execute("UPDATE inventory SET stock = stock - 1 WHERE product_id = %s", (100,))
        cur.execute("COMMIT")
    except Exception as e:
        cur.execute("ROLLBACK")
        print(f"Transaction failed: {e}")

frontend http_front
    bind *:80
    default_backend http_back

backend http_back
    balance roundrobin
    server server1 shard1.example.com:3306 check
    server server2 shard2.example.com:3306 check
    server server3 shard3.example.com:3306 check