> 백엔드 개발 > PHP 튜토리얼 > mysql을 동작시키기 위한 PHP 클래스

mysql을 동작시키기 위한 PHP 클래스

WBOY
풀어 주다: 2016-07-25 08:42:00
원래의
958명이 탐색했습니다.

[PHP] 코드

  1. class mysql {
  2. private $db_host; //데이터베이스 호스트
  3. private $db_user; //데이터베이스 사용자 이름
  4. private $ db_pwd; //데이터베이스 사용자 이름 및 비밀번호
  5. private $db_database; //데이터베이스 이름
  6. private $conn; //데이터베이스 연결 식별자;
  7. private $result; command
  8. private $sql; //SQL 실행 문
  9. private $row; //반환된 항목 수
  10. private $coding; //데이터베이스 인코딩, GBK, UTF8, gb2312
  11. private $bulletin true; / /오류 로깅 활성화 여부
  12. private $show_error = false; //테스트 단계에서는 보안 위험이 있는 모든 오류가 표시됩니다.
  13. private $is_error = false ; //오류 발견 시 즉시 종료할지 여부, 기본값은 true, 권장 문제가 있을 때 사용자에게 아무것도 표시되지 않는 것이 매우 답답하기 때문에 활성화하지 않음
  14. /*Constructor*/
  15. public function __construct($db_host, $db_user, $db_pwd, $db_database, $ conn, $coding) {
  16. $this->db_host = $db_host;
  17. $this->db_user = $db_user;
  18. $this->db_pwd = $db_pwd;
  19. $this ->db_database = $db_database;
  20. $this->conn = $conn;
  21. $this->coding = $coding;
  22. $this->connect();
  23. }
  24. /*데이터베이스 연결*/
  25. 공용 함수 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. }
  33. if (!mysql_select_db($this->db_database, $this->conn)) {
  34. if ($this->show_error) {
  35. $this->show_error( "데이터베이스를 사용할 수 없음:", $this->db_database);
  36. }
  37. }
  38. mysql_query("SET NAMES $this->coding");
  39. }
  40. /*데이터베이스 실행문, 실행 쿼리, 추가, 수정, 삭제 등 모든 SQL 문*/
  41. public function query($sql) {
  42. if ($sql == "") {
  43. $ this->show_error("SQL 문 오류:", "SQL 쿼리 문이 비어 있습니다.");
  44. }
  45. $this->sql = $sql;
  46. $result = mysql_query( $this->sql, $this->conn);
  47. if ( !$result) {
  48. //디버깅에 사용되며 SQL 문에서 오류가 발생하면 자동으로 인쇄됩니다.
  49. if ($this->show_error) {
  50. $this->show_error("오류 SQL 문: ", $this->sql);
  51. }
  52. } else {
  53. $this->result = $result;
  54. }
  55. return $this->result;
  56. }
  57. /*새 데이터베이스 생성 및 추가*/
  58. public function create_database($database_name) {
  59. $database = $database_name;
  60. $sqlDatabase = '데이터베이스 생성' .
  61. $this->query($sqlDatabase);
  62. }
  63. /*서버의 모든 데이터베이스 쿼리*/
  64. //보다 직관적인 표시를 위해 시스템 데이터베이스와 사용자 데이터베이스를 분리 ?
  65. 공개 함수 show_databases() {
  66. $this->query("showdatabases");
  67. echo "기존 데이터베이스:" . $amount = $this->db_num_rows($rs); 🎜> echo "
    ";
  68. $i = 1;
  69. while ($row = $this->fetch_array($rs)) {
  70. echo "$i $row [ Database]";
  71. echo "
    ";
  72. $i ;
  73. }
  74. }
  75. //호스트에 있는 모든 데이터베이스 이름을 배열 형식으로 반환
  76. 공용 함수 데이터베이스() {
  77. $rsPtr = mysql_list_dbs($this->conn);
  78. $i = 0;
  79. $cnt = mysql_num_rows($rsPtr);
  80. while($ i < $cnt) {
  81. $rs[] = mysql_db_name($rsPtr, $i);
  82. $i ;
  83. }
  84. return $rs;
  85. }
  86. /*데이터베이스 아래의 모든 테이블 쿼리*/
  87. public function show_tables($database_name) {
  88. $this->query("show tables");
  89. echo "기존 데이터베이스:" $ amount. = $this->db_num_rows($rs);
  90. echo "
    ";
  91. $i = 1;
  92. while ($row = $this->fetch_array($ rs )) {
  93. $columnName = "테이블_in_" . $database_name;
  94. echo "$i $row[$columnName]";
  95. echo "
    ";
  96. $i ;
  97. }
  98. }
  99. /*
  100. mysql_fetch_row() 배열 $row[0],$row[1],$row[2]
  101. mysql_fetch_array() 배열 $row [ 0] 또는 $row[id]
  102. mysql_fetch_assoc() 배열은 $row->content 필드 대소문자 구분을 사용합니다.
  103. mysql_fetch_object() 객체는 $row[id],$row[content] 필드 대소문자 구분을 사용합니다.
  104. */
  105. /*결과 데이터 가져오기*/
  106. public function mysql_result_li() {
  107. return mysql_result($str);
  108. }
  109. /*Get Recordset, get 배열 인덱스 및 연관, $row['content'] 사용 */
  110. public function fetch_array($resultt="") {
  111. if($resultt<>""){
  112. return mysql_fetch_array( $resultt);
  113. }else{
  114. return mysql_fetch_array($this->result);
  115. }
  116. }
  117. //연관 배열을 가져오고 $ row['를 사용합니다. field name']
  118. public function fetch_assoc() {
  119. return mysql_fetch_assoc($this->result);
  120. }
  121. //숫자 인덱스 배열을 가져오고 $row [0 사용 ],$row[1],$row[2]
  122. public function fetch_row() {
  123. return mysql_fetch_row($this->result);
  124. }
  125. // 가져오려면 객체 배열, $row->content 사용
  126. public function fetch_Object() {
  127. return mysql_fetch_object($this->result);
  128. }
  129. //단순 쿼리 select
  130. public function findall($table) {
  131. $this->query("SELECT * FROM $table");
  132. }
  133. //간단한 쿼리 select
  134. public function select ($table, $columnName = "*", $condition = '', $debug = '') {
  135. $condition = $condition ? ' Where ' . $condition : NULL;
  136. if ($debug) {
  137. echo "SELECT $columnName FROM $table $condition";
  138. } else {
  139. $this->query("SELECT $columnName FROM $table $condition");
  140. }
  141. }
  142. //간단한 삭제 del
  143. public function delete($table, $condition, $url = '') {
  144. if ($this->query("DELETE FROM $table WHERE $condition")) {
  145. if (!empty ($url))
  146. $this->Get_admin_msg($url, '삭제에 성공했습니다! ');
  147. }
  148. }
  149. //단순 삽입 insert
  150. public function insert($table, $columnName, $value, $url = '') {
  151. if ( $this->query("INSERT INTO $table ($columnName) VALUES ($value)")) {
  152. if (!empty ($url))
  153. $this->Get_admin_msg($url, '성공적으로 추가되었습니다!');
  154. }
  155. }
  156. //简化修改update
  157. public function update($table, $mod_content, $condition, $url = '') {
  158. //echo "UPDATE $table SET $mod_content WHERE $condition"; exit();
  159. if ($this->query("UPDATE $table SET $mod_content WHERE $condition")) {
  160. if (!empty ($url))
  161. $this->Get_admin_msg($url);
  162. }
  163. }
  164. /*取得上一步 INSERT 操作产生的 ID*/
  165. public function insert_id() {
  166. return mysql_insert_id();
  167. }
  168. //指向确定的一条数据记录
  169. public function db_data_seek($id) {
  170. if ($id > 0) {
  171. $id = $id -1;
  172. }
  173. if (!@ mysql_data_seek($this->result, $id)) {
  174. $this->show_error("SQL语句有误:", "指定的数据为空");
  175. }
  176. return $this->result;
  177. }
  178. // 根据select查询结果计算结果集条数
  179. public function db_num_rows() {
  180. if ($this->result == null) {
  181. if ($this->show_error) {
  182. $this->show_error("SQL语句错误", "暂时为空,没有任何内容!");
  183. }
  184. } else {
  185. return mysql_num_rows($this->result);
  186. }
  187. }
  188. // 根据insert,update,delete执行结果取得影响行数
  189. public function db_affected_rows() {
  190. return mysql_affected_rows();
  191. }
  192. //输出显示sql语句
  193. public function show_error($message = "", $sql = "") {
  194. if (!$sql) {
  195. echo "" . $message . "";
  196. echo "
    ";
  197. } else {
  198. echo "
    ";
  199. echo "错误信息提示:
    ";
  200. echo "
    ";
  201. echo "
    ";
  202. echo "错误号:12142";
  203. 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; $i < $total; $i ) {<li> print_r(mysql_fetch_field($this->result , $i) );</li>
    <li> }</li>
    <li> echo "
    ";
  • echo "
    ";
  • }
  • //MySQL 서버 가져오기 information
  • public function mysql_server($num = '') {
  • 스위치($num) {
  • 사례 1 :
  • return mysql_get_server_info() //MySQL 서버 정보
  • break;
  • 사례 2 :
  • return mysql_get_host_info(); //MySQL 호스트 정보 가져오기
  • break;
  • 사례 3 :
  • return mysql_get_client_info(); //MySQL 클라이언트 정보 가져오기
  • break ;
  • 사례 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);
  • } //함수 __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"), "알 수 없음")) {
  • $ip = getenv(" HTTP_X_FORWARDED_FOR");
  • } else
  • if (getenv("REMOTE_ADDR") && strcasecmp(getenv("REMOTE_ADDR"), "알 수 없음")) {
  • $ip = getenv("REMOTE_ADDR ");
  • } else
  • if (isset ($_SERVER['REMOTE_ADDR']) && $_SERVER['REMOTE_ADDR'] &&strcasecmp($_SERVER['REMOTE_ADDR'], "알 수 없음")) {
  • $ip = $ _SERVER['REMOTE_ADDR'];
  • } else {
  • $ip = "알 수 없음";
  • }
  • return ($ip);
  • }
  • function inject_check( $sql_str) { //삽입 방지
  • $check =eregi('select|insert|update|delete|'|/*|*|../|./|union|into|load_file|outfile',$sql_str );
  • if ($check) {
  • echo "불법 주입 내용을 입력하세요! ";
  • 종료 ();
  • } else {
  • return $sql_str;
  • }
  • }
  • function checkurl() { //소스 확인
  • if (preg_replace( "/https?://([^:/] ).*/i", "\1", $_SERVER['HTTP_REFERER']) !== preg_replace("/([^:] ).*/" , "\1", $_SERVER['HTTP_HOST'])) {
  • header("위치: http://www.dareng.com");
  • exit();
  • }
  • }
  • }
  • ?>
  • 코드 복사
    PHP, MySQL


    관련 라벨:
    원천:php.cn
    본 웹사이트의 성명
    본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
    최신 이슈
    인기 튜토리얼
    더>
    최신 다운로드
    더>
    웹 효과
    웹사이트 소스 코드
    웹사이트 자료
    프론트엔드 템플릿