Support binary data type, support specify data length in column config, support specify allow null column.

Author: quinvit

src/Serilog.Sinks.MSSqlServer/Configuration/ColumnConfig.cs

@@ -52,11 +52,31 @@ public string ColumnName
         /// Type of column as it exists in SQL Server
         /// </summary>
         [ConfigurationProperty("DataType", IsRequired = true, IsKey = false, DefaultValue ="varchar")]
-        [RegexStringValidator("(bigint)|(bit)|(char)|(date)|(datetime)|(datetime2)|(decimal)|(float)|(int)|(money)|(nchar)|(ntext)|(numeric)|(nvarchar)|(real)|(smalldatetime)|(smallint)|(smallmoney)|(text)|(time)|(uniqueidentifier)|(varchar)")]
+        [RegexStringValidator("(bigint)|(bit)|(binary)|(char)|(date)|(datetime)|(datetime2)|(decimal)|(float)|(int)|(money)|(nchar)|(ntext)|(numeric)|(nvarchar)|(real)|(smalldatetime)|(smallint)|(smallmoney)|(text)|(time)|(uniqueidentifier)|(varchar)")]
         public string DataType
         {
             get { return (string)this["DataType"]; }
             set { this["DataType"] = value; }
         }
+
+        /// <summary>
+        /// Length of column as it exists in SQL Server for string or binary data type.
+        /// </summary>
+        [ConfigurationProperty("DataLength", IsRequired = false, IsKey = false, DefaultValue = 128)]
+        public int DataLength
+        {
+            get { return (int)this["DataLength"]; }
+            set { this["DataLength"] = value; }
+        }
+
+        /// <summary>
+        /// Allow nullable column as it exists in SQL Server.
+        /// </summary>
+        [ConfigurationProperty("AllowNull", IsRequired = false, IsKey = false, DefaultValue = true)]
+        public bool AllowNull
+        {
+            get { return (bool)this["AllowNull"]; }
+            set { this["AllowNull"] = value; }
+        }
     }
 }

src/Serilog.Sinks.MSSqlServer/LoggerConfigurationMSSqlServerExtensions.cs

@@ -142,6 +142,10 @@ private static void GenerateDataColumnsFromConfig(MSSqlServerConfigurationSectio
                     case "bigint":
                         dataType = Type.GetType("System.Int64");
                         break;
+                    case "binary":
+                        dataType = Type.GetType("System.Byte[]");
+                        column.ExtendedProperties["DataLength"] = c.DataLength;
+                        break;
                     case "bit":
                         dataType = Type.GetType("System.Boolean");
                         break;
@@ -152,6 +156,7 @@ private static void GenerateDataColumnsFromConfig(MSSqlServerConfigurationSectio
                     case "text":
                     case "varchar":
                         dataType = Type.GetType("System.String");
+                        column.MaxLength = c.DataLength;
                         break;
                     case "date":
                     case "datetime":
@@ -184,11 +189,14 @@ private static void GenerateDataColumnsFromConfig(MSSqlServerConfigurationSectio
                         dataType = Type.GetType("System.Guid");
                         break;
                 }
+
                 column.DataType = dataType;
+                column.AllowDBNull = c.AllowNull;
                 if (columnOptions.AdditionalDataColumns == null)
                 {
                     columnOptions.AdditionalDataColumns = new Collection<DataColumn>();
                 }
+
                 columnOptions.AdditionalDataColumns.Add(column);
             }
         }

src/Serilog.Sinks.MSSqlServer/Sinks/MSSqlServer/SqlTableCreator.cs

@@ -101,6 +101,10 @@ private static string SqlGetType(object type, int columnSize, int numericPrecisi
                     sqlType = "TINYINT";
                     break;
 
+                case "System.Byte[]":
+                    sqlType = columnSize == -1 ? "VARBINARY" : "BINARY(" + columnSize.ToString() + ")";
+                    break;
+
                 case "System.String":
 	                sqlType = "NVARCHAR(" + ((columnSize == -1) ? "MAX" : columnSize.ToString()) + ")";
 	                break;
@@ -148,7 +152,13 @@ private static string SqlGetType(object type, int columnSize, int numericPrecisi
 	    // Overload based on DataColumn from DataTable type
 		private static string SqlGetType(DataColumn column)
 		{
-			return SqlGetType(column.DataType, column.MaxLength, 10, 2, column.AllowDBNull);
+            int dataLength = -1;
+            if (!column.ExtendedProperties.ContainsKey("DataLength") || !int.TryParse(column.ExtendedProperties["DataLength"].ToString(), out dataLength))
+            {
+                dataLength = column.MaxLength;
+            }
+
+            return SqlGetType(column.DataType, dataLength, 10, 2, column.AllowDBNull);
 		}
 
 		#endregion