php使用PDO扩展连接PostgreSQL对象关系数据库-php教程-PHP中文网

php使用PDO扩展连接PostgreSQL对象关系数据库

php中文网

发布： 2016-07-29 09:12:04

原创

1985人浏览过

php使用pdo扩展连接postgresql对象关系数据库

citySHOP多用户商城系统

citySHOP是一款集CMS、网店、商品、分类信息、论坛等为一体的城市多用户商城系统，已完美整合目前流行的Discuz! 6.0论坛，采用最新的5.0版PHP+MYSQL技术。面向对象的数据库连接机制，缓存及80%静态化处理，使它能最大程度减轻服务器负担，为您节约建设成本。多级店铺区分及联盟商户地图标注，实体店与虚拟完美结合。个性化的店铺系统，会员后台一体化管理。后台登陆初始网站密匙：LOVES

查看详情

$pdo = NULL;
		if(<strong>version_compare</strong>(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 \<strong>Exception</strong>($errorInfo[0].'###'.$errorInfo[1].'###'.$errorInfo[2]);
				}
				$id = 1;
				$myPDOStatement->bindParam(":id",$id);
				$myPDOStatement->execute();
				if($myPDOStatement->errorCode()>0){
					$errorInfo = $myPDOStatement->errorInfo();
					throw new \<strong>Exception</strong>($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 \<strong>Exception</strong>($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 \<strong>Exception</strong>($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 \<strong>Exception</strong>($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 \<strong>Exception</strong>($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 \<strong>Exception</strong>($errorInfo[0].'###'.$errorInfo[1].'###'.$errorInfo[2]);
				}
				$id = 0;
				$myPDOStatement->bindParam(":id",$id);
				$myPDOStatement->execute();
				if($myPDOStatement->errorCode()>0){
					$errorInfo = $myPDOStatement->errorInfo();
					throw new \<strong>Exception</strong>($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 \<strong>Exception</strong>($errorInfo[0].'###'.$errorInfo[1].'###'.$errorInfo[2]);
				}
				//$insertedId = 10;
				$myPDOStatement->bindParam(":id",$insertedId);
				$myPDOStatement->execute();
				if($myPDOStatement->errorCode()>0){
					$errorInfo = $myPDOStatement->errorInfo();
					throw new \<strong>Exception</strong>($errorInfo[0].'###'.$errorInfo[1].'###'.$errorInfo[2]);
				}
				$affectRowCount = $myPDOStatement->rowCount();
				print_r('$affectRowCount = '.$affectRowCount);
			}
			$pdo->commit();
		} catch (\<strong>Exception</strong> $e) {
			$pdo->rollBack();
// 			print_r($e);
		}
		$pdo = null;

登录后复制

以上就介绍了php使用pdo扩展连接postgresql对象关系数据库，包括了version_compare,Exception方面的内容，希望对PHP教程有兴趣的朋友有所帮助。