tp5 分表+ 分页查询

1
2
3
4
5
6
CREATE TABLE `tb_article` (
  `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT,
  `stub` char(1) COLLATE utf8_bin NOT NULL DEFAULT '',
  PRIMARY KEY (`id`),
  UNIQUE KEY `stub` (`stub`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_bin;

1
2
3
4
5
6
7
8
9
CREATE TABLE `tb_article_1` (
  `id` INT(11) UNSIGNED NOT NULL AUTO_INCREMENT COMMENT '文章id',
  `user_id` INT(11) NOT NULL COMMENT '作者id',
  `add_time` INT(10) DEFAULT NULL COMMENT '时间',
  `typeid` INT(1) DEFAULT NULL COMMENT '文章栏目 1财经 2娱乐 3体育',
  `title` varchar(155) NOT NULL COMMENT '文章标题',
  `content` text NOT NULL COMMENT '文章内容',
  PRIMARY KEY (`id`)
) ENGINE=MyISAM AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='文章表1';

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
<?php
namespace appindexmodel;
use thinkModel;
class Article extends Model
{
    protected $table = 'tb_article';
    private function getRule(){
        return [
            'type' => 'mod', // 分表方式
            'num'  => 3     // 分表数量
        ];
    }    //获取插入ID，根据ID来取模分表
    public function getLastId(){
        $data['stub']='a';
        return $this->insertGetId($data, true);
    }
 
    public function saveData($data, $id){
        return $this->partition(['id' => $id], "id", $this->getRule())->insert($data);
    }
    
    public function getArticleById($where, $field = "*", $id){
        return $this->partition(['id' => $id], "id", $this->getRule())->where($where)->field($field)->select();
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
<?php
namespace appindexcontroller;use thinkController;
use appindexmodelArticle as ArticleModel;
class Article extends Controller
{
    //执行添加分表数据
    public function articleAdd(){
        $Article = new ArticleModel();
        $id = $Article->getLastId();
        $data = [
            'id' => $id,
            'user_id' => 10,
            'add_time' => time(),
            'typeid' => 3,
            'title' => '这里是新闻标题',
            'content' => '这里是新闻内容',
        ];
        if($Article->saveData($data,$id)){　　　　　　　　
              $this->success('文章添加成功！');      
        }
    }
//根据id查询分表数据
    public function getArticle(){
        $id = input('id');
        if($id){
            $Article = new ArticleModel();
            $news = $Article->getArticleById(['id'=>$id],'*',$id);
            return json($news);
        }
    }
//删除分表数据，原理和查询相同，直接根据id执行删除就行
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
//新建控制器查询方法
public function getList(){
        $Article = new subModel();
//1,  先去获取相关数据的主键id                    表名     主键id  要获取的字段  分表数量 条件
        $news = $Article->buildPartitionSql('car_article','id',$fields='',$num=3,$where='');
//2,  根据获取的主键id获取数据                        表名        主键id  id值   分表数量
        $newlist = $Article->buildPartitionListSql('car_article','id',$news,$num=3);
    var_dump($newlist);  //输出的就是我们需要的数据

}

//新建模型方法
/**
 * 构造获取总记录数及主键ID的sql子查询语句
 * @param $table 主表名称
 * @param $idKey 主键id字段名称
 * @param string $fields 其它字段名称,多个字段用英文逗号分隔
 * @param int $num 子表数量
 * @param string $where 查询条件
 * @return array
 */
function buildPartitionSql($table,$idKey,$fields='',$num=3,$where='') {
    $offset=0;        //分页数据,跟普通分页一样,直接传参就好
    $rows=9;          //分页数据,跟普通分页一样,直接传参就好


    $countTable = [];
    $listTable = [];
    $fieldList = [$idKey];
    if ($fields) {
        $fieldList = array_merge($fieldList,explode(',',$fields));
        $fieldList = array_unique($fieldList);
    }
    $fieldStr = implode(',',$fieldList);
    for ($i = 0; $i < $num; $i++) {
        $countTable[] = sprintf('SELECT %s FROM %s_%s where 1=1 %s', $idKey, $table, ($i + 1), $where);
        $listTable[] = sprintf('SELECT %s FROM %s_%s where 1=1 %s', $fieldStr,$table, ($i + 1), $where);
    }
    $countTable = '( ' . implode(" UNION ", $countTable) . ') AS ' . $table;
    $listTable = '( ' . implode(" UNION ", $listTable) . ') AS ' . $table;
    $tables = ['countSql' => $countTable, 'listSql' => $listTable];

//这里返回的是两个sql语句,咱们简单点直接执行好,返回的就是数据的主键id
    return   Db::query("select * from". $tables['listSql']. " limit ".$offset.",".$rows);

   //return $tables;
}
/**
 * 构造获取指定id对应记录的sql子查询语句
 * @param $table 主表名称
 * @param $idKey 指定的id字段名称
 * @param $idValues 指定的id字段值
 * @param int $num 子表数量
 * @return string
 */
function buildPartitionListSql($table,$idKey,$idValues,$num=1) {
    $idValues=array_column($idValues,'id');
    $sql = '';
    $ids = is_array($idValues) ? implode(',',$idValues) : $idValues;

    if ($ids) {
        $listTable = [];
        for ($i = 0; $i < $num; $i++) {
            $listTable[] = sprintf('SELECT * FROM %s_%s where %s in (%s)', $table, ($i + 1), $idKey, $ids);
        }
        $sql = '( ' . implode(" UNION ", $listTable) . ') AS ' . $table;
    }
//这里返回的是获取数据的失sql语句,简单点,直接执行就好,返回的就是我们需要的数据
    return   Db::query("select * from". $sql." order by id");

}