検索

ホームページ >バックエンド開発 >PHPチュートリアル >mysql 操作クラス、v0.2、大量のデータを処理するためのソリューションを追加

mysql 操作クラス、v0.2、大量のデータを処理するためのソリューションを追加

WBOY
WBOYオリジナル
2016-07-25 09:06:191039ブラウズ
/*mysql の単純なクラス by joffe q89949401 bib@Crazycode 詩人; このクラスは完全に静的です。使用する場合は、直接インクルードして mysql::method() 名を使用します。クラスは php5 でグローバルに表示されるため、コメントがある場合は変数のスコープを気にする必要はありません。プライベート メッセージ ||qq メールを送信してください。 現在、ストアド プロシージャに関連するメソッドはありません。もちろん、ストアド プロシージャは通常、データベースを作成するときに実行されます。 構成ファイルでは、次の定数情報を構成する必要があります。 LIB: クラスの保存場所 DEBUG：デバッグを有効にするかどうか（有効にするとエラー情報追跡が出力されます） TB_EX: データベーステーブルのプレフィックス。

select del update insert big_select big_del 関数を追加しました

*/
  1. /*mysql simple class by joffe q89949401 bib@Crazycode quote;
  2. このクラスが完全に静的に使用される場合は、クラスがグローバルであるため、直接インクルードし、mysql::method() 名を使用します。 php5 可視なので、変数のスコープを気にする必要はありません。コメントがある場合は、プライベート メッセージを送信してください ||qq メール;
  3. ストアド プロシージャに関連するメソッドは現在ありません。
  4. データベース作成時に設定が必要な設定ファイル 以下の定数情報:
  5. LIB: クラスの格納場所
  6. DEBUG: デバッグを有効にするかどうか (有効にするとエラーメッセージの追跡が出力されます)
  7. TB_EX: データベーステーブルのプレフィックス;
  8. */
  9. define('LIB') または die('Missing config!! ');
  10. final class mysql {
  11. /**
  12. * クエリの合計数
  13. *
  14. * @var int
  15. */
  16. public static $querynum = 0; &*/
  17. public static $link;
  18. /*
  19. table prefix
  20. @var string 次のメソッドでは、テーブルのプレフィックスとして TB_EX を構成する必要があります
  21. */
  23. static function add_ex($tb){
  24. return TB_EX.$tb_ex.$tb;
  25. }
  26. /*mysql データベースが厳密な型を使用するかどうか (mysql 型は自動的に変換されません) デフォルトは false で、mysql の型変換がオンになっていることを意味します。自動変換を行わない mysql の挿入関数の一重引用符。関連する関数は将来追加される可能性があります
  28. */
  29. public static $is_type_tight=false;
  31. /**
  32. * 接続ハンドル
  33. *
  34. * @var オブジェクト
  35. */
  36. static function connent($dbhost) , $dbuser, $dbpw, $dbname = "",$dbcharset, $pconnect = 0) {
  37. if($ pconnect) {
  38. if(!self::$link = @mysql_pconnect($dbhost, $dbuser, $dbpw )) {
  39. self::halt("MySQL サーバーに接続できません");
  40. }
  41. } else {
  42. if(!self::$link = @mysql_connect($dbhost, $dbuser, $dbpw)) {
  43. self::halt("MySQL サーバーに接続できません");
  44. }
  45. }
  46. if(self::version () > "4.1") {
  47. if($dbcharset) {
  48. mysql_query("SETcharacter_set_connection={ $dbcharset},character_set_results=$dbcharset,character_set_client=binary", self::$link);
  49. }
  50. if( self::version() > "5.0.1") {
  51. mysql_query("SET sql_mode='') ", self::$link);
  52. }
  53. }
  54. if($dbname) {
  55. mysql_select_db($dbname, self::$link);
  56. }
  57. }
  58. /**
  59. * コンストラクター
  60. *
  61. * @param string $dbhost ホスト名
  62. * @param string $dbuser user
  63. * @param string $dbpw パスワード
  64. * @param string $dbname データベース名
  65. * @param int $pconnectつながり
  66. */
  67. 静的関数 select_db ($dbname) {
  68. return mysql_select_db($dbname, self::$link);
  69. }
  70. /**
  71. * データベースを選択
  72. *
  73. * @param string $dbname
  74. * @return
  75. */
  76. static function fetch_array($query, $result_type = MYSQL_ASSOC) { //デフォルトでは、数値配列ではなく、連想配列がフェッチされます。 = $type == "UNBUFFERED" && @function_exists("mysql_unbuffered_query")
  77. "mysql_unbuffered_query" : "mysql_query"
  78. if( !($query = $func($sql, self::$link)) && $type != "SILENT") {
  79. self::halt("MySQL クエリ エラー", $sql);
  80. self:: $querynum++
  81. }
  82. /**
  83. * 結果セットからレコードを取得します
  84. *
  85. * @param object $query
  86. * @param int $result_type
  87. * @return array
  88. */
  89. static関数影響を受ける_rows() {
  90. return mysql_affected_rows(self::$link);
  91. }
  92. /**
  93. * 查询SQL
  94. *
  95. * @param string $sql
  96. * @param string $type
  97. * @return object
  98. */
  99. static 関数 error() {
  100. return ((self::$link) ? mysql_error(self:: $link) : mysql_error());
  101. }
  102. /**
  103. * 影響を受けるアイテムの数を取得します
  104. *
  105. * @return int
  106. */
  107. static 関数 errno() {
  108. return intval((self::$link) ? mysql_errno(self::$link) : mysql_errno( ));
  109. }
  110. /**
  111. * エラーメッセージを返す
  112. *
  113. * @return array
  114. */
  115. 静的関数 result($query, $row,$flname=0 ) {
  116. $query = @mysql_result($query, $row,$flname); $query;
  117. }
  118. /**
  119. * エラーコードを返す
  120. *
  121. * @return int
  122. */
  123. 静的関数 num_rows($query) {
  124. $query = mysql_num_rows( $query);
  125. /**
  126. * クエリ結果を返す
  127. *
  128. * @param object $query
  129. * @param string $row
  130. * @returnmixed
  131. */
  132. 静的関数 num_fields($query) {
  133. return mysql_num_fields($query);
  134. /**
  135. * 結果の数
  136. *
  137. * @param object $query
  138. * @return int
  139. */
  140. static 関数 free_result($query) {
  141. return @mysql_free_result($query);
  142. /**
  143. * 自動インクリメント ID を返す
  144. *
  145. * @return int
  146. */
  147. 静的関数 insert_id() {
  148. return ($id = mysql_insert_id(self::$link)) >= 0 ? $id : self::$result(self::$query("SELECT last_insert_id()"), 0);
  149. }
  150. /**
  151. * 結果セットから列挙型配列として行を取得します
  152. *
  153. * @param object $query
  154. * @return array
  155. */
  156. 静的関数 fetch_row($query) {
  157. $query = mysql_fetch_row($query);
  158. $query を返す;
  159. }
  160. /**
  161. * 結果セットから列情報を取得し、オブジェクトとして返します
  162. *
  163. * @param object $query
  164. * @return object
  165. */
  166. 静的関数 fetch_fields($query) {
  167. return mysql_fetch_field($query);
  168. }
  170. 静的関数 select_affectedt_rows($rs){
  171. return mysql_affected_rows($rs,self::$link);
  173. }
  174. /**
  175. * mysql バージョンを返す
  176. *
  177. * @return string
  178. */
  179. 静的関数 version() {
  180. return mysql_get_server_info(self) ::$リンク);
  181. }
  182. /**
  183. * 近い接続
  184. *
  185. * @return bool
  186. */
  187. 静的関数 close() {
  188. return mysql_close(self::$link);
  189. }
  190. /**
  191. * エラーメッセージを出力します
  192. *
  193. * @param string $message
  194. * @param string $sql
  195. */
  196. static function halt($message = "", $sql = "") {
  197. @header("Content-type: text/html; charset=utf-8");
  199. if (DEBUG==1){
  200. $debug = debug_backtrace();
  201. echo $message 。 "rn
    SQL--> " . $sql."rn
    ERROR_MESSAGE-->".self::error().
  202. "rn
    --------------デバッグ--- -----------rn
    ";
  203. self::echoarray($debug);
  204. echo "rn
    ----------- -デバッグ終了----------------";
  206. }else{
  207. echo 'SQL エラー';
  208. }
  209. @self::rollback();
  210. exit;
  211. }
  212. ///////////////////// ////////以下は展の sql メソッドです。//////
  213. /* 数組照合 key value value の对应系插入データテーブル中
  214. テーブルに必要なデータテーブル
  215. 要注意メソッドは自己给表に追加されたものです。
  216. */
  217. static function insert($table,$array){
  218. $temp="";$temp2='';
  219. foreach($array as $key=> $value){
  220. if(self::$is_type_tight){
  221. if(is_string($value)){
  222. $temp .="$key,";$temp2 .="'$value',";
  223. }elseif (is_int($value||is_null($value)||is_float($value))){
  224. $value+=0;
  225. $temp .="$key,";$temp2 .="'$value'," ;
  226. }
  227. }else{
  228. $temp .="$key,";$temp2 .="'$value',";
  229. }
  230. }
  231. $temp = substr($temp,0,strlen($temp) -1);
  232. $temp2 = substr($temp2,0,strlen($temp2)-1);
  234. $sql = "INSERT INTO $table ($temp) VALUE($temp2)";
  235. return self:: query($sql);
  236. }
  239. 静的関数 del($table,$where){
  240. $sql = "DELETE FROM {$table} where {$where}";
  241. return self::query($sql) ;
  242. }
  244. static 関数 update($table,$array,$where){
  245. foreach ($array as $key=>$value){
  246. $temp .= "$key='$value',";
  247. }
  248. $temp = substr($temp,0,strlen($temp)-1);
  249. $sql = "update {$table} set ($temp) where {$where} ";
  250. return self::query " where:XXX" は where 条件です;
  251. 如果写上 "xxx" 如意は键值
  252. 如果写上 "by:XXX" は排序
  253. 如果写上 "limit:xxx,xxx" は分页です
  255. #パラメータ不正确则はfalseを返します; 成功した場合は評価後の数組;
  256. */
  257. static function select(){
  258. $numargs = func_num_args();//获取パラメータ数;
  259. $where = "";$key="";$limit=" ";$by="";
  260. if($numargs==0){return false;}
  261. //echo $numargs;
  262. if($numargs>=2){
  263. $arg_list = func_get_args();
  264. $table = $arg_list[0];
  265. unset($arg_list[0]);
  266. // print_r($arg_list);
  267. foreach($arg_list as $k=>$value){
  268. if(preg_match("#^( where:)w#",$value)){
  269. $temp =explode(":",$value);
  270. $where = "WHERE {$temp[1]} " ;
  271. }elseif(preg_match("#^ by:w#",$value)){
  272. $temp =explode(":",$value);
  273. $by = "{$temp[1]} で注文" ;
  274. }elseif(preg_match("#^ limit:w#",$value)){
  275. $temp =explode(":",$value);
  276. $limit = "limit {$temp[1]}";
  277. }else{
  278. $key .= " $value,";
  279. }
  280. }
  282. if($key==""){
  283. $key = "*";
  284. }else{
  285. $key =substr($key,0,strlen($key)- 1);
  286. }
  288. $sql_base="SELECT $key FROM $table";
  289. }
  290. if(!empty($where)){
  291. $sql_base .= " $where";
  292. }
  293. if(!empty($by) ){
  294. $sql_base .= " $by";
  295. }
  296. if(!empty($limit)){
  297. $sql_base .= " $limit";
  298. }
  299. //echo $sql_base;
  300. //echo $by ;
  301. $rs = self::query($sql_base);
  302. $re=array();
  303. if(self::num_rows($rs)>=1){
  304. while($info = self::fetch_array($rs)){
  305. $re[]=$info;
  306. }
  307. }
  308. self::free_result($rs);
  309. return $re;
  310. }
  313. /*回滚事务*/
  314. static function rollback(){
  315. self::query('rollback');
  316. }
  317. /*开始事务*/
  318. static function begin(){
  319. self::query('SET AUTOCOMMIT =0'); //停止用自動提交;
  320. self::query('BEGIN') ;//开始一事务;
  321. }
  323. /*提交事务*/
  324. static function commit(){
  325. self::query('commit' );
  326. }
  329. 静的関数 echoarray($array){
  330. foreach($array as $k=>$v ){
  331. if(is_array($v)){
  332. if(is_array($v)){
  333. エコー "
    --------------------------------
    ";
  334. self::echoarray($v);
  335. }
  336. }else{
  337. if($k==='line')
  338. echo "$k -> " .$ v." ";
  339. else
  340. echo "$k -> " .$v." ";
  341. }
  342. }
  343. }
  345. function get_server_info(){
  346. return mysql_get_server_info();
  347. }
  350. //下は应付大データの表の拡張蟥询です
  352. /*
  353. big_select は大规模用の蟥询に適合し、覆いインデックスを利用して大幅なオフセット活性化口、令状は覆いインデックス上に偏移されません。すべてのデータで、データ上の msql を減らし、他のデータを追加すると、効率が向上します。ただし、小規模なデータの場合は、この逆に、制限が 100 に達すると、その結果、強度が増加します。 00 ,20;mysql 会先查出 10020 条データさらに 10000 この操作代は非常に大きく、この関数を利用することで高い効果が得られますが、結果が制限 20 である場合、那就会稍微比直接選択遅いいくつか
  354. @table 文字列要監査対象の表 例: "table1"
  355. @keys string 要監査対象の鍵,複数の鍵使用","分割 例:"key1,key2,key3" 结束不含","少量用"*" およびいくつかの鍵请加上`;
  356. @Index string 主インデックス键または唯一のインデックス键名、ただ必要な 1 つの例 "id";
  357. @pagesize int 分页大小、必须、你不会想这么多数データ全部出来吧
  358. @pageNo 页コード、从0开開始
  359. @orderby string 排序 例: "id desc";可空,ただし不建议空
  360. @where 文字列条件 例: "date>122424533" 可空
  361. # 返回数组
  362. */
  363. static function big_select($table,$キー,$index,$pagesize,$pageNo,$orderby=NULL,$where=NULL){
  364. $start=$pageNo*$pagesize;
  365. if($where){
  366. $sqlIndex="SELEECT {$index} from {$table} where {$where}";
  367. }else{
  368. $sqlIndex="SELEECT {$index} from {$table}";
  369. }
  370. if($orderby){
  371. $sqlIndex .=" ORDER BY { $orderby} $start,$pagesize を制限します";
  372. }else{
  373. $sqlIndex .=" ORDER BY Limit $start,$pagesize";
  374. }
  375. $sql = "SELECT $keys FROM {$table} INNER JOIN({$sqlIndex}) AS lim USING({$index} })";
  377. $rs = self::query($sql);
  379. $re=array();
  380. if(self::num_rows($rs)>=1){
  381. while($info = self::fetch_array($rs)){
  382. $re[]=$info;
  383. }
  384. }
  385. self::free_result($rs);
  386. return $re;
  388. }
  389. /* 如果一个很大的データ(万行よりも大きい予定) 削除される動作周期は長すぎるため、そのテーブルまたは実行に長時間かかると、起動されていないデータがいくつか削除されます。 以下の方法は、大量の SQL タスクを実行することです。小さい (1 回あたり 5000 行) が、次の操作により空きスロット期間中に新しいデータが挿入される可能性がありますが、新しいデータは十分な条件により削除される可能性があります。この方法では時間が経過するとすぐに失われます。の表名
  390. @where 文字列条件は省略可能
  391. #int 删除削除の行数
  392. */
  393. static function big_del($table,$where){
  394. set_time_limit(0);
  395. $sql="{$table} から削除where {$where} 制限 5000";
  396. $rows = 0;
  397. $eff=0;
  398. do{
  399. self::query($sql);
  400. $rows=self::affected_rows();
  401. $eff += $rows;
  402. }while($rows>0);
  403. return $eff;
  404. }
  405. }
  408. ?>
复制代

声明：
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
前の記事：生年月日から年齢を計算します（閏年を考慮します）次の記事：生年月日から年齢を計算します（閏年を考慮します）

関連記事

続きを見る