5、PHP程序开发

5.1、连接数据库

  1. <?php     
  2. $host="172.16.0.29";
  3. $port="15432";
  4. $dbname="postgres";
  5. $user="tbase" ;
  6. $password="";  
  8. //连接数据库
  9. $conn=@pg_connect("host=$host port=$port dbname=$dbname user=$user password=$password");      
  10. if (!$conn){
  11.     $error_msg=@pg_errormessage($conn); 
  12.     echo "连接数据库出错，详情：".$error_msg."\n<BR>"; ;
  13.     exit;
  14. }else{
  15.     echo "连接数据库成功"."\n<BR>";      
  16. } 
  17. //关闭连接
  18. pg_close($conn);
  19. ?>

执行

  1. [root@VM_0_47_centos test]# curl http://127.0.0.1:8080/dbsta/test/conn.php
  2. 连接数据库成功

5.2、创建数据表

  1. <?php     
  2. $host="172.16.0.29";
  3. $port="15432";
  4. $dbname="postgres";
  5. $user="tbase" ;
  6. $password="";  
  8. //连接数据库
  9. $conn=@pg_connect("host=$host port=$port dbname=$dbname user=$user password=$password");      
  10. if (!$conn){
  11.     $error_msg=@pg_errormessage($conn); 
  12.     echo "连接数据库出错，详情：".$error_msg."\n"; ;
  13.     exit;
  14. }else{
  15.     echo "连接数据库成功"."\n";      
  16. } 
  18. //建立数据表
  19. $sql="create table public.tbase(id integer,nickname varchar(100)) distribute by shard(id) to group default_group;";
  20. $result = @pg_exec($conn,$sql) ;
  21. if (!$result){
  22.     $error_msg=@pg_errormessage($conn); 
  23.     echo "创建数据表出错，详情：".$error_msg."\n"; ;
  24.     exit;
  25. }else{
  26.     echo "创建数据表成功"."\n";       
  27. }
  28. //关闭连接
  29. pg_close($conn);
  30. ?>

执行

  1. [root@VM_0_47_centos test]# curl http://127.0.0.1:8080/dbsta/test/createtable.php
  2. 连接数据库成功
  3. 创建数据表成功

5.3、插入数据

  1. <?php     
  2. $host="172.16.0.29";
  3. $port="15432";
  4. $dbname="postgres";
  5. $user="tbase" ;
  6. $password="";  
  8. //连接数据库
  9. $conn=@pg_connect("host=$host port=$port dbname=$dbname user=$user password=$password");      
  10. if (!$conn){
  11.     $error_msg=@pg_errormessage($conn); 
  12.     echo "连接数据库出错，详情：".$error_msg."\n"; ;
  13.     exit;
  14. }else{
  15.     echo "连接数据库成功"."\n";      
  16. } 
  18. //插入数据
  19. $sql="insert into public.tbase values(1,'tbase'),(2,'pgxz');";    
  20. $result = @pg_exec($conn,$sql) ;
  21. if (!$result){
  22.     $error_msg=@pg_errormessage($conn); 
  23.     echo "插入数据出错，详情：".$error_msg."\n";
  24.     exit;
  25. }else{
  26.     echo "插入数据成功"."\n";       
  27. }
  29. //关闭连接
  30. pg_close($conn);
  32. ?>

执行

  1. [tbase@VM_0_47_centos test]$ curl http://127.0.0.1:8080/dbsta/test/insert.php
  2. 连接数据库成功
  3. 插入数据成功

