ThinkPHP中的分表使用

程序员文章站 2022-05-25 12:09:59

...

讲讲ThinkPHP中的分表使用
数据分表

对于大数据量的应用，经常会对数据进行分表，有些情况是可以利用数据库的分区功能，但并不是所有的数据库或者版本都支持，因此我们可以利用ThinkPHP内置的数据分表功能来实现。帮助我们更方便的进行数据的分表和读取操作。

和数据库分区功能不同，内置的数据分表功能需要根据分表规则手动创建相应的数据表。

在需要分表的模型中定义partition属性即可。

protected $partition = array(
'field' => 'name',// 要分表的字段通常数据会根据某个字段的值按照规则进行分表
'type' => 'md5',// 分表的规则包括id year mod md5 函数和首字母
'expr' => 'name',// 分表辅助表达式可选配合不同的分表规则
'num' => 'name',// 分表的数目可选实际分表的数量
);
定义好了分表属性后，我们就可以来进行CURD操作了，唯一不同的是，获取当前的数据表不再使用getTableName方法，而是使用getPartitionTableName方法，而且必须传入当前的数据。然后根据数据分析应该实际操作哪个数据表。因此，分表的字段值必须存在于传入的数据中，否则会进行联合查询。

这是tp3.2.3官方文档介绍的，对于还未阅读tp源代码的coder，光看这几句话其实是很难理解如何在tp中使用分表技术的。之前我有专门了解过分表原理，再结合tp的源代码，我和分享一下我是怎么使用tp中的分表。
一、准备工作
1、安装最新的tp3.2.3框架 http://thinkphp.cn/down/framework.html
2、按自己的喜欢新建测试数据库（例如: thinkphp），接下来建表，因为我只需要完成功能演示就行，因此我就简单地建了tp_user、tp_blog_1、tp_blog_2。表结构如下：
表user:
id: 用户id，自增，我们blog分表就是根据这个id去定位表的；
username: 账号

表tp_blog_1:
id: 博客id, 自增
uid: 作者用户 id
title: 标题
content: 内容

表tp_blog_2和表tp_blog_1一样
可以发现，我们是对blog表进行了分表操作，表的数量是2。
手动添加一些user表数据，演示要用到。

二、核心部分：建立模型
user表的模型和正常情况一样，这里不作说明。
重点在于blog表的模型，我直接先上BlogModel:


namespace Home\Model;

use Think\Model\AdvModel;

class BlogModel extends AdvModel{


   protected $tableName = 'blog';

   Protected $autoCheckFields = false;  //一定要关闭字段缓存，不然会报找不到表的错误


   protected $partition = array(

      'field' => 'uid',// 要分表的字段 通常数据会根据某个字段的值按照规则进行分表,我们这里按照用户的id进行分表

      'type' => 'mod',// 分表的规则 包括id year mod md5 函数 和首字母，此处选择mod（求余）的方式

      'expr' => '',// 分表辅助表达式 可选 配合不同的分表规则，这个参数没有深入研究

      'num' => '2',// 分表的数目 可选 实际分表的数量，在建表阶段就要确定好数量，后期不能增减表的数量

   );


    /**

     * 计算在哪张表

     * @param array $data

     * @return \Think\Model

     */

