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-5007. Fixed import to mongo (#2612)

Browse Source 
* CB-5007. Fixed import to mongo

* CB-5007. Fixed checkstyle
This commit is contained in:
DenisSinelnikov
2024-05-14 16:18:08 +00:00
committed by GitHub
parent 39bfc54ca5
commit bbd296f197
1 changed files with 9 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/bundles/io.cloudbeaver.service.data.transfer/src/io/cloudbeaver/service/data/transfer/impl/WebServiceDataTransfer.java
+9 -10
View File
@@ -338,22 +338,17 @@ public class WebServiceDataTransfer implements DBWServiceDataTransfer {
DBRProgressMonitor monitor,
DataTransferProcessorDescriptor processor,
@NotNull DBSDataManipulator dataContainer,
Path path) throws DBException
{
Path path) throws DBException {
IDataTransferProcessor processorInstance = processor.getInstance();
StreamTransferProducer producer;
if (dataContainer.getDataSource() != null) {
DatabaseTransferConsumer consumer = new DatabaseTransferConsumer(dataContainer);
producer = new StreamTransferProducer(new StreamEntityMapping(path), processor);
DatabaseTransferConsumer consumer = new DatabaseTransferConsumer(dataContainer);
DatabaseConsumerSettings databaseConsumerSettings = new DatabaseConsumerSettings();
databaseConsumerSettings.setContainer((DBSObjectContainer) dataContainer.getDataSource());
consumer.setSettings(databaseConsumerSettings);
DatabaseMappingContainer databaseMappingContainer = new DatabaseMappingContainer(databaseConsumerSettings, dataContainer);
databaseMappingContainer.getAttributeMappings(monitor);
databaseMappingContainer.setTarget(dataContainer);
consumer.setContainerMapping(databaseMappingContainer);
StreamTransferProducer producer = new StreamTransferProducer(new StreamEntityMapping(path), processor);
StreamProducerSettings producerSettings = new StreamProducerSettings();
Map<String, Object> properties = new HashMap<>();
@@ -366,7 +361,11 @@ public class WebServiceDataTransfer implements DBWServiceDataTransfer {
producer,
processorInstance,
properties);
DatabaseMappingContainer databaseMappingContainer =
new DatabaseMappingContainer(databaseConsumerSettings, producer.getDatabaseObject());
databaseMappingContainer.getAttributeMappings(monitor);
databaseMappingContainer.setTarget(dataContainer);
consumer.setContainerMapping(databaseMappingContainer);
try {
producer.transferData(monitor, consumer, processorInstance, producerSettings, null);
} catch (DBException e) {