数据库存储双十一活动

import redis
import pymysql

# 连接Redis
redis_client = redis.StrictRedis(host='localhost', port=6379, db=0)

# 连接MySQL
mysql_conn = pymysql.connect(host='localhost', user='user', password='password', db='database')

def get_data(key):
    # 先从Redis缓存中获取数据
    data = redis_client.get(key)
    if data is not None:
        return data.decode('utf-8')
    
    # 如果缓存中没有数据，从MySQL中获取
    with mysql_conn.cursor() as cursor:
        cursor.execute(f"SELECT value FROM table WHERE key = '{key}'")
        result = cursor.fetchone()
        if result:
            value = result[0]
            # 将数据存入Redis缓存
            redis_client.set(key, value)
            return value
    return None

try:
    with mysql_conn.cursor() as cursor:
        # 开启事务
        mysql_conn.begin()
        
        # 执行一系列数据库操作
        cursor.execute("UPDATE table SET stock = stock - 1 WHERE id = 1 AND stock > 0")
        cursor.execute("INSERT INTO order_table (product_id, quantity) VALUES (1, 1)")
        
        # 提交事务
        mysql_conn.commit()
except Exception as e:
    # 发生异常时回滚事务
    mysql_conn.rollback()
    print(f"Error: {e}")