検索

ホームページ >バックエンド開発 >PHPチュートリアル >mysqlを操作するためのPHPクラス

mysqlを操作するためのPHPクラス

WBOY
WBOYオリジナル
2016-07-25 08:42:00944ブラウズ

[PHP] コード

    class mysql {
  1. private $db_host; //データベース ホスト
  2. private $db_pwd; //データベース ユーザー名とパスワード
  3. private $db_database;
  4. private $conn; //データベース接続の識別
  5. private $result; //クエリコマンドの実行結果の識別
  6. private $sql;
  7. 返されるエントリの数
  8. private $coding; //データベースエンコーディング、GBK、UTF8、gb2312
  9. private $bulletin = true; //エラーログを有効にするかどうか
  10. private $show_error = false; //テスト段階では、セキュリティ上のリスクがあるため、すべてのエラーが表示されます。 by default
  11. private $ is_error = false; //エラーが検出されたときにすぐに終了するかどうか、デフォルトは true です。問題が発生したときに何も表示されないのはユーザーにとって非常に不快なため、有効にしないことをお勧めします。
  13. /*コンストラクター*/
  14. public function __construct($db_host, $db_user, $db_pwd, $db_database, $conn, $coding) {
  15. $this->db_host = $db_host;
  16. $this->db_user = $db_user;
  17. $this->db_pwd = $db_pwd;
  18. $this->db_database = $db_database;
  19. $this->conn = $conn;
  20. $this->coding = $coding;
  21. $this ->connect();
  22. }
  24. /*データベース接続 */
  25. public function connect() {
  26. if ($this->conn == "pconn") {
  27. //永続リンク
  28. $this-> ;conn = mysql_pconnect($this->db_host, $this->db_user, $this->db_pwd);
  29. } else {
  30. //リンクが
  31. であっても $this->conn = mysql_connect($ this->db_host, $this->db_user, $this->db_pwd);
  32. }
  34. if (!mysql_select_db($this->db_database, $this->conn)) {
  35. if ($ this->show_error) {
  36. $this->show_error("データベースが使用できません使用: ", $this->db_database);
  37. }
  38. }
  39. mysql_query("SET NAMES $this->coding") ;
  40. }
  42. /*データベース実行ステートメント、実行可能なクエリ、追加、変更、削除など、任意の SQL ステートメント*/
  43. public function query($sql) {
  44. if ($sql == "") {
  45. $this ->show_error("SQL ステートメント エラー:", "SQL クエリ ステートメントが空です");
  46. }
  47. $this->sql = $sql;
  49. $result = mysql_query($this->sql, $this ->conn);
  51. if (!$result) {
  52. //デバッグで使用、SQL文 エラーが発生した場合、自動的に出力されます
  53. if ($this->show_error) {
  54. $this- >show_error("エラー SQL ステートメント: ", $this->sql);
  55. }
  56. } else {
  57. $this- >result = $result;
  58. }
  59. return $this->result;
  60. }
  62. /*新しいデータベースを作成して追加します*/
  63. public function create_database($database_name) {
  64. $database = $database_name;
  65. $sqlDatabase = 'データベースを作成します ' . $this->query($sqlDatabase) ;
  66. }
  68. /*サーバー上のすべてのデータベースをクエリ*/
  69. //より直観的に表示するためにシステム データベースをユーザー データベースから分離しますか?
  70. public function show_databases() {
  71. $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[データベース]";
  77. echo "
    ;
  78. $i++;
  79. }
  80. }
  82. //ホスト内のすべてのデータベース名を配列として返します
  83. public functiondatabases() {
  84. $rsPtr = mysql_list_dbs($this->conn);
  85. $i = 0;
  86. $cnt = mysql_num_rows($rsPtr);
  87. while ($i < $cnt) {
  88. $rs[] = mysql_db_name($rsPtr, $i);
  89. $i++;
  90. }
  91. return $rs;
  92. }
  94. /*データベース内のすべてのテーブルをクエリします*/
  95. public 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_" $データベース名;
  102. echo "$i $row[$columnName]";
  103. echo "
    ";
  104. $i++;
  105. }
  106. }
  108. /*
  109. mysql_fetch_row() array $row[0], $ row[1],$row[2]
  110. mysql_fetch_array() 配列 $row[0] または $row[id]
  111. mysql_fetch_assoc() 配列は $row->コンテンツ フィールドの大文字と小文字を区別します
  112. mysql_fetch_object() オブジェクトは $ row[ id],$row[content] フィールドは大文字と小文字が区別されます
  113. */
  115. /*結果データを取得*/
  116. public function mysql_result_li() {
  117. return mysql_result($str);
  118. }
  120. /*レコードセットを取得 ,配列インデックスと関連付けを取得します。 $row['content'] を使用します */
  121. public function fetch_array($resultt="") {
  122. if($resultt<>""){
  123. return mysql_fetch_array($resultt); }else{
  124. return mysql_fetch_array($this->result);
  125. }
  126. }
  128. //連想配列を取得し、$row['フィールド名']を使用します
  129. public function fetch_assoc() {
  130. return mysql_fetch_assoc($this) ->result);
  131. }
  133. //数値インデックス配列を取得し、$row[0],$row[1],$row[2]を使用します
  134. public function fetch_row() {
  135. return mysql_fetch_row($this- > ;result);
  136. }
  138. //オブジェクト配列を取得し、$row->content
  139. public function fetch_Object() {
  140. return mysql_fetch_object($this->result);
  141. }
  143. // クエリを簡素化select
  144. public function findall($table) {
  145. $this->query("SELECT * FROM $table");
  146. }
  148. // 簡略化されたクエリ select
  149. public function select($table, $columnName = "*" , $condition = '', $debug = '') {
  150. $condition = $condition ? ' Where ' . $condition : NULL;
  151. if ($debug) {
  152. echo "SELECT $columnName FROM $table $condition";
  153. } else {
  154. $this->query("SELECT $columnName FROM $table $condition");
  155. }
  156. }
  158. //簡易削除 del
  159. public function delete($table, $condition, $url = ' ') {
  160. if ($this->query("DELETE FROM $table WHERE $condition")) {
  161. if (!empty ($url))
  162. $this->Get_admin_msg($url, '削除に成功しました! ');
  163. }
  164. }
  166. //挿入
  167. public function insert($table, $columnName, $value, $url = '') {
  168. if ($this->query("INSERT INTO $table ( $columnName) VALUES ($value)")) {
  169. if (!empty ($url))
  170. $this->Get_admin_msg($url, '追加されました!');
  171. }
  172. }
  174. //简化修改update
  175. public function update($table, $mod_content, $condition, $url = '') {
  176. //echo "UPDATE $table SET $mod_content WHERE $condition"; exit();
  177. if ($this->query("UPDATE $table SET $mod_content WHERE $condition")) {
  178. if (!empty ($url))
  179. $this->Get_admin_msg($url);
  180. }
  181. }
  183. /*取得上一步 INSERT 操作产生的 ID*/
  184. public function insert_id() {
  185. return mysql_insert_id();
  186. }
  188. //指向确定的一条数据记录
  189. public function db_data_seek($id) {
  190. if ($id > 0) {
  191. $id = $id -1;
  192. }
  193. if (!@ mysql_data_seek($this->result, $id)) {
  194. $this->show_error("SQL语句有误：", "指定的数据为空");
  195. }
  196. return $this->result;
  197. }
  199. // 根据select查询结果计算结果集条数
  200. public function db_num_rows() {
  201. if ($this->result == null) {
  202. if ($this->show_error) {
  203. $this->show_error("SQL语句错误", "暂时为空，没有任何内容！");
  204. }
  205. } else {
  206. return mysql_num_rows($this->result);
  207. }
  208. }
  210. // 根据insert,update,delete执行结果取得影响行数
  211. public function db_affected_rows() {
  212. return mysql_affected_rows();
  213. }
  215. //输出显示sql语句
  216. public function show_error($message = "", $sql = "") {
  217. if (!$sql) {
  218. echo "" . $message . "";
  219. echo "
    ";
  220. } else {
  221. echo "
    ";
  222. echo "错误信息提示:
    ";
  223. echo "
    ";
  224. echo "
    ";
  225. echo "错误号：12142";
  226. 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 "字段数：" . ($this->result);
  • echo "
    ";</li>
<li> for ($i = 0; $i  print_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 协议情報を取得
  • Break;
  • default :
  • return mysql_get_client_info(); //默认mysql版本情報
  • }
  • }
  • //分析関数関数，自動关闭数据库,垃圾回收机制
  • public function __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);
  • }
  • function inject_check($sql_str) { // 注入を防ぐ
  • $check =eregi('select|insert|update|delete|'|/*|*|../|./|union|into|load_file|outfile',$sql_str);
  • if ($check) {
  • echo "输入非法注入内容！";
  • exit ();
  • } else {
  • return $sql_str;
  • }
  • }
  • function checkurl() { //检查来路
  • if (preg_replace("/https?://( [^:/]+).*/i", "\1", $_SERVER['HTTP_REFERER']) !== preg_replace("/([^:]+).*/", "\1", $_SERVER['HTTP_HOST'])) {
  • header("Location: http://www.dareng.com");
  • exit();
  • }
  • }
  • }
  • ?>
    • 复制代码
    php、mysql


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

    関連記事

    続きを見る