游戏源码带数据库

import mysql.connector.pooling

db_config = {
    "host": "localhost",
    "user": "user",
    "password": "password",
    "database": "game_db"
}

pool = mysql.connector.pooling.MySQLConnectionPool(pool_name="mypool", pool_size=5, **db_config)

def get_connection():
    return pool.get_connection()

try:
    conn = get_connection()
    cursor = conn.cursor()
    cursor.execute("START TRANSACTION")
    cursor.execute("UPDATE players SET score = score + 10 WHERE id = 1")
    cursor.execute("COMMIT")
except mysql.connector.Error as err:
    cursor.execute("ROLLBACK")
    print(f"Error: {err}")
finally:
    cursor.close()
    conn.close()

-- 创建索引
CREATE INDEX idx_player_id ON players(id);

-- 使用缓存
import redis

redis_client = redis.Redis(host='localhost', port=6379, db=0)

def get_player_score(player_id):
    score = redis_client.get(f"player:{player_id}:score")
    if score is None:
        cursor.execute("SELECT score FROM players WHERE id = %s", (player_id,))
        score = cursor.fetchone()[0]
        redis_client.set(f"player:{player_id}:score", score)
    return score