<pre name="code" class="sql"><span style="font-family: Arial, Helvetica, sans-serif;">数据分表</span>定义好了分表属性后，我们就可以来进行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: 作者用户 idtitle: 标题content: 内容
表tp_blog_2和表<span style="font-family: Arial, Helvetica, sans-serif;">tp_blog_1一样</span>手动添加一些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模型具有的操作可以举一反三得到，希望各自去使用。
