検索

ホームページ  >  記事  >  バックエンド開発  >  phpがmysqlデータベースに接続するためのクラス

phpがmysqlデータベースに接続するためのクラス

WBOY
WBOYオリジナル
2016-07-25 08:59:06871ブラウズ
  2. /*
  3. * ファイル名: mysql データベース接続クラス
  4. * edit bbs.it-home.org
  5. */
  6. class mysql{
  7. private $db_host //データベースホスト
  8. private $db_user; ; //データベースユーザー名
  9. private $db_pwd; //データベースユーザー名
  10. private $conn; //データベース接続識別子;
  11. private $result;
  12. private $sql; //SQL 実行ステートメント
  13. private $row; //返されるエントリの数
  14. private $coding; //データベースエンコーディング、GBK、UTF8、gb2312
  15. private $bulletin = true;
  16. private $show_error = true; // テスト段階ではすべてのエラーが表示されますが、デフォルトではオフになっています。
  17. private $is_error = false;デフォルトは true です。問題が発生したときにユーザーが何も表示されない場合は非常にイライラするため、有効にしないことをお勧めします
  18. /*Constructor*/
  19. public function __construct($db_host,$db_user,$db_pwd) ,$db_database,$conn,$coding){
  20. $this->db_host=$db_host ;
  21. $this->db_user=$db_user;
  22. $this->db_pwd = $db_pwd;
  23. $this-> db_database=$db_database;
  24. $this->conn=$conn;
  25. $this-> ;coding=$coding;
  26. $this->connect();
  27. }
  28. /*データベース接続*/
  29. パブリック関数接続()
  30. {
  31. if($this->conn=="pconn"){
  32. //固定リンク
  33. $this->conn=mysql_pconnect($this->db_host,$this->db_user,$ this->db_pwd);
  34. }else{
  35. //インスタント リンク
  36. $this->db_host,$this->db_user,$this->db_pwd);
  37. }
  38. if(!mysql_select_db($this->db_database,$this->conn)) {
  39. if($this->show_error){
  40. $this->show_error("データベースが利用できません:",$this ->db_database);
  41. }
  42. }
  43. mysql_query("SET NAMES $this->coding");
  44. }
  45. /*データベース実行ステートメント、実行可能クエリ、追加、変更、削除などの SQL ステートメント*/
  46. パブリック関数 query($sql)
  47. {
  48. if($sql == ""){
  49. $this- >show_error("SQL ステートメント エラー:","SQL クエリ ステートメントが空です");}
  50. $this- >sql = $sql;
  51. $result = mysql_query($this->sql,$this-> conn);
  52. if(!$result){
  53. //デバッグで使用され、実行時に自動的に出力されます。 SQL ステートメントでエラーが発生しました
  54. if($this->show_error){
  55. $this->show_error("Error SQL ステートメント: ",$this->sql);
  56. }
  57. }else{
  58. $this ->result = $result;
  59. }
  60. return $this->result;
  61. }
  62. /*新しいデータベースを作成して追加*/
  63. public function create_database($database_name){
  64. $database=$database_name;
  65. $ sqlDatabase = 'データベースの作成 '.$database;
  66. $this->query($sqlDatabase);
  67. }
  68. /*サーバーのすべてのデータベースをクエリ* /
  69. //より直観的な表示のためにシステム データベースとユーザー データベースを分離します?
  70. public function show_databases(){
  71. $rs=$this->query("show databases");
  72. echo "现有数据库：".$amount =$this->db_num_rows($rs);
  73. echo "
    ";
  74. $i=1;
  75. while($row = $this->fetch_array($rs)){
  76. echo "$i $row[Database]";
  77. echo "
    ";
  78. $i++;
  79. }
  80. }
  81. //以数组形式返回主机中所有数据库名
  82. public function databases()
  83. {
  84. $rsPtr=mysql_list_dbs($this->conn);
  85. $i=0;
  86. $cnt=mysql_num_rows($rsPtr);
  87. while($i<$cnt)
  88. {
  89. $rs[]=mysql_db_name($rsPtr,$i);
  90. $i++;
  91. }
  92. return $rs;
  93. }
  94. /*查询数据库下所有的表*/
  95. function show_tables($database_name){
  96. $this->query("show tables");
  97. echo "现有数据库：".$amount = $this->db_num_rows($rs);
  98. echo "
    ";
  99. $i=1;
  100. while($row = $this->fetch_array($rs)){
  101. $columnName="Tables_in_".$database_name;
  102. echo "$i $row[$columnName]";
  103. echo "
    ";
  104. $i++;
  105. }
  106. }
  107. /*
  108. mysql_fetch_row() array $row[0],$row[1],$row[2]
  109. mysql_fetch_array() array $row[0] 或 $row[id]
  110. mysql_fetch_assoc() array 用$row->content 字段大小写敏感
  111. mysql_fetch_object() object 用$row[id],$row[content] 字段大小写敏感
  112. */
  113. /*取得结果数据*/
  114. public function mysql_result_li()
  115. {
  116. return mysql_result($str);
  117. }
  118. /*取得记录集,获取数组-索引和关联,使用$row['content'] */
  119. public function fetch_array()
  120. {
  121. return mysql_fetch_array($this->result);
  122. }
  123. //获取关联数组,使用$row['字段名']
  124. public function fetch_assoc()
  125. {
  126. return mysql_fetch_assoc($this->result);
  127. }
  128. //获取数字索引数组,使用$row[0],$row[1],$row[2]
  129. public function fetch_row()
  130. {
  131. return mysql_fetch_row($this->result);
  132. }
  133. //获取对象数组,使用$row->content
  134. public function fetch_Object()
  135. {
  136. return mysql_fetch_object($this->result);
  137. }
  138. //简化查询select
  139. public function findall($table)
  140. {
  141. $this->query("SELECT * FROM $table");
  142. }
  143. //简化查询select
  144. public function select($table,$columnName,$condition)
  145. {
  146. if($columnName==""){
  147. $columnName="*";
  148. }
  149. $this->query("SELECT $columnName FROM $table $condition");
  150. }
  151. //简化删除del
  152. public function delete($table,$condition){
  153. $this->query("DELETE FROM $table WHERE $condition");
  154. }
  155. //简化插入insert
  156. public function insert($table,$columnName,$value){
  157. $this->query("INSERT INTO $table ($columnName) VALUES ($value)");
  158. }
  159. //简化修改update
  160. public function update($table,$mod_content,$condition){
  161. $this->query("UPDATE $table SET $mod_content WHERE $condition");
  162. }
  163. /*取得上一步 INSERT 操作产生的 ID*/
  164. public function insert_id(){
  165. return mysql_insert_id();
  166. }
  167. //指向确定的一条数据记录
  168. public function db_data_seek($id){
  169. if($id>0){
  170. $id=$id-1;
  171. }
  172. if(!@mysql_data_seek($this->result,$id)){
  173. $this->show_error("sql语句有误：", "指定的数据为空");
  174. }
  175. return $this->result;
  176. }
  177. // 根据select查询结果计算结果集条数
  178. public function db_num_rows(){
  179. if($this->result==null){
  180. if($this->show_error){
  181. $this->show_error("sql语句错误","暂时为空，没有任何内容！");
  182. }
  183. }else{
  184. return mysql_num_rows($this->result);
  185. }
  186. }
  187. // 根据insert,update,delete执行结果取得影响行数
  188. public function db_affected_rows(){
  189. return mysql_affected_rows();
  190. }
  191. //输出显示sql语句
  192. public function show_error($message="",$sql=""){
  193. if(!$sql){
  194. echo "".$message."";
  195. echo "
    ";
  196. }else{
  197. echo "
    ";
  198. echo "错误信息提示:
    ";
  199. echo "
    ";
  200. echo "
    ";
  201. echo "错误号：12142";
  202. echo "

";
  • echo "错误原因：".mysql_error()."

    ";
  • echo "
    ";
  • echo "".$message."";
  • echo "
    • ";
  • echo "
    ".$sql."
    ";
  • $ip=$this->getip();
  • if($this->bulletin){
  • $time = date("Y-m-d H:i:s");
  • $message=$message."/r/n$this->sql"."/r/n客户IP:$ip"."/r/n时间 :$time"."/r/n/r/n";
  • $server_date=date("Y-m-d");
  • $filename=$server_date.".txt";
  • $file_path="error/".$filename;
  • $error_content=$message;
  • //$error_content="错误的数据库，不可以链接";
  • $file = "error"; //设置文件保存目录
  • //建立文件夹
  • if(!file_exists($file)){
  • if(!mkdir($file,0777)){
  • //默认的 mode 是 0777，意味着最大可能的访问权
  • die("upload files directory does not exist and creation failed");
  • }
  • }
  • //建立txt日期文件
  • if(!file_exists($file_path)){
  • //echo "建立日期文件";
  • fopen($file_path,"w+");
  • //首先要确定文件存在并且可写
  • if (is_writable($file_path))
  • {
  • //使用添加模式打开$filename，文件指针将会在文件的开头
  • if (!$handle = fopen($file_path, 'a'))
  • {
  • echo "不能打开文件 $filename";
  • exit;
  • }
  • //将$somecontent写入到我们打开的文件中。
  • if (!fwrite($handle, $error_content))
  • {
  • echo "不能写入到文件 $filename";
  • exit;
  • }
  • //echo "文件 $filename 写入成功";
  • echo "——错误记录被保存!";
  • //关闭文件
  • fclose($handle);
  • } else {
  • echo "文件 $filename 不可写";
  • }
  • }else{
  • //首先要确定文件存在并且可写
  • if (is_writable($file_path))
  • {
  • //使用添加模式打开$filename，文件指针将会在文件的开头
  • if (!$handle = fopen($file_path, 'a'))
  • {
  • echo "不能打开文件 $filename";
  • exit;
  • }
  • //将$somecontent写入到我们打开的文件中。
  • if (!fwrite($handle, $error_content))
  • {
  • echo "不能写入到文件 $filename";
  • exit;
  • }
  • //echo "文件 $filename 写入成功";
  • echo "——错误记录被保存!";
  • //关闭文件
  • fclose($handle);
  • } else {
  • echo "文件 $filename 不可写";
  • }
  • }
  • }
  • echo "
    ";
  • if($this->is_error){
  • exit;
  • }
  • }
  • echo "";
  • echo "";
  • echo "
    ";
  • }
  • //結果セットを解放する
  • public function free(){
  • @mysql_free_result($this->result ) ;
  • }
  • //データベース選択
  • public function select_db($db_database){
  • return mysql_select_db($db_database);
  • }
  • //フィールド数をクエリ
  • public function num_fields($table_name){
  • //return mysql_num_fields ($this ->result);
  • $this->query("select * from $table_name");
  • echo "
    ";
  • echo "フィールド数: ".$total = mysql_num_fields ($this- >result);
  • echo "
    ";</li>
<li>for ($i=0; $iprint_r(mysql_fetch_field($this->result,$i) ) );</li>
<li> }</li>
<li>echo "
    ";
  • echo "
    ";
  • }
  • //MySQLサーバー情報を取得
  • public function mysql_server($num=''){
  • switch ( $num){
  • case 1:
  • return mysql_get_server_info(); //MySQLサーバー情報
  • break;
  • case 2:
  • return mysql_get_host_info() //MySQLホスト情報を取得
  • break;
  • case 3:
  • return mysql_get_client_info(); ; //MySQL クライアント情報を取得します
  • break;
  • case 4:
  • return mysql_get_proto_info(); //MySQL プロトコル情報を取得します
  • default:
  • return mysql_get_client_info(); //デフォルトで mysql のバージョン情報を取得します
  • }
  • }
  • //分析コンストラクター、データベースを自動的に閉じる、ガベージ コレクション メカニズム
  • パブリック関数 __destruct()
  • {
  • if(!empty($this->result)){
  • $this->free();
  • }
  • mysql_close($this ->conn);
  • }//function __destruct();
  • /*クライアントの実際の IP アドレスを取得*/
  • 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 = "unknown";
  • }
  • return($ip);
  • }
  • }
  • ?>
  • コードをコピー

    • 声明：
    この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
    前の記事：ディレクトリ内のファイルの内容を参照するための PHP コード例次の記事：ディレクトリ内のファイルの内容を参照するための PHP コード例

    関連記事

    続きを見る