数据库操作类登陆

数据库操作类

新建数据库连接类MysqlDatabase.class.php

1,数据库连接需要用到的属性

<?php
/**
 * Created by PhpStorm.
 * User: Administrator
 * Date: 2018/3/3 0003
 * Time: 下午 2:57
 */
class MysqlDatabase{
    //数据库连接信息
    private $dbConfig=array(
        'host'=>'localhost',
        'port'=>'3306',
        'user'=>'root',
        'pwd'=>'root',
        'charset'=>'utf8',
        'dbname'=>'php',
    );
    //数据库连接资源
    private $link;
    }

2,初始化属性

<?php
private function initAttr($params){
    //初始化属性
    $this->dbConfig=array_merge($this->dbConfig,$params);
}

3,连接数数据库

<?php
//获取数据库连接
private function connectServer(){
    $host=$this->dbConfig['host'];
    $port=$this->dbConfig['port'];
    $user=$this->dbConfig['user'];
    $pwd=$this->dbConfig['pwd'];
    //连接数据库服务器
    if ($link=mysql_connect("$host:$port",$user,$pwd)){
        $this->link=$link;
    }else{
        die('数据库连接失败,请确认信息!'.mysql_error());
    }
}

4,查询数据库显示错误信息

<?php
//查询数据库显示错误信息
function query($sql){
    if($result=mysql_query($sql)){
        //执行成功
        return $result;
    }else{
        //执行失败,显示错误信息以便于调试程序
        echo 'sql执行失败:<br>';
        echo '错误的sql为:',$sql,'<br>';
        echo '错误的代码为:',mysql_errno(),'<br>';
        echo '错误的信息为:',mysql_error(),'<br>';
        die();
    }
}

5,设定字符集

<?php
//设定连接字符集
private function setCharset(){
    $sql="set names {$this->dbConfig['charset']}";
    $this->query($sql);
}

6,构造参数

<?php
//构造方法
public function __construct($params=array())
{
    //初始化属性
    $this->initAttr($params);
    //连接数数据库
    $this->connectServer();
    //设定字符集
    $this->setCharset();
}

7,查询单条数据并返回结果集

<?php
//查询单条数据并返回结果集
    function fetchRow($sql){
        //执行query()函数
        if($result=query($sql)){
            //从结果集取得依次数据即可
            $row=mysql_fetch_array($result,MYSQL_ASSOC);
            return $row;
        }else{
            return false;
        }
    }

8,查询所有数据并返回结果集

<?php
//查询所有数据并返回结果集
    function fetchAll($sql){
        //执行query()函数
        if($result=query($sql)){
            //执行成功
            //遍历结果集
            $rows=array();
            while($row=mysql_fetch_array($result,MYSQL_ASSOC)){
                $rows[]=$row;
            }
            //释放结果集资源
            mysql_free_result($result);
            return $rows;
        }else{
            //执行失败
            return false;
        }
    }

9,全部代码整体展示:

<?php
/**
 * Created by PhpStorm.
 * User: Administrator
 * Date: 2018/3/3 0003
 * Time: 下午 2:57
 */
