【问题标题】:Laravel get data from another project databaseLaravel 从另一个项目数据库中获取数据
【发布时间】:2019-06-14 18:36:04
【问题描述】:

我正在将旧项目数据库移动到新项目数据库。旧项目数据库的结构是单个MYSQL数据库,新项目是包含大量子域的多租户数据库。此外,新项目已经设置了一个 RESTFUL API 来接收来自旧项目的数据。因此,我的想法是在新项目中实现多连接,以便将两个数据库链接在一起,然后从旧项目中获取数据。例如,新项目sales 表是一个空的旧项目sales 表已经包含一些数据。现在在我的新项目界面中可能有一个同步按钮,以便将数据从旧数据库移动到新数据库中。在将数据发送到新项目之前,我是否需要传递 API 密钥?因为它是一个多租户结构。

这是我的配置/数据库

'mysql' => array(
            'driver'    => 'mysql',
            'host'      => 'aurora-2016-cluster.cluster-rtygfdfg.ap-southwest-1.rds.amazonaws.com',
            'database'  => 'newProject',
            'username'  => @$_ENV['DB_USER'] ?: '',
            'password'  => @$_ENV['DB_PASS'] ?: '',
            'charset'   => 'utf8',
            'collation' => 'utf8_unicode_ci',
            'prefix'    => '',
        ),

        # Our secondary database connection
        'mysql2' => array(
            'driver'    => 'mysql',
            'host'      => 'localhost',
            'database'  => 'oldProject',
            'username'  => 'root',
            'password'  => '',
            'charset'   => 'utf8',
            'collation' => 'utf8_unicode_ci',
            'prefix'    => '',
        ),

