PHP封装数据库操作类

• 封装数据库操作类：
• 因为目前所使用的mysqli扩展实现数据库的操作还比较零散，如果想要高效的使用，就必须要进行二次加工

• 在面向对象编程中，所有操作都应该是由类来实现完成
• 封装的完整程度是根据业务的需求来定

步骤

1、确定要封装的业务：基于mysqli的数据库底层实现，完成数据库操作的基本诉求

• 简化初始化操作
• 实现错误处理
• 实现增删改查

2、明确封装的类的作用，确定内部实现机制

• 方法独立性：一个方法只做一件事情
• 方法独立性：方法只负责执行，不对结果进行任何处理，交由外部调用处判定
• 灵活性：封装的所有操作应该是灵活的，不是写死的内容

3、根据思路明确封装类的数据和数据操作

• 数据使用属性保留：数据需要跨方法或者对外提供数据支持
  • 数据库操作的数据：主机地址、端口、用户名、密码、数据库名字、字符集
  • 数据库连接资源跨方法：连接资源
  • 错误信息对外数据支持：错误信息、错误编号
• 数据操作具体功能
  • 初始化资源工作：构造方法，实现属性初始化
  • 初始化数据库资源：实现数据库的连接认证、字符集设置和数据库选择：失败返回false并记录错误
  • SQL指令语法检查：SQL执行并完成错误处理：失败返回false并记录错误
  • 写操作：实现增伤改指令的执行：调用SQL指令语法检查，成功返回受影响行数
  • 自增长ID获取：实现自增长id获取
  • 读操作：单记录获取和多记录获取：调用SQL指令语法检查

4、确定类的控制

• 不需要外部访问和使用的私有
• 明确外部需要用到的公有
• 如果数据安全性要求高，那么可以属性私有，但是允许对外提供可以操作的公有方法（内部安全处理）

示例

1、一个类通常就是一个文件，所以要先确定文件的名字：通常类文件命名规范有两种

• 文件名字与类名字一样，如Sql.php
• 为了区分普通PHP文件，增加中间类描述，如Sql.class.php
• 现在PHP几乎都是面向对象编程，所以通常采用第一种方式：因此当前命名数据类的文件为：Sql.php

2、确定类文件名字后其实也就确定了类名字，因此可以创建一个Sql类

# 数据库操作类
class Sql{}

3、类的创建分两种：一是特定使用，即类里面的所有内容只为某次使用；二是通用，即工具类，以后很多地方可以用。

• 特定使用，功能可以不用太灵活
• 通用工具，功能应该大众化，数据的变化会比较多

数据库类以后凡是要操作数据库的地方都可以用得到，很多项目都会用到，所以应该是个通用工具类，因此要考虑其到处可用的特性，让其能够灵活

4、数据库的操作最基本的特性不会改变：即需要连接认证，而连接认证的信息是灵活的，所以可以通过设定属性来控制，这些信息也都是不同使用者不同的，应该可以改变，所以可以通过构造方法来实现数据传入

# 数据库操作类
class Sql{
	# 设置属性：数据库初始化信息
	public $host;
	public $port;
	public $user;
	public $pass;
	public $dbname;
	public $charset;
    
    # 构造方法初始化数据：数据较多，应该使用数组来传递数据，关联数组，而且绝大部分的开发者本意是用来测试，所以基本都是本地，因此可以给默认数据
    /*
    	$info = array(
    		'host' => 'localhost',
    		'port' => '3306',
    		'user' => 'root',
    		'pass' => 'root',
    		'dbname' => 'blog',
    		'charset' => 'utf8'
    	)
    */
    public function __construct(array $info = array()){
        # 初始化：确保用户传入了数据，否则使用默认值
        $this->host = $info['host'] ?? 'localhost';
        $this->port = $info['port'] ?? '3306';
        $this->user = $info['user'] ?? 'root';
        $this->pass = $info['pass'] ?? 'root';
        $this->dbname = $info['dbname'] ?? 'test';
        $this->charset = $info['charset'] ?? 'utf8';
    }
}

注意：方法设定的原则是一个方法只实现一个简单的功能，不要多个功能堆积到一个方法中。

5、数据库属性会在实例化Sql对象的时候自动初始化

# 接上述代码（类外测试）
$s1 = new Sql();			# 使用默认数据库信息
$db = array(
	'host' => '192.168.0.1',
	'user' => 'admin',
	'pass' => 'admin',
	'dbname' => 'Taobao'
);
$s2 = new Sql($db);			# 使用外部数据库信息

6、数据库要操作的第一件事就是连接认证，所以需要一个连接认证的功能。这里可以使用mysqli面向过程的方法。但是需要建立一个方法来实现连接认证：连接是否成功？

# 对外提供属性，记录错误数据（外部如何处理，不需要我们管）
public $errno;
public $error;

# mysqli的连接资源对象是任何mysqli扩展操作的基础，因此需要该连接对象能够在其他方法中使用：属性处理
public $link;

