dbeaver/pro#8821 feat: add import settings step

server/bundles/io.cloudbeaver.service.data.transfer/schema/service.data.transfer.graphqls

@@ -48,6 +48,8 @@ input DataTransferImportSettings {
     useBulkLoad: Boolean
     "Use transactions during import"
     useTransactions: Boolean
+    "Open new connection(s) for the import task"
+    openNewConnection: Boolean
 }
 
 input DataTransferImportParameters {

server/bundles/io.cloudbeaver.service.data.transfer/src/io/cloudbeaver/service/data/transfer/impl/WebServiceDataTransfer.java

@@ -425,7 +425,7 @@ private void importData(
                     throw new DBWebException("Import is canceled");
                 }
             } catch (DBException e) {
-                throw new DBWebException("Import failed cause: " + e.getMessage());
+                throw new DBWebException("Import failed", e);
             }
         }
     }
@@ -446,6 +446,9 @@ private void applyImportSettings(
         consumerSettings.setUseTransactions(CommonUtils.getBoolean(
             settings.get(DTConstants.PROP_USE_TRANSACTIONS),
             consumerSettings.isUseTransactions()));
+        consumerSettings.setOpenNewConnections(CommonUtils.getBoolean(
+            settings.get(DTConstants.PROP_OPEN_NEW_CONNECTION),
+            consumerSettings.isOpenNewConnections()));
     }
 
 }

webapp/packages/core-sdk/src/queries/connections/getConnectionImportDriverConfiguration.gql

@@ -0,0 +1,9 @@
+query getConnectionImportDriverConfiguration($projectId: ID, $connectionId: ID!) {
+  connections: userConnections(projectId: $projectId, id: $connectionId) {
+    id
+    projectId
+    driverConfiguration {
+      ...DriverConfiguration
+    }
+  }
+}

webapp/packages/core-sdk/src/queries/fragments/DriverConfiguration.gql

@@ -0,0 +1,9 @@
+fragment DriverConfiguration on DriverConfiguration {
+  supportedInsertReplaceMethods {
+    id
+    name
+    description
+  }
+  supportsBulkLoad
+  supportsTransactions
+}

webapp/packages/plugin-data-import/package.json

