php如何连接postgresql

PHP连接PostgreSQL数据库完整指南

在Web开发中,PHP与PostgreSQL的结合是一种经典的技术栈，尤其适合需要高稳定性、强一致性或复杂数据查询的场景，本文将详细介绍PHP连接PostgreSQL数据库的多种方式、核心步骤、常见问题及解决方案，帮助开发者快速上手。

连接前的准备工作

在开始编码前,需确保环境满足以下要求：

安装并启动PostgreSQL服务

• 下载并安装PostgreSQL（推荐官方版本：https://www.postgresql.org/download/），安装过程中设置postgres超级用户的密码。
• 启动PostgreSQL服务（Windows可通过“服务”管理器启动，Linux/Mac使用systemctl start postgresql命令）。

创建数据库及用户

• 使用psql命令行工具或图形化工具（如pgAdmin）连接到PostgreSQL：

  psql -U postgres -d postgres

• 创建目标数据库和用户（赋予该用户数据库的所有权限）：

  CREATE DATABASE mydb;
  CREATE USER myuser WITH PASSWORD 'mypassword';
  GRANT ALL PRIVILEGES ON DATABASE mydb TO myuser;

安装PHP的PostgreSQL扩展

PHP连接PostgreSQL需要依赖官方扩展,根据PHP版本选择对应方式：

通过包管理器安装（推荐）

• Linux（Ubuntu/Debian）：

  sudo apt-get install php-pgsql

• Linux（CentOS/RHEL）：

  sudo yum install php-pgsql

• Windows：确保php_pgsql.dll在PHP的ext目录下，并在php.ini中取消注释;extension=pgsql和;extension=pdo_pgsql。
• macOS（使用Homebrew）：

  brew install php-pgsql

手动编译安装

若无法通过包管理器安装,可手动编译扩展：

# 下载PHP源码（需与当前PHP版本一致）
wget https://www.php.net/distributions/php-8.2.0.tar.gz
tar -xzf php-8.2.0.tar.gz
cd php-8.2.0/ext/pgsql
# 编译并安装
phpize
./configure --with-pgsql=/path/to/postgres
make && make install

安装完成后,重启Web服务器（如Apache、Nginx）或PHP-FPM，并通过php -m | grep pgsql命令确认扩展是否加载成功。

PHP连接PostgreSQL的3种核心方式

PHP提供了多种连接PostgreSQL的方式,包括原生函数、PDO（PHP Data Objects）和第三方库（如Doctrine DBAL），其中原生函数和PDO是最常用的两种。

使用原生PostgreSQL函数（pg_系列）

PHP内置了一套PostgreSQL操作函数,以pg_开头，适合简单、直接的数据库操作。

建立连接

使用pg_connect()函数建立连接，支持DSN（Data Source Name）格式字符串：

<?php
$dsn = "host=localhost port=5432 dbname=mydb user=myuser password=mypassword";
$conn = pg_connect($dsn);
if (!$conn) {
    die("连接失败: " . pg_last_error());
}
echo "连接成功！";
?>

DSN参数说明：

• host：数据库服务器地址（默认localhost）。
• port：端口号（默认5432）。
• dbname：数据库名称。
• user：数据库用户名。
• password：用户密码。
• sslmode：SSL连接模式（如disable、require，默认disable）。

执行SQL查询

使用pg_query()执行查询语句，返回结果资源集：

$sql = "SELECT id, name, email FROM users WHERE age > 18";
$result = pg_query($conn, $sql);
if (!$result) {
    die("查询失败: " . pg_last_error());
}

遍历结果集

通过pg_fetch_array()、pg_fetch_assoc()等函数逐行获取数据：

while ($row = pg_fetch_assoc($result)) {
    echo "ID: " . $row['id'] . ", 姓名: " . $row['name'] . ", 邮箱: " . $row['email'] . "<br>";
}

关闭连接

使用pg_close()释放连接资源：

pg_close($conn);

完整示例

<?php
$dsn = "host=localhost port=5432 dbname=mydb user=myuser password=mypassword";
$conn = pg_connect($dsn);
if (!$conn) {
    die("连接失败: " . pg_last_error());
}
$sql = "INSERT INTO users (name, email, age) VALUES ('张三', 'zhangsan@example.com', 25)";
$result = pg_query($conn, $sql);
if ($result) {
    echo "插入成功，影响行数: " . pg_affected_rows($result);
} else {
    echo "插入失败: " . pg_last_error();
}
pg_close($conn);
?>

使用PDO（推荐）

PDO是PHP的数据库抽象层,支持多种数据库（MySQL、PostgreSQL、SQLite等），具备预处理、事务处理等高级功能，且代码可移植性更好。

建立连接

通过new PDO()实例化对象，DSN格式为pgsql:host=地址;port=端口;dbname=数据库名：

<?php
$dsn = "pgsql:host=localhost;port=5432;dbname=mydb";
$username = "myuser";
$password = "mypassword";
try {
    $pdo = new PDO($dsn, $username, $password, [
        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, // 开启异常模式
        PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC // 默认关联数组获取数据
    ]);
    echo "PDO连接成功！";
} catch (PDOException $e) {
    die("连接失败: " . $e->getMessage());
}
?>

执行查询（无预处理）

使用query()方法执行普通查询：

$sql = "SELECT id, name, email FROM users";
$stmt = $pdo->query($sql);
while ($row = $stmt->fetch()) {
    echo "ID: " . $row['id'] . ", 姓名: " . $row['name'] . "<br>";
}

执行预处理（防止SQL注入）

预处理是PDO的核心优势,通过prepare()和execute()组合使用：

$sql = "INSERT INTO users (name, email, age) VALUES (:name, :email, :age)";
$stmt = $pdo->prepare($sql);
$params = [
    ':name' => '李四',
    ':email' => 'lisi@example.com',
    ':age' => 30
];
$stmt->execute($params);
echo "插入成功，ID: " . $pdo->lastInsertId();

事务处理

PDO支持事务操作,确保数据一致性：

try {
    $pdo->beginTransaction(); // 开启事务
    $sql1 = "UPDATE accounts SET balance = balance - 100 WHERE user_id = 1";
    $pdo->exec($sql1);
    $sql2 = "UPDATE accounts SET balance = balance + 100 WHERE user_id = 2";
    $pdo->exec($sql2);
    $pdo->commit(); // 提交事务
    echo "事务提交成功！";
} catch (Exception $e) {
    $pdo->rollBack(); // 回滚事务
    echo "事务回滚: " . $e->getMessage();
}

关闭连接

PDO无需手动关闭连接,当脚本执行完毕或对象被销毁时自动释放：

$pdo = null; // 显式销毁（可选）

使用第三方库（Doctrine DBAL）

对于复杂项目,可使用Doctrine DBAL库，它提供了更高级的抽象，如实体映射、查询构建器等。

安装Doctrine DBAL

通过Composer安装：

composer require doctrine/dbal

连接数据库

<?php
require_once 'vendor/autoload.php';
use Doctrine\DBAL\DriverManager;
$config = new \Doctrine\DBAL\Configuration();
$connectionParams = [
    'dbname' => 'mydb',
    'user' => 'myuser',
    'password' => 'mypassword',
    'host' => 'localhost',
    'port' => '5432',
    'driver' => 'pdo_pgsql',
];
$conn = DriverManager::getConnection($connectionParams, $config);
echo "Doctrine DBAL连接成功！";
?>

执行