Add fallback values for job batches database config (#91)

duncanmcclean · web-flow · commit 8df469120ed3 · 2025-02-24T12:38:15.000Z
diff --git a/src/Http/Controllers/ImportController.php b/src/Http/Controllers/ImportController.php
@@ -217,7 +217,7 @@ private function createBlueprint(): Blueprint
     private function ensureJobBatchesTableExists(): bool
     {
         try {
-            if (Schema::connection(config('queue.batching.database'))->hasTable(config('queue.batching.table'))) {
+            if (Schema::connection(config('queue.batching.database', env('DB_CONNECTION', 'sqlite')))->hasTable(config('queue.batching.table', 'job_batches'))) {
                 return true;
             }
         } catch (QueryException $e) {
diff --git a/src/Importer.php b/src/Importer.php
@@ -21,7 +21,7 @@ public static function run(Import $import): void
     {
         Cache::forget("importer.{$import->id}.parents");
 
-        if (! Schema::connection(config('queue.batching.database'))->hasTable(config('queue.batching.table'))) {
+        if (! Schema::connection(config('queue.batching.database', env('DB_CONNECTION', 'sqlite')))->hasTable(config('queue.batching.table', 'job_batches'))) {
             throw new JobBatchesTableMissingException;
         }
 

Original file line number	Diff line number	Diff line change
`@@ -217,7 +217,7 @@ private function createBlueprint(): Blueprint`
`217`	`217`	`private function ensureJobBatchesTableExists(): bool`
`218`	`218`	`{`
`219`	`219`	`try {`
`220`		`- if (Schema::connection(config('queue.batching.database'))->hasTable(config('queue.batching.table'))) {`
	`220`	`+ if (Schema::connection(config('queue.batching.database', env('DB_CONNECTION', 'sqlite')))->hasTable(config('queue.batching.table', 'job_batches'))) {`
`221`	`221`	`return true;`
`222`	`222`	`}`
`223`	`223`	`} catch (QueryException $e) {`
Original file line number	Diff line number	Diff line change
`@@ -21,7 +21,7 @@ public static function run(Import $import): void`
`21`	`21`	`{`
`22`	`22`	`Cache::forget("importer.{$import->id}.parents");`
`23`	`23`
`24`		`- if (! Schema::connection(config('queue.batching.database'))->hasTable(config('queue.batching.table'))) {`
	`24`	`+ if (! Schema::connection(config('queue.batching.database', env('DB_CONNECTION', 'sqlite')))->hasTable(config('queue.batching.table', 'job_batches'))) {`
`25`	`25`	`throw new JobBatchesTableMissingException;`
`26`	`26`	`}`
`27`	`27`