npgsql · ahmednfwela · Aug 8, 2025 · Aug 8, 2025 · Aug 8, 2025 · Oct 27, 2025
@@ -21,18 +21,19 @@
 
         "extensions": [
           "ms-dotnettools.csharp",
+          "ms-dotnettools.csdevkit",
           "formulahendry.dotnet-test-explorer",
           "ms-azuretools.vscode-docker",
           "mutantdino.resourcemonitor"
         ]
     }
   },
-  
+
   "forwardPorts": [5432, 5050],
 
   "remoteEnv": {
     "DeveloperBuild": "True"
   },
 
-  "postCreateCommand": "dotnet restore Npgsql.sln"
+  "postCreateCommand": "dotnet restore Npgsql.slnx"
 }
@@ -1,4 +1,4 @@
 {
-  "dotnet-test-explorer.testProjectPath": "**/*.Tests.csproj",
-  "dotnet.defaultSolution": "Npgsql.sln"
+  "dotnet-test-explorer.testProjectPath": "test/**/*.csproj",
+  "dotnet.defaultSolution": "Npgsql.slnx"
 }
@@ -88,3 +88,5 @@ Npgsql.NpgsqlConnection.ReloadTypesAsync(System.Threading.CancellationToken canc
 *REMOVED*Npgsql.NpgsqlSlimDataSourceBuilder.MapEnum<TEnum>(string? pgName = null, Npgsql.INpgsqlNameTranslator? nameTranslator = null) -> Npgsql.TypeMapping.INpgsqlTypeMapper!
 static NpgsqlTypes.NpgsqlInet.implicit operator NpgsqlTypes.NpgsqlInet(System.Net.IPNetwork cidr) -> NpgsqlTypes.NpgsqlInet
 static readonly NpgsqlTypes.NpgsqlTsVector.Empty -> NpgsqlTypes.NpgsqlTsVector!
+Npgsql.Replication.LogicalReplicationConnection.LogicalReplicationConnection(Npgsql.NpgsqlConnection! connection) -> void
+Npgsql.Replication.PhysicalReplicationConnection.PhysicalReplicationConnection(Npgsql.NpgsqlConnection! connection) -> void
@@ -17,4 +17,16 @@ public LogicalReplicationConnection() {}
     /// </summary>
     /// <param name="connectionString">The connection used to open the PostgreSQL database.</param>
     public LogicalReplicationConnection(string? connectionString) : base(connectionString) {}
+
+    /// <summary>
+    /// Initializes a new instance of <see cref="LogicalReplicationConnection"/> with the given connection.
+    /// </summary>
+    /// <param name="connection">The connection to use as a template for logical replication.</param>
+    /// <remarks>
+    /// A new connection will be created based on the provided connection's settings, configured for logical replication
+    /// with pooling, enlistment, multiplexing, and keep-alive disabled. The original connection remains unchanged and
+    /// can continue to be used normally. This approach preserves sensitive information such as passwords that might
+    /// not be present in the connection string returned by <see cref="NpgsqlConnection.ConnectionString"/>.
+    /// </remarks>
+    public LogicalReplicationConnection(NpgsqlConnection connection) : base(connection) {}
 }
@@ -27,6 +27,18 @@ public PhysicalReplicationConnection() {}
     /// <param name="connectionString">The connection used to open the PostgreSQL database.</param>
     public PhysicalReplicationConnection(string? connectionString) : base(connectionString) {}
 
+    /// <summary>
+    /// Initializes a new instance of <see cref="PhysicalReplicationConnection"/> with the given connection.
+    /// </summary>
+    /// <param name="connection">The connection to use as a template for physical replication.</param>
+    /// <remarks>
+    /// A new connection will be created based on the provided connection's settings, configured for physical replication
+    /// with pooling, enlistment, multiplexing, and keep-alive disabled. The original connection remains unchanged and
+    /// can continue to be used normally. This approach preserves sensitive information such as passwords that might
+    /// not be present in the connection string returned by <see cref="NpgsqlConnection.ConnectionString"/>.
+    /// </remarks>
+    public PhysicalReplicationConnection(NpgsqlConnection connection) : base(connection) {}
+
     /// <summary>
     /// Creates a <see cref="PhysicalReplicationSlot"/> that wraps a PostgreSQL physical replication slot and
     /// can be used to start physical streaming replication

@@ -68,6 +68,28 @@ private protected ReplicationConnection()
     private protected ReplicationConnection(string? connectionString) : this()
         => ConnectionString = connectionString;
 
+    /// <summary>
+    /// Initializes a new instance of <see cref="ReplicationConnection"/> with the given connection.
+    /// The connection's <see cref="NpgsqlConnection.ConnectionString"/> is used to initialize the replication connection.
+    /// </summary>
+    /// <param name="connection"></param>
+    private protected ReplicationConnection(NpgsqlConnection connection)
+    {
+        ArgumentNullException.ThrowIfNull(connection);
+
+        _requestFeedbackInterval = new TimeSpan(_walReceiverTimeout.Ticks / 2);
+        var cs = new NpgsqlConnectionStringBuilder(connection.ConnectionString)
+        {
+            Pooling = false,
+            Enlist = false,
+            Multiplexing = false,
+            KeepAlive = 0,
+            ReplicationMode = ReplicationMode
+        };
+        _npgsqlConnection = connection.CloneWith(cs.ToString());
+        _userFacingConnectionString = _npgsqlConnection.ConnectionString;
+    }
+
     #endregion
 
     #region Properties

@@ -0,0 +1,27 @@
+using System.Threading.Tasks;
+using NUnit.Framework;
+using Npgsql.Replication;
+
+namespace Npgsql.Tests.Replication;
+
+[Platform(Exclude = "MacOsX", Reason = "Replication tests are flaky in CI on Mac")]
+[NonParallelizable]
+public class LogicalReplicationConnectionConstructorTests : SafeReplicationTestBase<LogicalReplicationConnection>
+{
+    [Test]
+    public async Task Construct_from_existing_connection()
+    {
+        var baseConn = new NpgsqlConnection(TestUtil.ConnectionString);
+        await using var rc = new LogicalReplicationConnection(baseConn);
+        await rc.Open();
+
+        var csb = new NpgsqlConnectionStringBuilder(rc.ConnectionString);
+        Assert.That(csb.ReplicationMode, Is.EqualTo(ReplicationMode.Logical));
+        Assert.That(csb.Pooling, Is.False);
+        Assert.That(csb.Enlist, Is.False);
+        Assert.That(csb.Multiplexing, Is.False);
+        Assert.That(csb.KeepAlive, Is.EqualTo(0));
+    }
+
+    protected override string Postfix => "ctor_l";
+}