1、代码示例
使用以下 Python 脚本来连接 Postgresql 数据库并执行 SQL 语句：
import psycopg2
def connect_postgresql():
try:
# 建立数据库连接
connection = psycopg2.connect(
# 数据库名
database=“your_database_name”,
# 用户名
user=“your_username”,
# 密码
password=“your_password”,
# 数据库地址
host=“your_host”,
#端口
port=“your_port”
)
print(“成功连接到PostgreSQL数据库”)
return connection
except (Exception, psycopg2.Error) as error:
print(“连接PostgreSQL数据库时出错:”, error)
return None
def sql_execute(conn, sql: str, params):
“”"
执行一条sql
:param sql: 需要执行的sql
:param params: sql参数
:return: 执行结果
“”"
with conn.cursor() as cursor:
cursor.execute(sql, params)
if cursor.description is None:
cursor.close()
return []
columns = list(map(lambda d: d.name, cursor.description))
res = cursor.fetchall()
result = list(map(lambda row: dict(list(zip(columns, row))), res))
cursor.close()
return result
def sql_execute(sql: str):
connect = get_connect()
res = sql_execute(connect, sql, [0, content])
rerurn res