使用Laravel 連接多個(gè)資料庫(kù)

為了管理Laravel 系統(tǒng)中的多個(gè)資料庫(kù)，Laravel 透過(guò)其資料庫(kù)外觀提供了通用的解決方案。

使用資料庫(kù)連線(xiàn)

當(dāng)使用多個(gè)資料庫(kù)連線(xiàn)時(shí)，您可以使用資料庫(kù)外觀上的連線(xiàn)方法存取每個(gè)連線(xiàn)。提供給連接方法的名稱(chēng)與config/database.php 設(shè)定檔中定義的名稱(chēng)一致：

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

連線(xiàn)定義

資料庫(kù)連線(xiàn)可以是使用.env檔案或config/database.php 檔案進(jìn)行設(shè)定：

使用.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'),
],

架構(gòu)和遷移

要指定用於架構(gòu)和遷移的連接，請(qǐng)使用connection()方法：

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

或者，您可以在類(lèi)別的頂部定義連接：

protected $connection = 'pgsql';

查詢(xún)產(chǎn)生器

查詢(xún)產(chǎn)生器

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

利用查詢(xún)產(chǎn)生器進(jìn)行特定連接：

模型

class ModelName extends Model {
    protected $connection = 'pgsql';
}

在Laravel 5.0 及更高版本中，您可以在模型中設(shè)定$connection 變數(shù)：

雄辯

class SomeModel extends Eloquent {
    protected $connection = 'pgsql';
}

在Laravel 中4.0 及以下版本，您可以在模型中定義$connection 變量：

事務(wù)模式

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

跨多個(gè)資料庫(kù)管理事務(wù)：

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;
}

或

運(yùn)行時(shí)連接管理

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;
    }
}

也可以在運(yùn)行時(shí)使用 setConnection 方法或 on static方法建立連接：

注意何時(shí)與不同資料庫(kù)中的表建立關(guān)係時(shí)，由於基於資料庫(kù)和設(shè)定的潛在警告，因此務(wù)必謹(jǐn)慎行事。僱用。

以上是如何在 Laravel 管理多個(gè)資料庫(kù)連線(xiàn)？的詳細(xì)內(nèi)容。更多資訊請(qǐng)關(guān)注PHP中文網(wǎng)其他相關(guān)文章！