hyperf 二十 数据库 三 创建脚本

教程：Hyperf

根据之前文章：hyperf 十九 数据库 二 模型-CSDN博客   应该能了解到visitors参数。

根据教程，使用visitors参数创建脚本。在配置在设置visitors参数，格式为数据。

一、可选脚本说明

  • Hyperf\Database\Commands\Ast\ModelRewriteKeyInfoVisitor：根据数据库中主键，生成对应的 $incrementing $primaryKey 和 $keyType。
  • Hyperf\Database\Commands\Ast\ModelRewriteSoftDeletesVisitor：据 DELETED_AT 常量判断该模型是否含有软删除字段，如果存在，则添加对应的 Trait SoftDeletes。
  • Hyperf\Database\Commands\Ast\ModelRewriteTimestampsVisitor：根据 created_at 和 updated_at 自动判断，是否启用默认记录 创建和修改时间 的功能。
  • Hyperf\Database\Commands\Ast\ModelRewriteGetterSetterVisitor：根据数据库字段生成对应的 getter 和 setter。

二、自定义映射关系

教程中作为例子的被覆盖的脚本为Hyperf\Database\Commands\Ast\ModelUpdateVisitor。

Hyperf\Database\Commands\ModelCommand中默认使用的脚本包括Hyperf\Database\Commands\Ast\ModelUpdateVisitor、Hyperf\Database\Commands\Ast\ModelRewriteConnectionVisitor。

ModelCommand中通过 PhpParser\NodeTraverser类调用脚本。对NodeTraverser类设置脚本，NodeTraverser::traverse()循环被添加的脚本处理节点数据。ModelCommand获取处理后的数据设置为文件内容。

如教程上所示，自定义脚本中覆盖部分方法，再对应类。再次运行应该会执行自定义的内容。

