diff --git a/pgjdbc/src/main/java/org/postgresql/core/PGStream.java b/pgjdbc/src/main/java/org/postgresql/core/PGStream.java
index 1f447582b0..44e0b65267 100644
--- a/pgjdbc/src/main/java/org/postgresql/core/PGStream.java
+++ b/pgjdbc/src/main/java/org/postgresql/core/PGStream.java
@@ -58,7 +58,9 @@ public PGStream(SocketFactory socketFactory, HostSpec hostSpec, int timeout) thr
     this.hostSpec = hostSpec;
 
     Socket socket = socketFactory.createSocket();
-    socket.connect(new InetSocketAddress(hostSpec.getHost(), hostSpec.getPort()), timeout);
+    if (!socket.isConnected()) {
+      socket.connect(new InetSocketAddress(hostSpec.getHost(), hostSpec.getPort()), timeout);
+    }
     changeSocket(socket);
     setEncoding(Encoding.getJVMEncoding("UTF-8"));