我想在我的系统中组合多个数据库。大多数时候,数据库是MySQL;但将来可能会有所不同,即管理员可以生成这样的报告,这是使用异构数据库系统的源。

所以我的问题是,Laravel提供任何门面来处理这种情况吗?或者有没有其他框架有更适合的能力来解决问题呢?


当前回答

实际上,DB::connection('name')->select(..)并不为我工作,因为'name'必须在双引号中:"name"

尽管如此,还是在默认连接上执行了选择查询。我还在试图弄清楚,如何说服Laravel按照它想要的方式工作:改变连接。

编辑:我想明白了。调试Laravels DatabaseManager后,它发现我的database.php(配置文件)(在$this->应用程序内)是错误的。在“连接”部分,我有像“数据库”这样的东西,我复制了它的值。明确地说,而不是

env('DB_DATABASE', 'name')

我需要放置一些东西

'myNewName'

因为所有的连接都列出了相同的数据库值,用户名,密码等,当然没有什么意义,如果我想访问至少另一个数据库名称

因此,每次我想从另一个数据库中选择一些东西时,我总是在默认数据库中结束

其他回答

实际上,DB::connection('name')->select(..)并不为我工作,因为'name'必须在双引号中:"name"

尽管如此,还是在默认连接上执行了选择查询。我还在试图弄清楚,如何说服Laravel按照它想要的方式工作:改变连接。

编辑:我想明白了。调试Laravels DatabaseManager后,它发现我的database.php(配置文件)(在$this->应用程序内)是错误的。在“连接”部分,我有像“数据库”这样的东西,我复制了它的值。明确地说,而不是

env('DB_DATABASE', 'name')

我需要放置一些东西

'myNewName'

因为所有的连接都列出了相同的数据库值,用户名,密码等,当然没有什么意义,如果我想访问至少另一个数据库名称

因此,每次我想从另一个数据库中选择一些东西时,我总是在默认数据库中结束

Laravel内置了对多个数据库系统的支持,您需要在config/database.php文件中提供连接细节

return [
    'default' => env('DB_CONNECTION', 'mysql'),

    'connections' => [
        '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', ''),
            'charset' => 'utf8',
            'collation' => 'utf8_unicode_ci',
            'prefix' => '',
            'strict' => false,
            'engine' => null,
        ],
'mysqlOne' => [
            'driver' => 'mysql',
            'host' => env('DB_HOST_ONE', '127.0.0.1'),
            'port' => env('DB_PORT', '3306'),
            'database' => env('DB_DATABASE_ONE', 'forge'),
            'username' => env('DB_USERNAME_ONE', 'forge'),
            'password' => env('DB_PASSWORD_ONE', ''),
            'charset' => 'utf8',
            'collation' => 'utf8_unicode_ci',
            'prefix' => '',
            'strict' => false,
            'engine' => null,
        ],
];

一旦您有了这些,您就可以为每个连接创建两个基模型类,并在这些模型中定义连接名称

//BaseModel.php
protected $connection = 'mysql';

//BaseModelOne.php
protected $connection = 'mysqlOne';

您可以扩展这些模型,为每个DB中的表创建更多的模型。

也可以使用postgres的fdw系统

https://www.postgresql.org/docs/9.5/postgres-fdw.html

你将能够在postgres中连接不同的db。在此之后,在一个查询中,您可以访问不同数据库中的表。

这对我很有效

中间件:

<?php 
namespace App\Http\Middleware;

use Config;
use Closure;
use DB;

class DBSelect
{

   public function handle($request, Closure $next)
   {
    //$db_name = "db1";
    $db_name = "db2";
    Config::set('database.connections.mysql.database', $db_name);

    DB::reconnect('mysql');

    return $next($request);
  }
 }

全球Kernel.php

protected $middleware = [
    .....
    \App\Http\Middleware\DBSelect::class,
];

