diff --git a/Config.cs b/Config.cs index 39ee49b..a2e7626 100644 --- a/Config.cs +++ b/Config.cs @@ -14,13 +14,14 @@ public static class Config public static int TargetPort => int.TryParse(Configuration.GetSection("TargetPort").Value, out int targetPort) ? targetPort : Cassandra.ProtocolOptions.DefaultPort; public static string TargetKeyspace => Configuration.GetSection("TargetKeyspace").Value; public static string TargetTable => Configuration.GetSection("TargetTable").Value; - public static string InsertionFilePath => Configuration.GetSection("InsertionFilePath").Value; public static string ExtractionFilePath => Configuration.GetSection("ExtractionFilePath").Value; + public static string InsertionFilePath => Configuration.GetSection("InsertionFilePath").Value; + public static bool InsertionFileHasHeader => string.Compare(Configuration.GetSection("InsertionFileHasHeader").Value, "true", true) == 0; public static int InsertionBatch => int.TryParse(Configuration.GetSection("InsertionBatch").Value, out int insertionBatch) ? insertionBatch : 100000; private static readonly IConfigurationRoot Configuration = new ConfigurationBuilder() - .SetBasePath(Directory.GetCurrentDirectory()) - .AddJsonFile("appsettings.json", optional: false, reloadOnChange: true) - .Build(); + .SetBasePath(Directory.GetCurrentDirectory()) + .AddJsonFile("appsettings.json", optional: false, reloadOnChange: true) + .Build(); } } \ No newline at end of file diff --git a/Models/Insertion.cs b/Models/Insertion.cs index d33eec5..372e9bf 100644 --- a/Models/Insertion.cs +++ b/Models/Insertion.cs @@ -106,7 +106,7 @@ private static dynamic[] PrepareRowForInsertion(IList columns, List