开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
mysql.lib.php
资源名称：dbfconverter.tar.gz　[点击查看]
上传用户：jiangbw
上传日期：2022-03-16
资源大小：49k
文件大小：38k
源码类别：

MySQL数据库

开发平台：

Unix_Linux

mysql.lib.php：源码内容
  1. <?
  2. /*======================================================================*
  3. || #################################################################### ||
  4. || # BUILD UNDER PHP SCRIPTNET 3.2.1 FRAMEWORK ||
  5. || # ---------------------------------------------------------------- # ||
  6. || # Code2Art Open Source Software. All Rights Reserved.  ||
  7. || # This file should be redistributed in whole or significant part.  # ||
  8. || # ------------------ SCRIPTNET IS FREE SOFTWARE ------------------ # ||
  9. || # http://www.code2art.com | http://www.code2art.com/scriptnet      # ||
  10. || # Copyleft by Benediktus Ardian Hersanto, SE       # ||
  11. || # Sorry if this framework is still unavailable for public       # ||
  12. || # because I still searching on my own head.       # ||
  13. || #################################################################### ||
  14. *======================================================================*/
  15. /*======================================================================*
  16. || #################################################################### ||
  17. || DBF to MySQL Bulk Converter 2.0 ||
  18. ||______________________________________________________________________||
  19. || This utility was developed on 2006, since this were used to be on    ||
  20. || my own library. But I think I should share it to you, because I      ||
  21. || need to save my work on Internet (I don't believe on my own HD drive)||
  22. || it always crash and had a terrible bad sectors.  ||
  23. || Thanks to all person who download this utility, I hope you enjoy it. ||
  24. || ||
  25. || Regards, ||
  26. || Benediktus Ardian Hersanto,SE (ardie_b@yahoo.com) ||
  27. /*======================================================================*/
  28. // ---------------------------------------------------------------------//
  29. // Free to use for everyone who understand PHP
  30. // ---------------------------------------------------------------------//
  31. // Last Update : 27.03.2007
  32. // CHANGES :
  33. // MySQL Exception Handler :
  34. //  Added : Assert command on handling error of mysql execution
  35. // --------------------------------------------------------------------------------
  36. // Free to use to everyone who understand PHP
  37. // --------------------------------------------------------------------------------
  38. /*
  39. *@author B. Ardian Hersanto
  40. *
  41. *@copyright GNU as long as you're friends of mine, just kidding
  42. *@package DBComponents
  43. */
  45. $basename = explode('.',basename(__FILE__));
  46. $file_ext = array_pop($basename);
  47. $lib_dir = str_replace('\','/',dirname(__FILE__));
  48. $filename = $lib_dir.'/rdbms.cls.' . FILE_EXT;
  49. define('DB_ROOT_CLASS',$filename);
  50. if(file_exists(DB_ROOT_CLASS)) include(DB_ROOT_CLASS);
  52. if(!isset($_LIBRARY[basename(__FILE__)])) 
  53. $_LIBRARY[basename(__FILE__)] = "mysql";
  55. // This MySQLException are trapping incorrect SQL syntax, the main core error are handled by debugger.lib.php
  56. function MySQLException($file, $line, $code) 
  57. {
  58. global $_ERROR;
  59. $_ERROR = new stdclass;
  60. $_ERROR->file = $file;
  61. $_ERROR->line = $line;
  62. $_ERROR->code = $code;
  63. if(ini_get('display_errors')==1) die('<b>MySQL Syntax ERROR :</b> '.mysql_error());
  64. trigger_error(mysql_error(),E_USER_ERROR);
  65. error_log("[".date("d-m-Y")." ".date("H:i:s")."] [client ".$_SERVER['REMOTE_ADDR']."] [FILE:".$file.", LINE:".$line."] [".mysql_error()."]rn", 3, ROOT_DIR.DB_ERROR_LOG);
  66. }
  68. class MySQL extends RDBMS {
  70. // These variables are used in START TRANSACTION MODE
  71. // NOTES : THE CHANGES TO TABLE IS AFFECTED ONLY TO InnoDB Type Table
  72. // THESE FLAG WILL IGNORED IF YOUR TABLE TYPE IS MyISAM TABLE
  73. var $safeMode = true;
  74. var $COMMIT_CHANGES = false;
  75. var $unbuffered = false;
  77. //These variables will evaluate itself on each query event
  78. var $onUpdate, $onBrowse, $onClose, $onDelete, $onInsert, $onQueryStart;
  80. //Library Properties
  81. var $about = "GNU PHP - MySQL Component for PHP 4";
  82. //var $error_log = true;
  83. //var $log_file = "AppError.txt"; //Already defined on RDBMS Class
  84. var $version = "4.2.06-dev.27.01";
  86. function MySQL()
  87. {
  88. if(!function_exists('mysql_connect')) 
  89. trigger_error('<p/><b/><font color="#FF0000" face="Verdana" size="2" onmouseover=""/>MySQL DB Component dependency problem<table border="0" width="29%" cellspacing="1" style="border:1px solid #000080;background-color:#D5E6DC"/><tr/><td/><font face="Verdana" size="2" color="#FF0000"/>php_mysql.dll is needed to run this component or your current PHP version is no longer support the original mysql function from PHP 4', E_ERROR);
  91. // Inherit create from base component RDBMS
  92. parent::_create();
  94. // Error Handler
  95. assert_options(ASSERT_ACTIVE, 1);
  96. assert_options(ASSERT_WARNING, 0);
  97. assert_options(ASSERT_QUIET_EVAL, 1);
  98. assert_options(ASSERT_CALLBACK, 'MySQLException');
  100. // Initial Connection
  101. if($this->Connect()) {
  102. if(!defined("__MYSQL")) define('__MYSQL',1);
  103. } else {
  104. trigger_error($this->TrackError(), $this->error_priority[0]);
  105. }
  106. $this->mysql_version = $this->GetServerVersion();
  107. }
  109. function _create() { parent::_create(); }
  111. function _destroy() { parent::_destroy(); }
  113. function TrackError()
  114. {
  115. $this->error_msg = mysql_error();
  116. $this->inherited(__FUNCTION__);
  117. }
  119. function TestConnection($dbname,$dbhost,$dbport,$dbuser,$dbpassword)
  120. {
  121. $cid = @mysql_connect($dbhost.":".$dbport,$dbuser,$dbpassword);
  122. if ($cid) {
  123. if(@mysql_select_db ($dbname,$cid)) {
  124. @mysql_close($cid);
  125. return true;
  126. } else { 
  127. @mysql_close($cid);
  128. return false;
  129. }
  130. } else {
  131. @mysql_close($cid);
  132. return false;
  133. }
  134. }
  136. function Connect()
  137. {
  138. if($this->port!='3306') $this->hostname .= ':'.$this->port;
  139. $this->db = @mysql_connect($this->hostname,$this->username,$this->password);
  140. if($this->db) {
  141. if(@mysql_select_db($this->database)) {
  142. /* Too much consume memory if there is more than 10000 tables
  143. if(is_array($this->Tables)) $this->Tables = array();
  144. $this->Tables = array_merge($this->Tables,$this->ListTables());*/
  145. $this->connected = true;
  146. return true;
  147. } else return false;
  148. } else {
  149. //trigger_error($this->TrackError(), E_USER_ERROR); // UnComment this line if you need to connect manually without using default constructor connection
  150. return false;
  151. }
  152. }
  154. function Reconnect($dbname,$hostname='',$username='',$password='')
  155. {
  156. if(!empty($hostname)) $this->hostname=$hostname;
  157. if(!empty($username)) $this->username=$username;
  158. if(!empty($password)) $this->password=$password;
  159. $this->db = @mysql_connect($this->hostname,$this->username,$this->password);
  160. if($this->db) {
  161. if(@mysql_select_db($dbname)) {
  162. $this->connected = true;
  163. $this->database = $dbname;
  164. /*if(is_array($this->Tables)) {
  165. $this->Tables = array();
  166. $this->Tables = array_merge($this->Tables,$this->ListTables());
  167. }*/
  168. return true;
  169. } else return false;
  170. } else {
  171. //trigger_error($this->TrackError(), E_USER_ERROR); // UnComment this line if you need to connect manually without using default constructor connection
  172. return false;
  173. }
  174. }
  176. function Browse($fields,$table,$exp='',$page='',$limit='',$urlquery='',$encode_method="base64_encode",$func_type="php") 
  177. {
  178. return $this->Select($fields,$table,$exp,$page,$limit,$urlquery,$encode_method,$func_type);
  179. }
  181. function Select($fields,$table,$exp='',$page='',$limit='',$urlquery='',$encode_method="",$func_type="php") 
  182. {
  183. if(strlen(trim($page))>0) if(!settype($page,"integer")) return;
  184. if(strlen(trim($limit))>0) if(!settype($limit,"integer")) return;
  185. if((is_int($page))&&(is_int($limit))) {
  186. parent::createNavigator($table,$exp,$page,$limit,$urlquery,$encode_method,$func_type);
  187. $paging = $this->SQL_LIMIT;
  188. } else $paging = '';
  189. if (empty($exp)) $this->command = "select {$fields} from {$table}".$paging;
  190. else $this->command = "select {$fields} from {$table} where {$exp}".$paging;
  191. if($this->unbuffered) $status = assert('$this->pid = @mysql_unbuffered_query($this->command)');
  192. else $status = assert('$this->pid = @mysql_query($this->command)');
  193. $results = array();
  194. if($status) {
  195. $this->active_table = $table;
  196. if ($this->pid) {
  197. if ($this->debug) echo "<hr><br><font face="Verdana" size="1">Executing SELECT STATEMENT on file : <b><font color=#FF0000>".basename($this->FILE)."</font></b> line <b><font color=#0000FF>".$this->LINE."</font></b><br>with SQL COMMAND : <font color=#FF0000>"<i>".$this->command."</i>"</font></font><br><hr>";
  198. if(!$this->unbuffered) {
  199. $this->RecordCount = @mysql_num_rows($this->pid);
  200. if ($this->RecordCount>0) {
  201. if($this->return_as_array) {
  202. while ($data=@mysql_fetch_array($this->pid)) $results[] = $data;
  203. mysql_free_result($this->pid);
  204. if(!empty($this->onBrowse)) $this->onBrowse();
  205. return $results;
  206. } else {
  207. while ($data=@mysql_fetch_object($this->pid)) $results[] = $data;
  208. mysql_free_result($this->pid);
  209. if(!empty($this->onBrowse)) $this->onBrowse();
  210. return $results;
  211. }
  212. } else return NULL;
  213. } else {
  214. while ($data=@mysql_fetch_array($this->pid)) {
  215. $results[] = $data;
  216. if(count($results)>5000) die('Data is too large to read please provide paging parameter');
  217. }
  218. mysql_free_result($this->pid);
  219. return $results;
  220. }
  221. } else {
  222. if ($this->debug) echo "<hr><br><font face="Verdana" size="1" color="#ff0000">Executing SELECT STATEMENT on file : <b><font color=#FF0000>".basename($this->FILE)."</font></b> line <b><font color=#0000FF>".$this->LINE."</font></b><br>with SQL COMMAND : <font color=#FF0000>"<i>".$this->command."</i>"</font></font><br><hr>";
  223. $this->TrackError();
  224. return false;
  225. }
  226. }
  227. }
  229. function GetServerVersion() 
  230. {
  231. $data = @mysql_query('select version()');
  232. $data = mysql_fetch_array($data);
  233. return $data[0];
  234. }
  236.     function Update($table,$value,$exp='') 
  237.     {
  238.      if($this->safeMode) {
  239.      if(preg_match("/^4.*/i",$this->mysql_version)) {
  240.      $uid = mysql_query('SET AUTOCOMMIT=0');
  241.      $uid = mysql_query('START TRANSACTION');
  242.      } else if (preg_match("/^3.*/i",$this->mysql_version)) {
  243.      $uid = mysql_query('SET AUTOCOMMIT=0');
  244.      $uid = mysql_query('BEGIN WORK');
  245.      }
  246.      } else {
  247.      $uid = mysql_query('SET AUTOCOMMIT=1');
  248.      }
  249.         if (empty($exp)) $this->command = "update {$table} set {$value}";
  250.         else $this->command = "update {$table} set {$value} where {$exp}";
  251. if(assert('$this->uid = mysql_query($this->command)')) {
  252. if ($this->uid) {
  253. if ($this->debug) echo "<hr><br><font face="Verdana" size="1" color="#ff0000">Executing UPDATE STATEMENT on file : <b><font color=#FF0000>".basename($this->FILE)."</font></b> line <b><font color=#0000FF>".$this->LINE."</font></b><br>with SQL COMMAND : <font color=#FF0000>"<i>".$this->command."</i>"</font></font><br><hr>";
  254. $this->AffectedRows = mysql_affected_rows();
  255. if(!empty($this->onUpdate)) $this->onUpdate();
  256. if($this->safeMode) {
  257. if($this->COMMIT_CHANGES) {
  258. $uid = mysql_query('COMMIT'); 
  259. } else {
  260. $uid = mysql_query('ROLLBACK');
  261. }
  262. }
  263. return true;
  264. } else {
  265. if ($this->debug) echo "<hr><br><font face="Verdana" size="1" color="#ff0000">Executing UPDATE STATEMENT on file : <b><font color=#FF0000>",basename($this->FILE),"</font></b> line <b><font color=#0000FF>",$this->LINE,"</font></b><br>with SQL COMMAND : <font color=#FF0000>"<i>",$this->command,"</i>"</font></font><br><hr>";
  266. $this->TrackError();
  267. return false;
  268.  }
  269. }
  270.     }
  272.     function Delete($table,$exp='') 
  273.     {
  274.      if($this->safeMode) {
  275.      if(preg_match("/^4.*/i",$this->mysql_version)) {
  276.      $uid = mysql_query('SET AUTOCOMMIT=0');
  277.      $uid = mysql_query('START TRANSACTION');
  278.      } else if (preg_match("/^3.*/i",$this->mysql_version)) {
  279.      $uid = mysql_query('SET AUTOCOMMIT=0');
  280.      $uid = mysql_query('BEGIN WORK');
  281.      }
  282.      } else {
  283.      $uid = mysql_query('SET AUTOCOMMIT=1');
  284.      }
  285. if($this->simulate) { $this->debug=true; $tmp = $this->Browse("*",$table,$exp); }
  286.         if (empty($exp)) $this->command = "delete from {$table}";
  287.         else $this->command = "delete from {$table} where {$exp}";
  288. if(assert('$this->eid = mysql_query($this->command)')) {
  289. if ($this->eid) {
  290. if ($this->debug) echo "<hr><br><font face="Verdana" size="1" color="#ff0000">Executing DELETE STATEMENT on file : <b><font color=#FF0000>".basename($this->FILE)."</font></b> line <b><font color=#0000FF>".$this->LINE."</font></b><br>with SQL COMMAND : <font color=#FF0000>"<i>".$this->command."</i>"</font></font><br><hr>";
  291. $this->AffectedRows = mysql_affected_rows();
  292. if(!empty($this->onDelete)) $this->onDelete();
  293. if($this->safeMode) {
  294. if($this->COMMIT_CHANGES) {
  295. $uid = mysql_query('COMMIT'); 
  296. } else {
  297. $uid = mysql_query('ROLLBACK');
  298. }
  299. }
  300. if($this->simulate) { 
  301. for($i=0;$i<count($tmp);$i++) {
  302. $this->Insert($table,implode(",",$this->getFieldsFromObject($tmp)),implode(",",$this->getDataFromObject($tmp,"'")));
  303. }
  304. $this->debug = false;
  305. }
  306. return true;
  307. } else {
  308. if ($this->debug) echo "<hr><br><font face="Verdana" size="1" color="#ff0000">Executing DELETE STATEMENT on file : <b><font color=#FF0000>".basename($this->FILE)."</font></b> line <b><font color=#0000FF>".$this->LINE."</font></b><br>with SQL COMMAND : <font color=#FF0000>"<i>".$this->command."</i>"</font></font><br><hr>";
  309. $this->TrackError();
  310. return false;
  311. }
  312. }
  313.     }
  314.     
  315.     //function Replace($table,$values
  317. function InsertSelect($dest_fields,$dest_table,$src_fields,$src_table,$exp='',$ignore=true) {
  318.      if($this->safeMode) {
  319.      if(preg_match("/^4.*/i",$this->mysql_version)) {
  320.      $uid = mysql_query('SET AUTOCOMMIT=0');
  321.      $uid = mysql_query('START TRANSACTION');
  322.      } else if (preg_match("/^3.*/i",$this->mysql_version)) {
  323.      $uid = mysql_query('SET AUTOCOMMIT=0');
  324.      $uid = mysql_query('BEGIN WORK');
  325.      }
  326.      } else {
  327.      $uid = mysql_query('SET AUTOCOMMIT=1');
  328.      }
  329. if (empty($exp))
  330.         $this->command = "Insert ".(($ignore)?"IGNORE":"")." into {$dest_table}({$dest_fields}) SELECT {$src_fields} FROM {$src_table}";
  331. else 
  332. $this->command = "Insert ".(($ignore)?"IGNORE":"")." into {$dest_table}({$dest_fields}) SELECT {$src_fields} FROM {$src_table} WHERE {$exp}";
  333.         $this->pid = @mysql_query($this->command);
  334.         if ($this->pid) {
  335.          if ($this->debug) echo "<hr><br><font face="Verdana" size="1" color="#ff0000">Executing INSERT STATEMENT on file : <b><font color=#FF0000>".basename($this->FILE)."</font></b> line <b><font color=#0000FF>".$this->LINE."</font></b><br>with SQL COMMAND : <font color=#FF0000>"<i>".$this->command."</i>"</font></font><br><hr>";
  336.             if($this->safeMode) {
  337.              if($this->COMMIT_CHANGES) {
  338.              $uid = mysql_query('COMMIT'); 
  339.              } else {
  340.              $uid = mysql_query('ROLLBACK');
  341.              }
  342.             }
  343.             return true;
  344.         } else {
  345. if ($this->debug) echo "<hr><br><font face="Verdana" size="1" color="#ff0000">Executing INSERT STATEMENT on file : <b><font color=#FF0000>".basename($this->FILE)."</font></b> line <b><font color=#0000FF>".$this->LINE."</font></b><br>with SQL COMMAND : <font color=#FF0000>"<i>".$this->command."</i>"</font></font><br><hr>";
  346.          $this->TrackError();
  347. return false;
  348.         }
  350. }
  352.     function Insert($table,$fields,$values,$ignore=false) 
  353.     {
  354.      if($this->safeMode) {
  355.      if(preg_match("/^4.*/i",$this->mysql_version)) {
  356.      $uid = mysql_query('SET AUTOCOMMIT=0');
  357.      $uid = mysql_query('START TRANSACTION');
  358.      } else if (preg_match("/^3.*/i",$this->mysql_version)) {
  359.      $uid = mysql_query('SET AUTOCOMMIT=0');
  360.      $uid = mysql_query('BEGIN WORK');
  361.      }
  362.      } else {
  363.      $uid = mysql_query('SET AUTOCOMMIT=1');
  364.      }
  365.         $this->command = "Insert ".(($ignore)?"Ignore":"")." into {$table}({$fields}) values ({$values})";
  366. if(assert('$this->pid = mysql_query($this->command)')) {
  367. $this->last_record_id = mysql_insert_id($this->db);
  368. if ($this->pid) {
  369. if ($this->debug) echo "<hr><br><font face="Verdana" size="1" color="#ff0000">Executing INSERT STATEMENT on file : <b><font color=#FF0000>".basename($this->FILE)."</font></b> line <b><font color=#0000FF>".$this->LINE."</font></b><br>with SQL COMMAND : <font color=#FF0000>"<i>".$this->command."</i>"</font></font><br><hr>";
  370. if(!empty($this->onInsert)) $this->onInsert();
  371. if($this->safeMode) {
  372. if($this->COMMIT_CHANGES) {
  373. $uid = mysql_query('COMMIT'); 
  374. } else {
  375. $uid = mysql_query('ROLLBACK');
  376. }
  377. }
  378. return true;
  379. } else {
  380. if ($this->debug) echo "<hr><br><font face="Verdana" size="1" color="#ff0000">Executing INSERT STATEMENT on file : <b><font color=#FF0000>".basename($this->FILE)."</font></b> line <b><font color=#0000FF>".$this->LINE."</font></b><br>with SQL COMMAND : <font color=#FF0000>"<i>".$this->command."</i>"</font></font><br><hr>";
  381. $this->TrackError();
  382. return false;
  383. }
  384. } else {
  385. if ($this->debug) echo "<hr><br><font face="Verdana" size="1" color="#ff0000">Executing INSERT STATEMENT on file : <b><font color=#FF0000>".basename($this->FILE)."</font></b> line <b><font color=#0000FF>".$this->LINE."</font></b><br>with SQL COMMAND : <font color=#FF0000>"<i>".$this->command."</i>"</font></font><br><hr>";
  386. $this->TrackError();
  387. return false;
  388. }
  389.     }
  391.     function Replace($table,$fields,$values) 
  392.     {
  393.      if($this->safeMode) {
  394.      if(preg_match("/^4.*/i",$this->mysql_version)) {
  395.      $uid = mysql_query('SET AUTOCOMMIT=0');
  396.      $uid = mysql_query('START TRANSACTION');
  397.      } else if (preg_match("/^3.*/i",$this->mysql_version)) {
  398.      $uid = mysql_query('SET AUTOCOMMIT=0');
  399.      $uid = mysql_query('BEGIN WORK');
  400.      }
  401.      } else {
  402.      $uid = mysql_query('SET AUTOCOMMIT=1');
  403.      }
  404.         $this->command = "Replace into {$table}({$fields}) values ({$values})";
  405. if(assert('$this->pid = mysql_query($this->command)')) {
  406. if ($this->pid) {
  407. if ($this->debug) echo "<hr><br><font face="Verdana" size="1" color="#ff0000">Executing REPLACE STATEMENT on file : <b><font color=#FF0000>".basename($this->FILE)."</font></b> line <b><font color=#0000FF>".$this->LINE."</font></b><br>with SQL COMMAND : <font color=#FF0000>"<i>".$this->command."</i>"</font></font><br><hr>";
  408. if(!empty($this->onInsert)) $this->onInsert();
  409. if($this->safeMode) {
  410. if($this->COMMIT_CHANGES) {
  411. $uid = mysql_query('COMMIT'); 
  412. } else {
  413. $uid = mysql_query('ROLLBACK');
  414. }
  415. }
  416. return true;
  417. } else {
  418. if ($this->debug) echo "<hr><br><font face="Verdana" size="1" color="#ff0000">Executing REPLACE STATEMENT on file : <b><font color=#FF0000>".basename($this->FILE)."</font></b> line <b><font color=#0000FF>".$this->LINE."</font></b><br>with SQL COMMAND : <font color=#FF0000>"<i>".$this->command."</i>"</font></font><br><hr>";
  419. $this->TrackError();
  420. return false;
  421. }
  422. }
  423.     }
  425.     function Query($command,$return_result=0) 
  426.     {
  427. settype($command,"string");
  428.         $this->command = (string)str_replace("rn","",stripslashes($command));
  429. if(assert('$this->pid = mysql_query($this->command,$this->db)')) {
  430. if ($this->pid) {
  431. if ($this->debug) echo "<hr><br><font face="Verdana" size="1">Executing QUERY STATEMENT on file : <b><font color=#FF0000>".basename($this->FILE)."</font></b> line <b><font color=#0000FF>".$this->LINE."</font></b><br>with SQL COMMAND : <font color=#FF0000>"<i>".$this->command."</i>"</font></font><br><hr>";
  432. if(!empty($this->onQueryStart)) $this->onQueryStart();
  433. if($return_result) {
  434. $this->AffectedRows = @mysql_affected_rows();
  435. $this->RecordCount = @mysql_num_rows($this->pid);
  436. if($this->return_as_array) {
  437. $time0     = time();
  438. while ($data=@mysql_fetch_array($this->pid)) {
  439. $results[] = $data;
  440. $time1     = time();
  441. if ($time1 >= $time0 + 30) {
  442. $time0 = $time1;
  443. header('X-pmaPing: Pong');
  444. }
  445. }
  446. mysql_free_result($this->pid);
  447. } else {
  448. $time0     = time();
  449. while ($data=@mysql_fetch_object($this->pid)) {
  450. $results[] = $data;
  451. $time1     = time();
  452. if ($time1 >= $time0 + 30) {
  453. $time0 = $time1;
  454. header('X-pmaPing: Pong');
  455. }
  456. }
  457. mysql_free_result($this->pid);
  458. }
  459. if(isset($results)) return $results; else return NULL;
  460. } else 
  461.    return $this->pid;
  462.  } else {
  463. if ($this->debug) echo "<hr><br><font face="Verdana" size="1" color="#ff0000">Executing QUERY STATEMENT on file : <b><font color=#FF0000>".basename($this->FILE)."</font></b> line <b><font color=#0000FF>".$this->LINE."</font></b><br>with SQL COMMAND : <font color=#FF0000>"<i>".$this->command."</i>"</font></font><br><hr>";
  464. $this->TrackError();
  465. return false;
  466.  }
  467. }
  468.     }
  470. function getRecordData($table,$expression='',$buffer_name='') 
  471. {
  472. $rec = $this->Browse("*",$table,$expression);
  473. if(count($rec)>0) {
  474. if(!empty($buffer_name)) {
  475. global $$buffer_name;
  476. $$buffer_name = $rec[0];
  477. } else {
  478. global $RECORD;
  479. $RECORD = $rec[0];
  480. }
  481. }
  482. }
  484. function getFieldDataType($database,$table,$fieldname) {
  485. $result = mysql_query("SHOW COLUMNS FROM `{$database}`.`{$table}`");
  486. if (!$result) {
  487. echo 'Could not run query: ' . mysql_error();
  488. exit;
  489. }
  490. if (mysql_num_rows($result) > 0) {
  491. while ($row = mysql_fetch_assoc($result)) {
  492. if($row['Field']==$fieldname) {
  493. return $row['Type'];
  494. break;
  495. }
  496. }
  497. }
  498. }
  500. function getCustomRecordData($fields,$table,$expression='',$buffer_name='')
  501. {
  502. $rec = $this->Browse($fields,$table,$expression);
  503. if(count($rec)>0) {
  504. if(!empty($buffer_name)) {
  505. global $$buffer_name;
  506. $$buffer_name = $rec[0];
  507. } else {
  508. global $RECORD;
  509. $RECORD = $rec[0];
  510. }
  511. }
  512. }
  514. function getFieldData($field_name,$fields,$table,$exp='') 
  515. {
  516. $this->return_as_array = true;
  517. $rec = $this->Select($fields,$table,$exp);
  518. $this->return_as_array = false;
  519. if(count($rec)>0) {
  520. return $rec[0][$field_name];
  521. } else return;
  522. }
  524.     function Count($items,$table,$exp='') 
  525.     {
  526.      if (empty($exp)) $this->command = "select count({$items}) from {$table}";
  527.         else $this->command = "select count($items) from {$table} where {$exp}";
  528.         if ($this->debug) echo "<hr><br><font face="Verdana" size="1">Executing COUNT STATEMENT on file : <b><font color=#FF0000>".basename($this->FILE)."</font></b> line <b><font color=#0000FF>".$this->LINE."</font></b><br>with SQL COMMAND : <font color=#FF0000>"<i>".$this->command."</i>"</font></font><br><hr>";
  529.         $this->pid = @mysql_query($this->command);
  530. if($this->pid) {
  531. if(mysql_num_rows($this->pid)>1) return mysql_num_rows($this->pid); else {
  532. $total = @mysql_fetch_array($this->pid);
  533.      return $total[0];
  534. }
  535. } else {
  536. $this->TrackError();
  537. }
  538.     }
  540.     function Sum($field,$table,$exp='') 
  541.     {
  542.             if (empty($exp)) $this->command = "select sum({$field}) from {$table}";
  543.             else $this->command = "select sum({$field}) from {$table} where {$exp}";
  544.             if ($this->debug) echo "<hr><br><font face="Verdana" size="1">Executing SUM STATEMENT on file : <b><font color=#FF0000>".basename($this->FILE)."</font></b> line <b><font color=#0000FF>".$this->LINE."</font></b><br>with SQL COMMAND : <font color=#FF0000>"<i>".$this->command."</i>"</font></font><br><hr>";
  545.             $this->pid = @mysql_query($this->command);
  546. if($this->pid) {
  547. $total = @mysql_fetch_array($this->pid);
  548.             return (empty($total[0]))?0:$total[0];
  549. } else {
  550. $this->TrackError();
  551. }
  552.     }
  554.     function Max($field,$table,$exp='') 
  555.     {
  556.             if (empty($exp)) $this->command = "select max({$field}) from {$table}";
  557.             else $this->command = "select max({$field}) from {$table} where {$exp}";
  558.             if ($this->debug) echo "<hr><br><font face="Verdana" size="1">Executing MAX STATEMENT on file : <b><font color=#FF0000>".basename($this->FILE)."</font></b> line <b><font color=#0000FF>".$this->LINE."</font></b><br>with SQL COMMAND : <font color=#FF0000>"<i>".$this->command."</i>"</font></font><br><hr>";
  559.             $this->pid = @mysql_query($this->command);
  560. if($this->pid) {
  561. $total = @mysql_fetch_array($this->pid);
  562.             return (empty($total[0]))?0:$total[0];
  563. } else {
  564. $this->TrackError();
  565. }
  566.     }
  568.     function Min($field,$table,$exp='') 
  569.     {
  570.             if (empty($exp)) $this->command = "select min({$field}) from {$table}";
  571.             else $this->command = "select min({$field}) from {$table} where {$exp}";
  572.             if ($this->debug) echo "<hr><br><font face="Verdana" size="1">Executing MIN STATEMENT on file : <b><font color=#FF0000>".basename($this->FILE)."</font></b> line <b><font color=#0000FF>".$this->LINE."</font></b><br>with SQL COMMAND : <font color=#FF0000>"<i>".$this->command."</i>"</font></font><br><hr>";
  573.             $this->pid = @mysql_query($this->command);
  574. if($this->pid) {
  575. $total = @mysql_fetch_array($this->pid);
  576.             return (empty($total[0]))?0:$total[0];
  577. } else {
  578. $this->TrackError();
  579. }
  580.     }
  582. function getRecordLen($table) {
  583. return $this->Count("*",$table);
  584. }
  586. function TruncateTable($table) {
  587. $pid = mysql_query("TRUNCATE TABLE ".$table);
  588. if($pid) return true; else die(mysql_error());
  589. }
  591. function DumpTableToTemp($data,$file,$separator) 
  592. {
  593. $fp = fopen($file,'w');
  594. if($fp) {
  595. fwrite($fp,ereg_replace(",",$separator,$this->GetFieldNames($data,$this->active_table))."rn");
  596. for($i=0;$i<count($data);$i++) {
  597. $fields = get_object_vars($data[$i]);
  598. fwrite($fp,implode($separator,array_values($fields))."rn");
  599. }
  600. }
  601. fclose($fp);
  602. }
  604. function DumpTableToExcel($tablename) 
  605. {
  606. header("Content-type: application/vnd.excel");
  607. $fields  = @mysql_list_fields($this->dbname, $tablename, $this->db);
  608. $columns = @mysql_num_fields($fields);
  609. for ($i = 0; $i < $columns; $i++) {
  610. echo mysql_field_name($fields, $i)."t";
  611. }
  612. echo  "rn";
  613. $records = $this->Query("select * from {$tablename}");
  614. while ($records = @mysql_fetch_array($this->pid)) {
  615. for($n=0;$n<$columns;$n++) echo $records[$n]."t";
  616. echo "rn";
  617. }
  618. header("Content-Disposition: attachment; filename={$tablename}.xls");
  619. }
  621. function getFieldsFromObject($obj) 
  622. {
  623. if(is_array($obj)) {
  624. if(count($obj)>0) {
  625. return array_keys(get_object_vars($obj[0]));
  626. }
  627. } else if(is_object($obj)) {
  628. return array_keys(get_object_vars($obj));
  629. }
  630. }
  632. function getFieldsFromAssoc($obj,$type='integer') 
  633. {
  634. if(is_array($obj)) {
  635. if(count($obj)>0) {
  636. if(is_array($obj[0]))
  637. $fields = array_keys($obj[0]); else
  638. $fields = array_keys($obj);
  639. for($n=0;$n<count($fields);$n++) {
  640. if($type=='integer') {
  641. if(is_int($fields[$n])) $field[] = $fields[$n];
  642. } else if($type=='string') {
  643. if(is_string($fields[$n])) $field[] = $fields[$n];
  644. }
  645. }
  646. return $field;
  647. }
  648. } else if(is_object($obj)) {
  649. return array();
  650. }
  651. }
  653. function getDataFromObject($obj,$quote='') 
  654. {
  655. if(is_array($obj)) {
  656. if(count($obj)>0) {
  657. if(empty($quote)) {
  658. return array_values(get_object_vars($obj[0]));
  659. } else {
  660. $dat = array_values(get_object_vars($obj[0]));
  661. for($i=0;$i<count($dat);$i++) $dat[$i] = $quote.$dat[$i].$quote;
  662. return $dat;
  663. }
  664. }
  665. } else if(is_object($obj)) {
  666. if(empty($quote)) {
  667. return array_values(get_object_vars($obj));
  668. } else {
  669. $dat = array_values(get_object_vars($obj));
  670. for($i=0;$i<count($dat);$i++) $dat[$i] = $quote.$dat[$i].$quote;
  671. return $dat;
  672. }
  673. }
  674. }
  676. function ListDatabases() 
  677. {
  678. $db_list = @mysql_list_dbs($this->db);
  679. while ($row = @mysql_fetch_array($db_list)) {
  680.     $dbs[] = $row[0];
  681. }
  682. if(isset($dbs)) return $dbs; else return NULL;
  683. }
  685. function CreateDatabase($dbname,$auth_user,$auth_password) 
  686. {
  687. $this->Close(); $current_user = $this->username; $this->username = $this->admin;
  688. $current_password = $this->password; $this->password = $this->dba_password; $current_database = $this->database; $this->database = "mysql";
  689. if ($this->Connect()) {
  690. $this->Query("Create database {$dbname}");
  691. $this->Query("grant all privileges on {$dbname}.* to {$auth_user}@{$this->hostname} identified by '{$auth_password}'");
  692. $this->Close();
  693. $this->username = $current_user;
  694. $this->password = $current_password;
  695. $this->database = $current_database;
  696. $this->Connect();
  697. return true;
  698. } else {
  699. $this->TrackError();
  700. return false;
  701. }
  702. }
  704. function getFieldName($sql,$fieldname) {
  705. $this->return_as_array=1;
  706. $res = $this->Query($sql);
  707. if($res) {
  708. $data = mysql_fetch_array($res);
  709. $this->return_as_array=0;
  710. return $data[$fieldname];
  711. } else {
  712. $this->TrackError();
  713. return false;
  714. }
  715. }
  717. function GetFieldNames($data,$table='') 
  718. {
  719. if(is_array($data)&&(count($data)>0)) {
  720. if(isset($data[0])) {
  721. if(is_object($data[0])) {
  722. $fields = get_object_vars($data[0]);
  723. return implode(",",array_keys($fields));
  724. } else if(is_array($data[0])) {
  725. return implode(",",array_keys($data[0]));
  726. }
  727. }
  728. } else {
  729. $fields = @mysql_list_fields($this->database, $table, $this->db); 
  730. $columns = @mysql_num_fields($fields); 
  731. for($i=0;$i<$columns;$i++) $data[] = @mysql_field_name($fields, $i);
  732. return implode(",",$data);
  733. }
  734. }
  736. function TimeStampExtract($date,$words,$as_array=true) 
  737. {
  738. if(!$as_array) $date = new stdclass;
  739. if ($words) {
  740. if(!$as_array) $date->year = substr($date,0,4); else $year = substr($date,0,4);
  741. if (substr($date,4,2)=="01") {if(!$as_array) $date->month="January"; else $month = "January"; }
  742. if (substr($date,4,2)=="02") {if(!$as_array) $date->month="February"; else $month = "February";}
  743. if (substr($date,4,2)=="03") {if(!$as_array) $date->month="March"; else $month = "March";}
  744. if (substr($date,4,2)=="04") {if(!$as_array) $date->month="April"; else $month = "April";}
  745. if (substr($date,4,2)=="05") {if(!$as_array) $date->month="May"; else $month = "May";}
  746. if (substr($date,4,2)=="06") {if(!$as_array) $date->month="June"; else $month = "June";}
  747. if (substr($date,4,2)=="07") {if(!$as_array) $date->month="July"; else $month = "July";}
  748. if (substr($date,4,2)=="08") {if(!$as_array) $date->month="August"; else $month = "August";}
  749. if (substr($date,4,2)=="09") {if(!$as_array) $date->month="September"; else $month = "September";}
  750. if (substr($date,4,2)=="10") {if(!$as_array) $date->month="October"; else $month = "October";}
  751. if (substr($date,4,2)=="11") {if(!$as_array) $date->month="November"; else $month = "November";}
  752. if (substr($date,4,2)=="12") {if(!$as_array) $date->month="December"; else $month = "December";}
  753. if(!$as_array) $date->day = substr($date,6,2); else $day = substr($date,6,2);
  754. if(!$as_array) $date->hour = substr($date,8,2); else $hour = substr($date,8,2);
  755. if(!$as_array) $date->minutes = substr($date,10,2); else $minutes = substr($date,10,2);
  756. if(!$as_array) $date->second = substr($date,12,2); else $second = substr($date,12,2);
  757. if($as_array) {
  758. return array("year"=>$year,"month"=>$month,"day"=>$day,"hour"=>$hour,"minutes"=>$minutes,"second"=>$second);
  759. } else {
  760. return $date;
  761. }
  762. } else {
  763. if(!$as_array) $date->year = substr($date,0,4); else $year = substr($date,0,4);
  764. if(!$as_array) $date->month = substr($date,4,2); else $month = substr($date,4,2);
  765. if(!$as_array) $date->day = substr($date,6,2); else $day = substr($date,6,2);
  766. if(!$as_array) $date->hour = substr($date,8,2); else $hour = substr($date,8,2);
  767. if(!$as_array) $date->minutes = substr($date,10,2); else $minutes = substr($date,10,2);
  768. if(!$as_array) $date->second = substr($date,12,2); else $second = substr($date,12,2);
  769. if($as_array) {
  770. return array("year"=>$year,"month"=>$month,"day"=>$day,"hour"=>$hour,"minutes"=>$minutes,"second"=>$second);
  771. } else {
  772. return $date;
  773. }
  774. }
  775. }
  776. // Uncomplete Function
  777. function ReadTableStruct($table_name) 
  778. {
  779. $result = @mysql_query("SELECT * FROM {$table_name}");
  780. $fields = @mysql_num_fields($result);
  781. $table = @mysql_field_table($result, 0);
  782. for ($i=0; $i < $fields; $i++) {
  783.      $type  = mysql_field_type($result, $i);
  784.      $name  = mysql_field_name($result, $i);
  785.      $len   = mysql_field_len($result, $i);
  786.      $flags = mysql_field_flags($result, $i);
  787.      echo $name . " " .$type." ". $len . " " . $flags . "<br>";
  788. }
  789. mysql_free_result($result);
  790. }
  792. function ListTables($pattern='') 
  793. {
  794. if($pattern=='') {
  795. $result = @mysql_list_tables($this->database);
  796. if (!$result) {
  797. echo "DB Error, could not list tablesn";
  798. echo 'MySQL Error: ' . mysql_error();
  799. exit;
  800. }
  801. while ($row = @mysql_fetch_row($result)) {
  802. $tables[] = $row[0];
  803. }
  804. @mysql_free_result($result);
  805. if(isset($tables)) return $tables; else return NULL;
  806. } else {
  807. $ret = $this->Query("SHOW TABLES LIKE '{$pattern}'",1);
  808. if(is_array($ret)&&count($ret)>0) {
  809. for($i=0;$i<count($ret);$i++) {
  810. list($k,$name)=each($ret[$i]);
  811. $tables[] = $name;
  812. }
  813. return $tables;
  814. } else return NULL;
  815. }
  816. }
  818. function TableExists($tableName) {
  819. $this->command = "Select * From {$tableName}";
  820. if($this->debug) echo "<hr><br><font face="Verdana" size="1">Executing QUERY STATEMENT on file : <b><font color=#FF0000>".basename($this->FILE)."</font></b> line <b><font color=#0000FF>".$this->LINE."</font></b><br>with SQL COMMAND : <font color=#FF0000>"<i>".$this->command."</i>"</font></font><br><hr>";
  821. if(@mysql_query($this->command))
  822. return true;
  823. else return false;
  824. }
  826. function ListFields($table_name) 
  827. {
  828. $fields = mysql_list_fields($this->database, $table_name, $this->db);
  829. $columns = mysql_num_fields($fields);
  831. for ($i = 0; $i < $columns; $i++) {
  832.     $field[] = mysql_field_name($fields, $i);
  833. }
  834. if(isset($field)) return $field; else return NULL;
  835. }
  837. function ListFieldNames($tablename,$style='ucfirst') {
  838. $result = mysql_query("SHOW COLUMNS FROM ".$tablename);
  839. if (!$result) {
  840. echo 'Could not run query: ' . mysql_error();
  841. exit;
  842. }
  843. if (mysql_num_rows($result) > 0) {
  844. while ($row = mysql_fetch_assoc($result)) {
  845. $fields[] = $style(strtolower($row['Field']));
  846. }
  847. }
  848. if(isset($fields)) return $fields; else return NULL;
  849. }
  851. function Close() {
  852. @mysql_close($this->db);
  853. if(!empty($this->onClose)) eval($this->onClose);
  854. $this->connected = false;
  855. }
  857. /*function getFieldName($sql,$fName)
  858. {
  859. $rec = @mysql_query($sql);
  860. $ret=mysql_fetch_array($rec);
  861. mysql_free_result($rec);
  862. return $ret[$fName];
  863. }*/
  865. function ExportTable($table_name,$fileoutput,$savefile=false,$compress=false) {
  866. if(isset($this->db)) {
  867. if($table_name=="*") {
  868. $tables = $this->ListTables();
  869. set_time_limit(0);
  870. for($i=0;$i<count($tables);$i++) {
  871. $pid = mysql_query("SHOW CREATE TABLE ".$tables[$i]);
  872. if($pid) {
  873. $struct = mysql_fetch_array($pid);
  874. $this->results = "DROP TABLE IF EXISTS ".$tables[$i].";rnrn";
  875. $this->results .= $struct[1];
  876. $contents = mysql_query("SELECT * FROM ".$tables[$i]);
  877. if($contents) {
  878. while($data = mysql_fetch_array($contents)) {
  879. $this->results .= "rnrnINSERT INTO ".$tables[$i]." VALUES (";
  880. if(isset($datas)) unset($datas);
  881. while(list($k,$v)=each($data)) {
  882. if(is_string($k))
  883. $datas[] = "'".$data[$k]."'";
  884. }
  885. if(isset($datas)&&is_array($datas)) 
  886. $this->results .= implode(",",$datas);
  887. $this->results .= ");";
  888. }
  889. if(function_exists('gzcompress')) {
  890. $compressed_data[] = gzcompress($this->results,9);
  891. }
  892. } else {
  893. trigger_error('Error while dumping table data due the following error : '.mysql_error(),E_USER_ERROR);
  894. }
  895. unset($this->results);
  896. } else {
  897. trigger_error('Cannot Execute SHOW CREATE TABLE due the following error : '.mysql_error(),E_USER_ERROR);
  898. }
  899. }
  900. $this->results = gzcompress(implode("(:EOF:)",$compressed_data));
  901. if($savefile) {
  902. header('Cache-Control: must-revalidate, post-check=0, pre-check=0');
  903. header('Pragma: public');
  904. //header('Transfer-Encoding: chunked');
  905. header('Content-Type: application/octet-stream');
  906. header('Content-Length: '.strlen($this->results));
  907. header('Content-Disposition: attachment; filename="'.$fileoutput.'"');
  908. echo $this->results;
  909. }
  910. return TRUE;
  911. } else {
  912. $pid = mysql_query("SHOW CREATE TABLE ".$table_name);
  913. if($pid) {
  914. $struct = mysql_fetch_array($pid);
  915. $this->results = "DROP TABLE IF EXISTS ".$table_name.";rnrn";
  916. $this->results .= $struct[1];
  917. $contents = mysql_query("SELECT * FROM ".$table_name);
  918. if($contents) {
  919. while($data = mysql_fetch_array($contents)) {
  920. $this->results .= "rnrnINSERT INTO ".$table_name." VALUES (";
  921. if(isset($datas)) unset($datas);
  922. while(list($k,$v)=each($data)) {
  923. if(is_string($k))
  924. $datas[] = "'".$data[$k]."'";
  925. }
  926. if(isset($datas)&&is_array($datas)) 
  927. $this->results .= implode(",",$datas);
  928. $this->results .= ");";
  929. }
  930. header('Cache-Control: must-revalidate, post-check=0, pre-check=0');
  931. header('Pragma: public');
  932. //header('Transfer-Encoding: chunked');
  933. header('Content-Type: application/octet-stream');
  934. header('Content-Length: '.strlen($this->results));
  935. header('Content-Disposition: attachment; filename="'.$table_name.'.sql"');
  936. echo $this->results;
  937. } else {
  938. trigger_error('Error while dumping table data due the following error : '.mysql_error(),E_USER_ERROR);
  939. }
  940. } else {
  941. trigger_error('Cannot Execute SHOW CREATE TABLE due the following error : '.mysql_error(),E_USER_ERROR);
  942. }
  943. }
  944. }
  945. }
  947. }
  949. ?>