关于如何在Laravel Artisan中使用自定义数据库链接

Created 6 years ago by amorZhu, Updated 6 years ago    Revision #1    2971 views    0 likes    0 collects

需求分析

打算用Laravel重写公司的帝国CMS，设计到一个栏目迁移的问题：将老站的栏目通过命令直接导入到新站数据库。所以需要链接老站数据库进行查询，需要链接新站数据库进行写入。

最后实现的方式

    // 获取老旧class，并返回树形结构
    protected function dealClassResult()
    {
        $connector = new Connector();
        $conn = $connector->createConnection("mysql:dbname={$this -> conn_config['database']};host={$this -> conn_config['host']};port={$this -> conn_config['port']};charset=UTF8", ['username' => $this -> conn_config['username'], 'password' => $this -> conn_config['password']], $connector->getDefaultOptions());
        $result = $conn -> query('select * from ' . $this -> conn_config['tbname'])->fetchAll();
        array_walk($result, function ($v) use (& $class_data) {
            $class_data[$v['classid']] = $v;
        });
        return $this->getClassTree($class_data, 0, 'bclassid', 'classid');
    }

但是，感觉很不好，有更优雅的实现方式吗？

PDO
Laravel
Vote Vote Cancel Collect Collect Cancel

<< 上一篇: laravel-admin怎么设置登陆过后的默认显示页

>> 下一篇: laravel/passport认证的二个问题

5 Comments
#1    学院君   学院君 commented 6 years ago

在 config/database.php 配置多个连接 然后在代码中通过 DB::connection() 指定要用的数据库实例：https://xueyuanjun.com/post/9576.html#toc_3

#2    amorZhu   amorZhu commented 6 years ago

我这些参数都是获取的用户输入，直接写死不太好啊，

/**
     * Execute the console command.
     *
     * @return mixed
     */
    public function handle()
    {
        $host = $this->ask('Please input mysql host!', '192.168.10.35');
        $username = $this->ask('Please input mysql username!', 'admin');
        $password = $this->secret('Please input mysql password!');
        $port = $this->ask('Please input mysql port!', '3306');
        $database = $this->ask('Please input mysql database!', 'empirecms_back');
        $tbname = $this->ask('Please input mysql table name!', 'phome_enewsclass');
        $columns_name = $this->anticipate('Please input DG class_failed name !', ['classid'], 'classid');
        $columns_p_name = $this->anticipate('Please input DG class_failed name !', ['bclassid'], 'bclassid');

        if ($this->confirm('Do you wish to continue? [y|N]')) {

            // 链接用户设置的数据库
            $this->conn_config = ['host' => $host, 'port' => $port, 'username' => $username, 'password' => $password, 'database' => $database, 'tbname' => $tbname, 'pname' => $columns_p_name, 'sname' => $columns_name];
            // 写入树形数据
            Column::rebuildTree($this->dealClassResult());
        }
    }
#3    学院君   学院君 commented 6 years ago
In reply to #2

你还没明白：

'mysql' => [
        'driver' => 'mysql',
        'host' => env('DB_HOST', '127.0.0.1'),
        'port' => env('DB_PORT', '3306'),
        'database' => env('DB_DATABASE', 'forge'),
        'username' => env('DB_USERNAME', 'forge'),
        'password' => env('DB_PASSWORD', ''),
        'unix_socket' => env('DB_SOCKET', ''),
        'charset' => 'utf8mb4',
        'collation' => 'utf8mb4_unicode_ci',
        'prefix' => '',
        'strict' => true,
        'engine' => null,
    ],

这里你可以配置多个这样的配置项，名字换成其它的比如 mysql_old，然后里面的配置成老站的数据库，然后在调用这个数据库进行增删改查的时候这样使用：DB::connection('mysql_old')->select(...) 这样连接的就是老的数据库了，并不是说这个配置里面只能配主站的数据库，你想配几个就配几个，敏感信息一样可以放到 .env 中，配置名和主站分开就好了

#4    学院君   学院君 commented 6 years ago
In reply to #2

你这个明显是一次性的命令 配置成用户输入费那个劲干嘛呢

#5    amorZhu   amorZhu commented 6 years ago
In reply to #4

好吧

登录后即可添加评论