Only add sqlite conn string in NETFX + System.Data.SQLite.Core

ServiceStack · Oct 3, 2023 · ba32cca · ba32cca
1 parent fb8d7a4
commit ba32cca
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 5 deletions.
diff --git a/ServiceStack.OrmLite/src/ServiceStack.OrmLite.Sqlite/SqliteOrmLiteDialectProvider.cs b/ServiceStack.OrmLite/src/ServiceStack.OrmLite.Sqlite/SqliteOrmLiteDialectProvider.cs
@@ -7,6 +7,13 @@ public class SqliteOrmLiteDialectProvider : SqliteOrmLiteDialectProviderBase
     {
         public static SqliteOrmLiteDialectProvider Instance = new();
 
+        public SqliteOrmLiteDialectProvider()
+        {
+#if NETFX
+            ConnectionStringFilter = sb => sb.Append("Version=3;New=True;Compress=True");
+#endif
+        }
+
         protected override IDbConnection CreateConnection(string connectionString)
         {
             return new SQLiteConnection(connectionString);

diff --git a/ServiceStack.OrmLite/src/ServiceStack.OrmLite.Sqlite/SqliteOrmLiteDialectProviderBase.cs b/ServiceStack.OrmLite/src/ServiceStack.OrmLite.Sqlite/SqliteOrmLiteDialectProviderBase.cs
@@ -3,6 +3,7 @@
 using System.Data;
 using System.IO;
 using System.Reflection;
+using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
 using ServiceStack.OrmLite.Sqlite.Converters;
@@ -179,11 +180,7 @@ public override IDbConnection CreateConnection(string connectionString, Dictiona
                     Directory.CreateDirectory(existingDir);
                 }
             }
-#if NETCORE
-                connString.AppendFormat(@"Data Source={0};", connectionString.Trim());
-#else
-            connString.AppendFormat(@"Data Source={0};Version=3;New=True;Compress=True;", connectionString.Trim());
-#endif
+            connString.AppendFormat(@"Data Source={0};", connectionString.Trim());
         }
         else
         {
@@ -205,9 +202,13 @@ public override IDbConnection CreateConnection(string connectionString, Dictiona
                 connString.AppendFormat("{0}={1};", option.Key, option.Value);
             }
         }
+
+        ConnectionStringFilter?.Invoke(connString);
 
         return CreateConnection(StringBuilderCache.ReturnAndFree(connString));
     }
+
+    public Action<StringBuilder> ConnectionStringFilter { get; set; }
 
     protected abstract IDbConnection CreateConnection(string connectionString);