PostgreSQL连接PHP("PHP与PostgreSQL数据库连接详解")

原创

ithorizon 6个月前 (10-19) 阅读数 41 #后端开发

语法如下：

PHP与PostgreSQL数据库连接详解

一、简介

PostgreSQL是一种功能强盛的开源对象关系型数据库系统，它赞成多种数据类型和高级功能，如存储过程、触发器、视图等。PHP是一种流行的服务器端脚本语言，频繁与各种数据库系统一起使用来开发动态网站。本文将详细介绍怎样使用PHP连接到PostgreSQL数据库。

二、环境准备

在起初之前，确保您的系统中已经安装了PHP和PostgreSQL。此外，您还需要安装PHP的PostgreSQL扩展，以便PHP能够与PostgreSQL数据库进行通信。

您可以通过以下命令来检查PHP的PostgreSQL扩展是否已经安装：

php -m | grep pgsql

三、连接PostgreSQL数据库

要连接到PostgreSQL数据库，您可以使用PHP的PDO（PHP Data Objects）扩展或者pg_connect()函数。下面分别介绍这两种方法。

3.1 使用PDO连接PostgreSQL

PDO提供了一个数据访问抽象层，允许您使用相同的函数来访问不同的数据库。以下是一个使用PDO连接到PostgreSQL数据库的示例：

<?php
$host = 'localhost';
$dbname = 'your_database_name';
$user = 'your_username';
$pass = 'your_password';
try {
    $pdo = new PDO("pgsql:host=$host;dbname=$dbname", $user, $pass);
    echo "连接圆满！";
} catch (PDOException $e) {
    echo "连接未果： " . $e->getMessage();
}
?>

3.2 使用pg_connect()连接PostgreSQL

pg_connect()函数是PHP专用于连接PostgreSQL数据库的函数。以下是一个使用pg_connect()连接到PostgreSQL数据库的示例：

<?php
$host = 'localhost';
$dbname = 'your_database_name';
$user = 'your_username';
$pass = 'your_password';
$conn_string = "host=$host dbname=$dbname user=$user password=$pass";
$conn = pg_connect($conn_string);
if (!$conn) {
    die("连接未果： " . pg_last_error());
}
echo "连接圆满！";
?>

四、执行SQL查询

一旦连接到PostgreSQL数据库，您就可以执行SQL查询了。以下是怎样使用PDO和pg_connect()执行查询的示例。

4.1 使用PDO执行查询

使用PDO执行查询非常单纯，您可以利用其提供的exec()或query()方法。以下是一个示例：

<?php
try {
    $pdo = new PDO("pgsql:host=localhost;dbname=your_database_name", "your_username", "your_password");
    
    // 使用exec()执行INSERT、UPDATE、DELETE等非SELECT查询
    $sql = "INSERT INTO your_table (column1, column2) VALUES ('value1', 'value2')";
    $pdo->exec($sql);
    echo "执行圆满！";
    
    // 使用query()执行SELECT查询
    $sql = "SELECT * FROM your_table";
    $result = $pdo->query($sql);
    
    while ($row = $result->fetch(PDO::FETCH_ASSOC)) {
        echo $row['column1'] . " - " . $row['column2'] . " ";
    }
} catch (PDOException $e) {
    echo "谬误： " . $e->getMessage();
}
?>

4.2 使用pg_connect()执行查询

使用pg_connect()执行查询时，您可以使用pg_query()函数。以下是一个示例：

<?php
$conn_string = "host=localhost dbname=your_database_name user=your_username password=your_password";
$conn = pg_connect($conn_string);
if (!$conn) {
    die("连接未果： " . pg_last_error());
}
// 执行INSERT、UPDATE、DELETE等非SELECT查询
$sql = "INSERT INTO your_table (column1, column2) VALUES ('value1', 'value2')";
$result = pg_query($conn, $sql);
if (!$result) {
    die("执行未果： " . pg_last_error());
}
echo "执行圆满！";
// 执行SELECT查询
$sql = "SELECT * FROM your_table";
$result = pg_query($conn, $sql);
while ($row = pg_fetch_assoc($result)) {
    echo $row['column1'] . " - " . $row['column2'] . " ";
}
pg_free_result($result); // 释放查询于是占用的内存
pg_close($conn); // 关闭数据库连接
?>

五、处理谬误和异常

在处理数据库连接和查询时，也许会遇到谬误或异常。正确处理这些谬误或异常是保证程序稳定运行的关键。

5.1 使用PDO处理谬误和异常

PDO提供了异常处理机制。您可以通过设置PDO谬误模式来启用异常处理。以下是一个示例：

<?php
$pdo = new PDO("pgsql:host=localhost;dbname=your_database_name", "your_username", "your_password");
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
try {
    $sql = "SELECT * FROM non_existent_table";
    $result = $pdo->query($sql);
    
    while ($row = $result->fetch(PDO::FETCH_ASSOC)) {
        echo $row['column1'] . " - " . $row['column2'] . " ";
    }
} catch (PDOException $e) {
    echo "出现谬误： " . $e->getMessage();
}
?>

5.2 使用pg_connect()处理谬误

使用pg_connect()时，您可以通过检查pg_last_error()函数的返回值来处理谬误。以下是一个示例：

<?php
$conn_string = "host=localhost dbname=your_database_name user=your_username password=your_password";
$conn = pg_connect($conn_string);
if (!$conn) {
    die("连接未果： " . pg_last_error());
}
$sql = "SELECT * FROM non_existent_table";
$result = pg_query($conn, $sql);
if (!$result) {
    die("查询未果： " . pg_last_error());
}
// 如果查询圆满，处理于是
while ($row = pg_fetch_assoc($result)) {
    echo $row['column1'] . " - " . $row['column2'] . " ";
}
pg_free_result($result);
pg_close($conn);
?>

六、关闭数据库连接

在完成数据库操作后，关闭数据库连接是一个好习惯，这可以帮助释放服务器资源。对于PDO，当脚本执行完毕后，连接会自动关闭。但是，对于pg_connect()，您需要显式地关闭连接。

<?php
$conn_string = "host=localhost dbname=your_database_name user=your_username password=your_password";
$conn = pg_connect($conn_string);
// ... 执行数据库操作 ...
pg_close($conn); // 关闭连接
?>