一、进行PostgreSQL数据库的连接
要在Python程序中进行PostgreSQL数据库的连接，需要安装Python中的psycopg2库。可以使用pip命令进行安装。
pip install psycopg2
然后使用psycopg2库中的connect()函数进行数据库的连接。connect()函数的参数可以是一个包含连接信息的字典，也可以是一组单独的参数。下面是一个使用字典进行连接的例子：
import psycopg2
conn = psycopg2.connect({
"host": "localhost",
"database": "my_database",
"user": "my_user",
"password": "my_password"
})
如果要使用单独的参数进行连接，可以这样写：
conn = psycopg2.connect(
host="localhost",
database="my_database",
user="my_user",
password="my_password"
)
二、进行数据库的查询操作
进行数据库的查询操作有两种方式：使用cursor.fetchall()方法查询所有的结果，或者使用fetchone()方法一行一行地查询结果。下面是一个使用fetchall()方法查询结果的例子：
cur = conn.cursor()
query = "SELECT * FROM my_table;"
cur.execute(query)
results = cur.fetchall()
for row in results:
print(row)
如果要使用fetchone()方法查询结果，可以这样写：
cur = conn.cursor()
query = "SELECT * FROM my_table;"
cur.execute(query)
row = cur.fetchone()
while row is not None:
print(row)
row = cur.fetchone()
三、进行数据库的更新操作
进行数据库的更新操作需要使用cursor.execute()方法。下面是一个使用execute()方法进行更新的例子：
cur = conn.cursor()
query = "UPDATE my_table SET my_column = 'new_value' WHERE id = '123';"
cur.execute(query)
conn.commit()
如果需要使用参数化查询进行更新操作，可以这样写：
cur = conn.cursor()
query = "UPDATE my_table SET my_column = %s WHERE id = %s;"
cur.execute(query, ('new_value', '123'))
conn.commit()
四、进行数据库的插入操作
进行数据库的插入操作也需要使用cursor.execute()方法。下面是一个使用execute()方法进行插入的例子：
cur = conn.cursor()
query = "INSERT INTO my_table (column1, column2) VALUES ('value1', 'value2');"
cur.execute(query)
conn.commit()
如果需要使用参数化查询进行插入操作，可以这样写：
cur = conn.cursor()
query = "INSERT INTO my_table (column1, column2) VALUES (%s, %s);"
cur.execute(query, ('value1', 'value2'))
conn.commit()
五、进行数据库的删除操作
进行数据库的删除操作也需要使用cursor.execute()方法。下面是一个使用execute()方法进行删除的例子：
cur = conn.cursor()
query = "DELETE FROM my_table WHERE id = '123';"
cur.execute(query)
conn.commit()
如果需要使用参数化查询进行删除操作，可以这样写：
cur = conn.cursor()
query = "DELETE FROM my_table WHERE id = %s;"
cur.execute(query, ('123', ))
conn.commit()
原创文章，作者：小蓝，如若转载，请注明出处：https://www.506064.com/n/245339.html
微信扫一扫 
支付宝扫一扫 