如何在Laravel中使用多个数据库
如何在Laravel中使用多个数据库
我想在我的系统中合并多个数据库。大部分时间,数据库是MySQL;但是未来可能会不同,即管理员可以生成使用异构数据库系统的源的报告。
因此,我的问题是,Laravel是否提供任何Facade来处理这种情况?或者任何其他框架具有更适合此问题的能力?
在Laravel 5.1中,您可以指定连接: \n
$users = DB::connection('foo')->select(...);
\n默认情况下,Laravel使用默认连接。很简单,对吧? \n在这里了解更多:http://laravel.com/docs/5.1/database#accessing-connections
已测试版本 (已更新)
版本 | 测试结果 (是/否) |
---|---|
4.2 | 否 |
5 | 是 (5.5) |
6 | 否 |
7 | 否 |
8 | 是 (8.4) |
9 | 是 (9.2) |
定义连接
在 .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
的前几行中提到。
app/config/database.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'; }
Eloquent (在 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']); });
或者
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
在运行时定义连接:
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; } }
注意: 当在不同的数据库之间建立关系时要小心! 这是有可能的,但根据你的数据库和设置可能会有附带条件。
使用多个数据库连接
当使用多个连接时,你可以使用DB
门面上的connection
方法来访问每个connection
。传递给connection
方法的name
应该对应于在config/database.php
配置文件中列出的连接之一:
$users = DB::connection('foo')->select(...);
你也可以使用连接实例上的getPdo
方法来访问原始底层的 PDO 实例:
$pdo = DB::connection()->getPdo();
有用的链接