From 26206f937b15140aaeb1a4e86e913bcd95512b5a Mon Sep 17 00:00:00 2001
From: "allen.yan" <hungyi0816@gmail.com>
Date: Tue, 3 Jun 2025 13:14:35 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8A=A0=E5=85=A5=20User.data=20(sqlite)=20?=
 =?UTF-8?q?=E7=94=A8seeder=20=E6=BB=99=E5=85=A5=E8=B3=87=E6=96=99=20202506?=
 =?UTF-8?q?03?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Controllers/SqliteUploadController.php    |   2 +-
 app/Jobs/TransferSqliteTableJob.php           |  24 ++++++++++--------
 database/User.data                            | Bin 0 -> 77824 bytes
 database/seeders/DatabaseSeeder.php           |  14 +++++-----
 4 files changed, 22 insertions(+), 18 deletions(-)
 create mode 100644 database/User.data

diff --git a/app/Http/Controllers/SqliteUploadController.php b/app/Http/Controllers/SqliteUploadController.php
index 4dbb3df..88a172d 100644
--- a/app/Http/Controllers/SqliteUploadController.php
+++ b/app/Http/Controllers/SqliteUploadController.php
@@ -66,7 +66,7 @@ class SqliteUploadController extends Controller
 
         $filename = $request->file('file')->getClientOriginalName();
         $path = $request->file('file')->storeAs('sqlite', $filename, 'local');
