为什么Laravel Dispatcer dispatch（）函数不在特定数据库的作业表中创建作业？

发布于 2025-02-10 14:24:09 字数 382 浏览 2 评论 0原文

在派遣作业之前，我有多个数据库和根据某些条件进行切换数据库。对于例如：

if(condition A){
  DB::setDefaultConnection('A');
} else {
  DB::setDefaultConnection('B');
}
dispatch(new CreateNewUser($user))

根据条件，DB连接更改。当我查询user :: find（$ id）之类的内容时，在派遣根据已连接的数据库返回数据的作业之前。但是问题是，dispatch（）在该数据库的作业表中创建一个作业记录，该数据库首先是在连接的。当DB连接更改为另一个时，仍然填充了第一个数据库的作业表。这是怎么发生的？

原文

I have multiple databases and switching database as per some conditions before dispatching jobs. For eg:

if(condition A){
  DB::setDefaultConnection('A');
} else {
  DB::setDefaultConnection('B');
}
dispatch(new CreateNewUser($user))

And the db connection is changed as per the condition.
As I query something like User::find($id) before dispatching the job which returns data as per the connected database.
But the problem is, the dispatch() create a jobs record in jobs table of that database which was connected at first. When the db connection changed to another, still the first database's jobs table is populated.
How is this happening?

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

情魔剑神 2025-02-17 14:24:09

根据评论，请执行以下操作，更改后清除和重新连接：

DB::purge('mysql'); 
//Do whatever you need to do to setup your connection
DB::setDefaultConnection('B');
DB::reconnect('mysql');

您要派遣运行异步的工作。您执行的DB更改不是在作业内部执行的。您应该将连接名称作为参数发送到工作：

dispatch(new CreateNewUser($user, $connName))

以及在作业初始化时，请：

    protected $connName;

    public function __construct($user, $connName)
    {
        $this->connName = $connName;
    }

    public function handle()
    {
        DB::setDefaultConnection($this->connName);
        ....
    }

Based on the comment, do the following, purge and reconnect after your change:

DB::purge('mysql'); 
//Do whatever you need to do to setup your connection
DB::setDefaultConnection('B');
DB::reconnect('mysql');

The job you are dispatching runs async. That DB change you are performing is not performed inside the Job. You should send the connection name as a parameter to the Job:

dispatch(new CreateNewUser($user, $connName))

and on the Job initialization, do:

    protected $connName;

    public function __construct($user, $connName)
    {
        $this->connName = $connName;
    }

    public function handle()
    {
        DB::setDefaultConnection($this->connName);
        ....
    }

回复收藏 0 原文

~没有更多了~