b

Author: polterguy

plugins/magic.data.common/magic.data.common/helpers/Executor.cs

@@ -9,6 +9,7 @@
 using magic.node;
 using magic.node.extensions;
 using magic.data.common.contracts;
+using magic.node.contracts;
 
 namespace magic.data.common.helpers
 {
@@ -93,6 +94,7 @@ public static async Task ExecuteAsync(
         /// <param name="settings">Configuration object from where to retrieve connection string templates</param>
         /// <returns>Connection string</returns>
         public static string GetConnectionString(
+            IRootResolver resolver,
             Node input,
             string databaseType,
             string defaultCatalogue,
@@ -128,6 +130,8 @@ public static string GetConnectionString(
                 var generic = settings.ConnectionString("generic", databaseType);
                 connectionString = generic.Replace("{database}", connectionString);
             }
+            if (databaseType == "sqlite")
+                connectionString = connectionString.Replace("files/data/", resolver.DynamicFiles + "data/");
             return connectionString;
         }
 

plugins/magic.lambda.mssql/magic.lambda.mssql/Connect.cs

@@ -38,6 +38,7 @@ public async Task SignalAsync(ISignaler signaler, Node input)
         {
             using (var connection = new SqlConnectionWrapper(
                 Executor.GetConnectionString(
+                    null,
                     input,
                     "mssql",
                     "master",

plugins/magic.lambda.mysql/magic.lambda.mysql/Connect.cs

@@ -38,6 +38,7 @@ public async Task SignalAsync(ISignaler signaler, Node input)
         {
             using (var connection = new MySqlConnectionWrapper(
                 Executor.GetConnectionString(
+                    null,
                     input,
                     "mysql",
                     "information_schema",

plugins/magic.lambda.odbc/Connect.cs

@@ -38,6 +38,7 @@ public async Task SignalAsync(ISignaler signaler, Node input)
         {
             using (var connection = new OdbcConnectionWrapper(
                 Executor.GetConnectionString(
+                    null,
                     input,
                     "odbc",
                     null,

plugins/magic.lambda.pgsql/magic.lambda.pgsql/Connect.cs

@@ -38,6 +38,7 @@ public async Task SignalAsync(ISignaler signaler, Node input)
         {
             using (var connection = new PgSqlConnectionWrapper(
                 Executor.GetConnectionString(
+                    null,
                     input,
                     "pgsql",
                     "postgres",

plugins/magic.lambda.sqlite/magic.lambda.sqlite/Connect.cs

@@ -48,6 +48,7 @@ public async Task SignalAsync(ISignaler signaler, Node input)
                 using (var connection = new SqliteConnectionWrapper(
                     _resolver,
                     Executor.GetConnectionString(
+                        _resolver,
                         input,
                         "sqlite",
                         "sys",