Initial setup - gitea

PriorBankParser/DbLoader.cs

@@ -0,0 +1,61 @@
+using System.Data.SqlClient;
+using System.Linq;
+using Dapper;
+using NUnit.Framework;
+
+namespace PriorBankParser
+{
+    public class DbLoader
+    {
+        private const string Sql = @"
+DROP TABLE IF EXISTS [dbo].[VPSK_IMPORT]
+GO
+
+CREATE TABLE [dbo].[VPSK_IMPORT]
+(
+    [Contract] NVARCHAR(255),
+    [TransactionName] NVARCHAR(2048),
+    [Category] NVARCHAR(2048),
+    [Currency] VARCHAR(5),
+    [IsIncome] VARCHAR(5),
+    [TransactionDate] DATETIME,
+    [OperationDate] DATETIME,
+    [Amount] DECIMAL(19, 6),
+    [Commission] DECIMAL(19, 6),
+    [AccountTurnover] DECIMAL(19, 6)
+)
+GO
+
+BULK INSERT [dbo].[VPSK_IMPORT]
+FROM '<SOURCE_FILE_PATH>'
+WITH (
+    TABLOCK
+    ,FORMAT = 'CSV'
+    ,FIRSTROW = 2
+    ,FIELDTERMINATOR = ','
+    ,FIELDQUOTE = '0x22'
+    --,ROWTERMINATOR = '0x0a'
+    ,CODEPAGE=65001
+);
+
+";
+
+        [Test]
+        public void Load()
+        {
+            const string sourceFile = @"D:\Cloud-storage\Dropbox\Home\Finance\Raw Source\ConvertedResult.csv";
+            var script = Sql.Replace("<SOURCE_FILE_PATH>", sourceFile);
+
+            var connectionString = new SqlConnectionStringBuilder
+                { DataSource = "(local)", InitialCatalog = "MY_FINANCE", IntegratedSecurity = true, }
+                .ConnectionString;
+            using var sqlConnection = new SqlConnection(connectionString);
+            sqlConnection.Open();
+
+            foreach (var scriptPart in script.Split("GO").Where(s => !string.IsNullOrEmpty(s)))
+            {
+                sqlConnection.Execute(scriptPart, commandTimeout: 60 * 60);
+            }
+        }
+    }
+}