这篇文章主要介绍了PHP操作Postgresql封装类,结合实例形式分析了php针对Postgresql数据库常见的连接、查询、统计等操作封装技巧与使用方法,需要的朋友可以参考下

本文实例讲述了PHP操作Postgresql封装类与应用。分享给大家供大家参考，具体如下：

这个类封装了一些常用的函数，原帖里面还有事务处理的内容，以后再学习吧。

类文件定义：

1. <?php 
2. class pgsql { 
3. private $linkid; // PostgreSQL连接标识符 
4. private $host; // PostgreSQL服务器主机 
5. private $port; // PostgreSQL服务器主机端口 
6. private $user; // PostgreSQL用户 
7. private $passwd; // PostgreSQL密码 
8. private $db; // Postgresql数据库 
9. private $result; // 查询的结果 
10. private $querycount; // 已执行的查询总数 
11. /* 类构造函数，用来初始化$host、$user、$passwd和$db字段。 */ 
12. function __construct($host, $port ,$db, $user, $passwd) { 
13. $this->host = $host; 
14. $this->port = $port; 
15. $this->user = $user; 
16. $this->passwd = $passwd; 
17. $this->db = $db; 
18. } 
19. /* 连接Postgresql数据库 */ 
20. function connect(){ 
21. try{ 
22. $this->linkid = @pg_connect("host=$this->host port=$this->port dbname=$this->db 
23. user=$this->user password=$this->passwd"); 
24. if (! $this->linkid) 
25. throw new Exception("Could not connect to PostgreSQL server."); 
26. } 
27. catch (Exception $e) { 
28. die($e->getMessage()); 
29. } 
30. } 
31. /* 执行数据库查询。 */ 
32. function query($query){ 
33. try{ 
34. $this->result = @pg_query($this->linkid,$query); 
35. if(! $this->result) 
36. throw new Exception("The database query failed."); 
37. } 
38. catch (Exception $e){ 
39. echo $e->getMessage(); 
40. } 
41. $this->querycount++; 
42. return $this->result; 
43. } 
44. /* 确定受查询所影响的行的总计。 */ 
45. function affectedRows(){ 
46. $count = @pg_affected_rows($this->linkid); 
47. return $count; 
48. } 
49. /* 确定查询返回的行的总计。 */ 
50. function numRows(){ 
51. $count = @pg_num_rows($this->result); 
52. return $count; 
53. } 
54. /* 将查询的结果行作为一个对象返回。 */ 
55. function fetchObject(){ 
56. $row = @pg_fetch_object($this->result); 
57. return $row; 
58. } 
59. /* 将查询的结果行作为一个索引数组返回。 */ 
60. function fetchRow(){ 
61. $row = @pg_fetch_row($this->result); 
62. return $row; 
63. } 
64. /* 将查询的结果行作为一个关联数组返回。 */ 
65. function fetchArray(){ 
66. $row = @pg_fetch_array($this->result); 
67. return $row; 
68. } 
69. /* 返回在这个对象的生存期内执行的查询总数。这不是必须的，但是您也许会感兴趣。 */ 
70. function numQueries(){ 
71. return $this->querycount; 
72. } 
73. } 
74. ?> 

测试的php一并放出，另外测试了下局域网内的另一台postgresql服务器，感觉查询速度还是很快的，查询postgregis数据也是杠杠滴。

1. <?php 
2.   include 'PGDB.php'; 
3.   $PG = new pgsql("192.168.1.167", "5432", "postgis", "postgres", "post"); 
4.   $PG->connect(); 
5.   if(!$PG) 
6.   { 
7.     $db_error = "无法连接到PostGreSQL数据库！"; 
8.     echo $db_error; 
9.   } 
10.   else 
11.   { 
12.     echo "成功连接！"; 
13.     $query = "select name from ex where gid = 2"; 
14.     $result = $PG->query($query); 
15.     $row = $PG->fetchRow(); 
16.     echo $row[0]; 
17.   } 
18. ?> 

出处：http://www.phpfensi.com/php/20210912/18010.html