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

WBOY
リリース: 2016-07-25 08:42:00
オリジナル
882 人が閲覧しました

[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 です。問題が発生したときに何も表示されないのはユーザーにとって非常に不快なため、有効にしないことをお勧めします。
  12. /*コンストラクター*/
  13. public function __construct($db_host, $db_user, $db_pwd, $db_database, $conn, $coding) {
  14. $this->db_host = $db_host;
  15. $this->db_user = $db_user;
  16. $this->db_pwd = $db_pwd;
  17. $this->db_database = $db_database;
  18. $this->conn = $conn;
  19. $this->coding = $coding;
  20. $this ->connect();
  21. }
  22. /*データベース接続 */
  23. public function connect() {
  24. if ($this->conn == "pconn") {
  25. //永続リンク
  26. $this-> ;conn = mysql_pconnect($this->db_host, $this->db_user, $this->db_pwd);
  27. } else {
  28. //リンクが
  29. であっても $this->conn = mysql_connect($ this->db_host, $this->db_user, $this->db_pwd);
  30. }
  31. if (!mysql_select_db($this->db_database, $this->conn)) {
  32. if ($ this->show_error) {
  33. $this->show_error("データベースが使用できません使用: ", $this->db_database);
  34. }
  35. }
  36. mysql_query("SET NAMES $this->coding") ;
  37. }
  38. /*データベース実行ステートメント、実行可能なクエリ、追加、変更、削除など、任意の SQL ステートメント*/
  39. public function query($sql) {
  40. if ($sql == "") {
  41. $this ->show_error("SQL ステートメント エラー:", "SQL クエリ ステートメントが空です");
  42. }
  43. $this->sql = $sql;
  44. $result = mysql_query($this->sql, $this ->conn);
  45. if (!$result) {
  46. //デバッグで使用、SQL文 エラーが発生した場合、自動的に出力されます
  47. if ($this->show_error) {
  48. $this- >show_error("エラー SQL ステートメント: ", $this->sql);
  49. }
  50. } else {
  51. $this- >result = $result;
  52. }
  53. return $this->result;
  54. }
  55. /*新しいデータベースを作成して追加します*/
  56. public function create_database($database_name) {
  57. $database = $database_name;
  58. $sqlDatabase = 'データベースを作成します ' . $this->query($sqlDatabase) ;
  59. }
  60. /*サーバー上のすべてのデータベースをクエリ*/
  61. //より直観的に表示するためにシステム データベースをユーザー データベースから分離しますか?
  62. public function show_databases() {
  63. $this->query("show Databases");
  64. echo "既存のデータベース:" . $amount = $this->db_num_rows($rs);
  65. echo "
    ";
  66. $i = 1;
  67. while ($row = $this->fetch_array($rs)) {
  68. echo "$i $row[データベース]";
  69. echo "
    ;
  70. $i++;
  71. }
  72. }
  73. //ホスト内のすべてのデータベース名を配列として返します
  74. public functiondatabases() {
  75. $rsPtr = mysql_list_dbs($this->conn);
  76. $i = 0;
  77. $cnt = mysql_num_rows($rsPtr);
  78. while ($i < $cnt) {
  79. $rs[] = mysql_db_name($rsPtr, $i);
  80. $i++;
  81. }
  82. return $rs;
  83. }
  84. /*データベース内のすべてのテーブルをクエリします*/
  85. public function show_tables($database_name) {
  86. $this->query("show tables");
  87. echo "既存のデータベース:" $amount = $this-> ; db_num_rows($rs);
  88. echo "
    ";
  89. $i = 1;
  90. while ($row = $this->fetch_array($rs)) {
  91. $columnName = "Tables_in_" $データベース名;
  92. echo "$i $row[$columnName]";
  93. echo "
    ";
  94. $i++;
  95. }
  96. }
  97. /*
  98. mysql_fetch_row() array $row[0], $ row[1],$row[2]
  99. mysql_fetch_array() 配列 $row[0] または $row[id]
  100. mysql_fetch_assoc() 配列は $row->コンテンツ フィールドの大文字と小文字を区別します
  101. mysql_fetch_object() オブジェクトは $ row[ id],$row[content] フィールドは大文字と小文字が区別されます
  102. */
  103. /*結果データを取得*/
  104. public function mysql_result_li() {
  105. return mysql_result($str);
  106. }
  107. /*レコードセットを取得 ,配列インデックスと関連付けを取得します。 $row['content'] を使用します */
  108. public function fetch_array($resultt="") {
  109. if($resultt<>""){
  110. return mysql_fetch_array($resultt); }else{
  111. return mysql_fetch_array($this->result);
  112. }
  113. }
  114. //連想配列を取得し、$row['フィールド名']を使用します
  115. public function fetch_assoc() {
  116. return mysql_fetch_assoc($this) ->result);
  117. }
  118. //数値インデックス配列を取得し、$row[0],$row[1],$row[2]を使用します
  119. public function fetch_row() {
  120. return mysql_fetch_row($this- > ;result);
  121. }
  122. //オブジェクト配列を取得し、$row->content
  123. public function fetch_Object() {
  124. return mysql_fetch_object($this->result);
  125. }
  126. // クエリを簡素化select
  127. public function findall($table) {
  128. $this->query("SELECT * FROM $table");
  129. }
  130. // 簡略化されたクエリ select
  131. public function select($table, $columnName = "*" , $condition = '', $debug = '') {
  132. $condition = $condition ? ' Where ' . $condition : NULL;
  133. if ($debug) {
  134. echo "SELECT $columnName FROM $table $condition";
  135. } else {
  136. $this->query("SELECT $columnName FROM $table $condition");
  137. }
  138. }
  139. //簡易削除 del
  140. public function delete($table, $condition, $url = ' ') {
  141. if ($this->query("DELETE FROM $table WHERE $condition")) {
  142. if (!empty ($url))
  143. $this->Get_admin_msg($url, '削除に成功しました! ');
  144. }
  145. }
  146. //挿入
  147. public function insert($table, $columnName, $value, $url = '') {
  148. if ($this->query("INSERT INTO $table ( $columnName) VALUES ($value)")) {
  149. if (!empty ($url))
  150. $this->Get_admin_msg($url, '追加されました!');
  151. }
  152. }
  153. //简化修改update
  154. public function update($table, $mod_content, $condition, $url = '') {
  155. //echo "UPDATE $table SET $mod_content WHERE $condition"; exit();
  156. if ($this->query("UPDATE $table SET $mod_content WHERE $condition")) {
  157. if (!empty ($url))
  158. $this->Get_admin_msg($url);
  159. }
  160. }
  161. /*取得上一步 INSERT 操作产生的 ID*/
  162. public function insert_id() {
  163. return mysql_insert_id();
  164. }
  165. //指向确定的一条数据记录
  166. public function db_data_seek($id) {
  167. if ($id > 0) {
  168. $id = $id -1;
  169. }
  170. if (!@ mysql_data_seek($this->result, $id)) {
  171. $this->show_error("SQL语句有误:", "指定的数据为空");
  172. }
  173. return $this->result;
  174. }
  175. // 根据select查询结果计算结果集条数
  176. public function db_num_rows() {
  177. if ($this->result == null) {
  178. if ($this->show_error) {
  179. $this->show_error("SQL语句错误", "暂时为空,没有任何内容!");
  180. }
  181. } else {
  182. return mysql_num_rows($this->result);
  183. }
  184. }
  185. // 根据insert,update,delete执行结果取得影响行数
  186. public function db_affected_rows() {
  187. return mysql_affected_rows();
  188. }
  189. //输出显示sql语句
  190. public function show_error($message = "", $sql = "") {
  191. if (!$sql) {
  192. echo "" . $message . "";
  193. echo "
    ";
  194. } else {
  195. echo "
    ";
  196. echo "错误信息提示:
    ";
  197. echo "
    ";
  198. echo "
    ";
  199. echo "错误号:12142";
  200. 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


    関連ラベル:
    ソース:php.cn
    このウェブサイトの声明
    この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
    最新の問題
    人気のチュートリアル
    詳細>
    最新のダウンロード
    詳細>
    ウェブエフェクト
    公式サイト
    サイト素材
    フロントエンドテンプレート
    私たちについて 免責事項 Sitemap
    PHP中国語ウェブサイト:福祉オンライン PHP トレーニング,PHP 学習者の迅速な成長を支援します!