扫码关注官方微信

扫码下载APP
返回顶部
首页 > 资讯 > 数据库 >Python连接和操作PostgreSQL数据库的流程步骤
  • 853

0
分享到

Python连接和操作PostgreSQL数据库的流程步骤

Python连接和操作PostgreSQLPython连接PostgreSQLPython操作PostgreSQLPythonPostgreSQL 2024-10-23 10:10:14 853人浏览 八月长安
摘要

目录引言环境搭建安装 postgresql在 windows 上安装 Postgresql在 linux 上安装 PostgreSQL在 MacOS 上安装 PostgreSQL安装 python 和相关库连接数据库导入

引言

在当今信息化的时代，数据库已成为存储和管理数据的关键技术。PostgreSQL 是一种开源的对象关系型数据库管理系统（ORDBMS），以其强大的功能和稳定性而广受欢迎。Python 作为一种高级编程语言，因其简洁易读的语法和丰富的库支持，成为了数据处理和数据库操作的理想选择。本文将详细介绍如何使用 Python 连接和操作 PostgreSQL 数据库，包括环境搭建、连接数据库、执行 SQL 查询和更新操作，以及处理异常和事务管理等内容。

环境搭建

在开始之前，我们需要确保系统上已经安装了 PostgreSQL 数据库和 Python 环境。以下是安装步骤：

安装 PostgreSQL

在 Windows 上安装 PostgreSQL

  • 访问 PostgreSQL 官方网站下载适用于 Windows 的安装程序。
  • 运行安装程序并按照提示完成安装。
  • 安装完成后，启动 PostgreSQL 服务并记下端口号（默认为 5432）。

在 Linux 上安装 PostgreSQL

sudo apt-get update
sudo apt-get install postgresql postgresql-contrib

在 macOS 上安装 PostgreSQL

brew install postgresql

安装 Python 和相关库

确保系统上已经安装了 Python。然后使用 pip 安装 psycopg2 库，这是一个用于连接 PostgreSQL 数据库的 Python 扩展模块。

pip install psycopg2

连接数据库

连接数据库是进行数据库操作的第一步。以下是使用 Python 连接 PostgreSQL 数据库的基本步骤：

导入库

import psycopg2

建立连接

try:
    conn = psycopg2.connect(
        host="localhost",
        database="mydatabase",
        user="myuser",
        passWord="mypassword"
    )
    print("成功连接到数据库")
except psycopg2.Error as e:
    print(f"连接数据库失败: {e}")

创建游标

游标用于执行 SQL 查询并获取结果。

cur = conn.cursor()

执行查询

try:
    cur.execute("SELECT version();")
    db_version = cur.fetchone()
    print(f"数据库版本: {db_version[0]}")
except psycopg2.Error as e:
    print(f"执行查询失败: {e}")

关闭游标和连接

cur.close()
conn.close()

执行 SQL 查询和更新操作

查询数据

查询数据是最常见的数据库操作之一。以下是一个简单的查询示例：

try:
    cur.execute("SELECT * FROM mytable;")
    rows = cur.fetchall()
    for row in rows:
        print(row)
except psycopg2.Error as e:
    print(f"查询失败: {e}")

插入数据

插入数据用于向数据库表中添加新记录。

try:
    cur.execute("INSERT INTO mytable (column1, column2) VALUES (%s, %s);", ("value1", "value2"))
    conn.commit()
    print("插入成功")
except psycopg2.Error as e:
    print(f"插入失败: {e}")
    conn.rollback()

更新数据

更新数据用于修改数据库表中的现有记录。

try:
    cur.execute("UPDATE mytable SET column1 = %s WHERE column2 = %s;", ("new_value1", "value2"))
    conn.commit()
    print("更新成功")
except psycopg2.Error as e:
    print(f"更新失败: {e}")
    conn.rollback()

删除数据

删除数据用于从数据库表中移除记录。

try:
    cur.execute("DELETE FROM mytable WHERE column1 = %s;", ("value1",))
    conn.commit()
    print("删除成功")
except psycopg2.Error as e:
    print(f"删除失败: {e}")
    conn.rollback()

处理异常

在数据库操作过程中，可能会遇到各种异常情况。为了确保程序的健壮性，我们需要捕获并处理这些异常。

捕获异常

try:
    # 数据库操作代码
except psycopg2.Error as e:
    print(f"数据库操作失败: {e}")
finally:
    if conn is not None:
        conn.close()

处理特定异常

有时我们需要处理特定类型的异常，例如连接异常或查询异常。

try:
    # 数据库操作代码
except psycopg2.OperationalError as e:
    print(f"连接或操作错误: {e}")
except psycopg2.ProgrammingError as e:
    print(f"SQL 语句错误: {e}")

事务管理

