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='database')
mysql_cursor = mysql_conn.cursor()

def get_data_from_mysql(table_name):
    query = f"SELECT * FROM {table_name}"
    mysql_cursor.execute(query)
    return mysql_cursor.fetchall()

def get_data(table_name):
    cache_key = f"table:{table_name}"
    data = redis_client.get(cache_key)
    if data is None:
        data = get_data_from_mysql(table_name)
        redis_client.setex(cache_key, 3600, str(data))  # 缓存1小时
    else:
        data = eval(data)
    return data

# 示例调用
data = get_data('users')
print(data)