## 1. 案例背景
– 系统：TiDB 7.5.0
– 业务：电商平台订单处理
– 需求：实现订单创建、库存扣减、支付处理的原子操作

## 2. 实施步骤

### 步骤1：创建测试表
– 创建商品表：
[root@fgedu.net.cn ~]# mysql -h 192.168.1.1 -P 4000 -u fgedu -p fgedudb
mysql> CREATE TABLE fgedu_products (
mysql> id INT PRIMARY KEY AUTO_INCREMENT,
mysql> name VARCHAR(100) NOT NULL,
mysql> price DECIMAL(10,2) NOT NULL,
mysql> stock INT NOT NULL
mysql> ) ENGINE=InnoDB;

– 创建订单表：
mysql> CREATE TABLE fgedu_orders (
mysql> id INT PRIMARY KEY AUTO_INCREMENT,
mysql> user_id INT NOT NULL,
mysql> product_id INT NOT NULL,
mysql> quantity INT NOT NULL,
mysql> total_amount DECIMAL(10,2) NOT NULL,
mysql> status VARCHAR(20) DEFAULT ‘pending’,
mysql> created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
mysql> FOREIGN KEY (product_id) REFERENCES fgedu_products(id)
mysql> ) ENGINE=InnoDB;

– 创建支付表：
mysql> CREATE TABLE fgedu_payments (
mysql> id INT PRIMARY KEY AUTO_INCREMENT,
mysql> order_id INT NOT NULL,
mysql> amount DECIMAL(10,2) NOT NULL,
mysql> status VARCHAR(20) DEFAULT ‘pending’,
mysql> created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
mysql> FOREIGN KEY (order_id) REFERENCES fgedu_orders(id)
mysql> ) ENGINE=InnoDB;

### 步骤2：插入测试数据
– 插入商品数据：
mysql> INSERT INTO fgedu_products (name, price, stock) VALUES (‘product1’, 100.00, 100);

### 步骤3：实现分布式事务
– 开始事务：
mysql> START TRANSACTION;

– 检查商品库存：
mysql> SELECT stock FROM fgedu_products WHERE id = 1 FOR UPDATE;

结果：
+——-+
| stock |
+——-+
| 100 |
+——-+

– 创建订单：
mysql> INSERT INTO fgedu_orders (user_id, product_id, quantity, total_amount) VALUES (1, 1, 2, 200.00);

– 扣减库存：
mysql> UPDATE fgedu_products SET stock = stock – 2 WHERE id = 1;

– 创建支付记录：
mysql> INSERT INTO fgedu_payments (order_id, amount) VALUES (LAST_INSERT_ID(), 200.00);

– 更新支付状态：
mysql> UPDATE fgedu_payments SET status = ‘completed’ WHERE order_id = LAST_INSERT_ID();

– 更新订单状态：
mysql> UPDATE fgedu_orders SET status = ‘paid’ WHERE id = LAST_INSERT_ID();

– 提交事务：
mysql> COMMIT;

### 步骤4：验证结果
– 查看商品库存：
mysql> SELECT stock FROM fgedu_products WHERE id = 1;

结果：
+——-+
| stock |
+——-+
| 98 |
+——-+

– 查看订单：
mysql> SELECT * FROM fgedu_orders WHERE user_id = 1;

结果：
+—-+———+————+———-+————–+——-+———————+
| id | user_id | product_id | quantity | total_amount | status | created_at |
+—-+———+————+———-+————–+——-+———————+
| 1 | 1 | 1 | 2 | 200.00 | paid | 2024-01-01 12:00:00 |
+—-+———+————+———-+————–+——-+———————+

– 查看支付记录：
mysql> SELECT * FROM fgedu_payments WHERE order_id = 1;

结果：
+—-+———-+——–+———-+———————+
| id | order_id | amount | status | created_at |
+—-+———-+——–+———-+———————+
| 1 | 1 | 200.00 | completed | 2024-01-01 12:00:00 |
+—-+———-+——–+———-+———————+

## 3. 案例效果
– 分布式事务执行成功：所有操作要么全部成功，要么全部失败
– 数据一致性：库存、订单、支付记录数据一致
– 并发控制：使用FOR UPDATE避免并发冲突
– 系统稳定性：事务执行过程中系统稳定

## 1. 案例背景
– 系统：TiDB 7.5.0
– 业务：秒杀活动
– 问题：高并发下库存扣减冲突严重

## 2. 实施步骤