事务是一组数据库操作，这些操作要么全部成功，要么全部失败。事务管理对于确保数据的一致性和完整性至关重要。

开启事务

conn.autocommit = False

提交事务

try:
    # 数据库操作代码
    conn.commit()
    print("事务提交成功")
except psycopg2.Error as e:
    conn.rollback()
    print(f"事务提交失败: {e}")

回滚事务

try:
    # 数据库操作代码
    conn.commit()
except psycopg2.Error as e:
    conn.rollback()
    print(f"事务回滚: {e}")

使用上下文管理器

Python 的上下文管理器可以简化资源管理，特别是在处理数据库连接和游标时。

使用 with 语句管理连接

try:
    with psycopg2.connect(
        host="localhost",
        database="mydatabase",
        user="myuser",
        password="mypassword"
    ) as conn:
        with conn.cursor() as cur:
            cur.execute("SELECT version();")
            db_version = cur.fetchone()
            print(f"数据库版本: {db_version[0]}")
except psycopg2.Error as e:
    print(f"连接或查询失败: {e}")

使用 with 语句管理事务

try:
    with psycopg2.connect(
        host="localhost",
        database="mydatabase",
        user="myuser",
        password="mypassword"
    ) as conn:
        conn.autocommit = False
        with conn.cursor() as cur:
            cur.execute("INSERT INTO mytable (column1, column2) VALUES (%s, %s);", ("value1", "value2"))
            conn.commit()
            print("插入成功")
except psycopg2.Error as e:
    print(f"插入失败: {e}")

高级功能

使用参数化查询

参数化查询可以有效防止 SQL 注入攻击，并提高查询性能。

try:
    with psycopg2.connect(
        host="localhost",
        database="mydatabase",
        user="myuser",
        password="mypassword"
    ) as conn:
        with conn.cursor() as cur:
            cur.execute("SELECT * FROM mytable WHERE column1 = %s;", ("value1",))
            rows = cur.fetchall()
            for row in rows:
                print(row)
except psycopg2.Error as e:
    print(f"查询失败: {e}")

使用批量操作

批量操作可以显著提高数据插入和更新的性能。

try:
    with psycopg2.connect(
        host="localhost",
        database="mydatabase",
        user="myuser",
        password="mypassword"
    ) as conn:
        with conn.cursor() as cur:
            data = [("value1", "value2"), ("value3", "value4")]
            cur.executemany("INSERT INTO mytable (column1, column2) VALUES (%s, %s);", data)
            conn.commit()
            print("批量插入成功")
except psycopg2.Error as e:
    print(f"批量插入失败: {e}")

使用存储过程

存储过程是预编译的 SQL 代码块，可以在数据库中存储并重复调用。

CREATE OR REPLACE FUNCTION get_user_by_id(user_id INT) RETURNS TABLE(id INT, name TEXT) AS $$
BEGIN
    RETURN QUERY SELECT id, name FROM users WHERE id = user_id;
END;
$$ LANGUAGE plpgsql;

try:
    with psycopg2.connect(
        host="localhost",
        database="mydatabase",
        user="myuser",
        password="mypassword"
    ) as conn:
        with conn.cursor() as cur:
            cur.callproc('get_user_by_id', [1])
            rows = cur.fetchall()
            for row in rows:
                print(row)
except psycopg2.Error as e:
    print(f"调用存储过程失败: {e}")

性能优化

使用连接池

连接池可以减少连接数据库的开销，提高性能。

from psycopg2 import pool

try:
    postgreSQL_pool = psycopg2.pool.SimpleConnectionPool(
        1, 20,
        host="localhost",
        database="mydatabase",
        user="myuser",
        password="mypassword"
    )
    if postgreSQL_pool:
        print("连接池创建成功")
except psycopg2.Error as e:
    print(f"连接池创建失败: {e}")

# 获取连接
conn = postgreSQL_pool.getconn()

try:
    with conn.cursor() as cur:
        cur.execute("SELECT version();")
        db_version = cur.fetchone()
        print(f"数据库版本: {db_version[0]}")
finally:
    # 释放连接
    postgreSQL_pool.putconn(conn)

使用索引

索引可以显著提高查询性能，特别是在大数据集上。

CREATE INDEX idx_column1 ON mytable(column1);

使用批量提交

批量提交可以减少事务的开销，提高性能。

try:
    with psycopg2.connect(
        host="localhost",
        database="mydatabase",
        user="myuser",
        password="mypassword"
    ) as conn:
        conn.autocommit = False
        with conn.cursor() as cur:
            data = [("value1", "value2"), ("value3", "value4")]
            for row in data:
                cur.execute("INSERT INTO mytable (column1, column2) VALUES (%s, %s);", row)
                if len(data) % 1000 == 0:
                    conn.commit()
                    print("批量提交成功")
            conn.commit()
            print("插入完成")