@@ -23,6 +23,7 @@
   },
   "dependencies": {
     "@cloudbeaver/core-blocks": "workspace:*",
+    "@cloudbeaver/core-connections": "workspace:*",
     "@cloudbeaver/core-di": "workspace:*",
     "@cloudbeaver/core-dialogs": "workspace:*",
     "@cloudbeaver/core-events": "workspace:*",

webapp/packages/plugin-data-import/src/DataImportBootstrap.ts

@@ -5,6 +5,7 @@
  * Licensed under the Apache License, Version 2.0.
  * you may not use this file except in compliance with the License.
  */
+import { createConnectionParam } from '@cloudbeaver/core-connections';
 import { Bootstrap, injectable } from '@cloudbeaver/core-di';
 import { CommonDialogService, DialogueStateResult } from '@cloudbeaver/core-dialogs';
 import { ACTION_IMPORT, ActionService, menuExtractItems, MenuService } from '@cloudbeaver/core-view';
@@ -32,7 +33,7 @@
     super();
   }
 
   override register() {
     this.actionService.addHandler({
       id: 'data-import-base-handler',
       contexts: [DATA_CONTEXT_DV_DDM, DATA_CONTEXT_DV_DDM_RESULT_INDEX],
@@ -72,16 +73,20 @@
             throw new Error('Execution context must be provided');
           }
 
-          const { status, result: dialogResult } = await this.commonDialogService.open(DataImportDialogLazy, { tableName: model.name ?? model.id });
+          const connectionKey = createConnectionParam(executionContext.projectId, executionContext.connectionId);
+          const { status, result: dialogResult } = await this.commonDialogService.open(DataImportDialogLazy, {
+            tableName: model.name ?? model.id,
+            connectionKey,
+          });
 
           if (status === DialogueStateResult.Resolved && dialogResult) {
             const success = await this.dataImportService.importData(
-              executionContext.connectionId,
+              connectionKey,
               executionContext.id,
-              executionContext.projectId,
               result.id,
               dialogResult.processorId,
               dialogResult.file,
+              dialogResult.settings,
             );
 
             if (success) {

webapp/packages/plugin-data-import/src/DataImportDialog/DataImportDialog.tsx

@@ -1,28 +1,34 @@
 /*
  * CloudBeaver - Cloud Database Manager
- * Copyright (C) 2020-2025 DBeaver Corp and others
+ * Copyright (C) 2020-2026 DBeaver Corp and others
  *
  * Licensed under the Apache License, Version 2.0.
  * you may not use this file except in compliance with the License.
  */
 import { observer } from 'mobx-react-lite';
 
-import { Button, CommonDialogBody, CommonDialogFooter, CommonDialogHeader, CommonDialogWrapper, useTranslate } from '@cloudbeaver/core-blocks';
+import { Button, CommonDialogBody, CommonDialogFooter, CommonDialogHeader, CommonDialogWrapper, useResource, useTranslate } from '@cloudbeaver/core-blocks';
+import type { IConnectionInfoParams } from '@cloudbeaver/core-connections';
 import type { DialogComponent } from '@cloudbeaver/core-dialogs';
+import type { DataTransferImportSettings } from '@cloudbeaver/core-sdk';
 
+import { DataImportDriverConfigurationResource } from '../DataImportDriverConfigurationResource.js';
 import { DataImportFileSelector } from './DataImportFileSelector.js';
 import { EDataImportDialogStep } from './EDataImportDialogStep.js';
 import type { IDataImportDialogState } from './IDataImportDialogState.js';
 import { ImportProcessorList } from './ImportProcessorList.js';
+import { ImportSettingsForm } from './ImportSettingsForm.js';
 import { useDataImportDialog } from './useDataImportDialog.js';
 
 export interface IDataImportDialogResult {
   file: File;
   processorId: string;
+  settings: DataTransferImportSettings;
 }
 
 export interface IDataImportDialogPayload {
   tableName: string;
+  connectionKey: IConnectionInfoParams;
   initialState?: IDataImportDialogState;
 }
 
@@ -33,21 +39,51 @@ export const DataImportDialog: DialogComponent<IDataImportDialogPayload, IDataIm
 }) {
   const translate = useTranslate();
   const dialog = useDataImportDialog(payload.initialState);
+  const driverConfigurationResource = useResource(
+    DataImportDialog,
+    DataImportDriverConfigurationResource,
+    payload.connectionKey,
+    { silent: true },
+  );
+
+  const driverConfiguration = driverConfigurationResource.tryGetData ?? null;
+  const hasSettings =
+    !!driverConfiguration &&
+    (driverConfiguration.supportsBulkLoad ||
+      driverConfiguration.supportsTransactions ||
+      driverConfiguration.supportedInsertReplaceMethods.length > 0);
 
   let title = translate('plugin_data_import_title');
   let icon = '/icons/data-import.svg';
 
-  if (dialog.state.step === EDataImportDialogStep.File && dialog.state.selectedProcessor) {
+  if (dialog.state.step !== EDataImportDialogStep.Processor && dialog.state.selectedProcessor) {
     title += ` (${dialog.state.selectedProcessor.name ?? dialog.state.selectedProcessor.id})`;
     icon = dialog.state.selectedProcessor.icon ?? icon;
   }
 
+  function importData() {
+    if (dialog.state.file && dialog.state.selectedProcessor) {
+      resolveDialog({ file: dialog.state.file, processorId: dialog.state.selectedProcessor.id, settings: dialog.state.settings });
+    }
+  }
+
+  function submitFileStep() {
+    if (driverConfiguration && hasSettings) {
+      dialog.goToSettings(driverConfiguration);
+    } else {
+      importData();
+    }
+  }
+
   return (
     <CommonDialogWrapper size="large" fixedSize>
       <CommonDialogHeader title={title} subTitle={payload.tableName} icon={icon} onReject={rejectDialog} />
       <CommonDialogBody noBodyPadding>
         {dialog.state.step === EDataImportDialogStep.Processor && <ImportProcessorList onSelect={dialog.selectProcessor} />}
         {dialog.state.step === EDataImportDialogStep.File && <DataImportFileSelector state={dialog.state} onDelete={dialog.deleteFile} />}
+        {dialog.state.step === EDataImportDialogStep.Settings && driverConfiguration && (
+          <ImportSettingsForm settings={dialog.state.settings} driverConfiguration={driverConfiguration} />
+        )}
       </CommonDialogBody>
 
       <CommonDialogFooter>
@@ -61,9 +97,20 @@ export const DataImportDialog: DialogComponent<IDataImportDialogPayload, IDataIm
             </Button>
             <Button
               type="button"
+              loading={driverConfigurationResource.isLoading()}
               disabled={!dialog.state.file || !dialog.state.selectedProcessor}
-              onClick={() => resolveDialog({ file: dialog.state.file!, processorId: dialog.state.selectedProcessor!.id })}
+              onClick={submitFileStep}
             >
+              {translate(hasSettings ? 'ui_stepper_next' : 'ui_import')}
+            </Button>
+          </div>
+        )}
+        {dialog.state.step === EDataImportDialogStep.Settings && (
+          <div className="tw:flex tw:ml-auto tw:gap-2">
+            <Button type="button" variant="secondary" onClick={dialog.stepBack}>
+              {translate('ui_stepper_back')}
+            </Button>
+            <Button type="button" disabled={!dialog.state.file || !dialog.state.selectedProcessor} onClick={importData}>
               {translate('ui_import')}
             </Button>
           </div>

webapp/packages/plugin-data-import/src/DataImportDialog/EDataImportDialogStep.ts

@@ -1,11 +1,12 @@
 /*
  * CloudBeaver - Cloud Database Manager
- * Copyright (C) 2020-2024 DBeaver Corp and others
+ * Copyright (C) 2020-2026 DBeaver Corp and others
  *
  * Licensed under the Apache License, Version 2.0.
  * you may not use this file except in compliance with the License.
  */
 export enum EDataImportDialogStep {
   Processor,
   File,
+  Settings, 
 }

webapp/packages/plugin-data-import/src/DataImportDialog/IDataImportDialogState.ts

@@ -1,16 +1,17 @@
 /*
  * CloudBeaver - Cloud Database Manager
- * Copyright (C) 2020-2024 DBeaver Corp and others
+ * Copyright (C) 2020-2026 DBeaver Corp and others
  *
  * Licensed under the Apache License, Version 2.0.
  * you may not use this file except in compliance with the License.
  */
-import type { DataTransferProcessorInfo } from '@cloudbeaver/core-sdk';
+import type { DataTransferImportSettings, DataTransferProcessorInfo } from '@cloudbeaver/core-sdk';
 
 import type { EDataImportDialogStep } from './EDataImportDialogStep.js';
 
 export interface IDataImportDialogState {
   step: EDataImportDialogStep;
   file: File | null;
   selectedProcessor: DataTransferProcessorInfo | null;
+  settings: DataTransferImportSettings;
 }

webapp/packages/plugin-data-import/src/DataImportDialog/ImportSettingsForm.tsx

@@ -0,0 +1,72 @@
+/*
+ * CloudBeaver - Cloud Database Manager
+ * Copyright (C) 2020-2026 DBeaver Corp and others
+ *
+ * Licensed under the Apache License, Version 2.0.
+ * you may not use this file except in compliance with the License.
+ */
+import { observer } from 'mobx-react-lite';
+import { useEffect } from 'react';
+
+import { Combobox, Container, FieldCheckbox, Link, useTranslate } from '@cloudbeaver/core-blocks';
+import type { DataTransferImportSettings } from '@cloudbeaver/core-sdk';
+
+import type { IDataImportDriverConfiguration } from '../DataImportDriverConfigurationResource.js';
+
+interface Props {
+  settings: DataTransferImportSettings;
+  driverConfiguration: IDataImportDriverConfiguration;
+}
+
+export const ImportSettingsForm = observer<Props>(function ImportSettingsForm({ settings, driverConfiguration }) {
+  const translate = useTranslate();
+  const { supportedInsertReplaceMethods, supportsBulkLoad, supportsTransactions } = driverConfiguration;
+
+  useEffect(() => {
+    if (settings.useBulkLoad) {
+      settings.onDuplicateKeyMethod = undefined;
+    }
+  }, [settings.useBulkLoad]);
+
+  return (
+    <Container gap parent>
+      {supportedInsertReplaceMethods.length > 0 && (
+        <div>
+          <Combobox
+            name="onDuplicateKeyMethod"
+            state={settings}
+            items={supportedInsertReplaceMethods}
+            keySelector={method => method.id}
+            valueSelector={method => method.name}
+            titleSelector={method => method.description ?? undefined}
+            disabled={settings.useBulkLoad}
+            title={translate('plugin_data_import_settings_on_duplicate_key_title')}
+            placeholder={translate('plugin_data_import_settings_on_duplicate_key_placeholder')}
+          >
+            {translate('plugin_data_import_settings_on_duplicate_key')}
+          </Combobox>
+          <Link className="tw:text-xs" href="https://dbeaver.com/docs/cloudbeaver/Data-Import-and-Replace/" target="_blank">
+            {translate('plugin_data_import_settings_on_duplicate_key_help')}
+          </Link>
+        </div>
+      )}
+      {(supportsBulkLoad || supportsTransactions) && (
+        <Container vertical>
+          {supportsBulkLoad && (
+            <FieldCheckbox title={translate('plugin_data_import_settings_use_bulk_load_title')} name="useBulkLoad" state={settings}>
+              {translate('plugin_data_import_settings_use_bulk_load')}
+            </FieldCheckbox>
+          )}
+          {supportsTransactions && (
+            <FieldCheckbox title={translate('plugin_data_import_settings_use_transactions_title')} name="useTransactions" state={settings}>
+              {translate('plugin_data_import_settings_use_transactions')}
+            </FieldCheckbox>
+          )}
+          <FieldCheckbox title={translate('plugin_data_import_settings_open_new_connection_title')} name="openNewConnection" state={settings}>
+            {translate('plugin_data_import_settings_open_new_connection')}
+          </FieldCheckbox>
+        </Container>
+      )}
+    </Container>
+  );
+});

webapp/packages/plugin-data-import/src/DataImportDialog/useDataImportDialog.ts

@@ -1,21 +1,23 @@
 /*
  * CloudBeaver - Cloud Database Manager
- * Copyright (C) 2020-2024 DBeaver Corp and others
+ * Copyright (C) 2020-2026 DBeaver Corp and others
  *
  * Licensed under the Apache License, Version 2.0.
  * you may not use this file except in compliance with the License.
  */
 import { action, observable } from 'mobx';
 
 import { useObservableRef } from '@cloudbeaver/core-blocks';
-import type { DataTransferProcessorInfo } from '@cloudbeaver/core-sdk';
+import type { DataTransferImportSettings, DataTransferProcessorInfo } from '@cloudbeaver/core-sdk';
 
+import type { IDataImportDriverConfiguration } from '../DataImportDriverConfigurationResource.js';
 import { EDataImportDialogStep } from './EDataImportDialogStep.js';
 import type { IDataImportDialogState } from './IDataImportDialogState.js';
 
 interface IDialog {
   state: IDataImportDialogState;
   stepBack: () => void;
+  goToSettings: (configuration: IDataImportDriverConfiguration) => void;
   selectProcessor: (processor: DataTransferProcessorInfo) => void;
   deleteFile: () => void;
   reset: () => void;
@@ -25,17 +27,44 @@ const DEFAULT_STATE_GETTER: () => IDataImportDialogState = () => ({
   step: EDataImportDialogStep.Processor,
   file: null,
   selectedProcessor: null,
+  settings: {},
 });
 
-export function useDataImportDialog(initialState?: IDataImportDialogState) {
-  const dialog = useObservableRef<IDialog>(
+function getDefaultSettings(configuration: IDataImportDriverConfiguration): DataTransferImportSettings {
+  const settings: DataTransferImportSettings = {
+    openNewConnection: true,
+  };
+
+  if (configuration.supportsTransactions) {
+    settings.useTransactions = true;
+  }
+
+  if (configuration.supportedInsertReplaceMethods) {
+    settings.onDuplicateKeyMethod = undefined;
+  }
+
+  if (configuration.supportsBulkLoad) {
+    settings.useBulkLoad = false;
+  }
+
+  return settings;
+}
+
+export function useDataImportDialog(initialState?: IDataImportDialogState): IDialog {
+  return useObservableRef<IDialog>(
     () => ({
       state: initialState ?? DEFAULT_STATE_GETTER(),
       stepBack() {
-        if (this.state.step === EDataImportDialogStep.File) {
+        if (this.state.step === EDataImportDialogStep.Settings) {
+          this.state.step = EDataImportDialogStep.File;
+        } else if (this.state.step === EDataImportDialogStep.File) {
           this.state.step = EDataImportDialogStep.Processor;
         }
       },
+      goToSettings(configuration: IDataImportDriverConfiguration) {
+        this.state.settings = { ...getDefaultSettings(configuration), ...this.state.settings };
+        this.state.step = EDataImportDialogStep.Settings;
+      },
       selectProcessor(processor: DataTransferProcessorInfo) {
         if (this.state.selectedProcessor && this.state.selectedProcessor.id !== processor.id) {
           this.reset();
@@ -51,9 +80,14 @@ export function useDataImportDialog(initialState?: IDataImportDialogState) {
         this.state = DEFAULT_STATE_GETTER();
       },
     }),
-    { state: observable, stepBack: action.bound, selectProcessor: action.bound, deleteFile: action.bound, reset: action.bound },
+    {
+      state: observable,
+      stepBack: action.bound,
+      goToSettings: action.bound,
+      selectProcessor: action.bound,
+      deleteFile: action.bound,
+      reset: action.bound,
+    },
     false,
   );
-
-  return dialog;
 }