未加星标

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

字体大小 | |
[开发(php) 所属分类 开发(php) | 发布者 店小二05 | 时间 | 作者 红领巾 ] 0人收藏点击收藏

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


您可能感兴趣的文章:php连接与操作PostgreSQL数据库的方法PostgreSQL管理工具phpPgAdmin入门指南PHP 读取Postgresql中的数组PHP5中使用PDO连接数据库的方法php使用PDO方法详解php中mysql连接方式PDO使用详解PHP PDO fetch 模式各种参数的输出结果一览Php中用PDO查询Mysql来避免SQL注入风险的方法php中在PDO中使用事务(Transaction)php使用pdo连接sqlserver示例分享

本文开发(php)相关术语:php代码审计工具 php开发工程师 移动开发者大会 移动互联网开发 web开发工程师 软件开发流程 软件开发工程师

tags: gt,errorInfo,myPDOStatement,###,id,pdo,new,Exception,username,PDO,throw,status,affectRowCount,bindParam
分页:12
转载请注明
本文标题:PHP实现基于PDO扩展连接PostgreSQL对象关系数据库示例
本站链接:https://www.codesec.net/view/574929.html


1.凡CodeSecTeam转载的文章,均出自其它媒体或其他官网介绍,目的在于传递更多的信息,并不代表本站赞同其观点和其真实性负责;
2.转载的文章仅代表原创作者观点,与本站无关。其原创性以及文中陈述文字和内容未经本站证实,本站对该文以及其中全部或者部分内容、文字的真实性、完整性、及时性,不作出任何保证或承若;
3.如本站转载稿涉及版权等问题,请作者及时联系本站,我们会及时处理。
登录后可拥有收藏文章、关注作者等权限...
技术大类 技术大类 | 开发(php) | 评论(0) | 阅读(41)