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

php  /  管理员 发布于 7年前   263

本文实例讲述了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程序设计有所帮助。

您可能感兴趣的文章:

• PHP5中使用PDO连接数据库的方法
• PHP中PDO连接数据库中各种DNS设置方法小结
• ThinkPHP框架基于PDO方式连接数据库操作示例
• php使用pdo连接并查询sql数据库的方法
• PHP使用PDO连接ACCESS数据库
• PHP使用pdo连接access数据库并循环显示数据操作示例
• PHP实现PDO的mysql数据库操作类
• php使用PDO操作MySQL数据库实例
• PHP封装的数据库模型Model类完整示例【基于PDO】
• PHP实现的pdo连接数据库并插入数据功能简单示例