diff --git a/sdk/extensions/extensions-datasource/src/main/java/io/dataease/extensions/datasource/provider/Provider.java b/sdk/extensions/extensions-datasource/src/main/java/io/dataease/extensions/datasource/provider/Provider.java index 8b434c2666..16ca7ed265 100644 --- a/sdk/extensions/extensions-datasource/src/main/java/io/dataease/extensions/datasource/provider/Provider.java +++ b/sdk/extensions/extensions-datasource/src/main/java/io/dataease/extensions/datasource/provider/Provider.java @@ -287,18 +287,18 @@ public abstract class Provider { connectionObj.setSession(session); } else { Integer lport = Provider.getLPorts().get(datasourceId); - configuration.setLPort(lport); if (lport != null) { + configuration.setLPort(lport); if (Provider.getSessions().get(datasourceId) == null || !Provider.getSessions().get(datasourceId).isConnected()) { Session session = initSession(configuration); Provider.getSessions().put(datasourceId, session); } } else { - configuration.setLPort(getLport(datasourceId)); + lport = getLport(datasourceId); + configuration.setLPort(lport); Session session = initSession(configuration); Provider.getSessions().put(datasourceId, session); } - configuration.setLPort(lport); } } }