opensource/cloudbeaver
3
0
Fork 0
mirror of https://github.com/dbeaver/cloudbeaver.git synced 2026-09-24 16:04:36 +08:00
Code Issues Packages Projects Releases Wiki Activity

CB-156 Connection state function implementation

Browse Source
This commit is contained in:
serge-rider
2020-06-12 18:32:28 +03:00
parent 0e9ba28756
commit 41bea6cedd
3 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/bundles/io.cloudbeaver.server/src/io/cloudbeaver/service/core/DBWServiceCore.java
+3
View File
@@ -66,6 +66,9 @@ public interface DBWServiceCore extends DBWService {
///////////////////////////////////////////
// Connections
@WebAction
WebConnectionInfo getConnectionState(WebSession webSession, String connectionId) throws DBWebException;
@WebAction
WebConnectionInfo openConnection(WebSession webSession, WebConnectionConfig connectionConfig) throws DBWebException;
server/bundles/io.cloudbeaver.server/src/io/cloudbeaver/service/core/WebServiceBindingCore.java
+1
View File
@@ -62,6 +62,7 @@ public class WebServiceBindingCore extends WebServiceBindingBase<DBWServiceCore>
.dataFetcher("touchSession", env -> getService(env).touchSession(GraphQLEndpoint.getServletRequest(env)))
.dataFetcher("changeSessionLanguage", env -> getService(env).changeSessionLanguage(getWebSession(env), env.getArgument("locale")))
.dataFetcher("connectionState", env -> getService(env).getConnectionState(getWebSession(env), env.getArgument("id")))
.dataFetcher("openConnection", env -> getService(env).openConnection(getWebSession(env), getConnectionConfig(env)))
.dataFetcher("createConnection", env -> getService(env).createConnection(getWebSession(env), getConnectionConfig(env)))
.dataFetcher("testConnection", env -> getService(env).testConnection(getWebSession(env), getConnectionConfig(env)))
server/bundles/io.cloudbeaver.server/src/io/cloudbeaver/service/core/impl/WebServiceCore.java
+5
View File
@@ -123,6 +123,11 @@ public class WebServiceCore implements DBWServiceCore {
return true;
}
@Override
public WebConnectionInfo getConnectionState(WebSession webSession, String connectionId) throws DBWebException {
return webSession.getWebConnectionInfo(connectionId);
}
@Override
public WebConnectionInfo openConnection(WebSession webSession, WebConnectionConfig config) throws DBWebException {
String dataSourceId = config.getDataSourceId();