讲讲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:<?php
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 < 4; $i++){
$this->show("<br/>添加第{$i}条数据<br/>");
$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."的博客在修改之前为<br>");
$blog = $blogM->getOne($map);
dump($blog);

$this->show("id为".$blog_id."的博客在修改之后为<br>");
$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("准备要删除的博客<br>");
dump($blogM->getOne($map));

$this->show("删除结果<br>");
$res = $blogM->delOne($map);
dump($res);
}浏览器访问: 域名/index.php?s=/home/index/delblog/uid/1/blog_id/1,可以自行核对是否达到预期的效果。

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

评论() 相关

收藏

赞

Plebs

ThinkPHP 是一个免费开源的,快速、简单的面向对象的 轻量级PHP开发框架 ,创立于2006年初,遵循Apache2开源协议发布,是为了敏捷WEB应用开发和简化企业应用开发而诞生的。ThinkPHP从诞生以来一直秉承简洁实用的设计原则,在保持出色的性能和至简的代码的同时,也注重易用性。并且拥有众多的原创功能和特性,在社区团队的积极参与下,在易用性、扩展性和性能方面不断优化和改进,已经成长为国内最领先和最具影响力的WEB应用开发框架,众多的典型案例确保可以稳定用于商业以及门户级的开发。