我从这个答案(https://stackoverflow.com/a/64744187/4514022)更改了一些代码,它为我工作。

测试版本(更新)

Version Tested (Yes/No)
4.2 No
5 Yes (5.5)
6 No
7 No
8 Yes (8.4)
9 Yes (9.2)

定义连接

使用.env >= 5.0(或更高)

在.env

DB_CONNECTION=mysql
DB_HOST=127.0.0.1
DB_PORT=3306
DB_DATABASE=mysql_database
DB_USERNAME=root
DB_PASSWORD=secret

DB_CONNECTION_PGSQL=pgsql
DB_HOST_PGSQL=127.0.0.1
DB_PORT_PGSQL=5432
DB_DATABASE_PGSQL=pgsql_database
DB_USERNAME_PGSQL=root
DB_PASSWORD_PGSQL=secret

在config / database.php

'mysql' => [
    'driver'    => env('DB_CONNECTION'),
    'host'      => env('DB_HOST'),
    'port'      => env('DB_PORT'),
    'database'  => env('DB_DATABASE'),
    'username'  => env('DB_USERNAME'),
    'password'  => env('DB_PASSWORD'),
],

'pgsql' => [
    'driver'    => env('DB_CONNECTION_PGSQL'),
    'host'      => env('DB_HOST_PGSQL'),
    'port'      => env('DB_PORT_PGSQL'),
    'database'  => env('DB_DATABASE_PGSQL'),
    'username'  => env('DB_USERNAME_PGSQL'),
    'password'  => env('DB_PASSWORD_PGSQL'),
],

注意:在pgsql中,如果DB_username和DB_password是相同的,那么你可以使用env(' DB_username '),它在.env的前几行中提到过。

没有。env <= 4.0(或更低)

app -配置数据库。php

return array(

    'default' => 'mysql',

    'connections' => array(

        # Primary/Default database connection
        'mysql' => array(
            'driver'    => 'mysql',
            'host'      => '127.0.0.1',
            'database'  => 'mysql_database',
            'username'  => 'root',
            'password'  => 'secret'
            'charset'   => 'utf8',
            'collation' => 'utf8_unicode_ci',
            'prefix'    => '',
        ),

        # Secondary database connection
       'pgsql' => [
            'driver' => 'pgsql',
            'host' => 'localhost',
            'port' => '5432',
            'database' => 'pgsql_database',
            'username' => 'root',
            'password' => 'secret',
            'charset' => 'utf8',
            'prefix' => '',
            'schema' => 'public',
        ]
    ),
);

架构/迁移

运行connection()方法指定使用哪个连接。

Schema::connection('pgsql')->create('some_table', function($table)
{
    $table->increments('id'):
});

或者,在顶部定义一个连接。

protected $connection = 'pgsql';

查询构建器

$users = DB::connection('pgsql')->select(...);

模型(在Laravel >= 5.0(或更高))

在模型中设置$connection变量

class ModelName extends Model { // extend changed

    protected $connection = 'pgsql';

}

雄辩的(在Laravel <= 4.0(或更低))

在模型中设置$connection变量

class SomeModel extends Eloquent {

    protected $connection = 'pgsql';

}

交易模式

DB::transaction(function () {
    DB::connection('mysql')->table('users')->update(['name' => 'John']);
    DB::connection('pgsql')->table('orders')->update(['status' => 'shipped']);
});

or

DB::connection('mysql')->beginTransaction();

try {
    DB::connection('mysql')->table('users')->update(['name' => 'John']);
    DB::connection('pgsql')->beginTransaction();
    DB::connection('pgsql')->table('orders')->update(['status' => 'shipped']);
    DB::connection('pgsql')->commit();
    DB::connection('mysql')->commit();
} catch (\Exception $e) {
    DB::connection('mysql')->rollBack();
    DB::connection('pgsql')->rollBack();
    throw $e;
}

你也可以通过setConnection方法或on static方法在运行时定义连接:

class SomeController extends BaseController {

    public function someMethod()
    {
        $someModel = new SomeModel;

        $someModel->setConnection('pgsql'); // non-static method

        $something = $someModel->find(1);

        $something = SomeModel::on('pgsql')->find(1); // static method

        return $something;
    }

}

注意:在跨数据库构建与表的关系时要小心!这是可以做到的,但根据您的数据库和设置,可能会有一些警告。


来自Laravel Docs

使用多个数据库连接

当使用多个连接时,您可以通过DB facade上的连接方法访问每个连接。传递给连接方法的名称应该对应于config/database.php配置文件中列出的连接之一:

$users = DB::connection('foo')->select(...);

你也可以在连接实例上使用getPdo方法访问原始的底层PDO实例:

$pdo = DB::connection()->getPdo();

有用的链接

Laravel 5多个数据库连接FROM laracasts.com 在Laravel从tutsnare.com连接多个数据库 Laravel的多个DB连接FROM fideloper.com