namespace App\Kernel\Visitor;use Hyperf\Database\Commands\Ast\ModelUpdateVisitor as Visitor;
use Hyperf\Utils\Str;class ModelUpdateVisitor extends Visitor
{/*** Used by `casts` attribute.*/protected function formatDatabaseType(string $type): ?string{switch ($type) {case 'tinyint':case 'smallint':case 'mediumint':case 'int':case 'bigint':return 'integer';case 'decimal':// 设置为 decimal，并设置对应精度return 'decimal:2';case 'float':case 'double':case 'real':return 'float';case 'bool':case 'boolean':return 'boolean';default:return null;}}/*** Used by `@property` docs.*/protected function formatPropertyType(string $type, ?string $cast): ?string{if (! isset($cast)) {$cast = $this->formatDatabaseType($type) ?? 'string';}switch ($cast) {case 'integer':return 'int';case 'date':case 'datetime':return '\Carbon\Carbon';case 'json':return 'array';}if (Str::startsWith($cast, 'decimal')) {// 如果 cast 为 decimal，则 @property 改为 stringreturn 'string';}return $cast;}
}
#config/autoload/dependencies.php
return [Hyperf\Database\Commands\Ast\ModelUpdateVisitor::class => App\Kernel\Visitor\ModelUpdateVisitor::class,
];

三、测试

配置

#config/autoload/database.php
'commands' => ['gen:model' => ['path' => '/app1/Model','force_casts' => true,'inheritance' => 'Model','visitors' => ['Hyperf\Database\Commands\Ast\ModelRewriteKeyInfoVisitor','Hyperf\Database\Commands\Ast\ModelRewriteTimestampsVisitor','Hyperf\Database\Commands\Ast\ModelRewriteSoftDeletesVisitor',],'table_mapping' => ['userinfo:User'],],],

这里需要注意的是gen:model里面的键名，比如命令为table-mapping，但是设置的时候键名为table_mapping。造成这个现象，是因为框架里获取用的键名与命令中参数名不一致。

执行命令：php bin/hyperf.php gen:model  userinfo

生成文件

declare (strict_types=1);
namespace App1\Model;use Hyperf\Database\Model\SoftDeletes;
use Hyperf\DbConnection\Model\Model;
/*** @property int $id * @property string $name * @property int $age * @property string $deleted_at */
class User extends Model
{use SoftDeletes;public $timestamps = false;/*** The table associated with the model.** @var string*/protected $table = 'userinfo';/*** The attributes that are mass assignable.** @var array*/protected $fillable = [];/*** The attributes that should be cast to native types.** @var array*/protected $casts = ['id' => 'integer', 'age' => 'integer'];
}

查询

#测试代码
$user = User::query()->where('id', 1)->first();
var_dump($user->name, $user->age, $user->toArray());#运行结果
string(3) "123"
int(22)
array(4) {["id"]=>int(1)["name"]=>string(3) "123"["age"]=>int(22)["deleted_at"]=>NULL
}

 四、测试 修改DELETED_AT

根据源码Hyperf\Database\Commands\Ast\ModelRewriteSoftDeletesVisitor::useSoftDeletes(),

DELETED_AT是动态设置，会判断model中是否有DELETED_AT没有才会设置为deleted_at。

自定义model的父类Hyperf\Database\Model\Model没有设置DELETED_AT，所以要修改DELETED_AT对应的数据库名，而且在不改源码的基础上，需要在已创建的model中设置DELETED_AT。

#测试代码
namespace App1\Model;use Hyperf\Database\Model\SoftDeletes;
use Hyperf\DbConnection\Model\Model;class User extends Model
{use SoftDeletes;public const DELETED_AT = 'deleted_time';
}#测试结果
SQLSTATE[42S22]: Column not found: 1054 Unknown column 'userinfo.deleted_time' in 'where clause' (SQL: update `userinfo` set `deleted_time` = 2024-01-05 08:23:02 where (`id` = 23) and `userinfo`.`deleted_time` is null)[1088] in /wj/hyperf/hyperfpro2/vendor/hyperf/database/src/Connection.php

 报错是因为没改数据库，所以没有对应字段。虽然报错，但是证明sql执行正常，所以测试成功。

CREATED_AT,UPDATED_AT修改方案和上面相同。

五、源码

4.1 参数值获取

#Hyperf\Database\Commands\ModelCommand 
public function handle(){$table = $this->input->getArgument('table');$pool = $this->input->getOption('pool');$option = new ModelOption();$option->setPool($pool)->setPath($this->getOption('path', 'commands.gen:model.path', $pool, 'app/Model'))->setPrefix($this->getOption('prefix', 'prefix', $pool, ''))->setInheritance($this->getOption('inheritance', 'commands.gen:model.inheritance', $pool, 'Model'))->setUses($this->getOption('uses', 'commands.gen:model.uses', $pool, 'Hyperf\DbConnection\Model\Model'))->setForceCasts($this->getOption('force-casts', 'commands.gen:model.force_casts', $pool, false))->setRefreshFillable($this->getOption('refresh-fillable', 'commands.gen:model.refresh_fillable', $pool, false))->setTableMapping($this->getOption('table-mapping', 'commands.gen:model.table_mapping', $pool, []))->setIgnoreTables($this->getOption('ignore-tables', 'commands.gen:model.ignore_tables', $pool, []))->setWithComments($this->getOption('with-comments', 'commands.gen:model.with_comments', $pool, false))->setWithIde($this->getOption('with-ide', 'commands.gen:model.with_ide', $pool, false))->setVisitors($this->getOption('visitors', 'commands.gen:model.visitors', $pool, []))->setPropertyCase($this->getOption('property-case', 'commands.gen:model.property_case', $pool));if ($table) {$this->createModel($table, $option);} else {$this->createModels($option);}}
protected function getOption(string $name, string $key, string $pool = 'default', $default = null){$result = $this->input->getOption($name);$nonInput = null;if (in_array($name, ['force-casts', 'refresh-fillable', 'with-comments', 'with-ide'])) {$nonInput = false;}if (in_array($name, ['table-mapping', 'ignore-tables', 'visitors'])) {$nonInput = [];}if ($result === $nonInput) {$result = $this->config->get("databases.{$pool}.{$key}", $default);}return $result;}
#Hyperf\Config\ConfigProvider
'dependencies' => [ConfigInterface::class => ConfigFactory::class,],
namespace Hyperf\Config;
class ConfigFactory
{public function __invoke(ContainerInterface $container){$configPath = BASE_PATH . '/config/';$config = $this->readConfig($configPath . 'config.php');$autoloadConfig = $this->readPaths([BASE_PATH . '/config/autoload']);$merged = array_merge_recursive(ProviderConfig::load(), $config, ...$autoloadConfig);return new Config($merged);}
}
namespace Hyperf\Config;
class Config implements ConfigInterface
{/*** @var array*/private $configs = [];public function __construct(array $configs){$this->configs = $configs;}public function get(string $key, $default = null){return data_get($this->configs, $key, $default);}
}
#vendor\hyperf\utils\src\Functions.php
if (!function_exists('data_get')) {/*** Get an item from an array or object using "dot" notation.** @param null|array|int|string $key* @param null|mixed $default* @param mixed $target*/function data_get($target, $key, $default = null){//var_dump("data_get");if (is_null($key)) {return $target;}//var_dump($target, $key);$key = is_array($key) ? $key : explode('.', is_int($key) ? (string) $key : $key);while (!is_null($segment = array_shift($key))) {//var_dump($segment);if ($segment === '*') {if ($target instanceof Collection) {$target = $target->all();} elseif (!is_array($target)) {return value($default);}$result = [];foreach ($target as $item) {$result[] = data_get($item, $key);}return in_array('*', $key) ? Arr::collapse($result) : $result;}if (Arr::accessible($target) && Arr::exists($target, $segment)) {$target = $target[$segment];} elseif (is_object($target) && isset($target->{$segment})) {$target = $target->{$segment};} else {return value($default);}}return $target;}
}

4.2 DELETED_AT、CREATED_AT、UPDATED_AT相关

#Hyperf\Database\Model\Modelpublic const CREATED_AT = 'created_at';public const UPDATED_AT = 'updated_at';

#Hyperf\Database\Commands\Ast\ModelRewriteSoftDeletesVisitor
public function afterTraverse(array $nodes){foreach ($nodes as $namespace) {if (! $namespace instanceof Node\Stmt\Namespace_) {continue;}if (! $this->hasSoftDeletesUse && ($newUse = $this->rewriteSoftDeletesUse())) {array_unshift($namespace->stmts, $newUse);}foreach ($namespace->stmts as $class) {if (! $class instanceof Node\Stmt\Class_) {continue;}if (! $this->hasSoftDeletesTraitUse && ($newTraitUse = $this->rewriteSoftDeletesTraitUse())) {array_unshift($class->stmts, $newTraitUse);}}}}
protected function rewriteSoftDeletesUse(?Node\Stmt\Use_ $node = null): ?Node\Stmt\Use_{if ($this->shouldRemovedSoftDeletes()) {return null;}if (is_null($node)) {$use = new Node\Stmt\UseUse(new Node\Name(SoftDeletes::class));$node = new Node\Stmt\Use_([$use]);}return $node;}protected function rewriteSoftDeletesTraitUse(?Node\Stmt\TraitUse $node = null): ?Node\Stmt\TraitUse{if ($this->shouldRemovedSoftDeletes()) {return null;}if (is_null($node)) {$node = new Node\Stmt\TraitUse([new Node\Name('SoftDeletes')]);}return $node;}protected function shouldRemovedSoftDeletes(): bool{$useSoftDeletes = $this->useSoftDeletes();$ref = new \ReflectionClass($this->data->getClass());if (! $ref->getParentClass()) {return false;}return $useSoftDeletes == $ref->getParentClass()->hasMethod('getDeletedAtColumn');}
protected function useSoftDeletes(): bool{$model = $this->data->getClass();$deletedAt = defined("{$model}::DELETED_AT") ? $model::DELETED_AT : 'deleted_at';return Collection::make($this->data->getColumns())->where('column_name', $deletedAt)->count() > 0;}
#PhpParser\NodeTraverser 
public function traverse(array $nodes) : array {$this->stopTraversal = false;foreach ($this->visitors as $visitor) {if (null !== $return = $visitor->beforeTraverse($nodes)) {$nodes = $return;}}$nodes = $this->traverseArray($nodes);foreach ($this->visitors as $visitor) {if (null !== $return = $visitor->afterTraverse($nodes)) {$nodes = $return;}}return $nodes;}
#Hyperf\Database\Commands\ModelCommand
protected function createModel(string $table, ModelOption $option){$builder = $this->getSchemaBuilder($option->getPool());$table = Str::replaceFirst($option->getPrefix(), '', $table);$columns = $this->formatColumns($builder->getColumnTypeListing($table));$project = new Project();$class = $option->getTableMapping()[$table] ?? Str::studly(Str::singular($table));$class = $project->namespace($option->getPath()) . $class;$path = BASE_PATH . '/' . $project->path($class);if (!file_exists($path)) {$this->mkdir($path);file_put_contents($path, $this->buildClass($table, $class, $option));}$columns = $this->getColumns($class, $columns, $option->isForceCasts());$stms = $this->astParser->parse(file_get_contents($path));$traverser = new NodeTraverser();$traverser->addVisitor(make(ModelUpdateVisitor::class, ['class' => $class,'columns' => $columns,'option' => $option,]));$traverser->addVisitor(make(ModelRewriteConnectionVisitor::class, [$class, $option->getPool()]));$data = make(ModelData::class)->setClass($class)->setColumns($columns);foreach ($option->getVisitors() as $visitorClass) {$traverser->addVisitor(make($visitorClass, [$option, $data]));}$stms = $traverser->traverse($stms);$code = $this->printer->prettyPrintFile($stms);file_put_contents($path, $code);$this->output->writeln(sprintf('<info>Model %s was created.</info>', $class));if ($option->isWithIde()) {$this->generateIDE($code, $option, $data);}}

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

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

相关文章

理解二叉树的遍历（算法村第七关白银挑战）

理解二叉树的遍历（算法村第七关白银挑战）

二叉树的前序遍历 144. 二叉树的前序遍历 - 力扣&#xff08;LeetCode&#xff09; 给你二叉树的根节点 root &#xff0c;返回它节点值的 前序 遍历。 示例 1&#xff1a; 输入&#xff1a;root [1,null,2,3] 输出&#xff1a;[1,2,3]解 LeetCode以及面试中提供的方法可能…
阅读更多...
科普：嵌入式多核并行仿真

科普：嵌入式多核并行仿真

自信息技术革命以来&#xff0c;计算机一直被应用在各种复杂的数据处理中&#xff0c;如火箭弹道&#xff0c;高能物理和生物学数据等。随着嵌入式领域的多样化需求的不断丰富&#xff0c;多核CPU的应用也越来越广泛&#xff1a;嵌入式系统通常需要同时处理多个任务和实时数据&…
阅读更多...
【C语言】6-3 分别实现单个“图书”类型变量的输入和输出。分数 10

【C语言】6-3 分别实现单个“图书”类型变量的输入和输出。分数 10

6-3 分别实现单个“图书”类型变量的输入和输出。 分数 10 全屏浏览题目 切换布局 作者 赵静静 单位 浙江工贸职业技术学院 编写2个函数&#xff0c;分别实现单个“图书”类型变量的输入和输出。其中“图书”的成员包括书名、ISBN、单价、作者、出版社。 函数接口定义&…
阅读更多...
ChatGPT是什么，海鲸AI软件功能有哪些

ChatGPT是什么，海鲸AI软件功能有哪些

ChatGPT是一种基于人工智能的对话生成技术&#xff0c;它利用深度学习模型来理解和生成自然语言对话。ChatGPT的核心是一种称为生成式预训练模型(GPT)的技术&#xff0c;它能够根据输入的对话内容生成连贯、自然的回答&#xff0c;实现智能对话的目的。这种技术的出现&#xff…
阅读更多...
高级鉴权验签方式的实践，技术方案为注解+ASCII排序+多类型多层级动态拼接+RSA加密（或国密SM2）+Base64+Redis滑动窗口限流

高级鉴权验签方式的实践，技术方案为注解+ASCII排序+多类型多层级动态拼接+RSA加密（或国密SM2）+Base64+Redis滑动窗口限流

背景 虽然大多数企业的流量没有那么大&#xff0c;不过限流还是要有的&#xff0c;毕竟还有外部调用我方系统接口&#xff0c;需要验证访问权限进行&#xff0c;同时防止万一接口并发量大影响我方系统&#xff0c; 所以要增加流控处理&#xff1b;不同的来源在独立配置&#x…
阅读更多...
嵌入式工程师有什么热门的发展方向？

嵌入式工程师有什么热门的发展方向？

随着5G的普及和物联网时代的到来&#xff0c;各种技术不断融合创新&#xff0c;嵌入式技术已成为互联网行业中具有前景的职业之一。 嵌入式工程师在当今数字化时代拥有广泛的就业前景&#xff0c;新技术的发展也为嵌入式工程师提供了更多机会&#xff0c;给大家列举了四个嵌入…
阅读更多...
【JAVA】实验二 类与对象

【JAVA】实验二 类与对象

实验名称 实验二 类与对象 实验目的 1. 深刻理解类的封装与继承&#xff1b; 2. 熟练掌握类的定义、包与路径、对象的创建、方法的调用、类的继承、方法的重写、运行时多态、访问权限修饰符的使用等&#xff1b; 3. 熟练运用JDK提供的常用类及API。 实验内容&…
阅读更多...
文件二维码能下载文件吗？扫码看文件效率更高

文件二维码能下载文件吗？扫码看文件效率更高

为了让文件更快的传递&#xff0c;现在将文件制作二维码图片后&#xff0c;让其他人通过扫码查看或者下载文件的方式&#xff0c;被越来越多的人应用。一般想要制作文件二维码&#xff0c;大多会使用文件二维码生成器&#xff08;文件二维码生成器_word、excel、ppt、pdf文档制…
阅读更多...
linux下安装Nginx及其常用命令

linux下安装Nginx及其常用命令

安装Nginx 接下来在Linux服务器进行操作就可以了 安装插件 yum -y install gcc pcre-devel zlib-devel openssl openssl-devel直接使用wget进行安装(如果没有wget需要先安装wget) yum install wgetwget https://nginx.org/download/nginx-1.24.0.tar.gz解压 tar -zxvf nginx..…
阅读更多...
代码训练day59｜单调栈part02

代码训练day59｜单调栈part02

参考&#xff1a; 代码随想录 如何高效解决接雨水问题 | labuladong 的算法笔记 503.下一个更大元素II 与下一个更大元素&#xff5c;的区别就是要把数组考虑为环形&#xff08;只有数组内最大值为-1&#xff09; 按照之前的环形为题解决经验&#xff0c;直接拼接两个数组解…
阅读更多...
解决mock单元测试中 无法获取实体类xxx对应的表名

解决mock单元测试中 无法获取实体类xxx对应的表名

错误描述&#xff1a;在执行单元测试时&#xff0c;执行到new Example时抛出异常&#xff0c;提示无法获取实体类xxx对应的表名 Example example new Example(ServeSubscribeRecord.class);Example.Criteria criteria example.createCriteria();criteria.andEqualTo("se…
阅读更多...
【Linux】Linux Page Cache页面缓存的原理

【Linux】Linux Page Cache页面缓存的原理

Page cache&#xff08;页面缓存&#xff09;是计算机操作系统中的一种机制&#xff0c;用于将频繁访问的数据从磁盘存储到内存中&#xff0c;以便更快地访问。当程序从磁盘请求数据时&#xff0c;操作系统会检查该数据是否已经存在于页面缓存中。如果存在&#xff0c;数据可以…
阅读更多...
QT上位机开发（动态库dll的开发）

QT上位机开发（动态库dll的开发）

【 声明&#xff1a;版权所有&#xff0c;欢迎转载&#xff0c;请勿用于商业用途。 联系信箱&#xff1a;feixiaoxing 163.com】 有的时候&#xff0c;我们不想把所有的代码都放在一个exe里面&#xff0c;这个时候我们就需要引入dll动态库的概念。在windows平台上面&#xff0c…
阅读更多...
IC工程师到底有哪些？每个岗位具体有哪些要求？

IC工程师到底有哪些？每个岗位具体有哪些要求？

随着摩尔定律和技术的发展&#xff0c;芯片集成度也越来越高&#xff0c;与之伴随的就是岗位愈加细分。芯片产业链很长且环环相扣&#xff0c;每一个环节都需要不同的工程师角色分工协作。 很多人以为芯片工程师就是单纯搞芯片的工程师&#xff0c;殊不知这其中可能要分十几个…
阅读更多...
FlagData 2.0：全面、高效的大模型训练数据治理工具集

FlagData 2.0：全面、高效的大模型训练数据治理工具集

数据是大模型训练至关重要的一环。数据规模、质量、配比&#xff0c;很大程度上决定了最后大模型的性能表现。无论是大规模的预训练数据、精益求精的SFT数据都依托于一个完整的“获取-准备-处理-分析”数据流程。然而&#xff0c;当前的开源工具通常只专注于流程中的某一环节&a…
阅读更多...
ThreeJs通过canvas和Sprite添加标签

ThreeJs通过canvas和Sprite添加标签

在3D场景中很多时候会用到给模型添加标签&#xff0c;以表示这个模型的代号&#xff0c;尤其是大量重复模型的时候&#xff0c;添加标签是为了更直观的看到场景中每个模型的数据和名称&#xff0c;比如在仓库中有很多货架&#xff0c;就会需要查看每个货架的编号&#xff0c;如…
阅读更多...
2023年度智能汽车产业链TOP100创新企业

2023年度智能汽车产业链TOP100创新企业

阅读更多...
Flink Connector 开发

Flink Connector 开发

Flink Streaming Connector Flink是新一代流批统一的计算引擎&#xff0c;它需要从不同的第三方存储引擎中把数据读过来&#xff0c;进行处理&#xff0c;然后再写出到另外的存储引擎中。Connector的作用就相当于一个连接器&#xff0c;连接Flink计算引擎跟外界存储系统。Flin…
阅读更多...
ES6定义一个类(函数内部定义属性，，原型定义方法 )， 实现继承？

ES6定义一个类(函数内部定义属性，，原型定义方法 )， 实现继承？

ES6中使用class关键字定义一个类&#xff0c;使用extends关键字实现继承。下面是一个示例&#xff1a; class Animal {constructor(name) {this.name name;}sayHello() {console.log(Hello, my name is ${this.name});} }class Dog extends Animal {constructor(name, breed)…
阅读更多...
长亭牧云主机管理助手——免费轻量的服务器管理软件初体验

长亭牧云主机管理助手——免费轻量的服务器管理软件初体验

优点 安装十分简单&#xff0c;新手友好&#xff0c;一行命令搞定界面简洁&#xff0c;操作流畅无需公网 IP&#xff0c;可以面对复杂 NAT 环境进行救急可以统一管理大量主机&#xff0c;无需记住主机秘钥 地址 https://rivers.chaitin.cn/app/collie 安装 安装很简单&…
阅读更多...
最新文章

Copyright @ 2022~2023