찾다

집  >  기사  >  백엔드 개발  >  mysql 데이터베이스에 연결하기 위한 PHP 클래스

mysql 데이터베이스에 연결하기 위한 PHP 클래스

WBOY
WBOY원래의
2016-07-25 08:59:06871검색
  2. /*
  3. * 파일 이름: mysql 데이터베이스 연결 클래스
  4. * bbs.it-home.org 편집
  5. * /
  6. class mysql{
  7. private $db_host; //데이터베이스 호스트
  8. private $db_user; //데이터베이스 사용자 이름
  9. private $db_pwd; //데이터베이스 사용자 이름 및 비밀번호
  10. private $db_database; /데이터베이스 이름
  11. private $conn; //데이터베이스 연결 식별자;
  12. private $result; //쿼리 명령 실행 결과 식별자
  13. private $sql; //SQL 실행 문
  14. private $ row; //반환된 항목 수
  15. private $coding; //데이터베이스 인코딩, GBK, UTF8, gb2312
  16. private $bulletin = true; //오류 로깅 활성화 여부
  17. private $show_error = true; 테스트 단계는 모든 오류를 표시하며 보안 위험이 있으며 기본적으로 꺼져 있습니다.
  18. private $is_error = false; //오류 발견 시 즉시 종료할지 여부, 기본값은 true이므로 활성화하지 않는 것이 좋습니다. 문제가 있을 때 사용자가 아무것도 볼 수 없기 때문에 매우 괴로움
  19. /*Constructor*/
  20. 공용 함수 __construct($db_host,$db_user,$db_pwd,$db_database,$conn,$coding){
  21. $this->db_host=$db_host ;
  22. $this->db_user=$db_user;
  23. $this->db_pwd = $db_pwd;
  24. $this->db_database=$db_database;
  25. $this->conn= $conn;
  26. $this->coding=$coding;
  27. $this->connect();
  28. }
  29. /*데이터베이스 연결*/
  30. 공용 함수 connect()
  31. {
  32. if($this->conn=="pconn"){
  33. //영구 링크
  34. $this->conn=mysql_pconnect($ this->db_host,$this- >db_user,$this->db_pwd);
  35. }else{
  36. //인스턴트 링크
  37. $this->conn=mysql_connect($this-> ;db_host,$this->db_user ,$this->db_pwd);
  38. }
  39. if(!mysql_select_db($this->db_database,$this->conn)){
  40. if ($this->show_error){
  41. $this->show_error("데이터베이스를 사용할 수 없음:",$this->db_database);
  42. }
  43. }
  44. mysql_query("이름 설정 $this->coding");
  45. }
  46. /*데이터베이스 실행문, 실행 쿼리, 추가, 수정, 삭제 등 모든 sql 문*/
  47. 공용 함수 쿼리($sql)
  48. {
  49. if($sql == "" ){
  50. $this->show_error("sql 문 오류:","sql 쿼리 문이 비어 있습니다.");}
  51. $this-> sql = $sql;
  52. $result = mysql_query( $this->sql,$this->conn);
  53. if(!$result){
  54. //디버깅에 사용하면 자동으로 sql 문에서 오류가 발생하면 출력
  55. if($this- >show_error){
  56. $this->show_error("Error sql 문: ",$this->sql);
  57. }
  58. }else{
  59. $this->result = $result;
  60. }
  61. return $this->result;
  62. }
  63. /*새 항목을 만들고 추가합니다. 데이터베이스*/
  64. 공용 함수 create_database($database_name){
  65. $database =$database_name;
  66. $sqlDatabase = '데이터베이스 생성'.$database;
  67. $this->query($sqlDatabase) ;
  68. }
  69. /*서버의 모든 데이터베이스 쿼리*/
  70. //더 직관적인 표시를 위해 시스템 데이터베이스와 사용자 데이터베이스를 분리하시겠습니까?
  71. public function show_databases(){
  72. $rs=$this->query("show databases");
  73. echo "现有数据库：".$amount =$this->db_num_rows($rs);
  74. echo "
    ";
  75. $i=1;
  76. while($row = $this->fetch_array($rs)){
  77. echo "$i $row[Database]";
  78. echo "
    ";
  79. $i++;
  80. }
  81. }
  82. //以数组形式返回主机中所有数据库名
  83. public function databases()
  84. {
  85. $rsPtr=mysql_list_dbs($this->conn);
  86. $i=0;
  87. $cnt=mysql_num_rows($rsPtr);
  88. while($i<$cnt)
  89. {
  90. $rs[]=mysql_db_name($rsPtr,$i);
  91. $i++;
  92. }
  93. return $rs;
  94. }
  95. /*查询数据库下所有的表*/
  96. function show_tables($database_name){
  97. $this->query("show tables");
  98. echo "现有数据库：".$amount = $this->db_num_rows($rs);
  99. echo "
    ";
  100. $i=1;
  101. while($row = $this->fetch_array($rs)){
  102. $columnName="Tables_in_".$database_name;
  103. echo "$i $row[$columnName]";
  104. echo "
    ";
  105. $i++;
  106. }
  107. }
  108. /*
  109. mysql_fetch_row() array $row[0],$row[1],$row[2]
  110. mysql_fetch_array() array $row[0] 或 $row[id]
  111. mysql_fetch_assoc() array 用$row->content 字段大小写敏感
  112. mysql_fetch_object() object 用$row[id],$row[content] 字段大小写敏感
  113. */
  114. /*取得结果数据*/
  115. public function mysql_result_li()
  116. {
  117. return mysql_result($str);
  118. }
  119. /*取得记录集,获取数组-索引和关联,使用$row['content'] */
  120. public function fetch_array()
  121. {
  122. return mysql_fetch_array($this->result);
  123. }
  124. //获取关联数组,使用$row['字段名']
  125. public function fetch_assoc()
  126. {
  127. return mysql_fetch_assoc($this->result);
  128. }
  129. //获取数字索引数组,使用$row[0],$row[1],$row[2]
  130. public function fetch_row()
  131. {
  132. return mysql_fetch_row($this->result);
  133. }
  134. //获取对象数组,使用$row->content
  135. public function fetch_Object()
  136. {
  137. return mysql_fetch_object($this->result);
  138. }
  139. //简化查询select
  140. public function findall($table)
  141. {
  142. $this->query("SELECT * FROM $table");
  143. }
  144. //简化查询select
  145. public function select($table,$columnName,$condition)
  146. {
  147. if($columnName==""){
  148. $columnName="*";
  149. }
  150. $this->query("SELECT $columnName FROM $table $condition");
  151. }
  152. //简化删除del
  153. public function delete($table,$condition){
  154. $this->query("DELETE FROM $table WHERE $condition");
  155. }
  156. //简化插入insert
  157. public function insert($table,$columnName,$value){
  158. $this->query("INSERT INTO $table ($columnName) VALUES ($value)");
  159. }
  160. //简化修改update
  161. public function update($table,$mod_content,$condition){
  162. $this->query("UPDATE $table SET $mod_content WHERE $condition");
  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 "
    ";
  • }
  • //결과 세트 해제
  • 공개 함수 free(){
  • @mysql_free_result($this->result);
  • }
  • //데이터베이스 선택
  • 공개 함수 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 "< pre>";
  • for ($i=0; $i<$total; $i ){
  • print_r(mysql_fetch_field($this->result,$i) );
  • }
  • echo "< /pre>";
  • echo "
    ";
  • }
  • //MySQL 서버 정보 가져오기
  • 공개 함수 mysql_server($num=''){
  • 스위치( $num){
  • 케이스 1 :
  • return mysql_get_server_info(); //MySQL 서버 정보
  • break;
  • 케이스 2 :
  • return mysql_get_host_info(); 호스트 정보
  • 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 버전 정보 가져오기
  • }
  • }
  • //Destructor, 자동으로 데이터베이스 닫기, 가비지 수집 메커니즘
  • 공용 함수 __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"), "알 수 없음"))
  • {
  • $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);
  • }
  • }
  • ?>
    • 코드 복사


    성명：
    본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
    이전 기사：디렉토리의 파일 내용을 검색하기 위한 PHP 코드 예제다음 기사：디렉토리의 파일 내용을 검색하기 위한 PHP 코드 예제

    관련 기사

    더보기