Better way of adding logging to internal NpgsqlDataSource. Closes GH-…

…2966
JasperFx · Feb 28, 2024 · fc6b110 · fc6b110
1 parent 4d9f119
commit fc6b110
Showing 1 changed file with 13 additions and 1 deletion.
diff --git a/src/Marten/StoreOptions.cs b/src/Marten/StoreOptions.cs
@@ -116,6 +116,18 @@ public StoreOptions()
         ResiliencePipeline = strategy;
 
         #endregion
+
+        // Add logging into our NpgsqlDataSource
+        NpgsqlDataSourceFactory = new DefaultNpgsqlDataSourceFactory(connectionString =>
+        {
+            var builder = new NpgsqlDataSourceBuilder(connectionString);
+            if (LogFactory != null)
+            {
+                builder.UseLoggerFactory(LogFactory);
+            }
+
+            return builder;
+        });
     }
 
     /// <summary>
@@ -334,7 +346,7 @@ public ITenancy Tenancy
 
     private Lazy<ITenancy>? _tenancy;
     private Func<string, NpgsqlDataSourceBuilder> _npgsqlDataSourceBuilderFactory = DefaultNpgsqlDataSourceBuilderFactory;
-    private INpgsqlDataSourceFactory _npgsqlDataSourceFactory = new DefaultNpgsqlDataSourceFactory();
+    private INpgsqlDataSourceFactory _npgsqlDataSourceFactory;
     private readonly IList<Type> _compiledQueryTypes = new List<Type>();
     private int _applyChangesLockId = 4004;
     private bool _shouldApplyChangesOnStartup = false;