migrations

Author: corey

MyClasses/bd_db.cs

@@ -4,7 +4,8 @@
 using System.Collections.Generic;
 using Microsoft.AspNetCore.Mvc.Rendering;
 using System.Threading.Tasks;
-
+using System.Linq;
+using System.IO;
 
 namespace budoco
 {
@@ -219,5 +220,27 @@ public static dynamic format(dynamic data)
 
         }
 
+        public static void update_db_schema(string content_root_path)
+        {
+            int current_db_version = (int)bd_db.exec_scalar("select db_version from db_version");
+
+            string db_changes_folder = content_root_path + "/sql/db_changes/";
+
+            string[] files = System.IO.Directory.GetFiles(db_changes_folder);
+
+            Array.Sort(files, StringComparer.InvariantCulture);
+
+            foreach (string file in files)
+            {
+                string digits = new String(file.Where(Char.IsDigit).ToArray());
+                int version_from_filename = Convert.ToInt32(digits);
+
+                if (version_from_filename > current_db_version)
+                {
+                    string sql = File.ReadAllText(file);
+                    bd_db.exec(sql);
+                }
+            }
+        }
     }
-}
+}

Pages/Admin/Logs.cshtml.cs

@@ -33,7 +33,7 @@ public void OnGet()
 
             bd_util.log(log_folder);
 
-            files = System.IO.Directory.GetFiles(log_folder); // , ";");
+            files = System.IO.Directory.GetFiles(log_folder);
 
             for (int i = 0; i < files.Length; i++)
             {

Startup.cs

@@ -16,7 +16,7 @@ namespace budoco
 {
     public class Startup
     {
-        public Startup(IConfiguration configuration)
+        public Startup(IConfiguration configuration, IWebHostEnvironment env)
         {
             bd_util.log("Startup");
             Configuration = configuration;
@@ -26,14 +26,15 @@ public Startup(IConfiguration configuration)
             //NpgsqlLogManager.Provider = new ConsoleLoggingProvider(NpgsqlLogLevel.Debug, false, false);
             NpgsqlLogManager.Provider = new bd_pg_log_provider();
 
+            bd_db.update_db_schema(env.ContentRootPath);
+
             // If there are pending outgoing emails try to send them.
             bd_email.spawn_email_sending_thread();
 
             bd_email.spawn_email_receiving_thread();
 
             bd_email.spawn_registration_request_expiration_thread();
 
-
         }
 
         public IConfiguration Configuration { get; }

budoco.csproj

@@ -13,6 +13,12 @@
     <PackageReference Include="Serilog.AspNetCore" Version="3.4.0" />
     <PackageReference Include="System.Data.SqlClient" Version="4.8.2" />
     <PackageReference Include="System.Drawing.Common" Version="5.0.0" />
+
+
+    <Content Include="sql\**"> 
+      <CopyToOutputDirectory>Always</CopyToOutputDirectory> 
+    </Content>
   </ItemGroup>
 
+
 </Project>

sql/db_changes/002_one_to_two.sql

@@ -0,0 +1,11 @@
+BEGIN;
+
+create table junk1
+(
+my_col int
+);
+
+update db_version set db_version = 2;
+
+
+COMMIT;

sql/db_changes/003_two_to_three.sql

@@ -0,0 +1,5 @@
+BEGIN;
+
+update db_version set db_version = 3;
+
+COMMIT;

sql/setup.sql

@@ -268,3 +268,10 @@ insert into queries (qu_name, qu_sql) values (
 'Raw "select * from issues" Please run queries.sql',
 'select * from issues order by i_id desc');
 
+-- one row, for schema changes, "migrations"
+drop table db_version;
+create table db_version
+(
+db_version int 
+);
+insert into db_version (db_version) values(1);