### 步骤1：创建测试表
– 创建秒杀商品表：
[root@fgedu.net.cn ~]# mysql -h 192.168.1.1 -P 4000 -u fgedu -p fgedudb
mysql> CREATE TABLE fgedu_seckill_products (
mysql> id INT PRIMARY KEY AUTO_INCREMENT,
mysql> name VARCHAR(100) NOT NULL,
mysql> price DECIMAL(10,2) NOT NULL,
mysql> stock INT NOT NULL,
mysql> version INT DEFAULT 1
mysql> ) ENGINE=InnoDB;

### 步骤2：插入测试数据
– 插入秒杀商品：
mysql> INSERT INTO fgedu_seckill_products (name, price, stock) VALUES (‘seckill_product’, 1.00, 10);

### 步骤3：实现并发控制
– 编写Python脚本：
import pymysql
import time
import random

def seckill(product_id, user_id):
max_retries = 5
base_delay = 0.1

for i in range(max_retries):
try:
conn = pymysql.connect(
host=’192.168.1.1′,
port=4000,
user=’fgedu’,
password=’password’,
db=’fgedudb’
)
cursor = conn.cursor()

# 开始事务
conn.begin()

# 读取商品信息
cursor.execute(“SELECT stock, version FROM fgedu_seckill_products WHERE id = %s”, (product_id,))
result = cursor.fetchone()
if not result:
conn.rollback()
cursor.close()
conn.close()
return False, “Product not found”

stock, version = result
if stock <= 0: conn.rollback() cursor.close() conn.close() return False, "Stock out" # 扣减库存（乐观锁） cursor.execute( "UPDATE fgedu_seckill_products SET stock = stock - 1, version = version + 1 WHERE id = %s AND version = %s", (product_id, version) ) if cursor.rowcount == 0: # 冲突，重试 conn.rollback() cursor.close() conn.close() delay = min(base_delay * (2 ** i) + random.uniform(0, 0.1), 1.0) time.sleep(delay) continue # 记录秒杀记录 cursor.execute( "INSERT INTO fgedu_seckill_records (user_id, product_id, price) VALUES (%s, %s, %s)", (user_id, product_id, 1.00) ) # 提交事务 conn.commit() cursor.close() conn.close() return True, "Seckill success" except Exception as e: if conn: conn.rollback() cursor.close() conn.close() if 'Write conflict' in str(e): delay = min(base_delay * (2 ** i) + random.uniform(0, 0.1), 1.0) time.sleep(delay) continue else: return False, str(e) return False, "Max retries exceeded" ### 步骤4：模拟并发测试 - 编写并发测试脚本： import threading import time def test_seckill(user_id): success, message = seckill(1, user_id) print(f"User {user_id}: {'success' if success else 'failed'} - {message}") # 创建20个线程模拟并发 threads = [] for i in range(20): t = threading.Thread(target=test_seckill, args=(i+1,)) threads.append(t) t.start() # 等待所有线程完成 for t in threads: t.join() ### 步骤5：验证结果 - 查看商品库存： mysql> SELECT stock FROM fgedu_seckill_products WHERE id = 1;

结果：
+——-+
| stock |
+——-+
| 0 |
+——-+

– 查看秒杀记录：
mysql> SELECT COUNT(*) FROM fgedu_seckill_records;

结果：
+———-+
| COUNT(*) |
+———-+
| 10 |
+———-+

## 3. 案例效果
– 并发测试成功：10个用户成功秒杀
– 库存正确：最终库存为0
– 无超卖：秒杀记录数量等于库存数量
– 冲突处理：通过乐观锁和重试机制处理并发冲突

## 1. 案例背景
– 系统：TiDB 7.5.0
– 业务：批量数据处理
– 问题：批量处理100万条数据时，事务执行失败

## 2. 实施步骤

### 步骤1：分析问题
– 查看错误日志：
[root@fgedu.net.cn ~]# tail -f /tidb/app/log/tidb/tidb.log | grep -i “large transaction”

结果：
[2024-01-01 12:00:00.123] [error] [kv/txn.go:1234] [“large transaction detected”] [size=104857600] [limit=104857600]

### 步骤2：优化方案
– 方案1：拆分批量处理为多个小批次
– 方案2：使用批量插入语句
– 方案3：优化SQL语句，减少事务大小

### 步骤3：实施优化
– 拆分批量处理：
[root@fgedu.net.cn ~]# cat > batch_process.sh << 'EOF' #!/bin/bash # batch_process.sh # from:www.itpux.com.qq113257174.wx:itpux-com # web: `http://www.fgedu.net.cn` batch_size=10000 total_rows=1000000 for ((i=0; i