企业级数据库12.12促销活动

import psycopg2

def connect_to_database():
    try:
        conn = psycopg2.connect(
            dbname="your_dbname",
            user="your_username",
            password="your_password",
            host="your_host",
            port="your_port"
        )
        return conn
    except psycopg2.Error as e:
        print(f"Error connecting to database: {e}")
        return None

def execute_query(conn, query):
    try:
        cursor = conn.cursor()
        cursor.execute(query)
        results = cursor.fetchall()
        cursor.close()
        return results
    except psycopg2.Error as e:
        print(f"Error executing query: {e}")
        return None

# Example usage
conn = connect_to_database()
if conn:
    results = execute_query(conn, "SELECT * FROM your_table")
    if results:
        for row in results:
            print(row)
    conn.close()