讲讲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 <br />
namespace Home\Model;<br>
use Think\Model\AdvModel;<br>
class BlogModel extends AdvModel{<br>
<br>
protected $tableName = 'blog';<br>
Protected $autoCheckFields = false; //一定要关闭字段缓存,不然会报找不到表的错误<br>
<br>
protected $partition = array(<br>
'field' => 'uid',// 要分表的字段 通常数据会根据某个字段的值按照规则进行分表,我们这里按照用户的id进行分表<br>
'type' => 'mod',// 分表的规则 包括id year mod md5 函数 和首字母,此处选择mod(求余)的方式<br>
'expr' => '',// 分表辅助表达式 可选 配合不同的分表规则,这个参数没有深入研究<br>
'num' => '2',// 分表的数目 可选 实际分表的数量,在建表阶段就要确定好数量,后期不能增减表的数量<br>
);<br>
<br>
/**<br>
* 计算在哪张表<br>
* @param array $data<br>
* @return \Think\Model<br>
*/<br>
public function computeTable($data = []){<br>
$data = empty($data) ? $_POST : $data;<br>
$table = $this->getPartitionTableName($data);<br>
return $this->table($table);<br>
}
这样我们的分表模型就可以工作了,接下来进行增删改查的演示操作。
三、演示
1、插入数据:
在BlogModel中新增函数addOne:/**<br>
* 添加一条数据<br>
* @param array $data<br>
* @return bool|int<br>
*/<br>
public function addOne($data=[]){<br>
if(empty($data[$this->partition['field']])){<br>
E('缺少' . $this->partition['field']);<br>
}<br>
$data['id'] = intval($this->computeTable()->max('id')) + 1;<br>
if($this->create($data)){<br>
$id = $this->computeTable($data)->add();<br>
if($id === false){<br>
$this->error = '插入数据错误';<br>
return false;<br>
}else{<br>
return $data['id'];<br>
}<br>
}<br>
return false;<br>
}
在Home/Controller/IndexController文件新增操作addBlog:/**<br>
* 新增数据演示<br>
*/<br>
public function addBlog($uid=1){<br>
$blogM = D('Blog');<br>
for($i=1; $i
$this->show("<br>添加第{$i}条数据<br>");<br>
$data = ['title'=>'标题'.$i, 'content'=>'内容内容', 'uid'=>$uid];<br>
<br>
$result = $blogM->addOne($data);<br>
if($result !== false){<br>
$this->show('插入数据后的id为:'.$result);<br>
}else{<br>
$this->show('插入数据失败,失败原因:'.$blogM->getError());<br>
}<br>
}<br>
<br>
}
打开浏览器访问: 域名/index.php?s=/home/index/addBlog/uid/1 ,可以自行核对是否达到预期的效果。
2、获取所有博客:
在BlogModel中新增函数getAll:/**<br>
* 获取所有记录<br>
*/<br>
public function getAll(){<br>
<br>
return $this->computeTable()->select();<br>
}
在Home/Controller/IndexController文件新增操作getBlogs:/**<br>
* 获取所有数据演示<br>
*/<br>
public function getBlogs(){<br>
$blogM = D('Blog');<br>
$list = $blogM->getAll();<br>
dump($list);<br>
}
浏览器访问: 域名/index.php?s=/home/index/getBlogs,可以自行核对是否达到预期的效果。
3、根据条件获取多条数据
在BlogModel中新增函数getList:/**<br>
* 条件查询列表<br>
* @param $map<br>
* @return mixed<br>
*/<br>
public function getList($map){<br>
if(empty($map[$this->partition['field']])){<br>
E('缺少' . $this->partition['field']);<br>
}<br>
<br>
return $this->computeTable($map)->where($map)->select();<br>
}
在Home/Controller/IndexController文件新增操作getBlogByUid:/**<br>
* 根据条件查询数据演示<br>
* @param int $uid<br>
*/<br>
public function getBlogsByUid($uid = 1){<br>
$blogM = D('Blog');<br>
$list = $blogM->getList(['uid' => $uid]);<br>
dump($list);<br>
}
浏览器访问: 域名/index.php?s=/home/index/getBlogsByUid/uid/1,可以自行核对是否达到预期的效果。
4、查询单条记录
在BlogModel中新增函数getOne:/**<br>
* 根据查询条件获取一条记录<br>
* @param $map<br>
* @return mixed<br>
*/<br>
public function getOne($map){<br>
if(empty($map[$this->partition['field']])){<br>
E('缺少' . $this->partition['field']);<br>
}<br>
return $this->computeTable($map)->where($map)->find();<br>
}
在Home/Controller/IndexController文件新增操作blogDetail:/**<br>
* 查询一条数据演示<br>
* @param int $uid<br>
* @param int $blog_id<br>
*/<br>
public function blogDetail($uid = 1, $blog_id=1){<br>
$blogM = D('Blog');<br>
$data = $blogM->getOne(['uid' => $uid, 'id' => $blog_id]);<br>
dump($data);<br>
}
浏览器访问: 域名/index.php?s=/home/index/blogdetail/uid/1/blog_id/1,可以自行核对是否达到预期的效果。
5、更新一条记录
在BlogModel中新增函数updateOne:/**<br>
* 更新一条记录<br>
* @param $map<br>
* @param $data<br>
* @return bool<br>
*/<br>
public function updateOne($map, $data){<br>
if(empty($map[$this->partition['field']])){<br>
E('缺少' . $this->partition['field']);<br>
}<br>
if($this->create($data)){<br>
$res = $this->computeTable($map)->save($data);<br>
if($res === false){<br>
$this->error = '更新数据出错';<br>
}else{<br>
return $res; //更新的数据条数<br>
}<br>
}<br>
return false;<br>
}
在Home/Controller/IndexController文件新增操作updateBlog:/**<br>
* 更新一条记录演示<br>
* @param int $uid<br>
* @param int $blog_id<br>
*/<br>
public function updateBlog($uid=1, $blog_id=1){<br>
$blogM = D('Blog');<br>
$map = ['uid'=>$uid, 'id'=>$blog_id];<br>
$this->show("id为".$blog_id."的博客在修改之前为<br>");<br>
$blog = $blogM->getOne($map);<br>
dump($blog);<br>
<br>
$this->show("id为".$blog_id."的博客在修改之后为<br>");<br>
$data = ['title' => '我被修改了', 'id' => $blog_id];<br>
$res = $blogM->updateOne(['uid' => $uid], $data);<br>
if($res === false){<br>
dump($blogM->getError());<br>
}else{<br>
$blog = $blogM->getOne($map);<br>
dump($blog);<br>
}<br>
}
浏览器访问: 域名/index.php?s=/home/index/updateblog/uid/1/blog_id/1,可以自行核对是否达到预期的效果。
6、删除一条数据
在BlogModel中新增函数delOne:/**<br>
* 删除一条记录<br>
* @param $map<br>
* @return bool|mixed<br>
*/<br>
public function delOne($map){<br>
if(empty($map[$this->partition['field']])){<br>
E('缺少' . $this->partition['field']);<br>
}<br>
$res = $this->computeTable($map)->where($map)->delete();<br>
if($res === false){<br>
$this->error = '删除数据出错';<br>
return false;<br>
}else{<br>
return $res; //删除数据个数<br>
}<br>
}
在Home/Controller/IndexController文件新增操作delBlog:/**<br>
* 删除一条数据演示<br>
* @param int $uid<br>
* @param int $blog_id<br>
*/<br>
public function delBlog($uid = 1, $blog_id=1){<br>
$blogM = D('Blog');<br>
$map = ['uid' => $uid, 'id' => $blog_id];<br>
$this->show("准备要删除的博客<br>");<br>
dump($blogM->getOne($map));<br>
<br>
$this->show("删除结果<br>");<br>
$res = $blogM->delOne($map);<br>
dump($res);<br>
}
浏览器访问: 域名/index.php?s=/home/index/delblog/uid/1/blog_id/1,可以自行核对是否达到预期的效果。
以上只例举了一些其他操作,其他tp模型具有的操作可以举一反三得到,希望各自去使用。
AD:真正免费,域名+虚机+企业邮箱=0元

了解Python编程的入门级代码示例Python是一种简单易学,功能强大的编程语言。对于初学者来说,了解Python编程的入门级代码示例是非常重要的。本文将为您提供一些具体的代码示例,帮助您快速入门。打印HelloWorldprint("HelloWorld")这是Python中最简单的代码示例。print()函数用于将指定的内容输出

PHP变量存储程序运行期间的值,对于构建动态且交互式的WEB应用程序至关重要。本文将深入探讨php变量,并通过10个真实的示例展示它们的实际应用。1.存储用户输入$username=$_POST["username"];$passWord=$_POST["password"];此示例从表单提交中提取用户名和密码,并将其存储在变量中以供进一步处理。2.设置配置值$database_host="localhost";$database_username="username";$database_pa

标题:从入门到精通:Go语言中常用数据结构的代码实现数据结构在编程中起着至关重要的作用,它是程序设计的基础。在Go语言中,有许多常用的数据结构,掌握这些数据结构的实现方式对于成为一名优秀的程序员至关重要。本文将介绍Go语言中常用的数据结构,并给出相应的代码示例,帮助读者从入门到精通这些数据结构。1.数组(Array)数组是一种基本的数据结构,是一组相同类型

《Go语言编程实例:Web开发中的代码示例》随着互联网的快速发展,Web开发已经成为各行业中必不可少的一部分。作为一门功能强大且性能优越的编程语言,Go语言在Web开发中越来越受到开发者们的青睐。本文将通过具体的代码示例,介绍如何利用Go语言进行Web开发,让读者能够更好地理解和运用Go语言来构建自己的Web应用。1.简单的HTTP服务器首先,让我们从一个

Java冒泡排序最简单的代码示例冒泡排序是一种常见的排序算法,它的基本思想是通过相邻元素的比较和交换来将待排序序列逐步调整为有序序列。下面是一个简单的Java代码示例,演示了如何实现冒泡排序:publicclassBubbleSort{publicstaticvoidbubbleSort(int[]arr){int

如何使用PHP编写库存管理系统中的库存分仓管理功能代码库存管理是许多企业中不可或缺的一部分。对于拥有多个仓库的企业来说,库存分仓管理功能尤为重要。通过合理管理和跟踪库存,企业可以实现不同仓库之间的库存调拨,优化运营成本,改善协同效率。本文将介绍如何使用PHP编写库存分仓管理功能的代码,并为您提供相关的代码示例。一、建立数据库在开始编写库存分仓管理功能的代码之

华为云边缘计算对接指南:Java代码示例快速实现接口随着物联网技术的快速发展和边缘计算的兴起,越来越多的企业开始关注边缘计算的应用。华为云提供了边缘计算服务,为企业提供了高可靠的计算资源和便捷的开发环境,使得边缘计算应用更加容易实现。本文将介绍如何通过Java代码快速实现华为云边缘计算的接口。首先,我们需要准备好开发环境。确保你已经安装了Java开发工具包(

Java选择排序法代码编写指南及示例选择排序是一种简单直观的排序算法,其思想是每次从未排序的元素中选择最小(或最大)的元素进行交换,直到所有元素排序完成。本文将提供选择排序的代码编写指南,并附上具体的Java示例代码。算法原理选择排序的基本原理是将待排序数组分为已排序和未排序两部分,每次从未排序部分选择最小(或最大)的元素,将其放到已排序部分的末尾。重复上述


热AI工具

Undresser.AI Undress
人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover
用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool
免费脱衣服图片

Clothoff.io
AI脱衣机

AI Hentai Generator
免费生成ai无尽的。

热门文章

热工具

SublimeText3汉化版
中文版,非常好用

SublimeText3 英文版
推荐:为Win版本,支持代码提示!

螳螂BT
Mantis是一个易于部署的基于Web的缺陷跟踪工具,用于帮助产品缺陷跟踪。它需要PHP、MySQL和一个Web服务器。请查看我们的演示和托管服务。

Dreamweaver CS6
视觉化网页开发工具

WebStorm Mac版
好用的JavaScript开发工具