5.4、查询数据

  1. <?php     
  2. $host="172.16.0.29";
  3. $port="15432";
  4. $dbname="postgres";
  5. $user="tbase" ;
  6. $password="";  
  8. //连接数据库
  9. $conn=@pg_connect("host=$host port=$port dbname=$dbname user=$user password=$password");      
  10. if (!$conn){
  11.     $error_msg=@pg_errormessage($conn); 
  12.     echo "连接数据库出错，详情：".$error_msg."\n"; ;
  13.     exit;
  14. }else{
  15.     echo "连接数据库成功"."\n";      
  16. } 
  18. //查询数据 
  19. $sql="select id,nickname from public.tbase";    
  20. $result = @pg_exec($conn,$sql) ;
  21. if (!$result){
  22.     $error_msg=@pg_errormessage($conn); 
  23.     echo "查询数据出错，详情：".$error_msg."\n";
  24.     exit;
  25. }else{
  26.     echo "插入数据成功"."\n";      
  27. }
  28. $record_num = pg_numrows($result);  
  29. echo "返回记录数".$record_num."\n"; 
  30. $rec=pg_fetch_all($result); 
  31. for($i=0;$i<$record_num;$i++){
  32.     echo "记录数#".strval($i+1)."\n";
  33.     echo "id：".$rec[$i]["id"]."\n";
  34.     echo "nickname：".$rec[$i]["nickname"]."\n\n";
  35. }
  36. //关闭连接
  37. pg_close($conn);
  38. ?>

调用方法

  1. [root@VM_0_47_centos ~]# curl http://127.0.0.1:8080/dbsta/test/select.php
  2. 连接数据库成功
  3. 插入数据成功
  4. 返回记录数2
  5. 记录数#1
  6. id：1
  7. nickname：tbase
  9. 记录数#2
  10. id：2
  11. nickname：pgxz

5.5、流数据copy 入表

  1. <?php 
  3. $host="172.16.0.29";
  4. $port="15432";
  5. $dbname="postgres";
  6. $user="tbase" ;
  7. $password="";  
  9. //连接数据库
  10. $conn=@pg_connect("host=$host port=$port dbname=$dbname user=$user password=$password");      
  11. if (!$conn){
  12.     $error_msg=@pg_errormessage($conn); 
  13.     echo "连接数据库出错，详情：".$error_msg."\n"; ;
  14.     exit;
  15. }else{
  16.     echo "连接数据库成功"."\n";      
  17. }                                     
  18. $row=ARRAY("1,TBase","2,pgxz");   
  19. $flag=pg_copy_from($conn,"public.tbase",$row,",");
  21. if (!$flag){
  22.     $error_msg=@pg_errormessage($conn); 
  23.     echo "copy出错，详情：".$error_msg."\n";
  24. }else{
  25.     echo "copy成功"."\n";          
  26. }
  28. //关闭连接
  29. pg_close($conn);
  31. ?>

调用方法

  1. curl http://127.0.0.1/dbsta/cron/php_copy_from.php
  2. 连接数据库成功
  3. copy成功

5.6、copy to导出数据到一个数组中

  1. <?php 
  3. $host="172.16.0.29";
  4. $port="15432";
  5. $dbname="postgres";
  6. $user="tbase" ;
  7. $password="";  
  9. //连接数据库
  10. $conn=@pg_connect("host=$host port=$port dbname=$dbname user=$user password=$password");      
  11. if (!$conn){
  12.     $error_msg=@pg_errormessage($conn); 
  13.     echo "连接数据库出错，详情：".$error_msg."\n"; ;
  14.     exit;
  15. }else{
  16.     echo "连接数据库成功"."\n";      
  17. }                                     
  19. $row=pg_copy_to($conn,"public.tbase",",");  
  20. if (!$row){
  21.     $error_msg=@pg_errormessage($conn); 
  22.     echo "copy出错，详情：".$error_msg."\n";
  23. }else{
  24.     print_r($row);
  25. }  
  26. //关闭连接 
  27. pg_close($conn);              
  28. ?>

调用方法

  1. curl http://127.0.0.1/dbsta/cron/php_copy_to.php  
  2. 连接数据库成功
  3. Array
  4. (
  5.     [0] => 1,TBase
  7.     [1] => 2,pgxz
  9. )