migrations

CHANGES.md

@@ -1,4 +1,4 @@
-## 0.0.12 (2020/06/30)
+## 0.0.14 (2020/06/30)
 * Safer DB migrations
 
 ## 0.0.11 (2020/06/25)

Common.targets

@@ -1,8 +1,8 @@
 <Project>
   <PropertyGroup>
-    <Version>0.0.11</Version>
-    <AssemblyVersion>0.0.11</AssemblyVersion>
-    <FileVersion>0.0.11</FileVersion>
+    <Version>0.0.14</Version>
+    <AssemblyVersion>0.0.14</AssemblyVersion>
+    <FileVersion>0.0.14</FileVersion>
   </PropertyGroup>
   <PropertyGroup>
     <!-- Χρόνος -->

src/K4os.Shared/Extensions.cs

@@ -30,6 +30,9 @@ public static T NotLessThan<T>(this T subject, T limit) =>
 		public static T NotMoreThan<T>(this T subject, T limit) =>
 			Compare(subject, limit) > 0 ? limit : subject;
 
+		public static string NotBlank(this string text, string defaultValue = null) =>
+			string.IsNullOrWhiteSpace(text) ? defaultValue : text;
+
 		public static R PipeTo<T, R>(this T subject, Func<T, R> func) =>
 			func(subject);
 

src/K4os.Xpovoc.Core/Sql/AnySqlStorage.cs

@@ -35,9 +35,9 @@ protected virtual async Task<ILease<TConnection>> Connect()
 				if (connection.State == ConnectionState.Closed)
 					await OpenConnection(connection);
 
-				if (!IsDatabaseReady)
+				if (!DatabaseReady)
 					await TryCreateDatabase(connection);
-				
+
 				return lease;
 			}
 			catch
@@ -59,26 +59,31 @@ protected virtual async Task<ILease<TConnection>> Connect()
 
 		protected async Task TryCreateDatabase(TConnection connection)
 		{
-			if (IsDatabaseReady)
+			if (DatabaseReady)
 				return;
 
 			await _migrationLock.WaitAsync();
 			try
 			{
 				// check again
-				if (IsDatabaseReady) 
+				if (DatabaseReady)
 					return;
 
 				await CreateDatabase(connection);
+
+				DatabaseReady = true;
 			}
 			finally
 			{
 				_migrationLock.Release();
 			}
 		}
 
-		private bool IsDatabaseReady =>
-			Interlocked.CompareExchange(ref _databaseReady, 0, 0) != 0;
+		public bool DatabaseReady
+		{
+			get => Interlocked.CompareExchange(ref _databaseReady, 0, 0) != 0;
+			set => Interlocked.Exchange(ref _databaseReady, value ? 1 : 0);
+		}
 
 		protected virtual async Task<T> Exec<T>(
 			TConnection connection, Func<TConnection, Task<T>> action,

src/K4os.Xpovoc.MsSql/MsSqlMigrator.cs

@@ -1,3 +1,4 @@
+using System;
 using System.Collections.Generic;
 using System.Data;
 using Dapper;
@@ -19,7 +20,7 @@ public MsSqlMigrator(
 			base("Xpovoc", connection, migrations)
 		{
 			var hasSchema = !string.IsNullOrWhiteSpace(schema);
-			_schemaName = schema ?? string.Empty;
+			_schemaName = schema ?? "dbo";
 			_tableName = "Migrations";
 
 			_schema = hasSchema ? Quoted(schema) : string.Empty;