# 在上述类中增加一个方法：实现连接认证功能
public function connect(){
	# 利用属性可以跨方法访问：5个参数分别为：主机、用户名、密码、数据库、端口
    # 利用错误抑制符抑制可能出现的错误
	$this->link = @mysqli_connect($this->host,$this->user,$this->pass,$this->dbname,$this->port);
    # 判定连接是否成功
	if(!$this->link){
        # 将错误信息保存到记录错误的属性中，返回false
        $this->errno = mysqli_connect_errno();
        $this->error = mysqli_connect_error();
        return false;
	}
    
    # 返回一个连接结果：不需要返回资源对象，为真即可表示成功
    return true;
}

7、连接认证包括数据库选择设定好后，此时还存在一个细节问题：字符集，为了保证数据库连接的正常操作，需要新增一个方法设定字符集

# 在Sql类中增加设定字符集的方法
public function charset(){
    # 调用mysqli的设置字符集的函数
    $res = mysqli_set_charset($this->link,$this->charset);
    
    # 判定是否成功
	if(!$res){
		$this->errno = mysqli_errno($this->link);
		$this->error = mysqli_error($this->link);
		return false;
	}
    
    return true;
}

8、初始化完成后，可以实现具体的业务处理：所有的SQL都需要使用mysqli_query执行，也都可能产生错误，因此封装一个专门执行SQL并检查错误的方法

# SQL执行以及错误检查
public function check($sql){
	# 执行SQL
	$res = mysqli_query($this->link,$sql);

	# 判定结果
	if(!$res){
		$this->errno = mysqli_errno($this->link);
		$this->error = mysqli_error($this->link);
		return false;
	}

	# 返回正确结果
	return $res;
}

9、上述功能本质也可以是一个写操作（不完整），但是写操作是有业务性的：返回受影响的行数，因此独立增加一个写操作方法，调用上述方法实现，并根据结果返回受影响的行数

# 写操作
public function write($sql){
	# 调用方法检查执行
	$res = $this->check($sql);

	# 判定执行结果：成功返回受影响的行数，失败返回false，错误已经在check方法中记录
	return $res ? mysqli_affected_rows($this->link) : false;
}

10、写操作中可能会有新增需求，因此也对外提供一个获取自增长Id的方法

# 自增长id
public function insert_id(){
	return mysql_insert_id($this->link);
}

11、读取操作：读取一条记录（利用check进行SQL执行和错误检查）：读取一条数据可能需要获取当前查询结果的列数，增加属性保留

# 属性：记录查询结果中的列数
public $columns = 0;
    
# 读操作
public function read_one($sql){
	# 执行SQL错误检查
	$res = $this->check($sql);
    
    # 读取记录列数
    $this->columns = @mysqli_field_count($this->link);

	# 判定结果，进行加工：成功读取一条记录，失败返回错误信息
	return $res ? mysqli_fetch_assoc($res) : $res;
}

12、读取操作：读取多条记录：可能需要知道总的记录数以及查询结果的列数

# 属性：记录查询结果的行数
public $rows = 0;

# 读操作
public function read_all($sql){
	# 执行SQL错误检查
	$res = $this->check($sql);

	# 判定结果，进行加工
	if(!$res) return $res;
    
    # 记录结果数量
    $this->rows = mysqli_num_rows($res); 

	# 根据需求解析数据
	$list = [];
	while($row = mysqli_fetch_assoc($res)) $list[] = $row;

	# 返回结果
	return $list;
}

13、用户在使用Sql类的时候，必须要进行第一步实例化、然后连接认证和实现字符集设置。这样的话用户操作比较麻烦，应该是用户实例化Sql类就可以直接进行相应的业务处理：所以可以将连接认证、字符集设置在初始化方法中实现（构造方法）

public function __construct(array $info = array()){
    # 初始化：确保用户传入了数据，否则使用默认值
    $this->host = $info['host'] ?? 'localhost';
    $this->port = $info['port'] ?? '3306';
    $this->user = $info['user'] ?? 'root';
    $this->pass = $info['pass'] ?? 'root';
    $this->dbname = $info['dbname'] ?? 'test';
    $this->charset = $info['charset'] ?? 'utf8';
    
    # 调用初始化和字符集设置
    if(!$this->connect()) return;
    $this->charset();
}

14、确定类的控制：不需要外部访问的私有，需要外部访问的公有，重要的数据私有并增加公有操作方法进行安全控制

# 数据库初始化资源私有：不需要外部访问
private $host;
private $port;
private $user;
private $pass;
private $dbname;
private $charset;

# 连接资源仅限内部使用
private $link;

# 连接认证和字符集设置已经内部调用，不需要外部使用
private function connect(){}
private function charset(){}

# SQL检查属于内部调用，不需要公有
private function check($sql){}

14、测试：利用数据库类实现数据库的写操作和读操作

小结

1、类的封装是以功能驱动为前提，相关操作存放到一个类中

2、一个类通常是一个独立的文件，文件名与类名相同（方便后期维护和自动加载）

3、类中如果有数据需要管理，设定属性

4、类中如果有功能需要实现（数据加工），设定方法

