DBDA类

<?php
class DBDA
{
    public $host="localhost";    //服务器地址
    public $uid="root";             //用户名
    public $pwd="123";             //密码
    
    public $dbconnect; //连接对象
    
    //操作数据库的方法
    //$sql代表需要执行的SQL语句
    //$type代表SQL语句的类型,1代表查询,2代表增删改
    //$dbname代表要操作的数据库名称
    //如果是查询,返回二维数组
    //如果是增删改,返回true或false
    function Query($sql,$type=1,$dbname="yhmgc")
    {
        //造连接对象
        $this->dbconnect = new MySQLi($this->host,$this->uid,$this->pwd,$dbname);
        //判断是否出错
        if(!mysqli_connect_error())
        {
            //如果连接成功,执行SQL语句
            $result = $this->dbconnect->query($sql);
            
            //根据语句类型判断
            if($type==1)
            {
                //如果是查询语句,返回二维数组
                return $result->fetch_all();
            }
            else
            {
                //如果是其他语句,返回true或false
                return $result;
            }
        }
        else
        {
            return "连接失败!";
        }
    }
    /*ajax text 返回类型*/
    public function StrQuery($sql,$type=2,$dbname="yhmgc")
    {
        //造连接对象
        $this->dbconnect= new MYSQLi($this->host,$this->uid,$this->pwd,$dbname);
        if (!mysqli_connect_error())
        {
            //如果连接成功,执行sql语句
            $result = $this->dbconnect->query($sql);
            //根据语句判断
            if($type==2){
            $attr = $result->fetch_all();
            $str = "";
            //如果是查询语句返回字符串
            for($i=0;$i<count($attr);$i++){
                for($j=0;$j<count($attr[$i]);$j++){
                    $str = $str.$attr[$i][$j];
                    $str = $str."^";
                }
                $str = substr($str,0,strlen($str)-1);
                $str = $str."|";
            }
            $str = substr($str,0,strlen($str)-1);
            return $str;
            }
            else
            {
                    //如果是其他语句,返回true或false
            if($result){
                return "OK";
            }else{
                return "NO";
            }
            }
        }
        else
        {    
             return "连接失败";
        }
    }
      /*ajax json 返回类型*/
    public function JsonQuery($sql,$type=2,$dbname="yhmgc")
    {
        //造连接对象
        $this->dbconnect= new MYSQLi($this->host,$this->uid,$this->pwd,$dbname);
        if (!mysqli_connect_error())
        {
            //如果连接成功,执行sql语句
            $result = $this->dbconnect->query($sql);
            //根据语句判断
            if($type==2)
            {        
                $attr=$result->fetch_assoc();
                return json_encode($attr);
            
            }
            else
            {
                    //如果是其他语句,返回true或false
            if($result){
                return "OK";
            }else{
                return "NO";
            }
            }
        }
        else
        {    
             return "连接失败";
        }
    }
}
View Code
原文地址:https://www.cnblogs.com/bilibiliganbei/p/6415573.html