fix(TableDefinition): allow csv format file specification

Author: EJ-OB

src/ControlFileBuilder.php

@@ -11,9 +11,7 @@
 
 class ControlFileBuilder implements Stringable
 {
-    public function __construct(public SQLLoader $loader)
-    {
-    }
+    public function __construct(public SQLLoader $loader) {}
 
     public function __toString(): string
     {

src/CsvFile.php

@@ -11,9 +11,7 @@ final class CsvFile
     /**
      * @param  resource  $stream
      */
-    private function __construct(public string $file, public $stream)
-    {
-    }
+    private function __construct(public string $file, public $stream) {}
 
     /**
      * A list of possible modes. The default is 'w' (open for writing).:

src/InputFile.php

@@ -14,8 +14,7 @@ public function __construct(
         public ?string $discardFile = null,
         public ?string $discardMax = null,
         public ?string $osFileProcClause = null,
-    ) {
-    }
+    ) {}
 
     public function __toString(): string
     {

src/SQLLoader.php

@@ -46,9 +46,7 @@ class SQLLoader
 
     protected string $dateFormat = 'YYYY-MM-DD"T"HH24:MI:SS."000000Z"';
 
-    public function __construct(public array $options = [])
-    {
-    }
+    public function __construct(public array $options = []) {}
 
     /**
      * Define mode to use.
@@ -71,6 +69,8 @@ public function into(
         bool $trailing = true,
         array $formatOptions = [],
         ?string $when = null,
+        bool $csv = false,
+        bool $withEmbedded = false,
     ): static {
         if (! $columns && $this->defaultColumns) {
             $columns = $this->createColumnsFromHeaders($table, $this->defaultColumns);
@@ -88,7 +88,7 @@ public function into(
         $columns = array_merge($columns, $this->constants);
 
         $this->tables[] = new TableDefinition(
-            $table, $columns, $terminatedBy, $enclosedBy, $trailing, $formatOptions, $when
+            $table, $columns, $terminatedBy, $enclosedBy, $trailing, $formatOptions, $when, $csv, $withEmbedded
         );
 
         return $this;

src/TableDefinition.php

@@ -16,8 +16,9 @@ public function __construct(
         public bool $trailing = false,
         public array $formatOptions = [],
         public ?string $when = null,
-    ) {
-    }
+        public bool $csv = false,
+        public bool $withEmbedded = false,
+    ) {}
 
     public function __toString(): string
     {
@@ -27,12 +28,21 @@ public function __toString(): string
             $sql .= "WHEN {$this->when}".PHP_EOL;
         }
 
+        if ($this->csv) {
+            $sql .= 'FIELDS CSV '.($this->withEmbedded ? 'WITH' : 'WITHOUT').' EMBEDDED';
+        }
+
         if ($this->terminatedBy) {
-            $sql .= "FIELDS TERMINATED BY '{$this->terminatedBy}' ";
+            $sql .= ! str_contains($sql, 'FIELDS') ? 'FIELDS ' : ' ';
+            $sql .= "TERMINATED BY '{$this->terminatedBy}' ";
         }
 
         if ($this->enclosedBy) {
-            $sql .= "OPTIONALLY ENCLOSED BY '{$this->enclosedBy}'".PHP_EOL;
+            $sql .= "OPTIONALLY ENCLOSED BY '{$this->enclosedBy}'";
+        }
+
+        if ($this->csv || $this->terminatedBy || $this->enclosedBy) {
+            $sql .= PHP_EOL;
         }
 
         if ($this->formatOptions) {

tests/Unit/TableDefinitionTest.php

@@ -59,8 +59,8 @@
     );
 
     assertEquals(
-        "INTO TABLE users\nFIELDS TERMINATED BY ',' (\n  id,\n  name,\n  email\n)\n",
-        $table
+        "INTO TABLE users\nFIELDS TERMINATED BY ',' \n(\n  id,\n  name,\n  email\n)\n",
+        $table,
     );
 });
 
@@ -100,3 +100,30 @@
         $table
     );
 });
+
+test('it can build with csv format', function () {
+    $table = new TableDefinition(
+        'users',
+        ['id', 'name', 'email'],
+        csv: true,
+    );
+
+    assertEquals(
+        "INTO TABLE users\nFIELDS CSV WITHOUT EMBEDDED\n(\n  id,\n  name,\n  email\n)\n",
+        $table
+    );
+});
+
+test('it can build with csv format with embedded', function () {
+    $table = new TableDefinition(
+        'users',
+        ['id', 'name', 'email'],
+        csv: true,
+        withEmbedded: true,
+    );
+
+    assertEquals(
+        "INTO TABLE users\nFIELDS CSV WITH EMBEDDED\n(\n  id,\n  name,\n  email\n)\n",
+        $table
+    );
+});