検索

ホームページ  >  記事  >  バックエンド開発  >  mysqlデータベースを操作するための自作PHPクラスを共有する

mysqlデータベースを操作するための自作PHPクラスを共有する

WBOY
WBOYオリジナル
2016-07-25 08:48:56900ブラウズ
これは私自身が書いたクラスです。どなたでも議論したりガイドしたりできます。いくつかの使用法:
//データベース オブジェクトを宣言する
$Conn = new Mysql;ユーザー名、データベース パスワード、データベース名、データベース エンコーディング、データベース テーブル プレフィックス [空にすることもできます]);

上記のコードはすでにこのクラス ファイルをロードし、いくつかのデータベース接続パラメーターを初期化しています。
以下はいくつかの基本的なメソッド関数です:
1. $Conn -> Table();
データテーブルを選択します。パラメータはデータテーブルの名前です
2. $Conn -> Field();
フィールドを選択します。名前、複数 カンマで区切ります。このメソッドが呼び出されない場合は、すべてが返されます
3. $Conn -> Where();
Sql Where サブステートメント、条件に基づいてフィルターします
4. ;
SQL ソート
5 , $Conn -> Page (int);
パラメータは正の整数です。このメソッドが呼び出された場合、レコードはページ単位で表示されます
6. $Conn -> Select (ブール値) ;
クエリを実行し、クエリ結果を返します (存在しない場合は false を返します)。省略した場合、返される配列には数値要素が含まれます。 7、$Conn -> Del();
レコードを削除します
8、$ Conn -> Edit(array());
レコードを変更します。パラメータは 1 次元配列、配列キーはフィールド名です。配列の値はフィールドの値です
9 $Conn -> Into(array());
レコードを追加します。パラメータは 1 次元の配列、配列のキーはフィールド名、配列の値はフィールドです価値。

上記のメソッドは連続して呼び出すことができます。例:

$Rult = $Conn -> Table('user') -> Select(); //クエリはユーザー テーブル内のすべてのレコードを返します
$Rult = $ Conn -> Table( 'user') -> Page(20) -> Select();//クエリは user テーブル内のすべてのレコードを返し、それらをページごとに 20 レコードずつ表示します

