Merge pull request #163 from keboola/PST-1473-ondra-conversion-datatype-table

Snowflake: conversion table for aliases

Author: zajca

src/Definition/Snowflake.php

@@ -435,6 +435,44 @@ public static function getTypeByBasetype(string $basetype): string
         throw new LogicException(sprintf('Definition for base type "%s" is missing.', $basetype));
     }
 
+    public function getBackendBasetype(): string
+    {
+        return match (strtoupper($this->type)) {
+            self::TYPE_NVARCHAR => self::TYPE_VARCHAR,
+            self::TYPE_NVARCHAR2 => self::TYPE_VARCHAR,
+            self::TYPE_CHAR => self::TYPE_VARCHAR,
+            self::TYPE_CHARACTER => self::TYPE_VARCHAR,
+            self::TYPE_CHAR_VARYING => self::TYPE_VARCHAR,
+            self::TYPE_CHARACTER_VARYING => self::TYPE_VARCHAR,
+            self::TYPE_NCHAR_VARYING => self::TYPE_VARCHAR,
+            self::TYPE_NCHAR => self::TYPE_VARCHAR,
+            self::TYPE_STRING => self::TYPE_VARCHAR,
+            self::TYPE_TEXT => self::TYPE_VARCHAR,
+
+            self::TYPE_VARBINARY => self::TYPE_BINARY,
+
+            self::TYPE_DEC => self::TYPE_NUMBER,
+            self::TYPE_DECIMAL => self::TYPE_NUMBER,
+            self::TYPE_NUMERIC => self::TYPE_NUMBER,
+            self::TYPE_INT => self::TYPE_NUMBER,
+            self::TYPE_INTEGER => self::TYPE_NUMBER,
+            self::TYPE_BIGINT => self::TYPE_NUMBER,
+            self::TYPE_SMALLINT => self::TYPE_NUMBER,
+            self::TYPE_TINYINT => self::TYPE_NUMBER,
+            self::TYPE_BYTEINT => self::TYPE_NUMBER,
+
+            self::TYPE_FLOAT => self::TYPE_FLOAT,
+            self::TYPE_FLOAT4 => self::TYPE_FLOAT,
+            self::TYPE_FLOAT8 => self::TYPE_FLOAT,
+            self::TYPE_DOUBLE => self::TYPE_FLOAT,
+            self::TYPE_DOUBLE_PRECISION => self::TYPE_FLOAT,
+            self::TYPE_REAL => self::TYPE_FLOAT,
+
+            self::TYPE_DATETIME => self::TYPE_TIMESTAMP_NTZ,
+            default => $this->type
+        };
+    }
+
     public static function getDefinitionForBasetype(string $basetype): self
     {
         $basetype = strtoupper($basetype);

tests/SnowflakeDatatypeTest.php

@@ -479,6 +479,15 @@ public function testArrayFromLength(string $type, ?string $length, array $expect
         $this->assertSame($expectedArray, $definition->getArrayFromLength());
     }
 
+    /**
+     * @dataProvider provideTestGetTypeFromAlias
+     */
+    public function testBackendBasetypeFromAlias(string $type, string $expectedType): void
+    {
+        $definition = new Snowflake($type);
+        $this->assertSame($expectedType, $definition->getBackendBasetype());
+    }
+
     public function arrayFromLengthProvider(): Generator
     {
         yield 'simple' => [
@@ -507,4 +516,57 @@ public function arrayFromLengthProvider(): Generator
             ['numeric_precision' => 10, 'numeric_scale' => 0],
         ];
     }
+
+    public function provideTestGetTypeFromAlias(): Generator
+    {
+        foreach (Snowflake::TYPES as $type) {
+            switch ($type) {
+                case Snowflake::TYPE_NVARCHAR:
+                case Snowflake::TYPE_NVARCHAR2:
+                case Snowflake::TYPE_CHAR:
+                case Snowflake::TYPE_CHARACTER:
+                case Snowflake::TYPE_CHAR_VARYING:
+                case Snowflake::TYPE_CHARACTER_VARYING:
+                case Snowflake::TYPE_NCHAR_VARYING:
+                case Snowflake::TYPE_NCHAR:
+                case Snowflake::TYPE_STRING:
+                case Snowflake::TYPE_TEXT:
+                    $expectedType = Snowflake::TYPE_VARCHAR;
+                    break;
+                case Snowflake::TYPE_DEC:
+                case Snowflake::TYPE_DECIMAL:
+                case Snowflake::TYPE_NUMERIC:
+                case Snowflake::TYPE_INT:
+                case Snowflake::TYPE_INTEGER:
+                case Snowflake::TYPE_BIGINT:
+                case Snowflake::TYPE_SMALLINT:
+                case Snowflake::TYPE_TINYINT:
+                case Snowflake::TYPE_BYTEINT:
+                    $expectedType = Snowflake::TYPE_NUMBER;
+                    break;
+                case Snowflake::TYPE_FLOAT:
+                case Snowflake::TYPE_FLOAT4:
+                case Snowflake::TYPE_FLOAT8:
+                case Snowflake::TYPE_DOUBLE:
+                case Snowflake::TYPE_DOUBLE_PRECISION:
+                case Snowflake::TYPE_REAL:
+                    $expectedType = Snowflake::TYPE_FLOAT;
+                    break;
+                case Snowflake::TYPE_VARBINARY:
+                    $expectedType = Snowflake::TYPE_BINARY;
+                    break;
+                case Snowflake::TYPE_DATETIME:
+                    $expectedType = Snowflake::TYPE_TIMESTAMP_NTZ;
+                    break;
+                default:
+                    $expectedType = $type;
+                    break;
+            }
+
+            yield $type => [
+                'type' => $type,
+                'expectedType' => $expectedType,
+            ];
+        }
+    }
 }