一、進行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/zh-hant/n/245339.html