<?php

 header("content-type:text/html;charset=utf-8");

 error_reporting(E_ALL);

 /*

 连接数据库---类被实例化的自动连接

 获取提示信息的方法

 查询的方法

     单条查询

     多条查询

 增删改的方法

 统计记录数的方法

 关闭数据库、销毁资源----程序结束的时候调用

  */

 class dbManage{

     private $conn;  #保存数据库连接

     public $mess;  #保存提示信息

     /*

     方法名：__construct   构造方法

     方法功能: 类实例化的同时连接数据库

     方法参数：$hostname    主机地址

               $username   数据库用户名

               $password   数据库密码

               $dbname   数据库名称

      */

     public function __construct($hostname,$username,$password,$dbname){

         $this->conn=mysqli_connect($hostname,$username,$password,$dbname); #连接数据库

         //判断数据库是否正确连接

         if($this->conn){

             $this->getMessage('连接成功',true);

             $res=mysqli_query($this->conn,"set names utf8");

             //判断编码是否正确设置

             if($res){

                 $this->getMessage('数据库编码设置为utf8',true);

             }else{

                 $this->getMessage(mysqli_errno($this->conn).":".mysqli_error($this->conn),false);

             }

         }else{

             $this->getMessage('连接失败',false);

         }

     }

     /*

     方法名：getMessage

     方法功能: 改造提示信息

     方法参数：$info   提示信息

               $flag    true表示正确信息绿色文字   false  表示失败信息红色文字

      */

     public function getMessage($info,$flag){

         if($flag){

             $this->mess.="<div style='color:green;'>".$info."</div>";

         }else{

             $this->mess.="<div style='color:red;'>".$info."</div>";

         }

     }

     /*

     方法名： getMoreData

     方法功能: 获取多条记录

     方法参数：$sql  sql语句

      */

     public function getMoreData($sql){

         $rreg=preg_match('/^select/',trim($sql));#验证$sql是否为查询语句

         if($rreg){

             $data=mysqli_query($this->conn,$sql);

             //判断mysqli_query是否执行成功

             if($data){

             //将资源类型的数据$data改变成数组

             while($arr=mysqli_fetch_array($data,MYSQL_ASSOC)){

                 $res[]=$arr;

             }

             return $res;  #将执行成功结果返回

         }else{

             $this->getMessage(mysqli_errno($this->conn).":".mysqli_error($this->conn),false);

         }

         }else{

             $this->getMessage(__FUNCTION__.'()只能用于查询多条记录',false);

         }

     }

     /*

     方法名： getOneData

     方法功能: 获取单条记录

     方法参数：$sql  sql语句

      */

     public function getOneData($sql){

         $rreg=preg_match('/^select/',trim($sql));

         if($rreg){

             $data=mysqli_query($this->conn,$sql);

             if($data){

             $arr=mysqli_fetch_array($data,MYSQL_ASSOC);

             return $arr;

         }else{

             $this->getMessage(mysqli_errno($this->conn).":".mysqli_error($this->conn),false);

         }

         }else{

             $this->getMessage(__FUNCTION__.'()只能用于查询单条记录',false);

         }

     }

     /*

     方法名： execSql

     方法功能: 用于执行insert|update|delete|drop语句

     方法参数：$sql  sql语句

      */

     public function execSql($sql){

         $rreg=preg_match('/^insert|delete|update|drop/',trim($sql));

         if($rreg){

             $data=mysqli_query($this->conn,$sql);

             if($data){

                 $this->getMessage($sql.'语句执行成功',true);

                 return true;

             }else{

                 $this->getMessage(mysqli_errno($this->conn).":".mysqli_error($this->conn),false);

                 return false;

             }

         }else{

             $this->getMessage(__FUNCTION__.'()只能用于执行insert|update|delete|drop语句',false);

             return false;

         }

     }

     /*

     方法名： getRows

     方法功能: 获取满足条件的记录数

     方法参数：$tablename   表名称

               $tj   条件，默认为1,1表示统计整张表的记录数

      */

     public function getRows($tablename,$tj=1){

         // select count(*) from student where cj>80;

         $sql="select count(*) as c from ".$tablename." where ".$tj;

         $data=mysqli_query($this->conn,$sql);

         if($data){

             $arr=mysqli_fetch_array($data,MYSQL_ASSOC);

             // print_r($arr['c']);

             return $arr['c'];

         }else{

             $this->getMessage(mysql_errno($this->conn).":".mysqli_error($this->conn),false);

         }

     }

     /*

     方法名： __destruct   析构方法

     方法功能:销毁资源，关闭数据库   程序结束自动调用

     方法参数：无

      */

     public function __destruct(){

         mysqli_close($this->conn); #关闭数据库

         unset($this->mess);#销毁mess

     }

 }

 ?>