MySQL数据库托管秒杀

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='dbname')

def get_product_info(product_id):
    # 先从Redis获取数据
    product_info = redis_client.get(f'product:{product_id}')
    if product_info:
        return product_info.decode('utf-8')
    
    # 如果Redis中没有，再从MySQL获取
    with mysql_conn.cursor() as cursor:
        sql = "SELECT * FROM products WHERE id=%s"
        cursor.execute(sql, (product_id,))
        result = cursor.fetchone()
        if result:
            product_info = str(result)
            # 将数据存入Redis，设置过期时间
            redis_client.setex(f'product:{product_id}', 3600, product_info)
            return product_info
    return None

with mysql_conn.cursor() as cursor:
    try:
        # 开启事务
        mysql_conn.begin()
        
        # 执行SQL操作
        sql1 = "UPDATE accounts SET balance = balance - %s WHERE id = %s"
        cursor.execute(sql1, (amount, from_account))
        
        sql2 = "UPDATE accounts SET balance = balance + %s WHERE id = %s"
        cursor.execute(sql2, (amount, to_account))
        
        # 提交事务
        mysql_conn.commit()
    except Exception as e:
        # 发生异常时回滚事务
        mysql_conn.rollback()
        raise e