illuminate/database 使用 四

文档：Hyperf

Database: Getting Started - Laravel 10.x - The PHP Framework For Web Artisans

因为hyperf使用illuminate/database，所以按照文章，看illuminate/database代码实现。

一、读写分离

根据文档读写的host可以分开。设置读写分离的前提，做数据库出从同步。
 

1.1 数据库主从同步

参考：mysql5.7 主从配置-CSDN博客

1.2 设置

配置中设置三个数据read、write、sticky。read、write都包含host数组，其配置会和主要配置合并。就是说，比如host相同，应该在read、write中设置对应数据，以覆盖主要设置。

sticky选项是一个可选值，可用于允许在当前请求周期内立即读取已写入数据库的记录。如果启用了sticky选项，并且在当前请求周期中对数据库执行了“写”操作，则任何进一步的“读”操作都将使用“写”连接。这确保了在请求周期内写入的任何数据都可以在同一请求期间立即从数据库中读回。

源码如下：

#Illuminate\Database\Connectors\ConnectionFactory
protected function getReadConfig(array $config){return $this->mergeReadWriteConfig($config, $this->getReadWriteConfig($config, 'read'));}
protected function getWriteConfig(array $config){return $this->mergeReadWriteConfig($config, $this->getReadWriteConfig($config, 'write'));}
protected function mergeReadWriteConfig(array $config, array $merge){return Arr::except(array_merge($config, $merge), ['read', 'write']);}#Illuminate\Database\Connection
public function getReadPdo(){if ($this->transactions > 0) {return $this->getPdo();}if ($this->readOnWriteConnection ||($this->recordsModified && $this->getConfig('sticky'))) {return $this->getPdo();}if ($this->readPdo instanceof Closure) {return $this->readPdo = call_user_func($this->readPdo);}return $this->readPdo ?: $this->getPdo();}

1.3 测试

配置如下

#config/database.php
return ['migrations' => '', //数据迁移//PDO文档 https://www.php.net/manual/zh/pdo.constants.php'default' => 'master','connections' => ['master' => ['driver' => 'mysql','host' => 'localhost','database' => 'test','username' => 'root','password' => 'qwe110110','charset' => 'utf8','collation' => 'utf8_general_ci','prefix' => '','port' => '3306','read' => ['host' => ['127.0.0.1'],'port' => '3307',],'write' => ['host' => ['127.0.0.1'],'port' => '3306',],],]
];

 测试代码

function test1()
{new App();$query = "concat('-',id)";$as = "id";//$info1 = DbManager::table('userinfo')->select(['name'])->selectSub($query, $as)->addSelect(['age'])->get();$info1 = DbManager::table('userinfo')->select(['name'])->selectSub($query, $as)->addSelect(['age'])->get();var_dump($info1);$data = $info1->all();$insertData = ['name' => 'test1', 'age' => 1];$id = DbManager::table('userinfo')->insertGetId($insertData);var_dump($id);//exit;//$sql = "CONCAT('A-',name)";//$info2 = DbManager::table('userinfo')->selectSub($sql, "table")->toSql()->dump();
}
test1();

 返回结果

string(29) "Illuminate\Support\Collection"
array(8) {[0] =>class stdClass#18 (3) {public $name =>string(3) "123"public $id =>string(2) "-1"public $age =>int(22)}[1] =>class stdClass#22 (3) {public $name =>string(5) "name2"public $id =>string(2) "-2"public $age =>int(13)}[2] =>class stdClass#23 (3) {public $name =>string(5) "name3"public $id =>string(2) "-3"public $age =>int(24)}[3] =>class stdClass#24 (3) {public $name =>string(5) "33321"public $id =>string(2) "-4"public $age =>int(0)}[4] =>class stdClass#25 (3) {public $name =>string(5) "test1"public $id =>string(2) "-5"public $age =>int(1)}[5] =>class stdClass#26 (3) {public $name =>string(5) "test1"public $id =>string(2) "-6"public $age =>int(1)}[6] =>class stdClass#27 (3) {public $name =>string(5) "test1"public $id =>string(2) "-7"public $age =>int(1)}[7] =>class stdClass#28 (3) {public $name =>string(5) "test1"public $id =>string(2) "-8"public $age =>int(1)}
}
int(9)

 从库：

 主库

 

 测试成功~