class MysqlDatabase{
    //数据库连接信息
    private $dbConfig=array(
        'host'=>'localhost',
        'port'=>'3306',
        'user'=>'root',
        'pwd'=>'root',
        'charset'=>'utf8',
        'dbname'=>'php',
    );
    //数据库连接资源
    private $link;
    //构造方法,私有化可以防止类在外部被实例化
    private function __construct($params=array())
    {
        //初始化属性
        $this->initAttr($params);
        //连接数数据库
        $this->connectServer();
        //设定字符集
        $this->setCharset();
    }
    private function initAttr($params){
        //初始化属性
        $this->dbConfig=array_merge($this->dbConfig,$params);
    }
    //获取数据库连接
    private function connectServer(){
        $host=$this->dbConfig['host'];
        $port=$this->dbConfig['port'];
        $user=$this->dbConfig['user'];
        $pwd=$this->dbConfig['pwd'];
        //连接数据库服务器
        if ($link=mysql_connect("$host:$port",$user,$pwd)){
            $this->link=$link;
        }else{
            die('数据库连接失败,请确认信息!'.mysql_error());
        }
    }
    //设定连接字符集
    private function setCharset(){
        $sql="set names {$this->dbConfig['charset']}";
        $this->query($sql);
    }
    //查询数据库显示错误信息
    function query($sql){
        if($result=mysql_query($sql)){
            //执行成功
            return $result;
        }else{
            //执行失败,显示错误信息以便于调试程序
            echo 'sql执行失败:<br>';
            echo '错误的sql为:',$sql,'<br>';
            echo '错误的代码为:',mysql_errno(),'<br>';
            echo '错误的信息为:',mysql_error(),'<br>';
            die();
        }
    }
//查询所有数据并返回结果集
    function fetchAll($sql){
        //执行query()函数
        if($result=query($sql)){
            //执行成功
            //遍历结果集
            $rows=array();
            while($row=mysql_fetch_array($result,MYSQL_ASSOC)){
                $rows[]=$row;
            }
            //释放结果集资源
            mysql_free_result($result);
            return $rows;
        }else{
            //执行失败
            return false;
        }
    }
//查询单条数据并返回结果集
    function fetchRow($sql){
        //执行query()函数
        if($result=query($sql)){
            //从结果集取得依次数据即可
            $row=mysql_fetch_array($result,MYSQL_ASSOC);
            return $row;
        }else{
            return false;
        }
    }
    //限制脚本实例化多个对象
    //单例对象调用
    private static $instance;
    //接下来私有化构造方法
    public static function getInstance($params=array()){
        //判断是否没有实例化过
        if(!self::$instance instanceof self){
            //如果未被实例化
            self::$instance=new self($params);
        }
        //返回对象
        return self::$instance;
    }
    //私有克隆,在外部调用克隆clone $对象名,会调用clone方法复制这个对象
    private function __clone()
    {
        // TODO: Implement __clone() method.
    }
}


下一节
<?php /** * Created by PhpStorm. * User: Administrator * Date: 2018/3/3 0003 * Time: 下午 2:57 */ class MysqlDatabase{ //数据库连接信息 private $dbConfig=array( 'host'=>'localhost', 'port'=>'3306', 'user'=>'root', 'pwd'=>'root', 'charset'=>'utf8', 'dbname'=>'php', ); //数据库连接资源 private $link; //构造方法,私有化可以防止类在外部被实例化 private function __construct($params=array()) { //初始化属性 $this->initAttr($params); //连接数数据库 $this->connectServer(); //设定字符集 $this->setCharset(); } private function initAttr($params){ //初始化属性 $this->dbConfig=array_merge($this->dbConfig,$params); } //获取数据库连接 private function connectServer(){ $host=$this->dbConfig['host']; $port=$this->dbConfig['port']; $user=$this->dbConfig['user']; $pwd=$this->dbConfig['pwd']; //连接数据库服务器 if ($link=mysql_connect("$host:$port",$user,$pwd)){ $this->link=$link; }else{ die('数据库连接失败,请确认信息!'.mysql_error()); } } //设定连接字符集 private function setCharset(){ $sql="set names {$this->dbConfig['charset']}"; $this->query($sql); } //查询数据库显示错误信息 function query($sql){ if($result=mysql_query($sql)){ //执行成功 return $result; }else{ //执行失败,显示错误信息以便于调试程序 echo 'sql执行失败:<br>'; echo '错误的sql为:',$sql,'<br>'; echo '错误的代码为:',mysql_errno(),'<br>'; echo '错误的信息为:',mysql_error(),'<br>'; die(); } } //查询所有数据并返回结果集 function fetchAll($sql){ //执行query()函数 if($result=query($sql)){ //执行成功 //遍历结果集 $rows=array(); while($row=mysql_fetch_array($result,MYSQL_ASSOC)){ $rows[]=$row; } //释放结果集资源 mysql_free_result($result); return $rows; }else{ //执行失败 return false; } } //查询单条数据并返回结果集 function fetchRow($sql){ //执行query()函数 if($result=query($sql)){ //从结果集取得依次数据即可 $row=mysql_fetch_array($result,MYSQL_ASSOC); return $row; }else{ return false; } } //限制脚本实例化多个对象 //单例对象调用 private static $instance; //接下来私有化构造方法 public static function getInstance($params=array()){ //判断是否没有实例化过 if(!self::$instance instanceof self){ //如果未被实例化 self::$instance=new self($params); } //返回对象 return self::$instance; } //私有克隆,在外部调用克隆clone $对象名,会调用clone方法复制这个对象,(防止外部调用) private function __clone() { // TODO: Implement __clone() method. } }
提交重置代码
章节评论笔记课件
  • 取消回复发送
  • 取消发布笔记发送