hcq/openGauss-connector-jdbc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

!154 [bugfix] 修复unix域套接字无法正常连接数据库的问题

Browse Source 
Merge pull request !154 from 周斌/af_unix
This commit is contained in:
opengauss_bot
2023-08-26 08:23:31 +00:00
committed by Gitee
parent 423c61ea32 d0cf969ce3
commit 4d31a85a08
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
pgjdbc/src/main/java/org/postgresql/core/PGStream.java
View File

@ -21,6 +21,7 @@ import java.io.OutputStream;
import java.io.Writer; import java.io.Writer;
import java.net.InetSocketAddress; import java.net.InetSocketAddress;
import java.net.Socket; import java.net.Socket;
import java.net.SocketAddress;
import java.net.SocketTimeoutException; import java.net.SocketTimeoutException;
import java.sql.SQLException; import java.sql.SQLException;
import javax.net.SocketFactory; import javax.net.SocketFactory;
@ -566,13 +567,20 @@ public class PGStream implements Closeable, Flushable {
return connection.getSoTimeout(); return connection.getSoTimeout();
} }
private static String getSocketAddressDescStr(SocketAddress address) {
String strAddress = "af_unix";
if (address != null) {
strAddress = address.toString().substring(1);
}
return strAddress;
}
/** /**
* This function returns the String which contains the server socket address and client socket address. * This function returns the String which contains the server socket address and client socket address.
* This function is only used to distinguish different connections when we create dump file. * This function is only used to distinguish different connections when we create dump file.
*/ */
public String getConnectInfo() { public String getConnectInfo() {
String clientSocketAddress = connection.getLocalSocketAddress().toString().substring(1); String clientSocketAddress = getSocketAddressDescStr(connection.getLocalSocketAddress());
String serverSocketAddress = connection.getRemoteSocketAddress().toString().substring(1); String serverSocketAddress = getSocketAddressDescStr(connection.getRemoteSocketAddress());
return clientSocketAddress + "/" + serverSocketAddress; return clientSocketAddress + "/" + serverSocketAddress;
} }