home *** CD-ROM | disk | FTP | other *** search
/ PC World 2005 April / PCWorld_2005-04_cd.bin / akce / web / phpnuke / PHP-Nuke-7.5.exe / html / db / postgres7.php < prev   
PHP Script  |  2004-01-29  |  8KB  |  397 lines
  1. <?php
  2.   /***************************************************************************
  3.    *                               postgres7.php
  4.    *                            -------------------
  5.    *   begin                : Saturday, Feb 13, 2001
  6.    *   copyright            : (C) 2001 The phpBB Group
  7.    *   email                : supportphpbb.com
  8.    *
  9.    *   $Id: postgres7.php,v 1.19 2002/03/05 02:19:38 psotfx Exp $
  10.    *
  11.    ***************************************************************************/
  12.  
  13. /***************************************************************************
  14.  *
  15.  *   This program is free software; you can redistribute it and/or modify
  16.  *   it under the terms of the GNU General Public License as published by
  17.  *   the Free Software Foundation; either version 2 of the License, or
  18.  *   (at your option) any later version.
  19.  *
  20.  ***************************************************************************/
  21.  
  22. if(!defined("SQL_LAYER"))
  23. {
  24.  
  25. define("SQL_LAYER","postgresql");
  26.  
  27. class sql_db
  28. {
  29.  
  30.     var $db_connect_id;
  31.     var $query_result;
  32.     var $in_transaction = 0;
  33.     var $row = array();
  34.     var $rowset = array();
  35.     var $rownum = array();
  36.     var $num_queries = 0;
  37.  
  38.     //
  39.     // Constructor
  40.     //
  41.     function sql_db($sqlserver, $sqluser, $sqlpassword, $database, $persistency = true)
  42.     {
  43.         $this->connect_string = "";
  44.  
  45.         if( $sqluser )
  46.         {
  47.             $this->connect_string .= "user=$sqluser ";
  48.         }
  49.  
  50.         if( $sqlpassword )
  51.         {
  52.             $this->connect_string .= "password=$sqlpassword ";
  53.         }
  54.  
  55.         if( $sqlserver )
  56.         {
  57.             if( ereg(":", $sqlserver) )
  58.             {
  59.                 list($sqlserver, $sqlport) = split(":", $sqlserver);
  60.                 $this->connect_string .= "host=$sqlserver port=$sqlport ";
  61.             }
  62.             else
  63.             {
  64.                 if( $sqlserver != "localhost" )
  65.                 {
  66.                     $this->connect_string .= "host=$sqlserver ";
  67.                 }
  68.             }
  69.         }
  70.  
  71.         if( $database )
  72.         {
  73.             $this->dbname = $database;
  74.             $this->connect_string .= "dbname=$database";
  75.         }
  76.  
  77.         $this->persistency = $persistency;
  78.  
  79.         $this->db_connect_id = ( $this->persistency ) ? pg_pconnect($this->connect_string) : pg_connect($this->connect_string);
  80.  
  81.         return ( $this->db_connect_id ) ? $this->db_connect_id : false;
  82.     }
  83.  
  84.     //
  85.     // Other base methods
  86.     //
  87.     function sql_close()
  88.     {
  89.         if( $this->db_connect_id )
  90.         {
  91.             //
  92.             // Commit any remaining transactions
  93.             //
  94.             if( $this->in_transaction )
  95.             {
  96.                 @pg_exec($this->db_connect_id, "COMMIT");
  97.             }
  98.  
  99.             if( $this->query_result )
  100.             {
  101.                 @pg_freeresult($this->query_result);
  102.             }
  103.  
  104.             return @pg_close($this->db_connect_id);
  105.         }
  106.         else
  107.         {
  108.             return false;
  109.         }
  110.     }
  111.  
  112.     //
  113.     // Query method
  114.     //
  115.     function sql_query($query = "", $transaction = false)
  116.     {
  117.         //
  118.         // Remove any pre-existing queries
  119.         //
  120.         unset($this->query_result);
  121.         if( $query != "" )
  122.         {
  123.             $this->num_queries++;
  124.  
  125.             $query = preg_replace("/LIMIT ([0-9]+),([ 0-9]+)/", "LIMIT \\2 OFFSET \\1", $query);
  126.  
  127.             if( $transaction == BEGIN_TRANSACTION && !$this->in_transaction )
  128.             {
  129.                 $this->in_transaction = TRUE;
  130.  
  131.                 if( !@pg_exec($this->db_connect_id, "BEGIN") )
  132.                 {
  133.                     return false;
  134.                 }
  135.             }
  136.  
  137.             $this->query_result = @pg_exec($this->db_connect_id, $query);
  138.             if( $this->query_result )
  139.             {
  140.                 if( $transaction == END_TRANSACTION )
  141.                 {
  142.                     $this->in_transaction = FALSE;
  143.  
  144.                     if( !@pg_exec($this->db_connect_id, "COMMIT") )
  145.                     {
  146.                         @pg_exec($this->db_connect_id, "ROLLBACK");
  147.                         return false;
  148.                     }
  149.                 }
  150.  
  151.                 $this->last_query_text[$this->query_result] = $query;
  152.                 $this->rownum[$this->query_result] = 0;
  153.  
  154.                 unset($this->row[$this->query_result]);
  155.                 unset($this->rowset[$this->query_result]);
  156.  
  157.                 return $this->query_result;
  158.             }
  159.             else
  160.             {
  161.                 if( $this->in_transaction )
  162.                 {
  163.                     @pg_exec($this->db_connect_id, "ROLLBACK");
  164.                 }
  165.                 $this->in_transaction = FALSE;
  166.  
  167.                 return false;
  168.             }
  169.         }
  170.         else
  171.         {
  172.             if( $transaction == END_TRANSACTION && $this->in_transaction )
  173.             {
  174.                 $this->in_transaction = FALSE;
  175.  
  176.                 if( !@pg_exec($this->db_connect_id, "COMMIT") )
  177.                 {
  178.                     @pg_exec($this->db_connect_id, "ROLLBACK");
  179.                     return false;
  180.                 }
  181.             }
  182.  
  183.             return true;
  184.         }
  185.     }
  186.  
  187.     //
  188.     // Other query methods
  189.     //
  190.     function sql_numrows($query_id = 0)
  191.     {
  192.         if( !$query_id )
  193.         {
  194.             $query_id = $this->query_result;
  195.         }
  196.  
  197.         return ( $query_id ) ? @pg_numrows($query_id) : false;
  198.     }
  199.  
  200.     function sql_numfields($query_id = 0)
  201.     {
  202.         if( !$query_id )
  203.         {
  204.             $query_id = $this->query_result;
  205.         }
  206.  
  207.         return ( $query_id ) ? @pg_numfields($query_id) : false;
  208.     }
  209.  
  210.     function sql_fieldname($offset, $query_id = 0)
  211.     {
  212.         if( !$query_id )
  213.         {
  214.             $query_id = $this->query_result;
  215.         }
  216.  
  217.         return ( $query_id ) ? @pg_fieldname($query_id, $offset) : false;
  218.     }
  219.  
  220.     function sql_fieldtype($offset, $query_id = 0)
  221.     {
  222.         if( !$query_id )
  223.         {
  224.             $query_id = $this->query_result;
  225.         }
  226.  
  227.         return ( $query_id ) ? @pg_fieldtype($query_id, $offset) : false;
  228.     }
  229.  
  230.     function sql_fetchrow($query_id = 0)
  231.     {
  232.         if( !$query_id )
  233.         {
  234.             $query_id = $this->query_result;
  235.         }
  236.  
  237.         if($query_id)
  238.         {
  239.             $this->row = @pg_fetch_array($query_id, $this->rownum[$query_id]);
  240.  
  241.             if( $this->row )
  242.             {
  243.                 $this->rownum[$query_id]++;
  244.                 return $this->row;
  245.             }
  246.         }
  247.  
  248.         return false;
  249.     }
  250.  
  251.     function sql_fetchrowset($query_id = 0)
  252.     {
  253.         if( !$query_id )
  254.         {
  255.             $query_id = $this->query_result;
  256.         }
  257.  
  258.         if( $query_id )
  259.         {
  260.             unset($this->rowset[$query_id]);
  261.             unset($this->row[$query_id]);
  262.             $this->rownum[$query_id] = 0;
  263.  
  264.             while( $this->rowset = @pg_fetch_array($query_id, $this->rownum[$query_id], PGSQL_ASSOC) )
  265.             {
  266.                 $result[] = $this->rowset;
  267.                 $this->rownum[$query_id]++;
  268.             }
  269.  
  270.             return $result;
  271.         }
  272.  
  273.         return false;
  274.     }
  275.  
  276.     function sql_fetchfield($field, $row_offset=-1, $query_id = 0)
  277.     {
  278.         if( !$query_id )
  279.         {
  280.             $query_id = $this->query_result;
  281.         }
  282.  
  283.         if( $query_id )
  284.         {
  285.             if( $row_offset != -1 )
  286.             {
  287.                 $this->row = @pg_fetch_array($query_id, $row_offset, PGSQL_ASSOC);
  288.             }
  289.             else
  290.             {
  291.                 if( $this->rownum[$query_id] )
  292.                 {
  293.                     $this->row = @pg_fetch_array($query_id, $this->rownum[$query_id]-1, PGSQL_ASSOC);
  294.                 }
  295.                 else
  296.                 {
  297.                     $this->row = @pg_fetch_array($query_id, $this->rownum[$query_id], PGSQL_ASSOC);
  298.  
  299.                     if( $this->row )
  300.                     {
  301.                         $this->rownum[$query_id]++;
  302.                     }
  303.                 }
  304.             }
  305.  
  306.             return $this->row[$field];
  307.         }
  308.  
  309.         return false;
  310.     }
  311.  
  312.     function sql_rowseek($offset, $query_id = 0)
  313.     {
  314.  
  315.         if(!$query_id)
  316.         {
  317.             $query_id = $this->query_result;
  318.         }
  319.  
  320.         if( $query_id )
  321.         {
  322.             if( $offset > -1 )
  323.             {
  324.                 $this->rownum[$query_id] = $offset;
  325.                 return true;
  326.             }
  327.             else
  328.             {
  329.                 return false;
  330.             }
  331.         }
  332.  
  333.         return false;
  334.     }
  335.  
  336.     function sql_nextid()
  337.     {
  338.         $query_id = $this->query_result;
  339.  
  340.         if($query_id && $this->last_query_text[$query_id] != "")
  341.         {
  342.             if( preg_match("/^INSERT[\t\n ]+INTO[\t\n ]+([a-z0-9\_\-]+)/is", $this->last_query_text[$query_id], $tablename) )
  343.             {
  344.                 $query = "SELECT currval('" . $tablename[1] . "_id_seq') AS last_value";
  345.                 $temp_q_id =  @pg_exec($this->db_connect_id, $query);
  346.                 if( !$temp_q_id )
  347.                 {
  348.                     return false;
  349.                 }
  350.  
  351.                 $temp_result = @pg_fetch_array($temp_q_id, 0, PGSQL_ASSOC);
  352.  
  353.                 return ( $temp_result ) ? $temp_result['last_value'] : false;
  354.             }
  355.         }
  356.  
  357.         return false;
  358.     }
  359.  
  360.     function sql_affectedrows($query_id = 0)
  361.     {
  362.         if( !$query_id )
  363.         {
  364.             $query_id = $this->query_result;
  365.         }
  366.  
  367.         return ( $query_id ) ? @pg_cmdtuples($query_id) : false;
  368.     }
  369.  
  370.     function sql_freeresult($query_id = 0)
  371.     {
  372.         if( !$query_id )
  373.         {
  374.             $query_id = $this->query_result;
  375.         }
  376.  
  377.         return ( $query_id ) ? @pg_freeresult($query_id) : false;
  378.     }
  379.  
  380.     function sql_error($query_id = 0)
  381.     {
  382.         if( !$query_id )
  383.         {
  384.             $query_id = $this->query_result;
  385.         }
  386.  
  387.         $result['message'] = @pg_errormessage($this->db_connect_id);
  388.         $result['code'] = -1;
  389.  
  390.         return $result;
  391.     }
  392.  
  393. } // class ... db_sql
  394.  
  395. } // if ... defined
  396.  
  397. ?>