;メソッド呼び出しや裏技もたくさんありますので、時間があるときに詳しく説明します。
  1. /*
  3. データベース操作クラス
  4. 操作方法: オブジェクトに面する
  5. 作成時期: 2013-3-10
  6. 現在のバージョン: BqhMysql (mysqli) 1.0.1
  7. ソフトウェア作者: Sad Song
  8. お問い合わせQQ: 36975
  9. 連絡先番号: 18907975647
  10. 電子メール: admin@q128.com
  11. 連絡先住所: 江西省贛州市石城県小松鎮
  12. 郵便番号: 342706
  14. */
  15. class Mysql{
  16. private $LocalHost = ' localhost';
  17. private $LoaclUser = 'root';
  18. private $LocalPass = '123456';
  19. private $LocalBase = 'jiangxibaiyi';
  20. private $LocalCode = 'UTF8';
  21. private $PreFix;
  22. private $Conn;
  23. private $Start = 0;
  24. private $Error = false; //データベースの接続ステータス、false は接続されていない、または接続が異常であることを意味します
  25. public $Err = true //SQL の実行結果
  26. private $Table;
  27. private $Field = '*';
  28. private $Where = '';
  29. private $Order = '';
  31. private $PageSize = 0; //ページ表示->ページごとのアイテム数、0 はページング表示なしを意味します
  32. private $ PageCount = 1; //ページ表示 -> 合計ページ数
  33. private $PageNum = 1; //ページ表示 -> 合計ページ数
  34. private $PageNo = 1; ->現在のページとは何ですか
  35. private $PageKey = 'page'; //ページ URL パラメーター キー
  36. private $PageStart = 0; //ページ表示->返される現在の項目
  39. private $Select;
  40. private $Rest;
  42. private $Result = false;//結果セット
  44. public $FormArray = array();
  46. public $Instr_ID = 0;
  47. private $j = 0;
  50. public function Parameter($ Loca、$Root、$Pass、$Base、$Code、$PreFix = ''){
  51. $this->LoaclUser = $Root;
  52. $this->LocalBase = $Base;
  53. $this->LocalCode = $Code;
  54. $this->LocalHost = $Loca;
  55. $this->LocalPass = $Pass;
  56. $this->PreFix = $PreFix;
  57. return $this;
  58. }
  59. プライベート関数 Connection( $ Sql ){
  60. !function_exists(mysqli_connect ) ? die('クエリが失敗しました。mysqli 拡張機能をロードできません') : null;
  61. $this->Conn = @new mysqli( $this->LocalHost, $this-> LoaclUser, $this->LocalPass, $this->LocalBase);
  62. $this->Error = mysqli_connect_errno() == 0 ? true : false;
  63. !$this->Error die('データベース接続 ?エラー。データベース接続パラメータを確認してください') : null;
  64. $this->Conn->query('SET NAMES ' . $this->LocalCode);
  65. $this->Rest = $this-> ;Conn->query($Sql) ;
  66. $this->Err = mysqli_error($this->Conn);
  67. $this->Instr_ID = mysqli_insert_id($this->Conn);
  68. $this ->Rest->free_result;
  69. $this->Conn->close;
  70. $this -> FormArray = '';
  71. return $this;
  72. }
  74. public function null(){
  75. $this ->PageSize = 0;
  76. // $this->PageCount = 1;
  77. $this->PageStart = 1;
  78. $this->フィールド = ' * ';
  79. $this->Select = ' ';
  80. unset($this->Table, $this->Where,$this->Order, $this->Result);
  81. }
  83. public function Table( $TableName ) {//データ テーブル
  84. $this -> null();
  85. $this->Table = '`' . $TableName . '`';
  86. return $this;
  87. }
  88. public function Field( $ Array = '*' ) {//data フィールド
  89. !empty( $this->Field ) ? $this->Field = '' : null;
  90. $Array =explode(',', $Array);
  91. foreach ( $Array as $field ) {
  92. $this->Field .= !$this->Start ? '`' : ', `' . $this->Start++;
  93. }
  94. $this->Start = 0;
  95. return $this;
  96. }
  98. public function Where( $Where ) {//Condition
  99. $this->Where = ' where ' .$Where;
  100. return $this; }
  102. public function Order( $Order ) {//Sort
  103. $this->Order = ' order by ' . $Order;
  104. return $this;
  105. }
  107. public function pk( $key ) {//ページング URL パラメーター key
  108. $this->PageKey = $key;
  109. return $this;
  110. }
  112. public function Page( $PageSize ) {///ページング
  113. $this-> PageSize = $PageSize;
  114. $this->gt;PageNo = $this->gt;get( $this->PageKey );
  115. $this->PageNo = empty( $this->PageNo ) || $this->PageNo ) || ! is_numeric( $this->PageNo 1 ? 1 : $this->PageNo;
  116. return $this;
  117. }
  118. function post( $Key, $Filter = true ){
  119. return $Filter ?strip_tags($_POST[$Key]) : $_POST[$Key];
  120. }
  122. public function get( $Key, $Filter = true ) {
  123. $Filter を返す ?strip_tags($_GET [$Key]) : $_GET[$Key];
  124. }
  126. パブリック関数 Sel(){
  127. $this->Select = 'Select ' 。 $this->フィールド 。 ' から ' 。 $this->テーブル 。 $this->どこ . $this->Order;
  128. $this->Connection( $this->Select );
  129. if ( $this->Rest->num_rows ) {
  130. while ( $Rs = $this->Rest ->fetch_assoc() ) {
  131. $this->Result[] = $Rs;
  132. }
  133. }
  134. $DataBase = $this->Result;
  135. return empty($DataBase) ? false : $DataBase;
  136. }
  138. public function querys( $Sql = '', $Type = 'not', $biao = false ) {
  139. $this->Select = $Sql;
  140. $this->Connection ( $this->Select );
  141. if ( $this->Rest->num_rows ) {
  142. if ( !$biao ) {
  143. while ( $Rs = $this->Rest->fetch_array() ) {
  144. $this->Result[] = !preg_match('/^d+$/i', $Type) ? $Rs : $Rs[ $Type ];
  145. }
  146. } else {
  147. while ( $Rs = $this->gt;Rest->fetch_assoc() ) {
  148. $this->Result[] = $Rs;
  149. }
  150. }
  151. }
  152. $DataBase = $this->Result;
  153. return empty($DataBase) ? false : $DataBase;
  155. }
  157. public functionexecutes( $Sql = '' ){
  158. $this->Connection( $Sql );
  159. return $this->Rest;
  160. }
  163. public 関数が存在します( $T = '', $F = '', $W = ''){
  164. if ( empty( $F ) ) { return 0; }
  165. $cmd = 空( $W ) ? ' sum(' . $F . ') を `baiyinum` として `' から選択します。 $this->PreFix 。 $T .'`' : 'sum(' . $F . ') を `baiyinum` として `' から選択します。 $this->PreFix 。 $T .'' ここで ' . $W;
  166. $this->Connection( $cmd );
  167. unset( $T, $F, $W, $cmd );
  168. $Rel = $this->>Rest->fetch_array();
  169. return Round( $Rel['baiyinum'], 2 );
  170. }
  173. public function ExistsTo( $Bili = 10000, $T = '', $F = '', $W = ''){
  174. if ( empty ( $F ) ) { 0 を返します。 }
  175. $cmd = 空( $W ) ? ' sum(' . $F . ') を `baiyinum` として `' から選択します。 $this->PreFix 。 $T .'`' : 'sum(' . $F . ') を `baiyinum` として `' から選択します。 $this->PreFix 。 $T .'' ここで ' . $W;
  176. $this->Connection( $cmd );
  177. unset( $T, $F, $W, $cmd );
  178. $Rel = $this->>Rest->fetch_array();
  179. return round( $Rel['baiyinum'] * $Bili );
  180. }
  183. public function Select( $Type = true, $ListNum = 1 ){ // 返记录（数组形式、返条数）
  184. $this- >選択 = '選択' 。 $this->フィールド 。 ' から ' 。 $this->テーブル 。 $this->どこ . $this->Order;
  185. if ( is_numeric( $ListNum ) ) {
  186. if ( $this->PageSize > 0 ) {
  187. $this->Connection( $this->Select );//実行查询
  188. $this->PageCount = $this->Rest->num_rows;//取得录总数
  189. $this->PageNum = ceil($this->PageCount / $this->PageSize); //共通共有量
  190. $this->PageNo = $this->PageNo > $this->ページ番号 ? $this->PageNum : $this->PageNo;
  191. $this->PageStart = ( $this->PageNo - 1 ) * $this->PageSize; //当前从第几条开始返
  192. $this->Select .= 'limit' 。 $this->PageStart 。 ', ' .$this->PageSize; // 重新构造句sql语
  193. } else {
  194. $this->Select .= 'limit' . $ListNum; // 重新构造句sql语
  195. }
  196. } else {
  197. $this->Select .= ' 制限 1'; // 重新构造句sql语
  198. }
  199. //echo $this->Select;
  200. $this->Connection( $this->Select );// 再実行查询
  201. if ( $this->Rest- >num_rows ) {//如果记录存在
  202. if ( $Type ) {
  203. while ( $Rs = $this->Rest->fetch_array() ) {
  204. $this->Result[] = $Rs;
  205. }
  206. }else{
  207. while ( $Rs = $this->Rest->fetch_assoc() ) {
  208. $this->Result[] = $Rs;
  209. }
  210. }
  211. }
  212. if ( ( $ ListNum == 1 または !is_numeric( $ListNum ) ) && !$this->PageSize) { $this->Result = $this->Result[0]; }
  213. $DataBase = $this->Result;
  214. return empty($DataBase) ? false : $DataBase;
  215. }
  217. public function Num() { // 戻り记录总数
  218. $this->Select = 'Select ' . $this->フィールド 。 ' から ' 。 $this->テーブル 。 $this->どこ . $this->Order;
  219. $this->Connection( $this->Select );//実行查询
  220. return $this->Rest->num_rows;// 取得记录总数
  221. }
  223. public function PageNav($NumNav = false ) { //分页
  224. $Action = $this -> get('action');
  225. !empty( $Action ) or $Action = 'index';
  226. $Module = $this -> get('module');
  227. !empty( $Module ) or $Module = 'index';
  228. $NavUrl = '/' . $Module . '/' . $Action . '/' . $this -> PageKey .'/';
  229. $NaIndex = '/' . $Module . '/' . $Action;
  230. $PageHtml = "\n
    ";
  231. $PageHtml .= '' . $this->PageCount . '条记录 ' . $this->PageNo . '/' . $this->PageNum . '页 ';
  232. $this->PageNo <= 1 or $PageHtml .= "首页\nPageNo - 1) . "\">上一页\n";
  233. if ( $NumNav ) { $PageHtml .= $this->NumPage($NavUrl); }
  234. $this->PageNo >= $this->PageNum or $PageHtml .= "PageNo + 1) . "\">下一页\nPageNum . "\">尾页\n";
  235. $PageHtml .= "
\n";
  • return $PageHtml;
  • }
  • private function NumPage( $Can = '' ) { //数字分页
  • $NumHtml = '';
  • $First = 1;
  • $Last = $this->PageNum;
  • if ( $this->PageNum > 5 ) {
  • if ( $this->PageNo < $this->PageNum ) {
  • $First = $this->PageNo - 2;
  • $Last = $this->PageNo + 2;
  • }else{
  • $First = $this->PageNo - 4;
  • $Last = $this->PageNum;
  • }
  • }
  • if ( $First < 1 ) { $First = 1; $Last = $First + 4;}
  • if ( $Last > $this->PageNum ) { $First = $this->PageNum - 4; $Last = $this->PageNum;}
  • for( $i = $First; $i <= $Last; $i++) {
  • $NumHtml .= $this->PageNo != $i ? "\n\t" . '' . $i . '' . "\n\t" : "\n\t" .'' . $i . '' . "\n\t";
  • }
  • unset($Can, $First, $i, $Last);
  • return $NumHtml;
  • }
  • public function UserPage($NumNav = false, $PageName = 'index', $Mulu = 'user' ) { //会员中心分页
  • $NavUrl = '/' . $Mulu . '/' . $PageName . '/' . $this->PageKey . '/';
  • $PageHtml = "\n
    ";
  • $PageHtml .= '' . $this->PageCount . '条记录 ' . $this->PageNo . '/' . $this->PageNum . '页 ';
  • $this->PageNo <= 1 or $PageHtml .= "首页\nPageNo - 1) . "\">上一页\n";
  • if ( $NumNav ) { $PageHtml .= $this->NumPage($NavUrl); }
  • $this->PageNo >= $this->PageNum or $PageHtml .= "PageNo + 1) . "\">下一页\nPageNum . "\">尾页\n";
  • $PageHtml .= "
    • n";
  • return $PageHtml;
  • }
  • // フォーム処理開始
  • // フォーム判定時に送信
  • public function FormIs( $Keys = 'mm' ) {
  • return $_POST[ $Keys ] == 1 ? true : false;
  • }
  • //post 経由でデータを取得
  • public function _post( $Keys = '', $TiHuan = '') {
  • $Values =trip_tags( $_POST[ $Keys ] );
  • $ this->FormArray[$Keys] = empty( $Values ) ? $TiHuan : $Values;
  • return empty( $Values ) ? $TiHuan : $Values;
  • }
  • //メソッドを取得データを取得するには
  • public function _get ( $Keys = '', $TiHuan = '') {
  • $Values =trip_tags( $_GET[ $Keys ] );
  • return empty( $Values ) ? $Values;
  • }
  • //数値か0以上かを判定
  • public function IsNum( $Num = 0, $Mesg = 'パラメータは数値でなければなりません' ) {
  • if ( is_numeric( $Num ) && !empty( $Num ) && $Num >= 0 ) {
  • return $Num;
  • }else{
  • die( $Mesg );
  • }
  • }
  • //それが数値であり、0以上であるかどうかを判断しますそして return True/False
  • public function NumBer( $Num = 0) {
  • return is_numeric( $Num ) && !empty( $Num ) && $Num >= 0 ? true : false;
  • }
  • //それを検出します関連するデータが存在するようです
  • public function IsData($Types = true, $memg = 'データはすでに存在します' ){
  • $this->Connection('select ' . $this->Field . ' from ' . $this ->Table . $this->Where);
  • if ( $Types ){
  • $this->Rest->num_rows > die( $memg ) : null;
  • } else {
  • return $ this->Rest->num_rows;
  • }
  • }
  • //データベースレコードに書き込む
  • public function into( $Mesg = '' ){
  • !is_array( $this->FormArray ) ? Mesg ) : null;
  • $Sql = ' に挿入 . $this->Table . ' (`';
  • $I = 0;
  • foreach ( $this->FormArray as $Key => $Val ) {
  • $Duan .= !$I ? $Key . '`' : ', ` ' . '`';
  • if ( is_numeric( $Val ) ){
  • $Vals .= !$I ? : ', ' . $Val;
  • }else{
  • $Val .= !$I ? '' : ', '' . $Val .
  • }
  • $Sql .= $Duan . ') 値 (' . $Vals . ' )';
  • //@file_put_contents('1.sql', $Sql, FILE_APPEND);
  • $this-> ;Connection( $Sql );
  • return !empty( $this->Err ) ? false : true;
  • }
  • //データを配列形式で書き込む
  • public function MsgBox( $Table = '', $Filed = array () ) {
  • $this -> Table($Table);
  • foreach( $Filed as $Key => $Val ) {
  • $this -> FormArray[ $Key ] = $Val; $this -> Into('データが取得されません');
  • }
  • //データベース Record を変更します
  • public function Edit( $Array = array() ) {
  • if ( empty( $Array ) ) { $Array = $this -> }
  • if ( !is_array( $Array ) || empty( $Array ) ) {
  • return false;
  • } else {
  • $Sql = 'update ' . set ';
  • $I = 0;
  • $Sub = '';
  • $Huan = array(' -' => '[jian]', '+' => '[jia]', '*' = > '[チェン]', '/' => '[チュウ]');
  • $ ザン = array('[ジャン]' => '-', '[ジア]' => '+' , '[cheng]' => '*', '[chu]' => '/ ');
  • foreach ( $Array as $Files => $Val ) {
  • $Val = !is_numeric( $ Val ) && !preg_match('/`w+`s*(+|-|*|/)/ i', $Val) '' . $Val;
  • foreach ( $Huan as $key => $val ){
  • $Val = str_replace($key, $val, $Val );
  • $duan = '`' . $Files . ' . $Files . '' = ';
  • $Sub .= $duan . $Val;
  • $ I++;
  • }
  • $Sub . = $Fan ; => $Hui ) {
  • $Sql = str_replace($Fan, $Hui, $Sql);
  • }
  • //echo $Sql;
  • $this -> 接続を解除( $Array, $duan, $Fan, $Files, $Huan, $Hui, $I, $ key, $Sql, $Sub, $Val, $Zhan, $val );
  • return !empty( $this -> ; エラー) ? false : true;
  • }
  • // データベース レコードを削除します
  • $Sql = '$this->Table . $this->Connection( $Sql );
  • unset($Sql);
  • return !empty( $this->Err ) ? false : true;
  • }
  • //フォーム処理が終了します
  • //ページジャンプ
  • public function Msg( $Text = 'Operation success' ) {
  • echo '';
  • echo ' ';
  • exit;
  • }
  • #現在のシステム時刻を取得します
  • public function Times(){
  • return str_replace('-', '[jian]', date ('Y-m-d H:i:s'));
  • }
  • # 取得用户IP地址
  • public function GetIP(){
  • if (getenv("HTTP_CLIENT_IP") && strcasecmp(getenv("HTTP_CLIENT_IP"), "unknown"))
  • $ip = getenv("HTTP_CLIENT_IP");
  • else if (getenv("HTTP_X_FORWARDED_FOR") && strcasecmp(getenv("HTTP_X_FORWARDED_FOR"), "unknown"))
  • $ip = getenv("HTTP_X_FORWARDED_FOR");
  • else if (getenv("REMOTE_ADDR") && strcasecmp(getenv("REMOTE_ADDR"), "unknown"))
  • $ip = getenv("REMOTE_ADDR");
  • else if (isset($_SERVER['REMOTE_ADDR']) && $_SERVER['REMOTE_ADDR'] && strcasecmp($_SERVER['REMOTE_ADDR'], "unknown"))
  • $ip = $_SERVER['REMOTE_ADDR'];
  • else
  • $ip = "不明";
  • return($ip);
  • }
  • //最後关闭データベース库连接
  • public function Close(){
  • !is_object( $this -> Conn ) または mysqli_close( $this -> Conn );
  • }
  • }
    • 复制定


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

    関連記事

    続きを見る