CB-5369. Added API for transaction log for commits

server/bundles/io.cloudbeaver.server/schema/service.core.graphqls

@@ -458,6 +458,21 @@ type LogEntry {
     stackTrace: String
 }
 
+
+type TransactionLogInfos {
+    count: Int
+    transactionLogInfos: [TransactionLogInfoItem!]!
+}
+
+type TransactionLogInfoItem {
+    time: DateTime!
+    type: String!
+    queryString: String!
+    durationMs: Int!
+    rows: Int!
+    result: String!
+}
+
 ####################################################
 # Input types
 ####################################################

server/bundles/io.cloudbeaver.server/schema/service.sql.graphqls

@@ -331,6 +331,12 @@ extend type Mutation {
         dataFormat: ResultDataFormat
     ): AsyncTaskInfo!
 
+    getTransactionLogInfo(
+        projectId: ID!,
+        connectionId: ID!,
+        contextId: ID!
+    ): TransactionLogInfos
+
     # Close results (free resources)
     sqlResultClose(projectId: ID, connectionId: ID!, contextId: ID!, resultId: ID!): Boolean!
 

server/bundles/io.cloudbeaver.server/src/io/cloudbeaver/model/WebTransactionLogInfo.java

@@ -0,0 +1,28 @@
+/*
+ * DBeaver - Universal Database Manager
+ * Copyright (C) 2010-2025 DBeaver Corp and others
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.cloudbeaver.model;
+
+import org.jkiss.code.NotNull;
+import org.jkiss.code.Nullable;
+
+import java.util.List;
+
+public record WebTransactionLogInfo(@NotNull List<WebTransactionLogItemInfo> transactionLogInfos, @Nullable
+
+Integer count) {
+
+}

server/bundles/io.cloudbeaver.server/src/io/cloudbeaver/model/WebTransactionLogItemInfo.java

@@ -0,0 +1,29 @@
+/*
+ * DBeaver - Universal Database Manager
+ * Copyright (C) 2010-2025 DBeaver Corp and others
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.cloudbeaver.model;
+
+import org.jkiss.code.NotNull;
+
+public record WebTransactionLogItemInfo(
+    @NotNull String time,
+    @NotNull String type,
+    @NotNull String queryString,
+    long durationMs,
+    long rows,
+    String result
+) {
+}

server/bundles/io.cloudbeaver.server/src/io/cloudbeaver/service/sql/DBWServiceSQL.java

@@ -1,6 +1,6 @@
 /*
  * DBeaver - Universal Database Manager
- * Copyright (C) 2010-2024 DBeaver Corp and others
+ * Copyright (C) 2010-2025 DBeaver Corp and others
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -27,6 +27,7 @@
 import org.jkiss.dbeaver.DBException;
 import org.jkiss.dbeaver.model.exec.DBCLogicalOperator;
 import org.jkiss.dbeaver.model.exec.trace.DBCTraceProperty;
+import io.cloudbeaver.model.WebTransactionLogInfo;
 import org.jkiss.dbeaver.model.sql.registry.SQLGeneratorDescriptor;
 
 import java.util.List;
@@ -202,4 +203,10 @@
     WebAsyncTaskInfo asyncSqlCommitTransaction(
         @NotNull WebSession webSession,
         @NotNull WebSQLContextInfo sqlContext);
+
+    @WebAction
+    WebTransactionLogInfo getTransactionLogInfo(
+        @NotNull WebSession webSession,
+        @NotNull WebSQLContextInfo sqlContext
+    );
 }

server/bundles/io.cloudbeaver.server/src/io/cloudbeaver/service/sql/WebSQLContextInfo.java

@@ -1,6 +1,6 @@
 /*
  * DBeaver - Universal Database Manager
- * Copyright (C) 2010-2024 DBeaver Corp and others
+ * Copyright (C) 2010-2025 DBeaver Corp and others
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -26,13 +26,21 @@
 import org.jkiss.code.NotNull;
 import org.jkiss.dbeaver.DBException;
 import org.jkiss.dbeaver.Log;
+import org.jkiss.dbeaver.model.DBConstants;
 import org.jkiss.dbeaver.model.DBUtils;
 import org.jkiss.dbeaver.model.data.DBDAttributeBinding;
 import org.jkiss.dbeaver.model.exec.*;
 import org.jkiss.dbeaver.model.exec.trace.DBCTrace;
+import org.jkiss.dbeaver.model.messages.ModelMessages;
 import org.jkiss.dbeaver.model.meta.Property;
+import io.cloudbeaver.model.WebTransactionLogInfo;
+import io.cloudbeaver.model.WebTransactionLogItemInfo;
 import org.jkiss.dbeaver.model.qm.QMTransactionState;
 import org.jkiss.dbeaver.model.qm.QMUtils;
+import org.jkiss.dbeaver.model.qm.meta.QMMConnectionInfo;
+import org.jkiss.dbeaver.model.qm.meta.QMMStatementExecuteInfo;
+import org.jkiss.dbeaver.model.qm.meta.QMMTransactionInfo;
+import org.jkiss.dbeaver.model.qm.meta.QMMTransactionSavepointInfo;
 import org.jkiss.dbeaver.model.runtime.DBRProgressMonitor;
 import org.jkiss.dbeaver.model.struct.DBSDataContainer;
 import org.jkiss.dbeaver.model.struct.rdb.DBSCatalog;
@@ -41,7 +49,12 @@
 import org.jkiss.utils.CommonUtils;
 
 import java.lang.reflect.InvocationTargetException;
+import java.time.Instant;
+import java.time.ZoneId;
+import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 import java.util.concurrent.atomic.AtomicInteger;
 
@@ -59,6 +72,9 @@
 
     private final AtomicInteger resultId = new AtomicInteger();
 
+    public static final DateTimeFormatter ISO_DATE_FORMAT = DateTimeFormatter.ofPattern(DBConstants.DEFAULT_ISO_TIMESTAMP_FORMAT)
+        .withZone(ZoneId.of("UTC"));
+
     public WebSQLContextInfo(
         WebSQLProcessor processor, String id, String catalogName, String schemaName, String projectId
     ) throws DBCException {
@@ -216,7 +232,65 @@
 
     }
 
+    public WebTransactionLogInfo getTransactionLogInfo() {
+        DBCExecutionContext context = processor.getExecutionContext();
+        return getTransactionLogInfo(context);
+    }
+
+    @NotNull
+    private WebTransactionLogInfo getTransactionLogInfo(DBCExecutionContext executionContext) {
+        int updateCount = 0;
+        List<WebTransactionLogItemInfo> logItemInfos = new ArrayList<>();
+        QMMConnectionInfo sessionInfo = QMUtils.getCurrentConnection(executionContext);
+        if (sessionInfo.isTransactional()) {
+            QMMTransactionInfo txnInfo = sessionInfo.getTransaction();
+            if (txnInfo != null) {
+                QMMTransactionSavepointInfo sp = txnInfo.getCurrentSavepoint();
+                QMMStatementExecuteInfo execInfo = sp.getLastExecute();
+                for (QMMStatementExecuteInfo exec = execInfo; exec != null && exec.getSavepoint() == sp; exec = exec.getPrevious()) {
+                    if (exec.getUpdateRowCount() > 0 ) {
+                        DBCExecutionPurpose purpose = exec.getStatement().getPurpose();
+                        if (!exec.hasError() && purpose != DBCExecutionPurpose.META && purpose != DBCExecutionPurpose.UTIL) {
+                            updateCount++;
+                        }
+                        generateLogInfo(logItemInfos, exec, purpose);
+                    }
+                }
+            }
+        } else {
+            QMMStatementExecuteInfo execInfo = sessionInfo.getExecutionStack();
+            for (QMMStatementExecuteInfo exec = execInfo; exec != null; exec = exec.getPrevious()) {
+                if (exec.getUpdateRowCount() > 0) {
+                    DBCExecutionPurpose purpose = exec.getStatement().getPurpose();
+                    generateLogInfo(logItemInfos, exec, purpose);
+                }
+            }
+        }
+        return new WebTransactionLogInfo(logItemInfos, updateCount == 0 ? null : updateCount);
+    }
+
+    private void generateLogInfo(List<WebTransactionLogItemInfo> logItemInfos, QMMStatementExecuteInfo exec, DBCExecutionPurpose purpose) {
+        String type = "SQL / " + purpose.getTitle();
+        String dateTime = ISO_DATE_FORMAT.format(Instant.ofEpochMilli(exec.getCloseTime()));
+        String result = ModelMessages.controls_querylog_success;
+        if (exec.hasError()) {
+            if (exec.getErrorCode() == 0) {
+                result = exec.getErrorMessage();
+            } else if (exec.getErrorMessage() == null) {
+                result = ModelMessages.controls_querylog_error + exec.getErrorCode() + "]"; //$NON-NLS-1$
+            } else {
+                result = "[" + exec.getErrorCode() + "] " + exec.getErrorMessage(); //$NON-NLS-1$ //$NON-NLS-2$
+            }
+        }
+
+        logItemInfos.add(
+            new WebTransactionLogItemInfo(dateTime, type, exec.getQueryString(),
+                exec.getDuration(), exec.getUpdateRowCount(), result)
+        );
+    }
+
+
     public WebAsyncTaskInfo commitTransaction() {
         DBCExecutionContext context = processor.getExecutionContext();
         DBCTransactionManager txnManager = DBUtils.getTransactionManager(context);
         WebAsyncTaskProcessor<String> runnable = new WebAsyncTaskProcessor<>() {

server/bundles/io.cloudbeaver.server/src/io/cloudbeaver/service/sql/WebServiceBindingSQL.java

@@ -1,6 +1,6 @@
 /*
  * DBeaver - Universal Database Manager
- * Copyright (C) 2010-2024 DBeaver Corp and others
+ * Copyright (C) 2010-2025 DBeaver Corp and others
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -226,6 +226,11 @@ public void bindWiring(DBWBindingContext model) throws DBWebException {
                     getWebSession(env),
                     getSQLContext(env)
                 ))
+            .dataFetcher("getTransactionLogInfo", env ->
+                getService(env).getTransactionLogInfo(
+                    getWebSession(env),
+                    getSQLContext(env)
+                    ))
             .dataFetcher("asyncSqlRollbackTransaction", env ->
                 getService(env).asyncSqlRollbackTransaction(
                     getWebSession(env),

server/bundles/io.cloudbeaver.server/src/io/cloudbeaver/service/sql/impl/WebServiceSQL.java

@@ -1,6 +1,6 @@
 /*
  * DBeaver - Universal Database Manager
- * Copyright (C) 2010-2024 DBeaver Corp and others
+ * Copyright (C) 2010-2025 DBeaver Corp and others
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -42,6 +42,7 @@
 import org.jkiss.dbeaver.model.impl.sql.BasicSQLDialect;
 import org.jkiss.dbeaver.model.navigator.DBNModel;
 import org.jkiss.dbeaver.model.navigator.DBNNode;
+import io.cloudbeaver.model.WebTransactionLogInfo;
 import org.jkiss.dbeaver.model.runtime.DBRProgressMonitor;
 import org.jkiss.dbeaver.model.sql.*;
 import org.jkiss.dbeaver.model.sql.completion.SQLCompletionAnalyzer;
@@ -318,6 +319,7 @@
                     }
                 }
             );
+            // do event
             return result[0];
         } catch (DBException e) {
             throw new DBWebException("Error updating resultset data", e);
@@ -615,4 +617,8 @@
         return contextInfo.commitTransaction();
     }
 
+    @Override
+    public WebTransactionLogInfo getTransactionLogInfo(@NotNull WebSession webSession, @NotNull WebSQLContextInfo sqlContext) {
+        return sqlContext.getTransactionLogInfo();
+    }
 }

webapp/packages/core-connections/src/ConnectionExecutionContext/ConnectionExecutionContext.ts

@@ -162,6 +162,20 @@ export class ConnectionExecutionContext implements IConnectionExecutionContext {
     return mapAsyncTaskInfo(result);
   }
 
+  async getLogs() {
+    const result = await this.withContext(async context => {
+      const { logs } = await this.graphQLService.sdk.getTransactionsLogs({
+        projectId: context.projectId,
+        connectionId: context.connectionId,
+        contextId: context.id,
+      });
+
+      return logs;
+    });
+
+    return result?.transactionLogInfos;
+  }
+
   private withContext<R>(callback: (context: IConnectionExecutionContextInfo) => Promise<R>): Promise<R> {
     if (!this.context) {
       throw new Error('Execution Context not found');

webapp/packages/core-sdk/src/queries/transactions/getTransactionLogs.gql

@@ -0,0 +1,12 @@
+mutation getTransactionLogs($projectId: ID!, $connectionId: ID!, $contextId: ID!) {
+  logs: getTransactionLogInfo(projectId: $projectId, connectionId: $connectionId, contextId: $contextId) {
+    transactionLogInfos {
+      time
+      type
+      queryString
+      durationMs
+      rows
+      result
+    }
+  }
+}

webapp/packages/plugin-datasource-transaction-manager/package.json

@@ -25,15 +25,24 @@
     "@cloudbeaver/core-events": "^0",
     "@cloudbeaver/core-executor": "^0",
     "@cloudbeaver/core-localization": "^0",
+    "@cloudbeaver/core-sdk": "^0",
     "@cloudbeaver/core-settings": "^0",
     "@cloudbeaver/core-ui": "^0",
     "@cloudbeaver/core-utils": "^0",
     "@cloudbeaver/core-view": "^0",
+    "@cloudbeaver/plugin-codemirror6": "^0",
+    "@cloudbeaver/plugin-data-grid": "^0",
     "@cloudbeaver/plugin-datasource-context-switch": "^0",
-    "@cloudbeaver/plugin-top-app-bar": "^0"
+    "@cloudbeaver/plugin-sql-editor-new": "^0",
+    "@cloudbeaver/plugin-top-app-bar": "^0",
+    "mobx": "^6",
+    "mobx-react-lite": "^4",
+    "react": "^18"
   },
   "peerDependencies": {},
   "devDependencies": {
-    "typescript": "^5"
+    "@types/react": "^18",
+    "typescript": "^5",
+    "typescript-plugin-css-modules": "^5"
   }
 }