1.4 返回数据处理

从测试结果看，返回的都是对象，因为默认使用PDO::FETCH_OBJ。

参考：PHP: PDO - Manual

源码如下

#Illuminate\Database\Capsule\Manager
public function __construct(Container $container = null){$this->setupContainer($container ?: new Container);// Once we have the container setup, we will setup the default configuration// options in the container "config" binding. This will make the database// manager work correctly out of the box without extreme configuration.$this->setupDefaultConfiguration();$this->setupManager();}
protected function setupDefaultConfiguration(){$this->container['config']['database.fetch'] = PDO::FETCH_OBJ;$this->container['config']['database.default'] = 'default';}
public function setFetchMode($fetchMode){$this->container['config']['database.fetch'] = $fetchMode;return $this;}#Illuminate\Database\Connection
protected $fetchMode = PDO::FETCH_OBJ;
public function select($query, $bindings = [], $useReadPdo = true){return $this->run($query, $bindings, function ($query, $bindings) use ($useReadPdo) {if ($this->pretending()) {return [];}// For select statements, we'll simply execute the query and return an array// of the database result set. Each element in the array will be a single// row from the database table, and will either be an array or objects.$statement = $this->prepared($this->getPdoForSelect($useReadPdo)->prepare($query));$this->bindValues($statement, $this->prepareBindings($bindings));$statement->execute();return $statement->fetchAll();});}
protected function prepared(PDOStatement $statement){$statement->setFetchMode($this->fetchMode);$this->event(new StatementPrepared($this, $statement));return $statement;}

想返回数组可以设置为PDO::FETCH_ASSOC。最简单的方法就是替换源码，二次开发最好就是用对象，或者写个对象转数组的方法，tp里面有源码。tp是查出来对象，可使用toArray()搞成数组。

get()返回的类是Illuminate\Support\Collection，此类中还有一些数据统计的方法，比如平均值之类。意思就是查出来数据再做数据统计。

二、多库配置

根据laravel文档：如果应用程序在config/database.php配置文件中定义了多个连接，则可以通过DB facade提供的连接方法访问每个连接。

use Illuminate\Support\Facades\DB;$users = DB::connection('sqlite')->select(/* ... */);
$pdo = DB::connection()->getPdo();

但是仅用这个库由于没有对应数据，会返回db类是null。

源码如下：

#Illuminate\Support\Facades\Facade
public static function getFacadeRoot(){return static::resolveFacadeInstance(static::getFacadeAccessor());}
public static function __callStatic($method, $args){$instance = static::getFacadeRoot();if (!$instance) {throw new RuntimeException('A facade root has not been set.');}return $instance->$method(...$args);}protected static function resolveFacadeInstance($name){if (is_object($name)) {return $name;}if (isset(static::$resolvedInstance[$name])) {return static::$resolvedInstance[$name];}if (static::$app) {return static::$resolvedInstance[$name] = static::$app[$name];}}

根据方法resolveFacadeInstance(),$name应该是‘db’,不是对象，$resolvedInstance、$app没有对应对象，所以返回空。估计得配合其他类库。比如hyperf中需要

composer require hyperf/database

 那么不用其他类库怎么实现多库切换……

多库配置

return ['migrations' => '', //数据迁移//PDO文档 https://www.php.net/manual/zh/pdo.constants.php'default' => 'master','connections' => ['master' => ['driver' => 'mysql','host' => 'localhost','database' => 'test','username' => 'root','password' => 'mima','charset' => 'utf8','collation' => 'utf8_general_ci','prefix' => '','port' => '3306','read' => ['host' => ['127.0.0.1'],'port' => '3307',],'write' => ['host' => ['127.0.0.1'],'port' => '3306',],],'test' => ["driver" => "mysql","host" => "127.0.0.1","database" => "test1","username" => "root","password" => "mima",'charset' => 'utf8mb4','collation' => 'utf8mb4_unicode_ci','prefix' => '','port' => '3307',],],
];

function test2()
{$app = new App();$info = DbManager::connection('test')->table('userinfo')->where('id', '=', 1)->get();$info = $info->first();var_dump($info);
}test2();

 返回数据

class stdClass#20 (2) {public $id =>int(1)public $name =>string(1) "1"
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/170274.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

管理类联考——写作——考点+记忆篇——论证有效性分析——记忆

管理类联考——写作——考点+记忆篇——论证有效性分析——记忆

文章目录 论证有效性分析得分要点、寻找漏洞方法论证有效性分析五大逻辑漏洞类型论证有效性分析的具体写法论证有效性分析十大解题思路（上）方法一：理想法方法二：极端法方法三：其他因素法方法四：可行性法 论…
阅读更多...
Everything进行内网穿透搜索

Everything进行内网穿透搜索

文章目录 1\. 部署内网穿透1.1. 注册账号1.2. 登录1.3. 创建隧道 2\. 从外网访问Everything 借助cpolar可以让我们在公网上访问到本地的电脑 1. 部署内网穿透 1.1. 注册账号 在使用之前需要先进行注册cpolar cpolar secure introspectable tunnels to localhost 1.2. 登录 C…
阅读更多...
grdle 的安装与配置 、gradle和jdk版本对应关系

grdle 的安装与配置 、gradle和jdk版本对应关系

java与gradle对应的版本关系 Java Java Gradle需要Java版本在8到19之间。目前还不支持Java 20及更高版本。 Java 6和Java 7仍然可以用于编译，但已经不适合用于测试。Gradle 9.0不支持Java 6和Java 7的测试。任何完全支持的Java版本都可以用于编译或测试。 然而&…
阅读更多...
Ubuntu下使用protoBuf

Ubuntu下使用protoBuf

一、protobuf简介： 1.1 protobuf的定义： protobuf是用来干嘛的？ protobuf是一种用于 对结构数据进行序列化的工具，从而实现 数据存储和交换。 （主要用于网络通信中 收发两端进行消息交互。所谓的“结构数据”是指类…
阅读更多...
【STM32】GPIO输出

【STM32】GPIO输出

1 GPIO简介 （1）GPIO（General Purpose Input Output）通用输入输出口 （2）可配置为8种输入输出模式 （3）引脚电平：0V~3.3V，部分引脚可容忍5V（可以输…
阅读更多...
【LeetCode】挑战100天 Day15（热题+面试经典150题）

【LeetCode】挑战100天 Day15（热题+面试经典150题）

【LeetCode】挑战100天 Day15（热题面试经典150题） 一、LeetCode介绍二、LeetCode 热题 HOT 100-172.1 题目2.2 题解 三、面试经典 150 题-173.1 题目3.2 题解 一、LeetCode介绍 LeetCode是一个在线编程网站，提供各种算法和数据结构的题目&…
阅读更多...
QQ空间上传一次 500张限制突破记录

QQ空间上传一次 500张限制突破记录

手机又好多照片了，用手机上传耽误时间，就导出到电脑了，上传到qq空间去。 结果发现不开通黄钻无法上传原图，那就开通吧！ 开通了黄钻，居然不能一次上传超过 500 张，开通有何用？ 五千…
阅读更多...
电磁场信息论及先进MIMO (黄大年茶思屋座谈) 笔记

电磁场信息论及先进MIMO (黄大年茶思屋座谈) 笔记

天线阵的负载动态调控，动态阻抗匹配网络，实时跟着扫描角度的变化而变化，可能突破Hannan极限。 新的天线构架： 周期 —》非周期 每个单元不一样 动态可调，可重构 每个天线多端口或多模式 多层天线 非周期结构天线的增…
阅读更多...
vscode导入STM32CubeIDE工程文件夹未定义警告清除方法

vscode导入STM32CubeIDE工程文件夹未定义警告清除方法

0 前言 在我们使用vscode去编辑STM32CubeIDE的工程文件时，经常会出现一些类型未定义、头文件路径无效的问题，无法正常使用且非常影响观感。本文介绍如何设置vscode导入的STM32CubeIDE配置文件，解决这一问题。 1 vscode导入STM32CubeIDE工程…
阅读更多...
从0到0.01入门 Webpack| 003.精选 Webpack面试题

从0到0.01入门 Webpack| 003.精选 Webpack面试题

🤍 前端开发工程师（主业）、技术博主（副业）、已过CET6 🍨 阿珊和她的猫_CSDN个人主页 🕠 牛客高级专题作者、在牛客打造高质量专栏《前端面试必备》 🍚 蓝桥云课签约作者、已在蓝桥云…
阅读更多...
rocky8.9配置K8S集群kubernetes,centos同理

rocky8.9配置K8S集群kubernetes,centos同理

rocky8.9配置K8S集群 节点主机名IP地址mastertang1192.168.211.101node1tang2192.168.211.102node2tang3192.168.211.103 1）准备工作 全部主机都配置静态ip vi /etc/sysconfig/network-scriptsTYPEEthernet PROXY_METHODnone BROWSER_ONLYno BOOTPROTOstatic DE…
阅读更多...
【C指针（五）】6种转移表实现整合longjmp()/setjmp()函数和qsort函数详解分析模拟实现

【C指针（五）】6种转移表实现整合longjmp()/setjmp()函数和qsort函数详解分析模拟实现

🌈write in front :🔍个人主页 ： 啊森要自信的主页 ✏️真正相信奇迹的家伙，本身和奇迹一样了不起啊！ 欢迎大家关注🔍点赞👍收藏⭐️留言📝>希望看完我的文章对你有小小的帮助&am…
阅读更多...
java学习part11继承

java学习part11继承

1.类的继承 继承为了让类之间建立联系，同时复用代码。 子类和父类的同名函数构成重写，能覆盖，除非用super.xx()调。 同名属性不会覆盖，而是并存，用super.xx调。 2.子类初始化 子类会自动调用父类无参构造super() 3.重…
阅读更多...
如何把自己银行卡里的钱转账充值到自己支付宝上？

如何把自己银行卡里的钱转账充值到自己支付宝上？

原文来源：https://www.caochai.com/article-4524.html 支付宝余额是支付宝核心功能之一，主要用于网购支付、线下支付、转账等场景。用户可以将银行卡、余额宝等资金转入或转出至支付宝余额，实现快速转账和支付。 如何把自己银行卡里的钱转账…
阅读更多...
PyCharm 安装插件Vue

PyCharm 安装插件Vue

一、打开PyCharm工具 File -> Settings -> Plugins 二、在项目中添加Vue.js的依赖项。 npm install vue 三、页面应用
阅读更多...
基于51单片机的百叶窗控制系统设计

基于51单片机的百叶窗控制系统设计

**单片机设计介绍， 基于51单片机的百叶窗控制系统设计 文章目录 一 概要二、功能设计设计思路 三、 软件设计原理图 五、 程序六、 文章目录 一 概要 基于51单片机的百叶窗控制系统设计可以分为硬件设计和软件设计两个方面。下面是一个简要的设计介绍： …
阅读更多...
【微服务专题】SpringBoot自动配置简单源码解析

【微服务专题】SpringBoot自动配置简单源码解析

目录 前言阅读对象阅读导航前置知识什么是自动配置0.1 基本概念0.2 SpringBoot中的【约定大于配置】0.3 从SpringMVC看【约定大于配置】0.4 从Redis看【约定大于配置】0.5 小结 笔记正文一、EnableAutoConfiguration源码解析二、SpringBoot常用条件注解源码解析2.1 自定义条件注…
阅读更多...
HCIP-七、IS-IS 综合实验

HCIP-七、IS-IS 综合实验

七、IS-IS 综合实验 实验拓扑实验需求及解法1.如图所示，配置所有路由器的接口IP地址。2.运行IS-IS，进程号13.IS-IS优化4.路径优化 实验拓扑 实验需求及解法 本实验模拟IS-IS综合网络，完成以下需求： 1.如图所示，配置所…
阅读更多...
2017年7月13日 Go生态洞察：向Go 2迈进

2017年7月13日 Go生态洞察：向Go 2迈进

🌷🍁 博主猫头虎（🐅🐾）带您 Go to New World✨🍁 🦄 博客首页——🐅🐾猫头虎的博客🎐 🐳 《面试题大全专栏》 🦕 文章图文…
阅读更多...
影刀RPA_boss直聘翻页（避坑）

影刀RPA_boss直聘翻页（避坑）

boss直聘翻页这里有个坑 问题： 无限循环中，点击下一页按钮，直到不可点击为止。 发现，在点到第5页的时候，再次点击下一页，直接就点击了页码10，导致流程直接就结束了。 在第5页进行校验&#xff0…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023