【Fizzday04】构建MVC之数据库操作类Model

yes !!! 更加舒爽简洁的用法 ~~~
老规矩, 先过过眼瘾

用法示例

直接执行sql语句

<?php
use Fizzday\FizzDB\DB;
# 查询操作
DB::query("SELECT * FROM `user` WHERE `id`>1");
# 增删改操作
DB::execute("INSERT INTO `user` SET `name`='fizz'");
DB::execute("UPDATE  `user` SET `name`='fizzday' WHERE `id`=1");
DB::execute("DELETE FROM `user` WHERE `id`=1");

OR, 使用PDO标准格式

DB::query("SELECT * FROM `user` WHERE `id`>?", [1]);
DB::execute("INSERT INTO `user` SET `name`=?",  ['fizz']);
DB::execute("UPDATE `user` SET `name`='fizzday' WHERE `id`=?", [1]);
DB::execute("DELETE FROM `user` WHERE `id`=?", [1]);

链式操作方式

# 查询
DB::table('user')->get();
DB::table('user')->fields('id', 'name')->where('id', '=', 1)->group('id')->order('id asc')->limit(20, 0)->first();
DB::table('user')->insert(['name'=>'fizz3', 'age'=>26]);
DB::table('user')->where('id', 4)->update(['name'=>'fizz4', 'age'=>27]);
DB::table('user')->where([['name', 'fizz4'], ['age', 27]])->delete();
# 增删改
DB::table()->data()->insert();
DB::table()->where()->data()->update();
DB::table()->where()->delete();

说明: 写法上模仿了laravel的方式, 当然, 我们可以直接使用Eloquent作为我们的数据库操作类, 后边会加入支持. 不过, 为了学习交流, 我们可以自己造一遍轮子. 同样的宗旨, 要做到更简单

实现思路

封装基本的操作类

我们依然把db类放到composer统一管理

1. 新建DBIterface.php

<?php
interface DBInterface
{
    /**
     * 获取pdo链接 
     * @return mixed
     */
    public function getPdo();

    public function setConfig($config = []);
    
    public function table($con = '');
    /**
     * 设置要查询的字段, 可以是多个字段一起, 也可以是放数组中, 也可以是一个参数一个字段 (python's *args)
     * @return $this
     */
    public function fields();
    
    public function where();
    /**
     * 原始 pdo 查询语句
     * @param string $sql
     * @param string $param
     * @return mixed
     */
    public function query($sql = '', $param = []);
    /**
     * 执行原生 pdo 增删改操作
     * @param string $sql
     * @param array $param
     * @return mixed
     */
    public function execute($sql = '', $param = []);
    /**
     * 获取最后执行的语句
     * @return mixed
     */
    public function lastSql();
}

notes: 当然, 我们也可以不写interface, 这里为了结构清晰一点, 就定义了几个简单的方法

1. 新建DBBuilder.php来实现db的所有操作.
  具体实现方法请看源码
1. 为了实现静态调用, 我们新建一个入口文件DB.php, 做魔术方法调用, 只需要简单的几行即可

<?php
class DB {
    public static $instance;

    /**
     * @param $method
     * @param $params
     * @return mixed
     */
    public function __call( $method, $params ) {
        if ( !( self::$instance ) ) {
            $class_name = empty(self::$service) ? get_called_class() . 'Builder' : self::$service;
            self::$instance = new $class_name();
        }

        return call_user_func_array( [ self::$instance, $method ], $params );
    }

    /**
     * @param $name
     * @param $arguments
     * @return mixed
     */
    public static function __callStatic($method, $params)
    {
        return call_user_func_array([new static(), $method], $params);
    }
}

这里做了一个简单的单例实现$instance, 这里为了演示, 我直接将魔术方法写在DB.php中, 实际框架里, 我为了重复使用, 做了一个简单的 Trait , 这样, 其他地方需要用到魔术方法的时候, 就不用再写一遍了, 直接 use 一下 trait就可以了

使用

composer安装fizzdb包

cd ~/fizzday
composer require fizzday/fizzdb dev-master

文件中引用, 我们这里以 TestController.php 的 test 方法为例:

<?php
namespace App\Controller;
use Fizzday\FizzDB\DB;

class TestControlelr extends BaseController;
{
    public function test()
    {
        $users = DB::table('users')->where('id', 1)->first();
        
        print_r($users);
    }
}

notes: 这里的返回结果为object, 如果想返回array, 只需要这么做 (array) $users, 或者在配置中设定;

数据库配置

为了使用方便, 我把数据库的配置单独放了出来, 配置文件我放在了 ~/fizzday/config/database.php, 这里的路径可以自由更换, 在 boot.php 中配置即可

<?php
// 设置默认使用的配置
$config['db_default'] = 'mysql';

$config['mysql'] = [
    'driver'    => 'mysql',
    'host'      => 'localhost',
    'port'      => 3306,
    'database'  => 'test',
    'username'  => 'root',
    'password'  => 'root',
    'charset'   => 'utf8',
    'collation' => 'utf8_unicode_ci',
    'prefix'    => 'fizz_',
    'read'      => [
        'host'  => '127.0.0.1'
    ],
    'write'      => [
        'host'  => '127.0.0.1',
        'database'  => 'test2',
    ]
];
$config['mysql2'] = [
    // 详细参数
    ];

return $config;

没错, 支持读写分离, 表前缀, 多数据链接, 支持在db操作中使用 addConnection('mysql2') 方法调用新的链接
我做了个小项目使用测试, 没做缓存的时候, 整体请求完成返回数据, 一个完整的http链接到返回数据,普遍速度快时只需要50~70毫秒, 慢时也只有100+毫秒, 也就是, 你ajax请求数据, 拿到数据, 到完成, 几乎没有时间延迟

到此, 一个api框架基本完成, 没有view层, 只是一个轻而快的小马车, 后边会外挂一个view模块, 这样, 就可以做到框架自由组合了, 拒绝臃肿, 只取自己需要的东西