Added default value binary. Conversion from and to Postgre notation

Author: JaBistDuNarrisch

src/Migrator.Tests/Providers/PostgreSQL/PostgreSQLTransformationProvider_GetColumnsDefaultValueTests.cs

@@ -29,6 +29,7 @@ public void GetColumns_DataTypeResolveSucceeds()
         const string int32ColumnName1 = "int32column1";
         const string int64ColumnName1 = "int64column1";
         const string stringColumnName1 = "stringcolumn1";
+        const string binaryColumnName1 = "binarycolumn1";
 
         // Should be extended by remaining types
         Provider.AddTable(testTableName,
@@ -42,7 +43,8 @@ public void GetColumns_DataTypeResolveSucceeds()
 
             new Column(int32ColumnName1, DbType.Int32, defaultValue: 43),
             new Column(int64ColumnName1, DbType.Int64, defaultValue: 88),
-            new Column(stringColumnName1, DbType.String, defaultValue: "Hello")
+            new Column(stringColumnName1, DbType.String, defaultValue: "Hello"),
+            new Column(binaryColumnName1, DbType.Binary, defaultValue: new byte[] { 12, 32, 34 })
         );
 
         // Act
@@ -57,6 +59,7 @@ public void GetColumns_DataTypeResolveSucceeds()
         var int32Column1 = columns.Single(x => x.Name == int32ColumnName1);
         var int64Column1 = columns.Single(x => x.Name == int64ColumnName1);
         var stringColumn1 = columns.Single(x => x.Name == stringColumnName1);
+        var binarycolumn1 = columns.Single(x => x.Name == binaryColumnName1);
 
         Assert.That(dateTimeColumn1.DefaultValue, Is.EqualTo(dateTimeDefaultValue));
         Assert.That(dateTimeColumn2.DefaultValue, Is.EqualTo(dateTimeDefaultValue));
@@ -66,5 +69,6 @@ public void GetColumns_DataTypeResolveSucceeds()
         Assert.That(int32Column1.DefaultValue, Is.EqualTo(43));
         Assert.That(int64Column1.DefaultValue, Is.EqualTo(88));
         Assert.That(stringColumn1.DefaultValue, Is.EqualTo("Hello"));
+        Assert.That(binarycolumn1.DefaultValue, Is.EqualTo(new byte[] { 12, 32, 34 }));
     }
 }

src/Migrator.Tests/Providers/PostgreSQL/PostgreSQLTransformationProvider_GetColumnsTypeTests.cs

@@ -23,7 +23,7 @@ public void GetColumns_DataTypeResolveSucceeds()
         const string int64ColumnName1 = "int64column1";
         const string stringColumnName1 = "stringcolumn1";
         const string stringColumnName2 = "stringcolumn2";
-        const string byteColumnName = "bytecolumn";
+        const string binaryColumnName1 = "binarycolumn";
 
         // Should be extended by remaining types
         Provider.AddTable(testTableName,
@@ -35,7 +35,8 @@ public void GetColumns_DataTypeResolveSucceeds()
             new Column(int32ColumnName1, DbType.Int32),
             new Column(int64ColumnName1, DbType.Int64),
             new Column(stringColumnName1, DbType.String),
-            new Column(stringColumnName2, DbType.String) { Size = 30 }
+            new Column(stringColumnName2, DbType.String) { Size = 30 },
+            new Column(binaryColumnName1, DbType.Binary)
         );
 
         // Act
@@ -50,6 +51,7 @@ public void GetColumns_DataTypeResolveSucceeds()
         var int64column1 = columns.Single(x => x.Name == int64ColumnName1);
         var stringColumn1 = columns.Single(x => x.Name == stringColumnName1);
         var stringColumn2 = columns.Single(x => x.Name == stringColumnName2);
+        var binaryColumn1 = columns.Single(x => x.Name == binaryColumnName1);
 
 
         // Assert
@@ -67,5 +69,6 @@ public void GetColumns_DataTypeResolveSucceeds()
         Assert.That(stringColumn1.Type, Is.EqualTo(DbType.String));
         Assert.That(stringColumn2.Type, Is.EqualTo(DbType.String));
         Assert.That(stringColumn2.Size, Is.EqualTo(30));
+        Assert.That(binaryColumn1.Type, Is.EqualTo(DbType.Binary));
     }
 }

src/Migrator/Providers/Dialect.cs

@@ -363,6 +363,11 @@ public virtual string Default(object defaultValue)
             // .ToString("N") does not exist in old .NET version
             defaultValue = Convert.ToString(defaultValue, CultureInfo.InvariantCulture);
         }
+        else if (defaultValue is byte[] byteArray)
+        {
+            var convertedString = BitConverter.ToString(byteArray).Replace("-", "").ToLower();
+            defaultValue = $"'\\x{convertedString}'";
+        }
 
         return string.Format("DEFAULT {0}", defaultValue);
     }

src/Migrator/Providers/Impl/PostgreSQL/PostgreSQLTransformationProvider.cs

@@ -486,6 +486,37 @@ public override Column[] GetColumns(string table)
                             throw new NotImplementedException();
                         }
                     }
+                    else if (column.Type == DbType.Binary)
+                    {
+                        if (defaultValueString.StartsWith("'"))
+                        {
+                            var match = stripSingleQuoteRegEx.Match(defaultValueString);
+
+                            if (!match.Success)
+                            {
+                                throw new Exception("Postgre default value for bytea: Single quotes around the bytea string are expected.");
+                            }
+
+                            var singleQuoteString = match.Value;
+
+                            if (!singleQuoteString.StartsWith("\\x"))
+                            {
+                                throw new Exception(@"Postgre \x notation expected.");
+                            }
+
+                            var hexString = singleQuoteString.Substring(2);
+
+                            // Not available in old .NET version: Convert.FromHexString(hexString);
+
+                            column.DefaultValue = Enumerable.Range(0, hexString.Length / 2)
+                                .Select(x => Convert.ToByte(hexString.Substring(x * 2, 2), 16))
+                                .ToArray();
+                        }
+                        else
+                        {
+                            throw new NotImplementedException();
+                        }
+                    }
                     else
                     {
                         throw new NotImplementedException();