-        TransferSqliteTableJob::dispatch(Storage::disk('local')->path($path));  
+        TransferSqliteTableJob::dispatch(Storage::disk('local')->path($path),deleteFile: true);  
         return response()->json([
             'message' => '上傳成功，已派送資料處理任務',
             'path' => $path,
diff --git a/app/Jobs/TransferSqliteTableJob.php b/app/Jobs/TransferSqliteTableJob.php
index dbf304d..991368c 100644
--- a/app/Jobs/TransferSqliteTableJob.php
+++ b/app/Jobs/TransferSqliteTableJob.php
@@ -14,9 +14,11 @@ class TransferSqliteTableJob implements ShouldQueue
     use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
 
     protected string $sqlitePath;
+    protected bool $deleteFile;
 
-    public function __construct(string $sqlitePath){
+    public function __construct(string $sqlitePath , bool $deleteFile = false){
         $this->sqlitePath=$sqlitePath;
+        $this->deleteFile = $deleteFile;
     }
 
     public function handle(): void
@@ -26,7 +28,8 @@ class TransferSqliteTableJob implements ShouldQueue
             return;
         }
         // ✅ 動態產生唯一 connection 名稱
-        $connectionName = 'tempsqlite_' . md5($this->sqlitePath . microtime());
+        $connectionName = 'sqlite_' . md5($this->sqlitePath . microtime());
+        
         config(["database.connections.{$connectionName}" => [
             'driver' => 'sqlite',
             'database' => $this->sqlitePath,
@@ -42,6 +45,7 @@ class TransferSqliteTableJob implements ShouldQueue
 
         if (empty($sqliteTables)) {
             logger()->error("❌ No tables found in SQLite database.");
+            DB::purge($connectionName);
             return;
         }
 
@@ -58,7 +62,6 @@ class TransferSqliteTableJob implements ShouldQueue
                 DB::statement("CREATE TABLE IF NOT EXISTS _{$table} LIKE {$table}");
 
                 $rows = DB::connection($connectionName)->table($table)->cursor();
-
                 $buffer = [];
                 $count = 0;
 
@@ -67,22 +70,22 @@ class TransferSqliteTableJob implements ShouldQueue
                     $count++;
 
                     if ($count % 500 === 0) {
-                        DB::connection($mysqlConnection)->table("_" . $table)->insert($buffer);
+                        DB::connection($mysqlConnection)->table("_{$table}")->insert($buffer);
                         $buffer = [];
                     }
                 }
 
                 if (!empty($buffer)) {
-                    DB::connection($mysqlConnection)->table("_" . $table)->insert($buffer);
+                    DB::connection($mysqlConnection)->table("_{$table}")->insert($buffer);
                 }
 
                 DB::statement("RENAME TABLE {$table} TO {$table}_");
                 DB::statement("RENAME TABLE _{$table} TO {$table}");
                 DB::statement("DROP TABLE IF EXISTS {$table}_");
 
-                logger()->info("✅ Done: {$table} ({$count} records)");
+                logger()->info("✅ Imported: {$table} ({$count} records)");
             } catch (\Exception $e) {
-                logger()->error("❌ Failed to transfer {$table}: " . $e->getMessage());
+                logger()->error("❌ Failed to import {$table}: " . $e->getMessage());
             } finally {
                 DB::connection($mysqlConnection)->statement('SET FOREIGN_KEY_CHECKS=1;');
             }
@@ -90,12 +93,13 @@ class TransferSqliteTableJob implements ShouldQueue
 
         // 🔥 結束後刪檔與釋放 connection
         DB::purge($connectionName);
-        if (file_exists($this->sqlitePath)) {
+        
+        if ($this->deleteFile && file_exists($this->sqlitePath)) {
             sleep(1);
             unlink($this->sqlitePath);
-            logger()->info("🧹 Temp SQLite file deleted: {$this->sqlitePath}");
+            logger()->info("🧹 Deleted SQLite file: {$this->sqlitePath}");
         }
 
-        logger()->info("🎉 All tables transferred.");
+        logger()->info("🎉 SQLite import completed: {$this->sqlitePath}");
     }
 }
\ No newline at end of file
diff --git a/database/User.data b/database/User.data
new file mode 100644
index 0000000000000000000000000000000000000000..55c187fb946cd460b14576ba3c90fd09b05a0641
GIT binary patch
literal 77824
zcmeI*O>EoN0S9n?NiuCq&xsSL-40ch1c|4_p}s81Sh2dc^WoZY9NYP58wiw0*{mhX
z7Nx{Cx&d;q9fqFT(|Q=XQ%~Dr!wy?p>@ci{4Hz&i*cVXjP+-HbbpwhO7_iG8A0=6q
z=~QYmz-|6S!pD#I_}=@GkK~g{X>noJsOq6Yxl&TAp*T0h@jUljD8zBxG5UX){%;Ne
zIw3V@XvnusA2fN48#RCG_sw!g#b>y{azOOI<$reYje-C4e?xw=@8iC6z9sM1e4^*9
zmlOXgeLy2&fWYAqs81jD1=mu1y=Iu2zF8`3dNI4ITG@5IQZg*dD4SN+S!!sFiR#w6
zo;^7F@Z|OBiKXe#m8(<Jw?g3_HyI9<%>xpJLuVUXGqmuzW+b~b;gPyE<O`-!{C!VV
z%@uXmOkEcqX_R(p;`!O><~BP3?2LCkvNZRQVOI4Oy%I9Z)sR^$7WWn>bXTq9S5=qQ
z?rGO6MoFz~h1T?~eOa}(yuZ>TSB`jtcTzmZc80Z4q-VOUTC0}Xd}D8Q)Fm5rWjI=2
z4)}tR2*0Ct09MLH-P%pVX30TlY^}{@PyFAZnwdO|=vm?oE<`?^h?Tq@hb<VYPYn8k
z$t1sXnz67PJ4D@<`S$|3Md|LKVktk<LDNh*GIGi94Zf5-h`_CE*{Iu6`}){tpStSH
z1HRzNll;yGL)mQ_R@>y@UV^qYcFo(X)PD3kM{mBOmvoc1tlidSswF+_)~;4+YDLQ)
zxSDQCt?F7<t%gGyovIooogOc>b$e#-;*t7fzb_aJ@;iEKXInOeHL$lXY}w(h#cA0W
zT+HzG7uacl!dqoiEoRkxUbn1lwY;X&b2<yMHPhIr>F!bb8<k$ZdSzj`bvk#CyJvIG
zDcn7xt;VvZr);&)7yNpL-+B5|%W0p|v+T0N(z024IeJJsxl#DWMaaD{PN^TZ@vf@U
z+JJpgYA;}TWapmG7tCb%Z_3S<;<7K?3)i>zm~)TxnGV9;BC>0zTcg^I(%w+JX^t$V
zYeQ9Y2E9NTx)lyp_01}^DymjBTeCWvAzh(wt{WBI>TI+<wdJS0zTiB)u}L{ciE3H*
z%Jf7*H>+2hjX*D{MzL`ixkd1G97S$%vTYk_94>Cr>^;R|(gXjDhuy2xOU^;z7Jc1q
zp||6ZaEr5>&w=~Zb?>;@j;N9^7!C4uA2XzTszPrJSIef}IB~Ego<^zmo+tK4c5v8o
zyO3-<;Sp8bpM@jpoSRsD=^<IPNAAd?;eAc;+IKd$nReqY$<pb0&!i_r=ccJSEAA2Q
zSb5gI$eg25NA92H*@fa;7uYsg8QDnKlRn(4Y<nwuw9B1SC%1j;fV!>88I|g)rfxY`
zK-#`mbb7O2*?$~_G`*nKiq+7Wnn|0<85-59s?{28vYj`)yHOQ8nzI+~>J_74>~GJ_
zqj`UhG^u^9FXi-#(<oa}=o)q1$gUSv!)&f<oHyK#RT|y(n(n9fE27`x$kTxc4KP3e
z0uX=z1Rwwb2tWV=5P-nr6R0Oe!bRdI;=w+y?%}w2e4<#?&CqStJiAOkLl{x*+0iZ4
zd~U`50A@5_E-4ws8DcRdmOQT{&&N_BMHy%RSZDN9Z0l4sb}DyMo3-X<r$*Ds+nTa=
zIhm>ymgdXl^!(-8+}Ne9T5R^l<>c&EB~e_<STpx-##hv>wrxg}<H^{#l5km6UlRxy
zO*YHD(O&M7nqM_cePqrFUs$@~Qub)uM%~JOrMRpacNb<#Gjq2}6Y54RrCnSaHE&Jl
z%+dK5mp8Y^CexE~MJe3ezBHMe%ui0fSlWoaI(I!)DqekM@s+EW^Gg>u7B8C7>CNdE
z;`1xk^V>7(+?9k9y_{Z*r3-2yPLsEl;$gMbc*32JxYkzHN`^VY#xB)t&%mvk^U2Y*
zsfl|lQ>Kv_z4l^qZJ{=8&R<x)bYo4o=5Jq3&Q!KHrz+{K)$P@4-nw)lck6B}`s&Q&
zvN@%fZ*DBk-Yms7Z^jjKaltIk6vnQu78bM{8-}@l`}(!bu~cp>Q%JR!;vv<v`~MPo
zk0YOuKayY52@DW`00bZa0SG_<0uX=z1Rwwb2plc}B8ew?`s7pdN#r3}6oWi_{7(Fm
zAZF}!E)P@*GEbwihcCo_S|gFX%aI4<BN||U00bZa0SG_<0uX=z1Rwwb2teSF2?WJB
z@A9mO_>`FB-5$gcj*1bv<EaIw|Nnp^ACnKsgF{w96bAwjfB*y_009U<00Izz00bZa
zfdd5s;t78Dg%NSjY*g@zC*;;z#eV*ue(4_u2tWV=5P$##AOHafKmY;|fB*!(zykK)
z|Iz>d0`Fi{4FV8=00bZa0SG_<0uX=z1Ry{K?7#mDfg@btZ92jL0SG_<0uX=z1Rwwb
z2tWV=PmVx+SQz9Y{OP(s$bOn&ef{M*`&X~6m+jvs5Z3eOS9P^g&C#EYO=se2BA-v?
zl9`y6R|<L}pHd5nxS}OuW9dRJnv9O6w0N|jDJexssPUYVPv}ZCK9)=tk{Ru#@K?fj
zy8AZ%og2KLi^#)u|NRRt#iDP)CzOOXmeDf#Of;4+q!O`AJe`Q8qDfk)L^?W_P*N!+
z8I8x12|cYRv}h)i&@xIUr)w!Kk=I`e({IXKIbSraYWSQp?fi~jb57Tc)*9-eS9Q9k
zQZAR8Y1nit4V!DEVbiTN_80Fp)3E7Q8aCHR!=_tl?C<nzreV{qG;FSw4~^AG(<Q9^
z_kV%>jwAn|BMcCL00bZa0SG_<0uX=z1Rwwb2z-tNj!O}qpXm7LMi`bNvfQ!M>HpU_
z@(!tejw*<vLI45~fB*y_009U<00Izz00a)dz_e8N^N;%UgfK<7B0uV55BBr_BDuqn
zUy|2pfB^y!fB*y_009U<00Izz00bZafnEjTqL({99FH&4C;sp0x&5y?#9bDR3105Y
zG*ROh{JKt;;JsXsrkl`8hS_y0yZ=8lc#R|PlW&u2<XGTOf$s*iz*+x4{Xg_?`oHQI
z2HziijYhx#0SG_<0uX=z1Rwwb2tc4iV0_5Sous`G_FA&@DstC-ku>pg&otB8uQYd^
zay-zMtMh7f*J;!Kwp{Jkzq?L3KIr7y_NsQ*Y10EvuB}(TyG}XY-<E5yb(Pz4?X9kT
zO=0@Nd$0S|*A%8{d)u$xwp@FytEVm3-s&njxw0<==(Vo2%WogUENyRfrTu=p<*<~!
z)|K}CTe<dBSG)f|OkU&2f5|80U*vD(L-GOnJ^2m!75N4E8TkqM5&1rOn|zPFN#3B*
zFhBqT5P$##AOHafKmY;|fB*y_@Q4DQVUg#3g6Aj=yn^Ql4LpK0B=Yi*MCh1E0Xhyy
zemeF`gLFJ74bbs`)KAC#l1#_4)JMmCl8=skl9!IXl825xl0?UJM8~2e&@ufl%Ci0b
z|1jCM`~UwYACbS1Khx&`{y=u<Cji^@oq(T{cgc^*59lWVZ;|hi*B`NhNDcuAKmY;|
zfB*y_009U<00Izr;sksWZ};|xS?Cpxvd|+O@k+eR4-K(^5EcXiEb#kTFgVD9fdLlu
z_p?Bz{d}6Pua5;j9}B!*7I-`?kR%p}A`1jTl4MzS-v57(BY!6k$a_!RPC$hr009U<
z00Izz00bZa0SG_<0*7DVxG3=vUhMcvfAP3rFBUo$3&Xr5N8G;uUnK9?{r}(600RUd
z009U<00Izz00bZa0SG_<0*6Z==;7_&|Gw_Ovs~EM|3BuD_xJzpzyEVXhpS>J4Fn(n
z0SG_<0uX=z1Rwwb2tWV=k5|Bc{~!JT$7_nMK>z{}fB*y_009U<00Izz00a)30Q&!j
dZI7Tl5P$##AOHafKmY;|fB*y_0D;FZ@IQp}vLgTh

literal 0
HcmV?d00001

diff --git a/database/seeders/DatabaseSeeder.php b/database/seeders/DatabaseSeeder.php
index 9e5083a..11ddeea 100644
--- a/database/seeders/DatabaseSeeder.php
+++ b/database/seeders/DatabaseSeeder.php
@@ -2,9 +2,8 @@
 
 namespace Database\Seeders;
 
-use App\Models\User;
-// use Illuminate\Database\Console\Seeds\WithoutModelEvents;
 use Illuminate\Database\Seeder;
+use App\Jobs\ImportSqliteJob;
 
 class DatabaseSeeder extends Seeder
 {
@@ -13,10 +12,11 @@ class DatabaseSeeder extends Seeder
      */
     public function run(): void
     {
-        $this->call([
-            PermissionTableSeeder::class,
-            CreateAdminUserSeeder::class,
-            FavoriteSongsSeeder::class,
-        ]);
+        (new ImportSqliteJob('database/User.data', false))->handle();
+        //$this->call([
+        //    PermissionTableSeeder::class,
+        //    CreateAdminUserSeeder::class,
+        //    FavoriteSongsSeeder::class,
+        //]);
     }
 }