5、一个功能通常使用一个方法实现，方法的颗粒度应该尽可能小（方便复用）

6、应该尽可能增加类对成员的控制：即能私有尽可能私有

7、类中需要实现的功能应该由具体的业务来实现支撑

• 实用类：只考虑当前业务，不考虑全面性（代码少，应用范围小）
• 工具类：全面综合考虑，尽可能多的封装可能存在的业务（代码多，应用范围广）

封装代码如下：

<?php

//数据库操作类
class Sql
{
    private $host;
    private $port;
    private $user;
    private $pass;
    private $dbname;
    private $charset;

//    实现数据的初始化：灵活性（允许外部修改）和通用性（给定默认值）
    public function __construct(array $arr = array())
    {
//        完成初始化
        $this->host = $arr['host'] ?? '127.0.0.1';
        $this->port = $arr['port'] ?? '3306';
        $this->user = $arr['user'] ?? 'root';
        $this->pass = $arr['pass'] ?? 'root';
        $this->dbname = $arr['dbname'] ?? 'play';
        $this->charset = $arr['charset'] ?? 'utf8';
//    对象调用构造方法,永远不需要它的返回值
//        实现初始化数据库操作
        if(!$this->connect()) return; # 为了中断执行,初始化连接.加载时,连接数据库
        $this->charset(); //可以初始化字符集,当对象加载时,附上默认字符集
    }

    # 对外提供属性，记录错误数据（外部如何处理，不需要我们管）
    public $errno;
    public $error;
    # mysqli的连接资源对象是任何mysqli扩展操作的基础，因此需要该连接对象能够在其他方法中使用：属性处理
    private $link;

    # 在上述类中增加一个方法：实现连接认证功能
    private function connect()
    {
        # 利用属性可以跨方法访问：5个参数分别为：主机、用户名、密码、数据库、端口
        # 利用错误抑制符抑制可能出现的错误
        $this->link = @mysqli_connect($this->host, $this->user, $this->pass, $this->dbname, $this->port);
        if (!$this->link) {
//            记录错误信息 返回false
            $this->errno = mysqli_errno();
            $this->error = iconv('utf-8', 'gbk', mysqli_error()); #第一个参数原来的，第二个要转成的字符集
        }
        #正确返回
        return true;
    }

//    字符集设置
    private function charset()
    {
//        利用mysqli实现字符集设置
//            这个结果，不需要给外部使用，所以使用局部变量$res
        $res = @mysqli_set_charset($this->link, $this->charset);
//            判定结果
        if (!$res) {
            $this->errno = mysqli_errno($this->link);
            $this->error = mysqli_error($this->link);
            return false;
        }
//            正确操作
        return true;
    }

//        SQL执行检查
    private function check($sql)
    {
        #mysqli_query执行
        $res = mysqli_query($this->link, $sql);
//            判断错误
        if (!$res) {
            $this->errno = mysqli_errno($this->link);
            $this->error = mysqli_error($this->link);
            return false;
        }
//        成功返回结果
        return $res;
    }

//    写操作
    public function write($sql)
    {
//        调用SQL检查方法，检查和执行
        $res = $this->check($sql);
//        根据结果判定： 如果$res是true，说明执行成功，应该获取受影响的行数，如果为false就返回false
        return $res ? mysqli_affected_rows($this->link) : false;
    }

//    获取自增长ID的方法
    public function insert_id()
    {
        return mysqli_insert_id($this->link);
    }

//    读取操作，一条记录
//    定义属性，记录读取的列数
    public $columns = 0;

    public function read_one($sql)
    {
//        执行检查
        $res = $this->check($sql);
//        判定结果
        if ($res) {
//            有结果
            $this->columns = @mysqli_field_count($this->link);
            return mysqli_fetch_assoc($res);
        }
//        没有结果
        return false;
    }

//    读取多条记录
//    定义属性,记录行数
    public $rows;

    public function read_all($sql)
    {
//        执行检查
        $res = $this->check($sql);
//        错误检查
        if (!$res) return false;
//        结果正确
//        记录行
        $this->rows = @mysqli_num_rows($res);
//        记录列
        $this->columns = @mysqli_field_count($this->link);
//        获取所有记录,形成二维数组
        $list = [];
        while ($row = mysqli_fetch_assoc($res)) $list[] = $row;
//        返回结果
        return $list;
    }




}

$s1 = new Sql();

$res = $s1->read_all("select * from info");
//$res = $s1->write("insert into info values('null','潘长江','489360698','489360698@qq.com')");
var_dump($res);
echo $s1->insert_id();
echo $s1->errno, $s1->error;

对象操作mysqli数据库方法

<?php
$host='127.0.0.1';
$user =  'root';
$pwd = 'root';
$db = new  mysqli();
//创建连接
$db->connect($host,$user,$pwd);
//选择数据库
$db->select_db('plus');
//设置编码
$db->set_charset('utf8');
$sql = "select * from news";
$res = $db->query($sql);
while($row = $res->fetch_assoc()) {
    echo "<pre>";
    print_r($row);
    echo "</pre>";
}