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

SQL batch processing refactoring

Browse Source
This commit is contained in:
Serge Rider
2020-09-04 19:32:06 +03:00
parent d0beb1b3ad
commit 77b0d4bbbb
1 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/bundles/io.cloudbeaver.server/src/io/cloudbeaver/service/sql/WebSQLProcessor.java
+3 -6
View File
@@ -41,10 +41,7 @@ import org.jkiss.dbeaver.model.struct.DBSObject;
import org.jkiss.utils.CommonUtils;
import java.lang.reflect.InvocationTargetException;
import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.*;
import java.util.concurrent.atomic.AtomicInteger;
/**
@@ -284,7 +281,7 @@ public class WebSQLProcessor {
DBSDataManipulator.ExecuteBatch updateBatch = dataManipulator.updateData(session, updateAttributes, keyAttributes, null, executionSource);
updateBatch.add(rowValues);
DBCStatistics statistics = updateBatch.execute(session);
DBCStatistics statistics = updateBatch.execute(session, Collections.emptyMap());
// Returns fake resultset with updated row values
WebSQLQueryResultSet updatedResultSet = new WebSQLQueryResultSet();
@@ -381,7 +378,7 @@ public class WebSQLProcessor {
DBSDataManipulator.ExecuteBatch updateBatch = dataManipulator.updateData(session, updateAttributes, keyAttributes, null, executionSource);
updateBatch.add(rowValues);
DBCStatistics statistics = updateBatch.execute(session);
DBCStatistics statistics = updateBatch.execute(session, Collections.emptyMap());
totalUpdateCount += statistics.getRowsUpdated();
result.setDuration(result.getDuration() + statistics.getExecuteTime());