【问题讨论】:

    标签: database laravel laravel-4


    【解决方案1】:

    在 laravel 中打开你的 config/databse.php 文件非常简单

    你会发现这样的代码

    <?php
    
    return [
    
        /*
        |--------------------------------------------------------------------------
        | Default Database Connection Name
        |--------------------------------------------------------------------------
        |
        | Here you may specify which of the database connections below you wish
        | to use as your default connection for all database work. Of course
        | you may use many connections at once using the Database library.
        |
        */
    
        'default' => env('DB_CONNECTION', 'mysql'),
    
        /*
        |--------------------------------------------------------------------------
        | Database Connections
        |--------------------------------------------------------------------------
        |
        | Here are each of the database connections setup for your application.
        | Of course, examples of configuring each database platform that is
        | supported by Laravel is shown below to make development simple.
        |
        |
        | All database work in Laravel is done through the PHP PDO facilities
        | so make sure you have the driver for your particular database of
        | choice installed on your machine before you begin development.
        |
        */
    
        'connections' => [
    
            'sqlite' => [
                'driver' => 'sqlite',
                'database' => env('DB_DATABASE', database_path('database.sqlite')),
                'prefix' => '',
                'foreign_key_constraints' => env('DB_FOREIGN_KEYS', true),
            ],
    
            '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' => '',
                'prefix_indexes' => true,
                'strict' => true,
                'engine' => null,
            ],
    
            'pgsql' => [
                'driver' => 'pgsql',
                'host' => env('DB_HOST', '127.0.0.1'),
                'port' => env('DB_PORT', '5432'),
                'database' => env('DB_DATABASE', 'forge'),
                'username' => env('DB_USERNAME', 'forge'),
                'password' => env('DB_PASSWORD', ''),
                'charset' => 'utf8',
                'prefix' => '',
                'prefix_indexes' => true,
                'schema' => 'public',
                'sslmode' => 'prefer',
            ],
    
            'sqlsrv' => [
                'driver' => 'sqlsrv',
                'host' => env('DB_HOST', 'localhost'),
                'port' => env('DB_PORT', '1433'),
                'database' => env('DB_DATABASE', 'forge'),
                'username' => env('DB_USERNAME', 'forge'),
                'password' => env('DB_PASSWORD', ''),
                'charset' => 'utf8',
                'prefix' => '',
                'prefix_indexes' => true,
            ],
    
        ],
    
        /*
        |--------------------------------------------------------------------------
        | Migration Repository Table
        |--------------------------------------------------------------------------
        |
        | This table keeps track of all the migrations that have already run for
        | your application. Using this information, we can determine which of
        | the migrations on disk haven't actually been run in the database.
        |
        */
    
        'migrations' => 'migrations',
    
        /*
        |--------------------------------------------------------------------------
        | Redis Databases
        |--------------------------------------------------------------------------
        |
        | Redis is an open source, fast, and advanced key-value store that also
        | provides a richer body of commands than a typical key-value system
        | such as APC or Memcached. Laravel makes it easy to dig right in.
        |
        */
    
        'redis' => [
    
            'client' => 'predis',
    
            'default' => [
                'host' => env('REDIS_HOST', '127.0.0.1'),
                'password' => env('REDIS_PASSWORD', null),
                'port' => env('REDIS_PORT', 6379),
                'database' => env('REDIS_DB', 0),
            ],
    
            'cache' => [
                'host' => env('REDIS_HOST', '127.0.0.1'),
                'password' => env('REDIS_PASSWORD', null),
                'port' => env('REDIS_PORT', 6379),
                'database' => env('REDIS_CACHE_DB', 1),
            ],
    
        ],
    
    ];
    

    要遵循的步骤

    第一步: 向数据库连接数组添加新数组

    'mysqlSecondConnection' => [
                'driver' => 'mysql',
                'host' => env('DB_HOST1', '127.0.0.1'),
                'port' => env('DB_PORT1', '3306'),
                'database' => env('DB_DATABASE2', 'secondDatabseName'),
                'username' => env('DB_USERNAME2', 'secondDatabseUserName'),
                'password' => env('DB_PASSWORD2', 'secondDatabsePassword'),
                'unix_socket' => env('DB_SOCKET2', ''),
                'charset' => 'utf8mb4',
                'collation' => 'utf8mb4_unicode_ci',
                'prefix' => '',
                'strict' => false,
                'engine' => null,
            ],
    

    在此之后您的文件可能看起来像

    <?php
    
    return [
    
        /*
        |--------------------------------------------------------------------------
        | Default Database Connection Name
        |--------------------------------------------------------------------------
        |
        | Here you may specify which of the database connections below you wish
        | to use as your default connection for all database work. Of course
        | you may use many connections at once using the Database library.
        |
        */
    
        'default' => env('DB_CONNECTION', 'mysql'),
    
        /*
        |--------------------------------------------------------------------------
        | Database Connections
        |--------------------------------------------------------------------------
        |
        | Here are each of the database connections setup for your application.
        | Of course, examples of configuring each database platform that is
        | supported by Laravel is shown below to make development simple.
        |
        |
        | All database work in Laravel is done through the PHP PDO facilities
        | so make sure you have the driver for your particular database of
        | choice installed on your machine before you begin development.
        |
        */
    
        'connections' => [
    
            'sqlite' => [
                'driver' => 'sqlite',
                'database' => env('DB_DATABASE', database_path('database.sqlite')),
                'prefix' => '',
                'foreign_key_constraints' => env('DB_FOREIGN_KEYS', true),
            ],
    
            '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' => '',
                'prefix_indexes' => true,
                'strict' => true,
                'engine' => null,
            ],
    
            'mysqlSecondConnection' => [
                'driver' => 'mysql',
                'host' => env('DB_HOST1', '127.0.0.1'),
                'port' => env('DB_PORT1', '3306'),
                'database' => env('DB_DATABASE2', 'secondDatabseName'),
                'username' => env('DB_USERNAME2', 'secondDatabseUserName'),
                'password' => env('DB_PASSWORD2', 'secondDatabsePassword'),
                'unix_socket' => env('DB_SOCKET2', ''),
                'charset' => 'utf8mb4',
                'collation' => 'utf8mb4_unicode_ci',
                'prefix' => '',
                'strict' => false,
                'engine' => null,
            ],
    
    
            'pgsql' => [
                'driver' => 'pgsql',
                'host' => env('DB_HOST', '127.0.0.1'),
                'port' => env('DB_PORT', '5432'),
                'database' => env('DB_DATABASE', 'forge'),
                'username' => env('DB_USERNAME', 'forge'),
                'password' => env('DB_PASSWORD', ''),
                'charset' => 'utf8',
                'prefix' => '',
                'prefix_indexes' => true,
                'schema' => 'public',
                'sslmode' => 'prefer',
            ],
    
            'sqlsrv' => [
                'driver' => 'sqlsrv',
                'host' => env('DB_HOST', 'localhost'),
                'port' => env('DB_PORT', '1433'),
                'database' => env('DB_DATABASE', 'forge'),
                'username' => env('DB_USERNAME', 'forge'),
                'password' => env('DB_PASSWORD', ''),
                'charset' => 'utf8',
                'prefix' => '',
                'prefix_indexes' => true,
            ],
    
        ],
    
        /*
        |--------------------------------------------------------------------------
        | Migration Repository Table
        |--------------------------------------------------------------------------
        |
        | This table keeps track of all the migrations that have already run for
        | your application. Using this information, we can determine which of
        | the migrations on disk haven't actually been run in the database.
        |
        */
    
        'migrations' => 'migrations',
    
        /*
        |--------------------------------------------------------------------------
        | Redis Databases
        |--------------------------------------------------------------------------
        |
        | Redis is an open source, fast, and advanced key-value store that also
        | provides a richer body of commands than a typical key-value system
        | such as APC or Memcached. Laravel makes it easy to dig right in.
        |
        */
    
        'redis' => [
    
            'client' => 'predis',
    
            'default' => [
                'host' => env('REDIS_HOST', '127.0.0.1'),
                'password' => env('REDIS_PASSWORD', null),
                'port' => env('REDIS_PORT', 6379),
                'database' => env('REDIS_DB', 0),
            ],
    
            'cache' => [
                'host' => env('REDIS_HOST', '127.0.0.1'),
                'password' => env('REDIS_PASSWORD', null),
                'port' => env('REDIS_PORT', 6379),
                'database' => env('REDIS_CACHE_DB', 1),
            ],
    
        ],
    
    ];
    

    第二步:在mysqlSecondConnection数组中配置你的数据库名称

    IF THIS PROJECT IS TEAM COLLABRATING DONT FORGET TO ADD THE NEW ATTRIBUTES IN .ENV FILE

    第 3 步: 现在我们完成了数据库的配置

    第 4 步: 打开需要与mysqlSecondConnection 数据库交互的模型

    并添加

    房产

    protected $connection ='mysqlSecondConnection';
    

    在此之后,模式可能看起来像例如: 我认为它是Post.php

    <?php
    
    namespace App;
    
    use Illuminate\Database\Eloquent\Model;
    /**
     * Class Cat
     *
     * @package App
    */
    
    class Post extends Model
    {
    
    
        /**
         * The connection name for the model.
         *
         * @var string
         */
        protected $connection ='mysqlSecondConnection';
    
        /**
         * The attributes that aren't mass assignable.
         *
         * @var array
         */
        protected $guarded = ['id'];
    
         /**
         * The table associated with the model.
         *
         * @var string
         */
        protected $table = 'posts';
    
        /**
         * The primary key for the model.
         *
         * @var string
         */
    
        protected $primaryKey = 'id';
    
        /**
         * The "type" of the auto-incrementing ID.
         *
         * @var string
         */
        protected $keyType = 'int';
    
    
    
        /**
         * The attributes that are mass assignable.
         *
         * @var array
         */
        protected $fillable = ['name','title','desc'];
    
         /**
         * The attributes that should be hidden for arrays.
         *
         * @var array
         */
        protected $hidden = [];
    
        /**
         * @var array
         */
        protected $dates = ['created_at','updated_at'];
    
    
    }
    

    就是这样

    现在是测试部分

    在路由文件夹中打开你的 web.php 文件

    并粘贴以下代码

    Route::get('/testSecondConnection', function () 
    {
        $posts= App\Post::all();
        dd($posts);
    
    });
    

    现在导航到yourApplication/testSecondConnection

    现在查看转储文件中的connection 属性

    已编辑

    我实际上忘记添加另一个方法是通过DB Facade 版本

    只需将连接名称传递给connection 方法内的DB

    在使用这个时,它不会检查模型

    对于Post 模型中的$connection 属性

    $dbVersion = \DB::connection('mysqlSecondConnection')->table('posts')->get();
    dd($dbVersion);
    

    But which method is more efficient?编辑

    好问题,伙计

    情况1:

    例如:

    如果您在项目的所有情况下都将mysqlSecondConnection 用于Post 模型,那么 将此添加到您的模型中

    protected $connection ='mysqlSecondConnection';
    

    这很好 注意 $connection 属性将在 Eloquent 上工作,而不是在 DB Facade 中

    情况2:

    `例如:'

    如果您只使用很少的查询和调用mysqlSecondConnection

    你不需要添加

    protected $connection ='mysqlSecondConnection';

    Post模特

    DB Facade Version 
    
    $dbVersion = \DB::connection('mysqlSecondConnection')->table('posts')->get();
        dd($dbVersion);
    
    Eloquent Version
    
    $eloquentVersion = Post::on('mysqlSecondConnection')->get()
        dd($eloquentVersion);
    

    您可能会怀疑为什么 DB FACADE 不在 POST 模型中使用 mysqlSecondConnection

    解决方案:

    使用DB FACADE 时

    它将查看config/datbase.php

    对于default数组

    用于连接数据库

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

    希望它有所帮助,看起来清晰

    【讨论】:

    • 感谢您的回复,这意味着我可以使用ModelDB::connection 来获取posts 数据?但是哪种方法更有效呢?
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2021-04-02
    • 1970-01-01
    • 2018-12-18
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多