except psycopg2.Error as e:
    print(f"插入失败: {e}")
    conn.rollback()

案例分析

为了更好地理解如何使用 Python 连接和操作 PostgreSQL 数据库，我们将通过一个实际案例来进行演示。

案例背景

假设我们有一个简单的电子商务网站，需要管理用户信息和订单信息。我们将创建两个表：users 和 orders，并演示如何进行基本的增删改查操作。

创建表

CREATE TABLE users (
    id SERIAL PRIMARY KEY,
    name TEXT NOT NULL,
    email TEXT UNIQUE NOT NULL
);

CREATE TABLE orders (
    id SERIAL PRIMARY KEY,
    user_id INT NOT NULL,
    amount DECIMAL(10, 2) NOT NULL,
    FOREIGN KEY (user_id) REFERENCES users(id)
);

插入数据

try:
    with psycopg2.connect(
        host="localhost",
        database="mydatabase",
        user="myuser",
        password="mypassword"
    ) as conn:
        with conn.cursor() as cur:
            users_data = [
                ("Alice", "alice@example.com"),
                ("Bob", "bob@example.com")
            ]
            cur.executemany("INSERT INTO users (name, email) VALUES (%s, %s);", users_data)
            conn.commit()
            print("用户数据插入成功")

            orders_data = [
                (1, 100.00),
                (2, 200.00)
            ]
            cur.executemany("INSERT INTO orders (user_id, amount) VALUES (%s, %s);", orders_data)
            conn.commit()
            print("订单数据插入成功")
except psycopg2.Error as e:
    print(f"数据插入失败: {e}")

查询数据

try:
    with psycopg2.connect(
        host="localhost",
        database="mydatabase",
        user="myuser",
        password="mypassword"
    ) as conn:
        with conn.cursor() as cur:
            cur.execute("SELECT * FROM users;")
            users = cur.fetchall()
            print("用户数据:")
            for user in users:
                print(user)

            cur.execute("SELECT * FROM orders;")
            orders = cur.fetchall()
            print("订单数据:")
            for order in orders:
                print(order)
except psycopg2.Error as e:
    print(f"数据查询失败: {e}")

更新数据

try:
    with psycopg2.connect(
        host="localhost",
        database="mydatabase",
        user="myuser",
        password="mypassword"
    ) as conn:
        with conn.cursor() as cur:
            cur.execute("UPDATE users SET email = %s WHERE name = %s;", ("alice_new@example.com", "Alice"))
            conn.commit()
            print("用户数据更新成功")
except psycopg2.Error as e:
    print(f"数据更新失败: {e}")

删除数据

try:
    with psycopg2.connect(
        host="localhost",
        database="mydatabase",
        user="myuser",
        password="mypassword"
    ) as conn:
        with conn.cursor() as cur:
            cur.execute("DELETE FROM orders WHERE user_id = %s;", (1,))
            conn.commit()
            print("订单数据删除成功")
except psycopg2.Error as e:
    print(f"数据删除失败: {e}")

结论

通过本文的详细介绍，我们学习了如何使用 Python 连接和操作 PostgreSQL 数据库。从环境搭建到高级功能的使用，再到性能优化和实际案例的分析，我们涵盖了数据库操作的各个方面。希望本文能为新手朋友提供有价值的参考和指导，帮助大家在 Python 和 PostgreSQL 的世界中探索更多的可能性。

以上就是Python连接和操作PostgreSQL数据库的流程步骤的详细内容，更多关于Python连接和操作PostgreSQL的资料请关注编程网(www.lsjlt.com)其它相关文章！

您可能感兴趣的文档:

--结束END--

本文标题: Python连接和操作PostgreSQL数据库的流程步骤

本文链接: https://lsjlt.com/news/623949.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

