任意の環境から別環境へDBの全データをコピーする（WebUI用のコード）MySQL編

注）MySQL専用
管理ツールなどのWebUIで任意の環境から全データを別環境にコピーするような画面を作る時に使うコード
Laravel用のコードになっているので他で使う場合はDBクラスの部分を書き換えて。
※なおエンジニアが手動でコピーするならダンプ・リストアで終わりなので参考にならない。

用途
・開発環境がたくさんあってデータを統一するために
・開発環境から本番環境にデータ反映

コード

[xxxx]の部分はリクエストパラメータに置き換えてください。

$master_data_schema = '[マスターデータのスキーマ名]';
$conn_in = '[コピー元DBの接続文字列]';
$conn_dest = '[コピー先DBの接続文字列]';

$bulk_insert_chunk = 1000;
$table_exclude = [
    'テーブル名' => true,  // 除外したいテーブル名を配列のKEYにして設定しておく（issetでチェックしたいのでこの形式）
];

$table_list = [];
$column_list = [];
$master_data = [];
$tmp = DB::connection($conn_in)
    ->table('information_schema.tables')
    ->where('table_schema', $master_data_schema)
    ->get([
        'table_name',
        'table_comment',
    ]);
foreach ($tmp as $v) {
    $a = (array)$v;
    if (!isset($table_exclude[$a['table_name']])) {
        $table_list[$a['table_name']] = $a;
    }
}
$tmp = DB::connection($conn_in)
    ->table('information_schema.columns')
    ->where('table_schema', $master_data_schema)
    ->get([
        'table_name',
        'column_name',
        'column_type',
        'column_comment',
    ]);
foreach ($tmp as $v) {
    $a = (array)$v;
    if (!isset($table_exclude[$a['table_name']])) {
        $column_list[$a['table_name']][$a['column_name']] = $a;
    }
}
foreach ($table_list as $v) {
    $a = (array)$v;
    $count = 0;
    $chunk = 0;
    $tmp = DB::connection($conn_in)
        ->table($master_data_schema . '.' . $a['table_name'])
        ->orderBy('id')
        ->get(['*']);
    foreach ($tmp as $v2) {
        $d = (array)$v2;
        if ($count > $bulk_insert_chunk) {
            $count = 0;
            ++$chunk;
        }
        $master_data[$a['table_name']][$chunk][] = $d;
        ++$count;
    }
}
try {
    $table_name = null;
    DB::connection($conn_dest)->transaction(function () use (
        &$conn_dest,
        &$table_list,
        &$master_data,
        &$table_name,
        &$master_data_schema
    ) {
        foreach ($table_list as $v) {
            $table_name = $v['table_name'];
            DB::connection($conn_dest)->table($master_data_schema . '.' . $v['table_name'])->delete();
            if (isset($master_data[$v['table_name']])) {
                $insert_data = $master_data[$v['table_name']];
                foreach ($insert_data as $data) {
                    DB::connection($conn_dest)->table($master_data_schema . '.' . $v['table_name'])->insert($data);
                    unset($data);
                }
                unset($insert_data, $master_data[$v['table_name']]);
            }
        }
    });
} catch (Exception $e) {
    $sql_error = true;
    // エラー画面で表示する情報
    $error_table_name = $table_name;
    $error_message = explode(PHP_EOL, $e->getMessage())[0] . ' ...';
}