PHP连接PostgreSQL PHP操作Postgres数据库教程

<?php
$host = "localhost";
$port = "5432";
$dbname = "mydatabase";
$user = "myuser";
$password = "mypassword";

$conn_string = "host={$host} port={$port} dbname={$dbname} user={$user} password={$password}";

$dbconn = pg_connect($conn_string);

if (!$dbconn) {
  echo "Error connecting to database.";
  exit;
}

echo "Successfully connected to database.";

// 执行查询
$query = "SELECT * FROM mytable";
$result = pg_query($dbconn, $query);

if (!$result) {
  echo "Error executing query.";
  exit;
}

// 处理结果
while ($row = pg_fetch_assoc($result)) {
  echo "ID: " . $row['id'] . ", Name: " . $row['name'] . "<br>";
}

// 关闭连接
pg_close($dbconn);
?>

<?php
$query = "SELECT * FROM mytable WHERE name = $1"; // $1 是占位符
$result = pg_prepare($dbconn, "myquery", $query);

if (!$result) {
  echo "Error preparing statement.";
  exit;
}

$name = $_POST['name']; // 从用户输入获取
$result = pg_execute($dbconn, "myquery", array($name)); // 传递参数

if (!$result) {
  echo "Error executing query.";
  exit;
}

while ($row = pg_fetch_assoc($result)) {
  echo "ID: " . $row['id'] . ", Name: " . $row['name'] . "<br>";
}
?>

<?php
// 创建游标
$query = "DECLARE mycursor CURSOR FOR SELECT * FROM mytable";
$result = pg_query($dbconn, $query);

if (!$result) {
  echo "Error creating cursor.";
  exit;
}

// 循环读取数据
while (true) {
  $query = "FETCH 10 FROM mycursor"; // 每次读取10行
  $result = pg_query($dbconn, $query);

  if (!$result) {
    echo "Error fetching data.";
    exit;
  }

  if (pg_num_rows($result) == 0) {
    break; // 没有更多数据了
  }

  while ($row = pg_fetch_row($result)) {
    echo "ID: " . $row[0] . ", Name: " . $row[1] . "<br>";
  }
}

// 关闭游标
$query = "CLOSE mycursor";
$result = pg_query($dbconn, $query);

if (!$result) {
  echo "Error closing cursor.";
  exit;
}
?>