作者 lyh

gx

... ... @@ -614,12 +614,12 @@ class ProjectLogic extends BaseLogic
}
$sql = DB::connection('custom_tmp_mysql_copy')->select("SHOW CREATE TABLE {$v}");
DB::connection('custom_mysql')->statement(get_object_vars($sql[0])['Create Table']);
// 执行同步数据的操作
DB::connection('custom_mysql')->insert("INSERT INTO {$v} SELECT * FROM custom_tmp_mysql_copy.{$v}");
if (Schema::connection('custom_mysql')->hasColumn($v, 'project_id')) {
DB::connection('custom_mysql')->table($v)->update(['project_id' => $news_project_id]);
}
foreach ($table as $v1) {
if (!Schema::connection('custom_mysql')->hasColumn($v1, 'project_id')) {
continue; // 如果表中不存在 project_id 列,则跳过这个表
}
DB::connection('custom_mysql')->table($v1)->update(['project_id' => $news_project_id]);
}
return true;
}
... ...