双十一PostgreSQL数据库购买

import psycopg2
from psycopg2 import pool

# 创建连接池
min_conn = 1
max_conn = 10
postgreSQL_pool = psycopg2.pool.SimpleConnectionPool(min_conn, max_conn,
                                                      user="your_user",
                                                      password="your_password",
                                                      host="write_host",
                                                      port="5432",
                                                      database="your_db")

def get_read_connection():
    return psycopg2.connect(user="your_user",
                            password="your_password",
                            host="read_host",
                            port="5432",
                            database="your_db")

def execute_query(query, params=None):
    conn = postgreSQL_pool.getconn()
    try:
        with conn.cursor() as cur:
            cur.execute(query, params)
            if query.strip().upper().startswith("SELECT"):
                return cur.fetchall()
            else:
                conn.commit()
    finally:
        postgreSQL_pool.putconn(conn)

# 示例查询
results = execute_query("SELECT * FROM your_table")
for row in results:
    print(row)