摘要: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
免责声明:本站系转载,并不代表本网赞同其观点和对其真实性负责。如涉及作品内容、版权和其它问题,请在30日内与本站联系,我们将在第一时间删除内容!