PHP实现基于PDO扩展连接PostgreSQL对象关系数据库示例

本文实例讲述了PHP实现基于PDO扩展连接PostgreSQL对象关系数据库的方法。分享给大家供大家参考，具体如下：

$pdo = NULL;
if(version_compare(PHP_VERSION, \'5.3.6\', \'<\')){
  $pdo = new \\PDO(\'pgsql:host=127.0.0.1;port=5432;dbname=postgredb1\',\'postgres\',\"123456\",array(\\PDO::MYSQL_ATTR_INIT_COMMAND=>\'SET NAMES \\\'UTF8\'\' ));
}
else{
  $pdo = new \\PDO(\'pgsql:host=127.0.0.1;port=5432;dbname=postgredb1\',\'postgres\',\"123456\");
}
try {
  $pdo->beginTransaction();
  $tableName = \'user\';
  if($fetch = true){
    $myPDOStatement = $pdo->prepare(\"SELECT * FROM \" . $tableName . \" WHERE id=:id \");
    if(!$myPDOStatement) {
      $errorInfo = $myPDOStatement->errorInfo();
      throw new \\Exception($errorInfo[0].\'###\'.$errorInfo[1].\'###\'.$errorInfo[2]);
    }
    $id = 1;
    $myPDOStatement->bindParam(\":id\",$id);
    $myPDOStatement->execute();
    if($myPDOStatement->errorCode()>0){
      $errorInfo = $myPDOStatement->errorInfo();
      throw new \\Exception($errorInfo[0].\'###\'.$errorInfo[1].\'###\'.$errorInfo[2]);
    }
    $item = $myPDOStatement->fetch();
    print_r($item);
  }
  $insertedId = 0;
  if($insert = true){
    $myPDOStatement = $pdo->prepare(\"INSERT INTO \" . $tableName . \"(username,password,status)  VALUES(:username,:password,:status)\");
    if(!$myPDOStatement) {
      $errorInfo = $myPDOStatement->errorInfo();
      throw new \\Exception($errorInfo[0].\'###\'.$errorInfo[1].\'###\'.$errorInfo[2]);
    }
    $timestamp = time();
    $data = array(
      \'username\' =>\'usernamex\',
      \'password\' =>\'passwordx\',
      \'status\' =>\'1\',
    );
    $myPDOStatement->bindParam(\":username\",$data[\'username\']);
    $myPDOStatement->bindParam(\":password\",$data[\'password\']);
    $myPDOStatement->bindParam(\":status\",$data[\'status\']);
    $myPDOStatement->execute();
    if($myPDOStatement->errorCode()>0){
      $errorInfo = $myPDOStatement->errorInfo();
      throw new \\Exception($errorInfo[0].\'###\'.$errorInfo[1].\'###\'.$errorInfo[2]);
    }
    $affectRowCount = $myPDOStatement->rowCount();
    if($affectRowCount>0){
      $insertedId = $pdo->lastInsertId();
    }
    print_r(\'$insertedId = \'.$insertedId);//PostgreSQL不支持
    print_r(\'$affectRowCount = \'.$affectRowCount);
  }
  if($update = true){
    $myPDOStatement = $pdo->prepare(\"UPDATE \" . $tableName . \" SET username=:username, status=:status WHERE id=:id\");
    if(!$myPDOStatement) {
      $errorInfo = $myPDOStatement->errorInfo();
      throw new \\Exception($errorInfo[0].\'###\'.$errorInfo[1].\'###\'.$errorInfo[2]);
    }
    $id = 1;
    $username = \'username update\';
    $status = 0;
    $myPDOStatement->bindParam(\":id\",$id);
    $myPDOStatement->bindParam(\":username\",$username);
    $myPDOStatement->bindParam(\":status\",$status);
    $myPDOStatement->execute();
    if($myPDOStatement->errorCode()>0){
      $errorInfo = $myPDOStatement->errorInfo();
      throw new \\Exception($errorInfo[0].\'###\'.$errorInfo[1].\'###\'.$errorInfo[2]);
    }
    $affectRowCount = $myPDOStatement->rowCount();
    print_r(\'$affectRowCount = \'.$affectRowCount);
  }
  if($fetchAll = true){
    $myPDOStatement = $pdo->prepare(\"SELECT * FROM \" . $tableName .\" WHERE id > :id\");
    if(!$myPDOStatement) {
      $errorInfo = $myPDOStatement->errorInfo();
      throw new \\Exception($errorInfo[0].\'###\'.$errorInfo[1].\'###\'.$errorInfo[2]);
    }
    $id = 0;
    $myPDOStatement->bindParam(\":id\",$id);
    $myPDOStatement->execute();
    if($myPDOStatement->errorCode()>0){
      $errorInfo = $myPDOStatement->errorInfo();
      throw new \\Exception($errorInfo[0].\'###\'.$errorInfo[1].\'###\'.$errorInfo[2]);
    }
    $list = $myPDOStatement->fetchAll();
    print_r($list);
  }
  if($update = true){
    $myPDOStatement = $pdo->prepare(\"DELETE FROM \" . $tableName . \" WHERE id=:id\");
    if(!$myPDOStatement) {
      $errorInfo = $myPDOStatement->errorInfo();
      throw new \\Exception($errorInfo[0].\'###\'.$errorInfo[1].\'###\'.$errorInfo[2]);
    }
    //$insertedId = 10;
    $myPDOStatement->bindParam(\":id\",$insertedId);
    $myPDOStatement->execute();
    if($myPDOStatement->errorCode()>0){
      $errorInfo = $myPDOStatement->errorInfo();
      throw new \\Exception($errorInfo[0].\'###\'.$errorInfo[1].\'###\'.$errorInfo[2]);
    }
    $affectRowCount = $myPDOStatement->rowCount();
    print_r(\'$affectRowCount = \'.$affectRowCount);
  }
  $pdo->commit();
} catch (\\Exception $e) {
  $pdo->rollBack();
//     print_r($e);
}
$pdo = null;

更多关于PHP相关内容感兴趣的读者可查看本站专题：《PHP基于pdo操作数据库技巧总结》、《php+Oracle数据库程序设计技巧总结》、《PHP+MongoDB数据库操作技巧大全》、《php面向对象程序设计入门教程》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》

希望本文所述对大家PHP程序设计有所帮助。