搜尋

首頁  >  文章  >  後端開發  >  mysql操作類,v0.2,增加應對大數據量的一些解決方案

mysql操作類,v0.2,增加應對大數據量的一些解決方案

WBOY
WBOY原創
2016-07-25 09:06:191016瀏覽
複製代碼
/*mysql 簡單類 by joffe q89949401 圍脖@狂code詩人; 本類別全靜態 使用的時候直接include後 用mysql::方法()名即可 由於類別在php5裡面全域可視,所以不必擔心變數範圍的問題.如果有什麼意見 請圍脖私訊||qq郵件; 目前沒有與預存程序有關的方法,當然預存程序一般是創建資料庫的時候做的. config檔需要設定以下常數資訊: LIB:類存放位置 DEBUG:是否開啟debug(如果開啟會輸出錯誤訊息追蹤) TB_EX:資料庫表前綴;

增加了select del update insert big_select big_del函數

*/
  1. /*mysql 簡單類別by joffe q89949401 圍脖>/*mysql 簡單類別by joffe q89949401 圍脖@狂code詩人;
  2. 本類全靜態使用的時候直接include後用mysql::@狂code詩人;
  3. 本類全靜態使用的時候直接用mysql::@方法狂code方法()名即可由於類別在php5裡面全局可視,所以不必擔心變數範圍的問題.如果有什麼意見請圍脖私訊||qq郵件;
  4. 目前沒有與預存程序有關的方法,當然預存程序一般是建立資料庫的時候做的.
  5. config檔需要設定以下常數資訊:
  6. LIB:類別存放位置
  7. DEBUG:是否開啟debug(如果開啟會輸出錯誤訊息追蹤)
  8. TB_EX:資料庫錶字首;
  9. */
  10. defined('LIB') 或 die('Missing config!!');
  11. final class mysql {
  12. /**
  13. * 查詢總數
  14. *
  15. * @var int
  16. */
  17. publicsql {
  18. /**
  19. * 連接句柄
  20. *
  21. * @var object
  22. */
  23. public static $querynum = 0;
  24. /**
  25. * 建構子
  26. *
  27. * @param string $dbhost 主機名稱
  28. * @param string $dbuser 使用者
  29. * @param string $dbpw 密碼
  30. @param string $資料庫名稱
  31. * @param int $pconnect 是否持續連線
  32. */
  33. public static $link;
  34. /*
  35. 表前綴
  36. @var string 下列方法需要在設定檔中設定TB_EX作為表的前綴
  37. */
  39. static function add_ex($tb){
  40. return TB_EX.$tb_ex.$tb;
  41. }
  42. /*mysql資料庫是否使用嚴格的類型(mysql類型沒開啟自動轉換)預設為false,表示mysql有開啟類型轉換,這個變數目前只要是用於insert函數的單引號在沒有自動轉換的mysql裡面的問題,可能將來會增加相關函數
  44. */
  45. public static $is_type_tight=false;
  47. /**
  48. * 選擇資料庫
  49. *
  50. * @param string $dbname
  51. * @return
  52. */
  53. static function connent($dbhost, $dbuser, $dbpw, $dbname = " ",$dbcharset, $pconnect = 0) {
  54. if($pconnect) {
  55. if(!self::$link = @mysql_pconnect($dbhost, $dbuser, $dbpw)) {
  56. self ::halt("Can not connect to MySQL server");
  57. }
  58. } else {
  59. if(!self::$link = @mysql_connect($dbhost, $dbuser, $dbpw)) {
  60. self::halt("Can not connect to MySQL server");
  61. }
  62. }
  63. if(self::version() > "4.1") {
  64. if($dbcharset ) {
  65. mysql_query("SET character_set_connection={$dbcharset}, character_set_results=$dbcharset, character_set_client=binary", self::$link);
  66. } 5.0.1") {
  67. mysql_query("SET sql_mode=''", self::$link);
  68. }
  69. }
  70. if($dbname) {
  71. mysql_select_db($dbname , self::$link);
  72. }
  73. }
  74. /**
  75. * 取出結果集中一筆記錄
  76. *
  77. * @param object $query
  78. * @param int $result_type
  79. * @return array
  80. */
  81. static function select_db($dbname) {
  82. ::return mysql_select_db($dbname, self $link);
  83. }
  84. /**
  85. * QuerySQL
  86. *
  87. * @param string $sql
  88. * @param string $type
  89. * @return object
  90. */
  91. static function fetch_array($query, $result_type = MYSQL_ASSOC) { //預設只取關聯數組不取數字數組.
  92. return mysql_fetch_array($query, $result_type);
  93. }
  95. /**
  96. * 取影響條數
  97. *
  98. * @return int
  99. */
  100. static function query($sql, $type = "") {
  101. $func = $type == "UNBUFFERED" && @function_exists("mysql_unbuffered_query") ?
  102. "mysql_unbuffered_query" : "mysql_query";
  103. if(!($query = $func($link($link)($link) ) && $type != "SILENT") {
  104. self::halt("MySQL Query Error", $sql);
  105. }
  106. self::$querynum++;
  107. return $query;
  108. }
  109. /**
  110. * 回傳錯誤訊息
  111. *
  112. * @return array
  113. */
  114. static function affected_rows() {
  115. return mysql_affected_rows(self::$link);
  116. }
  117. ** /
  118. static function error() {
  119. return ((self::$link) ? mysql_error(self::$link) : mysql_error());
  120. }
  121. /**
  122. * 回傳錯誤碼
  123. *
  124. * @return int
  125. */
  126. static function errno() {
  127. return intval((self::$link) ? mysql_errno(self::$link) : mysql_errno());
  128. }
  129. /**
  130. * 回傳查詢結果
  131. *
  132. * @param object $query
  133. * @param string $row
  134. * @return mixed
  135. */
  136. static function result($query, $row,$flname=0) {
  137. $query = @mysql_result($query, $row,$flname);
  138. return $query;
  139. }
  140. /**
  141. * 結果條數
  142. *
  143. * @param object $query
  144. * @return int
  145. */
  146. static function num_rows($query) {
  147. $query = mysql_num_rows($query);
  148. return $query;
  149. }
  150. /**
  151. * 取總欄位
  152. *
  153. * @param object $query
  154. * @return int
  155. */
  156. static function num_fields($query) {
  157. return mysql_num_fields($query);
  158. }
  159. /**
  160. * 釋放結果集
  161. *
  162. * @param object $query
  163. * @return bool
  164. */ staticunction free_result($query) { return @mysql_free_result($query); }
  165. /**
  166. * 回傳自增ID
  167. *
  168. * @return int
  169. */
  170. 靜態函數insert_id() {
  171. return ($id = mysql_insert_id(self::$link)) >= 0 ? $id : self::$result( self::$query("SELECT last_insert_id()"), 0);
  172. }
  173. /**
  174. * 從結果集中取得一行作為枚舉數組
  175. *
  176. * @param object $query
  177. * @return array
  178. */
  179. 靜態函數fetch_row($query) {
  180. $query = mysql_fetch_row ($query);
  181. 回傳$query;
  182. }
  183. /**
  184. * 從結果集中取得列資訊並作為物件回傳
  185. *
  186. * @param object $query
  187. * @return object
  188. */
  189. 靜態函數fetch_fields($query) {
  190. return mysql_fetch_field($query);
  191. }
  193. 靜態函式select_affectedt_rows($rs){
  194. return mysql_affected_rows($rs,self::$link);
  196. }
  197. /**
  198. * 回傳mysql版本
  199. *
  200. * @return string
  201. */
  202. 靜態函式version() {
  203. return mysql_get_server_info(self::$link);
  204. }
  205. /**
  206. * 關閉連線
  207. *
  208. * @return bool
  209. */
  210. 靜態函式close() {
  211. return mysql_close(self::$link);
  212. }
  213. /**
  214. * 輸出錯誤訊息
  215. *
  216. * @param string $message
  217. * @param string $sql
  218. */
  219. 靜態函數halt($message = "", $sql = "") {
  220. @header( "內容類型：text/html; charset=utf-8");
  222. if (DEBUG==1){
  223. $debug = debug_backtrace();
  224. echo $message 。 “rn
    SQL-->”。 $sql."rn
    ERROR_MESSAGE-->".self::error().
  225. "rn
    --------------調試- --- ----------rn
    ";
  226. self::echoarray($debug);
  227. echo "rn
    ------ ----- --調試結束----------------";
  229. }else{
  230. echo 'SQL 錯誤';
  231. }
  232. @self: :rollback();
  233. exit;
  234. }
  235. ///// ////////////////////////以下是擴充的sql方法.//////
  236. /* 把佇列依照key value value的對應關係插入資料表表中
  237. table要插入的資料表
  238. 要注意這些擴充方法是沒自己給表有加外接的。
  239. */
  240. static function insert($table,$array ){
  241. $temp="";$temp2='';
  242. foreach($array as $key=>$value){
  243. if(self::$is_type_tight){
  244. if (is_string($value)){
  245. $temp .="$key,";$temp2 .="'$value',";
  246. }elseif(is_int($value||is_null($value)) ||is_float($value))){
  247. $value+=0;
  248. $temp .="$key,";$temp2 .="'$value',";
  249. }
  250. }else{
  251. $temp .="$key,";$temp2 .="'$value',";
  252. }
  253. }
  254. $temp = substr($temp,0,strlen ($temp)-1);
  255. $temp2 = substr($temp2,0,strlen($temp2)-1);
  257. $sql = "插入$table ($temp) VALUE( $temp2)";
  258. return self::query($sql);
  259. }
  262. 靜態函數del ($table,$where){
  263. $sql = "刪除FROM {$table} where {$where}";
  264. return self::query($sql);
  265. }
  267. 靜態函數update($table,$array,$where){
  268. foreach ($array as $key=>$value){
  269. $temp .= "$key='$value',";
  270. }
  271. $temp = substr($temp,0 ,strlen($temp)-1);
  272. $sql = "update {$table} set ($temp) where {$where} ";
  273. return self::query($sql);
  274. }
  276. /*進行資料庫查詢選擇參數不定
  277. 參數說明:所有參數必須是字串
  278. 第一個參數必須是表名;
  279. 從第二個參數開始,
  280. 如果是寫上"where:XXX" 則認為是where條件;
  281. 如果寫上"xxx" 則認為是鍵值
  282. 如果寫上"by:XXX" 則認為是排序
  283. 如果寫上"limit:xxx,xxx" 則認為是分頁
  285. #參數不正確則傳回false; 成功回傳查詢後的佇列;
  286. */
  287. static function select(){
  288. $numargs = func_num_args();//取得參數個數;
  289. $where = "";$key ="";$limit=" ";$by="";
  290. if($numargs==0){return false;}
  291. //echo $numargs;
  292. if($numargs>= 2){
  293. $arg_list = func_get_args();
  294. $table = $arg_list[0];
  295. unset($arg_list[0]);
  296. // print_r($arg_list);
  297. foreach($arg_list as $k =>$value){
  298. if(preg_match("#^(where:)w#",$value)){
  299. $temp =explode(":", $value);
  300. $where = "WHERE {$temp[1]} " ;
  301. }elseif(preg_match("#^by:w#",$value)){
  302. $temp = 爆炸(":",$value);
  303. $by = "依{$temp[1]} 排序" ;
  304. }elseif(preg_match("#^limit:w#",$value)){
  305. $temp =explode(": ",$value);
  306. $limit = "limit {$temp[1]}";
  307. }else{
  308. $key .= "$value," ;
  309. }
  310. }
  312. if($key==""){
  313. $key = "*";
  314. }else{
  315. $key =substr($鍵,0,strlen($key) -1);
  316. }
  318. $sql_base="SELECT $key FROM $table";
  319. }
  320. if(!empty($where)){
  321. $sql_base .= " $where" ;
  322. }
  323. if(!empty($by)){
  324. $sql_base .= " $by";
  325. }
  326. if(!empty($limit)){
  327. $sql_base .= " $limit";
  328. }
  329. //echo $sql_base;
  330. //echo $by ;
  331. $rs = self::query($sql_base);
  332. $re=array();
  333. if(self::num_rows($rs)>=1){
  334. while($info = self : :fetch_array($rs)){
  335. $re[]=$info;
  336. }
  337. }
  338. self::free_result($rs);
  339. return $re;
  340. }
  343. /*回滾事務*/
  344. static function rollback(){
  345. self::query('rollback');
  346. }
  347. /*開始事務* /
  348. static function begin(){
  349. self::query('SET AUTOCOMMIT =0'); //失效自動提交;
  350. self::query('BEGIN') ;//開始一個事務;
  351. }
  353. /*提交事務*/
  354. static function commit() {
  355. self::query('commit');
  356. }
  359. 靜態函數echoarray($array){
  360. foreach($array as $k=>$v ){
  361. if(is_array($v)){
  362. if(is_array($v)){
  363. echo "
    ------------- -------------------
    ";
  364. self::echoarray($v);
  365. }
  366. }else{
  367. if($k==='line')
  368. echo "$k -> " .$v." ";
  369. else
  370. echo "$k -> " .$v." ";
  371. }
  372. }
  373. }
  375. function get_server_info(){
  376. return mysql_get_server_info() ;
  377. }
  380. //是下面應付大數據的表的最佳化查詢
  382. //是下面應付大數據的表的最佳化查詢
  386. big_select 適合大規模的查詢，利用覆蓋索引實現忽略的偏移活動窗口，令查詢在覆蓋索引上偏移而不是在所有數據上，減少msql在數據上檢查，再把其他數據加入進來這樣更高效。但對於小規模數據，這種查詢反而相反地增加複雜度，增加優化器壓力。 舉個例子，如果你是limit 10000,20;mysql會先查出10020條資料重新丟棄10000這樣的操作成本非常大，利用這個函數可以有效提升效率，但如果是limit 20,那就會比直接select慢了一些
  387. @table string要查詢的表如"table1"
  388. @keys string要查詢的鍵值,多個鍵值用","分割如" key1,key2,key3"結束清晰", "學少用"*"且一些關鍵字請加上`;
  389. @Index string 主索引鍵或唯一索引鍵名,只需要一個如"id";
  390. @pagesize int 分頁大小,必須,你不會想那麼多資料全部出來吧
  391. @pageNo 頁碼,從0開始
  392. @orderby string 排序如"id desc";可空,但不建議空
  393. @where string 條件如"date >122424533"可空
  394. #回傳記憶體
  395. */
  396. static function big_select($table,$keys,$index,$pagesize,$pageNo,$ orderby=NULL,$where=NULL){
  397. $start=$pageNo*$pagesize;
  398. if($where){
  399. $sqlIndex="從{$table} 選擇{$index} where { $where}";
  400. }else {
  401. $sqlIndex="從{$table} 選擇{$index}";
  402. }
  403. if($orderby){
  404. $sqlIndex .= " ORDER BY {$orderby} 限制$start ,$pagesize";
  405. }else{
  406. $sqlIndex .=" ORDER BY Limit $start,$pagesize";
  407. }
  408. $sql = "從{$table} INNER JOIN 選擇$keys ({$sqlIndex} ) AS lim USING({$index})";
  410. $rs = self::query($sql);
  412. $re=array();
  413. if(self: :num_rows($rs)>=1){
  414. while($info = self::fetch_array($rs)){
  415. $re[]=$info;
  416. }
  417. }
  418. self::free_result($rs);
  419. return $re;
  421. }
  422. /* 如果一個很大的資料(預計最大萬行)刪除的工作週期會比較長，會長時間鎖住不應該鎖住的表或行，令一些不該打斷的數據被打斷方法如下是把一個大的sql任務分小（分成一次5000行）但次操作可能會造成刪除空白期間插入了新的數據，而新的數據可能會因滿足條件而被刪除。本方法很容易因為超時而失敗。
  423. @table string 要刪除資料的表名
  424. @where string 條件可省略
  425. #int 刪除掉的行數
  426. */
  427. static function big_del($table,$where){
  428. set_time_limit(0);
  429. $sql="delete from {$table}其中{$where} 限制5000";
  430. $rows = 0;
  431. $eff=0;
  432. do {
  433. self::query($sql);
  434. $rows=self: :affected_rows();
  435. $eff += $rows;
  436. }while($rows>0);
  437. return $eff;
  438. }
  439. }
?>


陳述：
本文內容由網友自願投稿，版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容，請聯絡admin@php.cn
上一篇：根據出生日期計算年齡（考慮閏年的情況）下一篇：根據出生日期計算年齡（考慮閏年的情況）

相關文章

看更多