Python连接Postgres

pip install psycopg2

import psycopg2

# 连接到数据库
conn = psycopg2.connect(
    dbname="mydatabase",
    user="myuser",
    password="mypassword",
    host="localhost"
)

# 创建一个cursor对象
cur = conn.cursor()

# 执行SQL查询
cur.execute("SELECT * FROM mytable")

# 获取查询结果
rows = cur.fetchall()

# 打印结果
for row in rows:
    print(row)

# 关闭连接
cur.close()
conn.close()

# 执行CREATE TABLE语句
cur.execute("CREATE TABLE students (id SERIAL PRIMARY KEY, name VARCHAR);")

# 插入数据
cur.execute("INSERT INTO students (name) VALUES ('Alice');")

# 提交事务
conn.commit()

# 查询数据
cur.execute("SELECT * FROM students;")

# 获取查询结果
rows = cur.fetchall()

# 打印结果
for row in rows:
    print(row)

# 参数化查询
name = "Bob"
cur.execute("INSERT INTO students (name) VALUES (%s);", (name,))

# 提交事务
conn.commit()

try:
    # 执行SQL查询
    cur.execute("SELECT * FROM non_existing_table;")
except psycopg2.Error as e:
    print("Error executing SQL statement:", e)

# 关闭连接
cur.close()
conn.close()