5分钟掌握Python中有关数据库的操作

B站影视 2025-02-08 13:39 2

摘要:import psycopg2connection = psycopg2.connect( dbname='your_database', user='your_username', password='your_password', host='your_h

创建与 Postgres 数据库的连接:

import psycopg2connection = psycopg2.connect( dbname='your_database', user='your_username', password='your_password', host='your_host')

创建数据库游标,以实现记录的遍历和操作:

cursor = connection.cursor

从数据库中选择数据:

cursor.execute("SELECT * FROM your_table")

使用游标获取数据:

records = cursor.fetchallfor record in records: print(record)

将数据插入数据库中的表:

cursor.execute("INSERT INTO your_table (column1, column2) VALUES (%s, %s)", ('value1', 'value2'))connection.commit # Seal the transaction

修改记录:

cursor.execute("UPDATE your_table SET column1 = %s WHERE column2 = %s", ('new_value', 'condition_value'))connection.commit

删除表中的记录:

cursor.execute("DELETE FROM your_table WHERE condition_column = %s", ('condition_value',))connection.commit

创建新表,定义其结构:

cursor.execute(""" CREATE TABLE your_new_table ( id SERIAL PRIMARY KEY, column1 VARCHAR(255), column2 INTEGER )""")connection.commit

删除表:

cursor.execute("DROP TABLE if exists your_table")connection.committry: cursor.execute("your first transactional query") cursor.execute("your second transactional query") connection.commit # Commit if all is wellexcept Exception as e: connection.rollback # Rollback in case of any issue print(f"An error occurred: {e}")

来源:自由坦荡的湖泊AI

相关推荐