猜你喜欢
  • Golang连接并操作PostgreSQL数据库基本操作
    目录前言：连接数据库sql.DB增删改查插入数据更新数据查询数据删除数据总结前言： 本篇文章对如何使用golang连接并操作postgre数据库进行了简要说明。文中使用到的主要工具：DBeaver21、VSCode，Go...
    99+
    2024-04-02
  • python连接postgresql数据库
    python连接postgresql数据库 postgresql是常用的关系型数据库，并且postgresql目前还保持着全部开源的状态，所以我们今天就一起来学习一下，如何用python连接postg...
    99+
    2023-09-04
    数据库 postgresql python
  • Python操作PostgreSQL数据库
    个人简介：一个从会计转行数据分析师的三旬老汉 擅长领域：数据分析、数据仓库、大数据 博客内容：平时会将自己工作中遇到的问题进行归纳总结，分享给各位小伙伴，意在帮助大家少加班、不掉发，让我们相互学习...
    99+
    2023-10-27
    数据库 postgresql python
  • python连接数据库的步骤是什么
    连接数据库的步骤如下：1. 导入需要的模块：导入Python中用于连接数据库的模块，如`pymysql`、`sqlite3`等。2....
    99+
    2023-08-15
    python 数据库
  • python连接数据库操作MySQL
    参考:http://www.liaoxuefeng.com/wiki/001374738125095c955c1e6d8bb493182103fac9270762a000/001391435131816c6...
    99+
    2024-04-02
  • Python操作SQLite数据库的基本步骤
    本篇内容介绍了“Python操作SQLite数据库的基本步骤”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！1.什么是SQLite数据库SQL...
    99+
    2023-06-02
  • 配置python连接oracle读取excel数据写入数据库的操作流程
    前提条件：本地已经安装好oracle单实例，能使用plsql developer连接，或者能使用TNS连接串远程连接到oracle集群 读取excel写入数据库的方式有多种，这里介绍...
    99+
    2024-04-02
  • Python连接MySQL数据库的步骤是什么
    连接MySQL数据库的步骤如下所示： 安装MySQL驱动程序： 在Python中连接MySQL数据库需要使用MySQL官方提供的驱...
    99+
    2024-04-09
    Python MySQL
  • PHP连接MySQL和读取数据库的步骤
    本篇内容介绍了“PHP连接MySQL和读取数据库的步骤”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！PHP...
    99+
    2024-04-02
  • sqlyog连接mysql的操作步骤
    小编给大家分享一下sqlyog连接mysql的操作步骤，希望大家阅读完这篇文章后大所收获，下面让我们一起去探讨吧！sqlyog连接mysql的方法：1、在桌面上点击sqlyog快捷方式，打开sqlyog窗口...
    99+
    2024-04-02
  • navicat连接mysql的操作步骤
    这篇文章主要介绍了navicat连接mysql的操作步骤，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。navicat连接mysql的方法：首...
    99+
    2024-04-02
  • Qt5连接并操作PostgreSQL数据库的实现示例
    教你如何查看官方demo 1. 浏览器搜索Qt，打开第一个连接。 2. 鼠标悬浮Learning，点击下边的Documentation进入文档说明。 3. 找到Qt 5，点击进入...
    99+
    2024-04-02
  • Android 连接MySql数据库步骤
    1.首先我们需要导入mysql驱动jar包下载地址：   在android studio的build.gradle中插入 dependencies { implementation 'mysql:mysql-connector-java:5...
    99+
    2023-09-18
    android 数据库 android studio
  • Python连接PostgreSQL数据库的方法
    前言 其实在Python中可以用来连接PostgreSQL的模块很多，这里比较推荐psycopg2。psycopg2安装起来非常的简单（pip install psycopg2），这里主要重点介绍下如何使用...
    99+
    2022-06-04
    数据库 方法 Python
  • python怎么连接postgresql数据库
    要连接到 PostgreSQL 数据库，可以使用 psycopg2 库。首先需要安装 psycopg2： pip install p...
    99+
    2024-04-17
    postgresql python
  • python中jdbc连接数据库的步骤是什么
    在Python中使用JDBC连接数据库的步骤如下：1. 安装JDBC驱动程序：对于不同的数据库，需要安装相应的JDBC驱动程序。可以...
    99+
    2023-10-30
    jdbc python 数据库
  • jdbc连接数据库的5个步骤
    推荐教程：java教程1、加载驱动　　在连接数据库之前,需要加载数据库的驱动到JVM(Java虚拟机),这需要通过java.lang.Class类的静态方法forName(String className)实现.例如://加载Oracle的...
    99+
    2021-02-08
    java教程 java jdbc
  • Java连接数据库的步骤介绍
    第一步：数据库驱动和数据量地址基本信息。 // MySQL 8.0 以下版本 - JDBC 驱动名及数据库 URL static final String JDBC_DRIV...
    99+
    2024-04-02
  • ADO.NET连接SQL Server数据库的步骤
    本篇内容主要讲解“ADO.NET连接SQL Server数据库的步骤”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“ADO.NET连接SQL Server数据库的步骤”吧!在.NET应用程序中，创...
    99+
    2023-06-17
  • SQL Server数据库分离和附加数据库的操作步骤
    目录1. 概述2. 分离数据库2.1 分离数据库的步骤3. 附加数据库3.1 附加数据的操作步骤总结 1. 概述 若要将数据库移动或更改到同一计算机的不同 SQL Server 实例，分离和附加数据库会很有用；...
    99+
    2024-04-02
软考高级职称资格查询
热门wiki
近期文章
推荐阅读
热门问答
热门标签
编程网，编程工程师的家园，是目前国内优秀的开源技术社区之一，形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容，为IT开发者提供了一个发现、使用、并交流开源技术的平台。

  • 官方手机版

  • 微信公众号

  • 商务合作