## thinkphp5.0数据库与模型的研究
**last update: 2022-11-03 15:08:22**
----
[TOC=3,8]
----
### getLastInsID 问题
同一个连接插入后如果不马上执行 `$this->getQuery()->getLastInsID($sequence)`,哪怕接下来执行一条 select 也会影响 `getLastInsID` 的值(变成0了)。
>[tip] **特别是持久连接时要注意**,所以多个持久连接时要使用 `\PDO::ATTR_PERSISTENT = 'string'` 字符串的方式区分不同的持久连接,不然有问题,参见: `app\smartpark\model\v1\DbActLog` 和 `think\log\driver\Socket`
(fpm 下 由于 日志保存是最后执行的,所以没出现过这个问题,不过如果强制写入日志时就会有问题了)
>[tip] **插入时如果指定了 id 主键的值,那么 getLastInsID 就获取不到插入的id,即 getLastInsID 的意思是获取 mysql 最后自动生成的id,而不是应用自主写入的。**
~~~
mysql> INSERT INTO `pt_parking_log` (`id` , `camera_id`) VALUES (1 , 1 );
Query OK, 1 row affected
mysql> SELECT LAST_INSERT_ID();
+------------------+
| LAST_INSERT_ID() |
+------------------+
| 0 |
+------------------+
1 row in set
mysql> INSERT INTO `pt_parking_log` (`camera_id`) VALUES (1);
Query OK, 1 row affected
mysql> SELECT LAST_INSERT_ID();
+------------------+
| LAST_INSERT_ID() |
+------------------+
| 2 |
+------------------+
1 row in set
mysql> INSERT INTO `pt_parking_log` (`id` , `camera_id`) VALUES (0 , 1 );
Query OK, 1 row affected
mysql> SELECT LAST_INSERT_ID();
+------------------+
| LAST_INSERT_ID() |
+------------------+
| 3 |
+------------------+
1 row in set
~~~
----
### PDO 连接复用 insertId 错乱 问题
本文记录解决 PDO 底层共用连接的导致 getLastInsID 错误的问题
[PHP: Connections and Connection management - Manual](https://www.php.net/manual/zh/pdo.connections.php
)
>[tip] PDO::ATTR_PERSISTENT选项的值转换为bool(启用/禁用持久连接),**除非它是非数字字符串,在这种情况下,它允许使用多个持久连接池。** 如果不同的连接使用不兼容的设置,这很有用
注意:即使 tp 层连接类 不是单例了,但是底层pdo 还是会复用,所以要设置 \PDO::ATTR_PERSISTENT 名称(字符串)来区分。
```php
<?php
namespace app\smartpark\model\v1;
class DbActLog extends BModel
{
protected $table = 'sp_db_act_log';
public function __construct($data = [])
{
// 避免和主 db 共用连接
$connection = config('database');
$connection['debug'] = false;
$connection['query'] = \think\db\Query::class;
// 不能使用同一个 主持久连接,否则 PDO 底层 会复用连接
// https://www.php.net/manual/zh/pdo.connections.php
$connection['params'][\PDO::ATTR_PERSISTENT] = 'db_act_log';
$this->connection = $connection;
parent::__construct($data);
}
}
```
----
### 源码分析
~~~php
think\Validate
protected $rule = []
protected $message = []
protected $field = []
protected $scene = []
$this->batch()->
// 定义场景或选择使用场景
$this->scene($name, $fields = null)->
hasScene($name)
check($data)
getError()
think\Model
// 设置验证规则
public $this->validate()->
// 自动验证数据 注意这是受保护的,不能外部主动调用
// 注意,验证通过的话,模型的验证规则会被重置位空:$this->validate = null
protected validateData() 只在 save/saveAll 中使用了
public save() // insert/update 操作
public saveAll()
public getError()
// Db::connect() 创建单例的 think\\db\\connector\Mysql [连接器对象]
// think\\db\\connector->connect() 单例的 new PDO 保存在 [连接器对象] $this->links[$linkNum] 中
// \\think\\db\\Query 查询器对象 保存在 think\\Model::$links(即一个模型类一个查询器单例对象) 中(new 查询器对象时 传入了连接实例 和当前模型对象),连接实例 是单例的 保存在 think\\Db::$instance
// 使用 db('name') 时,先单例 [连接器对象] connector (think\\Db::$instance),然后在 [连接器对象] 上执行 name()方法,实际是在 一个临时的、新的查询器上 (new 查询器对象时 传入了当前连接实例) 上执行,即 每次 db() 调用都会 new 新的 查询器对象
,但 [连接器对象] 是单例的。
// 注意 new \\think\\db\\Query 时,如果没有传入 连接器对象,则会 Db::connect([], true) 强制创建新 [连接器对象]
public getQuery() // 获取当前模型的查询对象
where 等链式操作都在查询器对象上
// 注意 new \\think\\db\\Query 时,如果没有传入 连接器对象,则会 Db::connect([], true); 强制创建新 [连接器对象]
查询器上的操作 最终都是通过调用 其属性 [连接器对象] 完成的:$this->connection->execute
()
系统获取 [连接器对象] 都是通过 think\\Db::connect() 连接配置生成key 保持单例 (think\\Db::$instance),数据库 PDO 连接 是惰性的,只有当 [连接器对象] 上有查询时才会真正连接,PDO连接 在 [连接器对象] 的 $this->links[$linkNum] 属性上,所以通常 系统中只有一个 [连接器对象] ,也只有 一个实际的数据库连接。
pdo sql 最终执行都是在连接器上,连接器上本身也有一些直接使用的sql执行方法 query/execute,如果调用的方法不存在 如 name()方法时,就会创建查询器 ($this->getQuery())在查询器上调用这个方法,注意这个创建的查询器对象是一次性的,没有在连接器对象上保存起来,所以 think\\Db::name('a') , think\\Db::name('a') 会返回两个独立的查询器对象
。
PDO 对象 在连接器对象上,连接器对象基本是单例的,不管在不同的模型上或是直接使用,所以 结果集的处理时要注意,即使在不同的模型上,因为共用连接,游标等,所以结果集处理时要注意,要防止获取到连接上上一次的查询结果集。
模型 每次自动验证后会清空 $this->validate 所以下次调用时,需要再次设置验证规则 ->validate(true),传入 true 则使用定义的 与当前模型名称同名的验证器类,tp 这里待优化,只记录了当前模型名称,没有记录完整类名,如果定位到与当前模块同名且同模块的验证器类。这就导致 如果在 index 模块 使用 admin 模块的模型,验证时使用的还是 index 模块的 验证器类,除非 传入 $this->validate('admin/User') 才行
~~~
----
### 总结
#### 连接器对象: PDO
think\\db\\connector\Mysql extends think\\db\\connector
$this->linkID 属性:PDO 数据库连接对象
单例在 `think\\Db::$instance` 上 (key 数据库配置MD5)
think\\Db::connect() 获取单例连接器对象(可传入强制连接,此时会重新实例化连接器对象)
think\\Db 调用不存在静态方法时,其实是调用 其连接器的方法
连接器上方法不存在时 就调用查询器上的方法(查询器对象是临时 new 的没有单例保存,创建查询器对象时传入了自身 $this)
`$this->links[$linkNum]` = new PDO();
连接器上每个连接序号的pdo对象是单例的,所以 **一个数据库连接在一个连接器对象上只会有一次,连接序号参数是因为主从多库的情况,此时一个连接器对象上可能有多个数据库的连接,但同样,每个数据库在一个连接器对象只有一次连接**
----
#### 查询器对象: Active Record: Data
\\think\\db\\Query
$this->connection 属性:连接器对象
$this->model 属性:模型对象
查询器上的sql执行方法,都是调用 连接器对象上的方法:
`query() => $this->connection->query() => $connection->linkID->execute()`
查询器主要是实现sql 解析等链式方法,如 where inc 等。最终生成sql 给连接器执行。
在返回结果前,如果 有 $model 属性,则会 返回 $model 对象,也就是 ActiveRecord 化处理。
----
#### 模型: Active Record: Object Item
self::$links[get_called_class()] 静态属性:查询器对象 (注意是 self 即 think\Model)
static::$initialized[get_class($this)] 静态属性:查询器对象 (注意是 static 即 实际调用的 模型类)
self::$event[get_called_class()] 静态属性:每个模型上有各自的事件
```php
public function __call($method, $args)
{
$query = $this->db(true, false);
...
}
public static function __callStatic($method, $args)
{
$model = new static();
$query = $model->db();
...
}
protected function initialize()
{
$class = get_class($this);
if (!isset(static::$initialized[$class])) {
static::$initialized[$class] = true;
static::init();
}
}
protected static function init()
{
}
```
当调用不存在的静态方法时,如 User::find()、Model::with() ,会 自动 new 当前模型类,并调用其 $this->db(true, true) 方法获取查询器对象(强制获取新 查询器对象),最终调用的是 查询器上的 find() 方法,并返回。
当调用 User::get() 时,static::parseQuery() -> self::with() : $query->find() (注意这里 static/self 的差别) 获取查询器,最终调用查询器的find() 方法 返回结果。(新模型对象,新查询器对象)
查询器对象保存在 `self::$links[$this->class]` 模型类上,**注意是类而不是对象实例。**
所以:如果**调用不存在的静态方法** 每次会创建新的查询器对象 $this->db(true, true),如果 **调用不存在的非静态方法**,则会有单例效果 $this->db(true, false) 即 **一个模型对象上 都是同一个查询器对象**。
buildQuery() new 创建查询器对象时,传入了 Db::connect($connection) 作为连接器对象参数,和 $this 作为模型对象参数。
~~~php
User::get()
$query = static::parseQuery()
self::with()
->find()
这里 self::with() 而不是 static::with() 暂时没研究清楚有什么区别意义。
~~~
----
#### 分析
1. 平时直接 Db::name('')->find() 执行sql, 多次操作会创建多次查询器对象,如果使用 new 模型就能避免(注意不是模型方法静态调用)
2. 不论直接使用连接器对象,还是使用模型,不论多次调用或实例化,数据库连接对象只有一个,因为单例在 think\\\\Db::$instance 上了。
3. 使用模型必须要定义自己的模型类,没有验证器那那样的 “独立验证”
----
### 补充知识:延迟静态绑定(late static binding)
注意 static:: 和 self:: 的区别:
类的静态属性全局只有一个,这二者都是将数据保存在类的静态属性上,不同的是 static:: 是实际执行的具体类,self:: 是当前类(字面代码所在的类)。 $this-> 是访问实际具体对象实例上的属性。
----
get_called_class() (获取静态方法调用的类名) 和 get_class() 的区别:
知识点:延迟静态绑定(late static binding),静态方法和属性在定义是就绑定了,static:: 关键字 可以访问延迟绑定的静态属性和方法。
所以请仔细理解 think\\Model 中 :
self:: 当前类,即 think\\Model
static:: 后期静态绑定类,如 User::get() 这种 用户定义的模型类
$this->class = get_called_class()
用来在每个实际具体模型上实现查询器对象的单例化
self::$links[$this->class] = 查询器对象(think\\Model::$links[A/B/C/...])
----
initialize() 模型初始化(实例化)
每个模型类 实例化为对象时的 构造方法
每次 new User 实例化 都会调用初始化方法,如 每次 User::get(1) 都会 new 新的实际模型对象
----
static init() 模型初始化
static::$initialized[get_class($this)] = true
> 同样也可以使用静态`init`方法,需要注意的是`init`只在第一次实例化的时候执行(多次 new 也只会执行一次),并且方法内需要注意静态调用的规范。
待研究 这里明明应该 使用 static::$initialized 标记就行了啊?
----
self::$event 每个模型上的事件
self::$event[get_called_class()][$event][] = $callback;
self::$event[stataic] 相当于事件是注册到 think\Model[模型定义类(A/B/C/...)] 上。
----
[PHP: 后期静态绑定 - Manual](https://www.php.net/manual/zh/language.oop5.late-static-bindings.php)
```php
<?php
// static,self 分析
class A {
static $a = 'a';
public function setA()
{
self::$a = 'b';
}
public function setA2()
{
static::$a = 'b';
}
public function getA()
{
return self::$a;
}
public function getA2()
{
return static::$a;
}
}
class B extends A {
// 如果没有子类继承重写, static 设置时会有 self 效果
static $a = 'a_';
}
class C extends A {
static $a = 'a__';
}
$A = new A;
$B = new B;
$C = new C;
----
echo C::$a;
// a__
echo $B->getA(); // a
echo $B->getA2(); // a_
$B->setA();
echo $B->getA(); // b
echo $B->getA2(); // a_
----
$B->setA(); // A/B/C 都是一样的
echo $A->getA(); // b
echo $A->getA2(); // b
echo $B->getA(); // b
echo $B->getA2(); // a_
echo $C->getA(); // b
echo $C->getA2(); // a__
echo A::$a; // b
echo B::$a; // a_
echo C::$a; // a__
----
$B->setA2();
echo $A->getA(); // a
echo $A->getA2(); // a
echo $B->getA(); // a
echo $B->getA2(); // b
echo $C->getA(); // a
echo $C->getA2(); // a__
echo A::$a; // a
echo B::$a; // b
echo C::$a; // a__
```
----
### 相关资料
[数据库 · ThinkPHP5.0完全开发手册 · 看云](https://www.kancloud.cn/manual/thinkphp5/118058)
[模型 · ThinkPHP5.0完全开发手册 · 看云](https://www.kancloud.cn/manual/thinkphp5/135186)
[掌握ThinkPHP5数据库和模型 · 看云](https://www.kancloud.cn/thinkphp/master-database-and-model)
[ThinkORM开发指南 · 看云](https://www.kancloud.cn/manual/think-orm)
[ORM介绍 - 知乎](https://zhuanlan.zhihu.com/p/151373067)
[ORM 实例教程 - 阮一峰的网络日志](http://www.ruanyifeng.com/blog/2019/02/orm-tutorial.html)
[浅谈MyBatis-Plus学习之ActiveRecord - hjjay - 博客园](https://www.cnblogs.com/jayhou/p/9824232.html)
> Active Record(简称AR),是一种领域模型模式,特点是一个模型类对应关系型数据库中的一个表,而模型类的一个实例对应表中的一行记录。
----
last update: 2022-04-05 18:12:22
- 开始
- 公益
- 更好的使用看云
- 推荐书单
- 优秀资源整理
- 技术文章写作规范
- SublimeText - 编码利器
- PSR-0/PSR-4命名标准
- php的多进程实验分析
- 高级PHP
- 进程
- 信号
- 事件
- IO模型
- 同步、异步
- socket
- Swoole
- PHP扩展
- Composer
- easyswoole
- php多线程
- 守护程序
- 文件锁
- s-socket
- aphp
- 队列&并发
- 队列
- 讲个故事
- 如何最大效率的问题
- 访问式的web服务(一)
- 访问式的web服务(二)
- 请求
- 浏览器访问阻塞问题
- Swoole
- 你必须理解的计算机核心概念 - 码农翻身
- CPU阿甘 - 码农翻身
- 异步通知,那我要怎么通知你啊?
- 实时操作系统
- 深入实时 Linux
- Redis 实现队列
- redis与队列
- 定时-时钟-阻塞
- 计算机的生命
- 多进程/多线程
- 进程通信
- 拜占庭将军问题深入探讨
- JAVA CAS原理深度分析
- 队列的思考
- 走进并发的世界
- 锁
- 事务笔记
- 并发问题带来的后果
- 为什么说乐观锁是安全的
- 内存锁与内存事务 - 刘小兵2014
- 加锁还是不加锁,这是一个问题 - 码农翻身
- 编程世界的那把锁 - 码农翻身
- 如何保证万无一失
- 传统事务与柔性事务
- 大白话搞懂什么是同步/异步/阻塞/非阻塞
- redis实现锁
- 浅谈mysql事务
- PHP异常
- php错误
- 文件加载
- 路由与伪静态
- URL模式之分析
- 字符串处理
- 正则表达式
- 数组合并与+
- 文件上传
- 常用验证与过滤
- 记录
- 趣图
- foreach需要注意的问题
- Discuz!笔记
- 程序设计思维
- 抽象与具体
- 配置
- 关于如何学习的思考
- 编程思维
- 谈编程
- 如何安全的修改对象
- 临时
- 临时笔记
- 透过问题看本质
- 程序后门
- 边界检查
- session
- 安全
- 王垠
- 第三方数据接口
- 验证码问题
- 还是少不了虚拟机
- 程序员如何谈恋爱
- 程序员为什么要一直改BUG,为什么不能一次性把代码写好?
- 碎碎念
- 算法
- 实用代码
- 相对私密与绝对私密
- 学习目标
- 随记
- 编程小知识
- foo
- 落盘
- URL编码的思考
- 字符编码
- Elasticsearch
- TCP-IP协议
- 碎碎念2
- Grafana
- EFK、ELK
- RPC
- 依赖注入
- 开发笔记
- 经纬度格式转换
- php时区问题
- 解决本地开发时调用远程AIP跨域问题
- 后期静态绑定
- 谈tp的跳转提示页面
- 无限分类问题
- 生成微缩图
- MVC名词
- MVC架构
- 也许模块不是唯一的答案
- 哈希算法
- 开发后台
- 软件设计架构
- mysql表字段设计
- 上传表如何设计
- 二开心得
- awesomes-tables
- 安全的代码部署
- 微信开发笔记
- 账户授权相关
- 小程序获取是否关注其公众号
- 支付相关
- 提交订单
- 微信支付笔记
- 支付接口笔记
- 支付中心开发
- 下单与支付
- 支付流程设计
- 订单与支付设计
- 敏感操作验证
- 排序设计
- 代码的运行环境
- 搜索关键字的显示处理
- 接口异步更新ip信息
- 图片处理
- 项目搭建
- 阅读文档的新方式
- mysql_insert_id并发问题思考
- 行锁注意事项
- 细节注意
- 如何处理用户的输入
- 不可见的字符
- 抽奖
- 时间处理
- 应用开发实战
- python 学习记录
- Scrapy 教程
- Playwright 教程
- stealth.min.js
- Selenium 教程
- requests 教程
- pyautogui 教程
- Flask 教程
- PyInstaller 教程
- 蜘蛛
- python 文档相似度验证
- thinkphp5.0数据库与模型的研究
- workerman进程管理
- workerman网络分析
- java学习记录
- docker
- 笔记
- kubernetes
- Kubernetes
- PaddlePaddle
- composer
- oneinstack
- 人工智能 AI
- 京东
- pc_detailpage_wareBusiness
- doc
- 电商网站设计
- iwebshop
- 商品规格分析
- 商品属性分析
- tpshop
- 商品规格分析
- 商品属性分析
- 电商表设计
- 设计记录
- 优惠券
- 生成唯一订单号
- 购物车技术
- 分类与类型
- 微信登录与绑定
- 京东到家库存系统架构设计
- crmeb
- 命名规范
- Nginx https配置
- 关于人工智能
- 从人的思考方式到二叉树
- 架构
- 今日有感
- 文章保存
- 安全背后: 浏览器是如何校验证书的
- 避不开的分布式事务
- devops自动化运维、部署、测试的最后一公里 —— ApiFox 云时代的接口管理工具
- 找到自己今生要做的事
- 自动化生活
- 开源与浆果
- Apifox: API 接口自动化测试指南