Redshift(PostgreSQL) Session 생성해서 Select - 6

기본적인 사용법

 

1) Redshift에 연결하기 위한 정보

conn_info = {
    "dbname": "your_database",
    "user":"your_username",
    "pwd":"your_password",
    "host":"your_host",
    "port":"your_port"
}

 

2) 연결 정보를 바탕으로 Redshift에 연결

import psycopg2

try:
    conn = psycopg2.connect(
        dbname=conn_info['dbname'],
        user=conn_info['user'],
        password=conn_info['pwd'],
        host=conn_info['host'],
        port=conn_info['port']
    )
    
    # autocommit를 True로 설정하면 각 쿼리가 자동으로 커밋되고
    # autocommit을 False로 설정하면 각 쿼리가 자동으로 커밋되지 않는다.
    conn.set_session(autocommit=True)
    # or
    conn.set_session(autocommit=False)
    
    
    # 커서를 생성한다. 커서는 SQL 쿼리를 실행하는 데 사용된다.
    cur = conn.cursor()

    # SELECT 쿼리를 실행한다.
    cur.execute("SELECT * FROM your_table")

    # 쿼리 결과를 가져온다.
    rows = cur.fetchall()

    for row in rows:
        print(row)

except Exception as e:
    print(f"An error occurred: {e}")
finally:
    # 커서와 연결을 종료
    cur.close()
    conn.close()