home *** CD-ROM | disk | FTP | other *** search
/ H4CK3R 4 / hacker04 / 04_HACK04.ISO / src / PHP / diow.php3.txt < prev    next >
Encoding:
Text File  |  2002-05-06  |  7.5 KB  |  287 lines
  1. database independence object wrapper 
  2.  
  3. This is a database abstraction layer, so that code can be written to run with any database. If you wish to switch database types, just change a parameter in the abstraction class ... not your entire code!! Currently supports mysql and postgres, I hope to add oracle and others. If you have any comments/suggestions, pls email me at manik@post1.com. 
  4.  
  5. <?php 
  6.  
  7. //------------------------------------------------------- 
  8. //     DATABASE.INDEPENDENCE.OBJECT.WRAPPER 
  9. //     VERSION 0.30 
  10. //     VERSION DATE: 15th July 1999 
  11. //------------------------------------------------------- 
  12. //     Author: Manik Surtani <manik@post1.com> 
  13. //------------------------------------------------------- 
  14.  
  15.  
  16.  
  17. //------------------------------------------------------- 
  18. // This version currently supports POSTGRESQL and MYSQL 
  19. // databases.  More support to be added sometime .... !! 
  20. //------------------------------------------------------- 
  21. // This wrapper provides 'physical' database connectivity 
  22. // and works as the link between the php3-based web site  
  23. // and the selected database.  
  24. //------------------------------------------------------- 
  25.  
  26.  
  27. // set the database TYPE.   
  28. //$database_type==1 --> POSTGRES 
  29. //$database_type==2 --> MYSQL 
  30.  
  31.  
  32. $database_type=2; 
  33.  
  34. /* 
  35.  
  36. --------------------------------------------------------- 
  37. "class resultSet" deals with a recordset produced by a 
  38. databse query. 
  39. --------------------------------------------------------- 
  40.  
  41. */ 
  42.  
  43.  
  44. class resultSet { 
  45.   var $element = array(); 
  46.   var $column_name = array(); 
  47.   var $numrows; 
  48.   var $numcols; 
  49.  
  50. function getColumn_by_name($rowNum,$colName) { 
  51.   $j=-1; 
  52.   for($i=0;$i<$this->numcols;$i++) 
  53.   { 
  54.    if ($this->column_name[$i]==$colName) { $j=$i; } 
  55.   } 
  56.   if ($j!=-1) { return $this->element[$rowNum][$j];} else { return  ""; } 
  57. } 
  58.  
  59. function getColumn_by_num($rowNum,$colNum) { 
  60.   return $this->element[$rowNum][$colNum]; 
  61. } 
  62.  
  63. function getColName($column) { 
  64.    return $this->column_name[$column]; 
  65. } 
  66.  
  67. function getNumRows()  { 
  68.    return $this->numrows; 
  69. } 
  70.  
  71. function getNumCols()  { 
  72.    return $this->numcols; 
  73. } 
  74.  
  75. } 
  76.  
  77.  
  78.  
  79. /* 
  80.  
  81. --------------------------------------------------------- 
  82. "class ConnInfo" provides a connection details object which returns information 
  83. given on a connection parameter to a database. 
  84. --------------------------------------------------------- 
  85.  
  86. */ 
  87.  
  88. class ConnectionInfo { 
  89.   var $cdbname; 
  90.   var $cusername; 
  91.   var $cpassword; 
  92.   var $chost; 
  93.   var $cport; 
  94.  
  95. function SplitThis($cparam) { 
  96.     $tok = strtok($cparam, " "); 
  97.     while($tok) { 
  98.         $pos=strpos($tok, "="); 
  99.         $type=substr($tok,0,$pos); 
  100.         switch ($type) { 
  101.            case  "dbname": 
  102.               $this->cdbname=substr($tok,$pos+1); 
  103.               break; 
  104.            case  "host": 
  105.               $this->chost=substr($tok,$pos+1); 
  106.               break; 
  107.            case  "port": 
  108.               $this->cport=substr($tok,$pos+1); 
  109.               break; 
  110.            case  "username": 
  111.               $this->cusername=substr($tok,$pos+1); 
  112.               break; 
  113.            case  "password": 
  114.               $this->cpassword=substr($tok,$pos+1); 
  115.               break; 
  116.         } 
  117.         $tok = strtok( " "); 
  118.     }   
  119. } 
  120.  
  121. function dbName() { return $this->cdbname; } 
  122. function Host() { return $this->chost; } 
  123. function Port() { return $this->cport; } 
  124. function UserName() { return $this->cusername; } 
  125. function Password() { return $this->cpassword; } 
  126.   
  127. } 
  128.  
  129. /* 
  130.  
  131. --------------------------------------------------------- 
  132. "class connection" provides functionality to deal with the 
  133. actual database. 
  134. --------------------------------------------------------- 
  135.  
  136. */ 
  137.  
  138.  
  139. class connection { 
  140.   var $my_connection; 
  141.   var $my_temp_resultID; 
  142.   var $my_temp_result_object = new resultSet; 
  143.  
  144.   function open($p1, $p2 =  "", $p3 =  "", $p4 =  "", $p5= "" )  { 
  145.   global $database_type; 
  146.   $ok = false; 
  147.  
  148.  
  149.   if (($p2 ==  "") && ($p3 ==  "") && ($p4 ==  "") && ($p5 ==  "") && ($database_type==1)) 
  150.   { 
  151.     $this->my_connection=pg_connect($p1); 
  152.     $ok = true; 
  153.   } 
  154.  
  155.   if (($p5 ==  "") && ($database_type==2)) 
  156.   { 
  157.      $connINF = new ConnectionInfo; 
  158.      $connINF->SplitThis($p1); 
  159.      $p1=$connINF->Host(); 
  160.      $p2=$connINF->UserName(); 
  161.      $p3=$connINF->Password(); 
  162.      $p4=$connINF->dbName(); 
  163.     $this->my_connection=mysql_connect($p1, $p2, $p3); 
  164.     mysql_select_db($p4,$this->my_connection); 
  165.     $ok = true; 
  166.   } 
  167.  
  168.   if (!($ok)) 
  169.   { 
  170.     print  "\n\nTHERE WAS AN ERROR CONNECTING.\n\n"; 
  171.   } 
  172.   }     
  173.  
  174. function close() { 
  175.   global $database_type; 
  176.  
  177. if ($database_type==1) 
  178.     { 
  179.     pg_close($this->my_connection); 
  180.     } 
  181.  
  182. if ($database_type==2) 
  183.     { 
  184.     mysql_close($this->my_connection); 
  185.     } 
  186. } 
  187.  
  188.  
  189.  
  190. function runActionQuery($someSQL) 
  191. { 
  192.  
  193. global $database_type; 
  194.  
  195.     // cleanup SQL for PHP versions! (sic) 
  196.    if (substr($someSQL,strlen($someSQL)-1,1)== ";") { 
  197.       $someSQL=substr($someSQL,0,strlen($someSQL)-1); 
  198.     } 
  199.  
  200.     if ($database_type==1) 
  201.     { 
  202.     pg_exec($this->my_connection, $someSQL); 
  203.     } 
  204.      
  205.     if ($database_type==2) 
  206.     { 
  207.     mysql_query($someSQL, $this->my_connection); 
  208.     } 
  209.  
  210. } 
  211.  
  212.  
  213.  
  214.  
  215.  
  216.  
  217. function runSQL($someSQL)     
  218. { 
  219.     global $database_type; 
  220.  
  221.     // cleanup SQL for PHP versions! (sic) 
  222.    if (substr($someSQL,strlen($someSQL)-1,1)== ";") { 
  223.       $someSQL=substr($someSQL,0,strlen($someSQL)-1); 
  224.     } 
  225.  
  226.     if ($database_type==1) 
  227.     { 
  228.      
  229.         $this->my_temp_resultID = pg_exec($this->my_connection, $someSQL); 
  230.         $this->my_temp_result_object->numrows = pg_numrows($this->my_temp_resultID); 
  231.         $this->my_temp_result_object->numcols = pg_numfields($this->my_temp_resultID); 
  232.  
  233.            // fill column_names from resultset 
  234.         for ($j=0; $j < $this->my_temp_result_object->numcols; $j++) 
  235.         { 
  236.             $this->my_temp_result_object->column_name[$j] = pg_fieldname($this->my_temp_resultID, $j); 
  237.         } 
  238.  
  239.            // fill data elements from resultset 
  240.         for ($i=0; $i < $this->my_temp_result_object->numrows; $i++) 
  241.         { 
  242.             for ($j=0; $j < $this->my_temp_result_object->numcols; $j++) 
  243.             { 
  244.                $this->my_temp_result_object->element[$i][$j] = pg_result($this->my_temp_resultID, $i, $j); 
  245.             } 
  246.         } 
  247.  
  248.         return $this->my_temp_result_object; 
  249.           pg_freeresult($this->my_temp_resultID); 
  250.     } 
  251.  
  252.  
  253. if ($database_type==2) 
  254.     { 
  255.     $this->my_temp_resultID = mysql_query($someSQL, $this->my_connection); 
  256.     $this->my_temp_result_object->numrows = mysql_num_rows($this->my_temp_resultID); 
  257.     $this->my_temp_result_object->numcols = mysql_num_fields($this->my_temp_resultID); 
  258.          
  259.        // fill column_names from resultset 
  260.     for ($j=0; $j < $this->my_temp_result_object->numcols; $j++) 
  261.     { 
  262.         $this->my_temp_result_object->column_name[$j] = mysql_fieldname($this->my_temp_resultID, $j); 
  263.     } 
  264.  
  265.        // fill data elements from resultset 
  266.     for ($i=0; $i < $this->my_temp_result_object->numrows; $i++) 
  267.         { 
  268.         $x = mysql_fetch_row($this->my_temp_resultID); 
  269.         for ($j=0; $j < $this->my_temp_result_object->numcols; $j++) 
  270.             { 
  271.             $this->my_temp_result_object->element[$i][$j] = $x[$j]; 
  272.             } 
  273.         } 
  274.  
  275.     return $this->my_temp_result_object; 
  276.     mysql_free_result($this->my_temp_resultID); 
  277.     } 
  278.  
  279.      
  280.     } 
  281.  
  282.  
  283. }  
  284.  
  285.  
  286. ?> 
  287.