   public function computeTable($data = []){

      $data = empty($data) ? $_POST : $data;

      $table = $this->getPartitionTableName($data);

      return $this->table($table);

   }

这样我们的分表模型就可以工作了，接下来进行增删改查的演示操作。

三、演示
1、插入数据：
在BlogModel中新增函数addOne：

/**

 * 添加一条数据

 * @param array $data

 * @return bool|int

 */

public function addOne($data=[]){

    if(empty($data[$this->partition['field']])){

        E('缺少' . $this->partition['field']);

    }

    $data['id'] = intval($this->computeTable()->max('id')) + 1;

    if($this->create($data)){

        $id = $this->computeTable($data)->add();

        if($id === false){

            $this->error = '插入数据错误';

            return false;

        }else{

            return $data['id'];

        }

    }

    return false;

}

在Home/Controller/IndexController文件新增操作addBlog:

/**

 * 新增数据演示

 */

public function addBlog($uid=1){

    $blogM = D('Blog');

    for($i=1; $i 
        $this->show("
添加第{$i}条数据
");

        $data = ['title'=>'标题'.$i, 'content'=>'内容内容', 'uid'=>$uid];


        $result = $blogM->addOne($data);

        if($result !== false){

            $this->show('插入数据后的id为：'.$result);

        }else{

            $this->show('插入数据失败,失败原因：'.$blogM->getError());

        }

    }


}

打开浏览器访问: 域名/index.php?s=/home/index/addBlog/uid/1 ，可以自行核对是否达到预期的效果。

2、获取所有博客：
在BlogModel中新增函数getAll：

/**

 * 获取所有记录

 */

public function getAll(){


    return $this->computeTable()->select();

}

在Home/Controller/IndexController文件新增操作getBlogs:

/**

 * 获取所有数据演示

 */

public function getBlogs(){

    $blogM = D('Blog');

    $list = $blogM->getAll();

    dump($list);

}

浏览器访问: 域名/index.php?s=/home/index/getBlogs，可以自行核对是否达到预期的效果。

3、根据条件获取多条数据
在BlogModel中新增函数getList：

/**

 * 条件查询列表

 * @param $map

 * @return mixed

 */

public function getList($map){

    if(empty($map[$this->partition['field']])){

        E('缺少' . $this->partition['field']);

    }


    return $this->computeTable($map)->where($map)->select();

}

在Home/Controller/IndexController文件新增操作getBlogByUid:

/**

 * 根据条件查询数据演示

 * @param int $uid

 */

public function getBlogsByUid($uid = 1){

    $blogM = D('Blog');

    $list = $blogM->getList(['uid' => $uid]);

    dump($list);

}

浏览器访问: 域名/index.php?s=/home/index/getBlogsByUid/uid/1，可以自行核对是否达到预期的效果。

4、查询单条记录
在BlogModel中新增函数getOne：

/**

 * 根据查询条件获取一条记录

 * @param $map

 * @return mixed

 */

public function getOne($map){

    if(empty($map[$this->partition['field']])){

        E('缺少' . $this->partition['field']);

    }

    return $this->computeTable($map)->where($map)->find();

}

在Home/Controller/IndexController文件新增操作blogDetail:

/**

 * 查询一条数据演示

 * @param int $uid

 * @param int $blog_id

 */

public function blogDetail($uid = 1, $blog_id=1){

    $blogM = D('Blog');

    $data = $blogM->getOne(['uid' => $uid, 'id' => $blog_id]);

    dump($data);

}

浏览器访问: 域名/index.php?s=/home/index/blogdetail/uid/1/blog_id/1，可以自行核对是否达到预期的效果。

5、更新一条记录
在BlogModel中新增函数updateOne：

/**

 * 更新一条记录

 * @param $map

 * @param $data

 * @return bool

 */

public function updateOne($map, $data){

    if(empty($map[$this->partition['field']])){

        E('缺少' . $this->partition['field']);

    }

    if($this->create($data)){

        $res = $this->computeTable($map)->save($data);

        if($res === false){

            $this->error = '更新数据出错';

        }else{

            return $res;   //更新的数据条数

        }

    }

    return false;

}

在Home/Controller/IndexController文件新增操作updateBlog:

/**

 * 更新一条记录演示

 * @param int $uid

 * @param int $blog_id

 */

public function updateBlog($uid=1, $blog_id=1){

    $blogM = D('Blog');

    $map = ['uid'=>$uid, 'id'=>$blog_id];

    $this->show("id为".$blog_id."的博客在修改之前为
");

    $blog = $blogM->getOne($map);

    dump($blog);


    $this->show("id为".$blog_id."的博客在修改之后为
");

    $data = ['title' => '我被修改了', 'id' => $blog_id];

    $res = $blogM->updateOne(['uid' => $uid], $data);

    if($res === false){

        dump($blogM->getError());

    }else{

        $blog = $blogM->getOne($map);

        dump($blog);

    }

}

浏览器访问: 域名/index.php?s=/home/index/updateblog/uid/1/blog_id/1，可以自行核对是否达到预期的效果。

6、删除一条数据
在BlogModel中新增函数delOne：

/**

 * 删除一条记录

 * @param $map

 * @return bool|mixed

 */

public function delOne($map){

    if(empty($map[$this->partition['field']])){

        E('缺少' . $this->partition['field']);

    }

    $res = $this->computeTable($map)->where($map)->delete();

    if($res === false){

        $this->error = '删除数据出错';

        return false;

    }else{

        return $res;   //删除数据个数

    }

}

在Home/Controller/IndexController文件新增操作delBlog:

/**

 * 删除一条数据演示

 * @param int $uid

 * @param int $blog_id

 */

public function delBlog($uid = 1, $blog_id=1){

    $blogM = D('Blog');

    $map = ['uid' => $uid, 'id' => $blog_id];

    $this->show("准备要删除的博客
");

    dump($blogM->getOne($map));


    $this->show("删除结果
");

    $res = $blogM->delOne($map);

    dump($res);

}

浏览器访问: 域名/index.php?s=/home/index/delblog/uid/1/blog_id/1，可以自行核对是否达到预期的效果。

以上只例举了一些其他操作，其他tp模型具有的操作可以举一反三得到，希望各自去使用。

AD：真正免费，域名+虚机+企业邮箱=0元

上一篇： C#解压或压缩文件夹的代码

下一篇： CodeIgniter 下引入ORM Doctrine，codeigniterorm

ThinkPHP中的分表使用

Python使用win32com模块实现数据库表结构自动生成word表格的方法

在vue中,v-for的索引index在html中的使用方法

对python中矩阵相加函数sum()的使用详解

PS中模糊工具该怎么使用? ps模糊工具的使用实例教程

Python中的exec、eval使用实例

Python中Collection的使用小技巧

selenium使用chrome浏览器测试（附chromedriver与chrome的对应关系表）

Python中类的定义、继承及使用对象实例详解

Java中是使用增强for的null问题

详解Linux中PostgreSQL和PostGIS的安装和使用