PostgreSQL事务功能与PHP编程
!--
Code highlighting produced byActiproCodeHighlighter(freeware)
http://www.CodeHighlighter.com/
-->
class pgsql {
private$linkid;//PostgreSQL连接标识符
private$host;//PostgreSQL服务器主机
private $user; //PostgreSQL用户
private $passwd; //PostgreSQL密码
private $db; //Postgresql数据库
private$result;//查询的结果
private$querycount;//已执行的查询总数
/*类构造函数，用来初始化$host、$user、$passwd和$db字段。*/
function __construct($host, $db, $user, $passwd){
$this->host = $host;
$this->user = $user;
$this->passwd = $passwd;
$this->db = $db;
}
/*连接Postgresql数据库 */
function connect(){
try{
$this->linkid=@pg_connect(host=$this->hostdbname=$this->db
user=$this->userpassword=$this->passwd);
if (! $this->linkid)
throw new Exception(Could not connect toPostgreSQLserver.);
}
catch (Exception $e) {
die($e->getMessage());
}
}
/*执行数据库查询。*/
function query($query){
try{
$this->result =@pg_query($this->linkid,$query);
throw new Exception(The database queryfailed.);
}
catch (Exception $e){
echo $e->getMessage();
}
$this->querycount++;
return $this->result;
}
/*确定受查询所影响的行的总计。*/
function affectedRows(){
$count = @pg_affected_rows($this->linkid);
return $count;
}
/*确定查询返回的行的总计。*/
function numRows(){
$count = @pg_num_rows($this->result);
return $count;
}
/*将查询的结果行作为一个对象返回。*/
function fetchObject(){
$row = @pg_fetch_object($this->result);
return $row;
}
/*将查询的结果行作为一个索引数组返回。*/
function fetchRow(){
$row = @pg_fetch_row($this->result);
return $row;
}
/*将查询的结果行作为一个关联数组返回。*/
function fetchArray(){
$row = @pg_fetch_array($this->result);
return $row;
}
PostgreSQL事务功能与PHP编程
