Synchronize repository - 2024-02-16

cmt-technical-user · cmt-technical-user · commit 1c5eee0341ef · 2024-02-16T10:26:41.000Z
diff --git a/commercedbsync/resources/commercedbsync-items.xml b/commercedbsync/resources/commercedbsync-items.xml
@@ -100,7 +100,18 @@
                     <persistence type="property"/>
                     <modifiers optional="false"/>
                     <defaultvalue>false</defaultvalue>
-                </attribute>            
+                </attribute>
+                <attribute qualifier="resumeMigration" type="boolean">
+                    <description>Resume a failed migration</description>
+                    <persistence type="property" />
+                    <modifiers optional="true"/>
+                    <defaultvalue>false</defaultvalue>
+                </attribute>
+                <attribute qualifier="migrationId" type="java.lang.String" >
+                    <description>Migration Id for the job</description>
+                    <persistence type="property" />
+                    <modifiers optional="true"/>
+                </attribute>
             </attributes>
         </itemtype>
 
diff --git a/commercedbsync/resources/commercedbsync-spring.xml b/commercedbsync/resources/commercedbsync-spring.xml
@@ -315,6 +315,7 @@
 
   <bean id="fullMigrationJob" class="com.sap.cx.boosters.commercedbsync.jobs.FullMigrationJob"
     parent="abstractMigrationJobPerformable">
+      <property name="modelService" ref="modelService"/>
   </bean>
 
 <!--  <bean id="defaultCMTRemoveInterceptor"-->
diff --git a/commercedbsync/resources/localization/commercedbsync-locales_en.properties b/commercedbsync/resources/localization/commercedbsync-locales_en.properties
@@ -30,3 +30,9 @@ type.MigrationCronJob.maxWriterWorkers.description=Number of writer workers to b
 
 type.MigrationCronJob.batchSize.name=Batch Size
 type.MigrationCronJob.batchSize.description=Batch size used to query data
+
+type.FullMigrationCronJob.resumeMigration.name=Resume Migration
+type.FullMigrationCronJob.resumeMigration.description=
+
+type.FullMigrationCronJob.migrationId.name=Migration ID
+type.FullMigrationCronJob.migrationId.description=
diff --git a/commercedbsync/src/com/sap/cx/boosters/commercedbsync/jobs/AbstractMigrationJobPerformable.java b/commercedbsync/src/com/sap/cx/boosters/commercedbsync/jobs/AbstractMigrationJobPerformable.java
@@ -74,12 +74,41 @@ public abstract class AbstractMigrationJobPerformable extends AbstractJobPerform
     @Override
     public boolean isPerformable() {
         for (CronJobModel cronJob : getCronJobService().getRunningOrRestartedCronJobs()) {
+            currentMigrationId = databaseMigrationService.getMigrationID(migrationContext);
+
             if ((cronJob instanceof IncrementalMigrationCronJobModel || cronJob instanceof FullMigrationCronJobModel)) {
-                LOG.info("Previous migrations job already running {} and Type {} ", cronJob.getCode(),
-                        cronJob.getItemtype());
+                if (isJobStateAborted(cronJob)) {
+                    try {
+                        abortCurrentMigration();
+                        databaseMigrationService.markRemainingTasksAborted(migrationContext, currentMigrationId);
+                        clearAbortRequestedIfNeeded(cronJob);
+
+                        LOG.info("Migration with ID: {} was marked as aborted", currentMigrationId);
+                    } catch (Exception e) {
+                        LOG.warn("Failed to abort current migration");
+                        LOG.debug("Migration abort failed", e);
+                    }
+                } else {
+                    LOG.info("Previous migration job already running {} and type {}", cronJob.getCode(),
+                            cronJob.getItemtype());
+                }
                 return false;
             }
         }
+
+        if (StringUtils.isNotEmpty(currentMigrationId)) {
+            try {
+                if (databaseMigrationService.getMigrationState(migrationContext, currentMigrationId)
+                        .getStatus() == MigrationProgress.RUNNING) {
+                    LOG.info("Previous migration already running, ID: {}", currentMigrationId);
+                    return false;
+                }
+            } catch (Exception e) {
+                LOG.warn("Unable to fetch current migration status");
+                LOG.debug("Migration status fetch failed", e);
+            }
+        }
+
         return true;
     }
 
@@ -199,13 +228,12 @@ protected MigrationStatus waitForFinishCronjobs(IncrementalMigrationContext cont
         } while (StringUtils.equalsAnyIgnoreCase(status.getStatus().toString(), RUNNING_MIGRATION));
 
         if (aborted) {
-            LOG.info(" Aborted ...STOPPING migration ");
-            databaseMigrationService.stopMigration(migrationContext, currentMigrationId);
+            abortCurrentMigration();
+            clearAbortRequestedIfNeeded(cronJobModel);
             LOG.error("Database migration has been ABORTED, Migration State= " + status + ", Total Tasks "
                     + status.getTotalTasks() + ", migration id =" + status.getMigrationID() + ", Completed Tasks "
                     + status.getCompletedTasks());
-            clearAbortRequestedIfNeeded(cronJobModel);
-            throw new AbortCronJobException("CronJOB ABORTED");
+            throw new AbortCronJobException("Cronjob ABORTED");
         }
 
         if (status.isFailed()) {
@@ -218,6 +246,11 @@ protected MigrationStatus waitForFinishCronjobs(IncrementalMigrationContext cont
         return status;
     }
 
+    private void abortCurrentMigration() throws Exception {
+        LOG.info("Aborted ...STOPPING migration");
+        databaseMigrationService.stopMigration(migrationContext, currentMigrationId);
+    }
+
     protected LaunchOptions createLaunchOptions(MigrationCronJobModel migrationCronJob) {
         final LaunchOptions launchOptions = new LaunchOptions();
 
@@ -240,8 +273,8 @@ private void putLaunchOptionProperty(final LaunchOptions launchOptions, String p
 
     protected boolean isJobStateAborted(final CronJobModel cronJobModel) {
         this.modelService.refresh(cronJobModel);
-        LOG.info("cron job status = " + cronJobModel.getStatus());
-        LOG.info("cron job request to abort =" + cronJobModel.getRequestAbort());
+        LOG.info("Cron job status: {}", cronJobModel.getStatus());
+        LOG.info("Cron job request to abort: {}", BooleanUtils.isTrue(cronJobModel.getRequestAbort()));
         return ((cronJobModel.getStatus() == CronJobStatus.ABORTED)
                 || (cronJobModel.getRequestAbort() != null && cronJobModel.getRequestAbort()));
     }
diff --git a/commercedbsync/src/com/sap/cx/boosters/commercedbsync/jobs/FullMigrationJob.java b/commercedbsync/src/com/sap/cx/boosters/commercedbsync/jobs/FullMigrationJob.java
@@ -7,13 +7,16 @@
 package com.sap.cx.boosters.commercedbsync.jobs;
 
 import com.google.common.base.Preconditions;
+import com.sap.cx.boosters.commercedbsync.constants.CommercedbsyncConstants;
 import com.sap.cx.boosters.commercedbsync.context.IncrementalMigrationContext;
+import com.sap.cx.boosters.commercedbsync.context.LaunchOptions;
 import de.hybris.platform.cronjob.enums.CronJobResult;
 import de.hybris.platform.cronjob.enums.CronJobStatus;
 import de.hybris.platform.cronjob.jalo.AbortCronJobException;
 import de.hybris.platform.cronjob.model.CronJobModel;
 import de.hybris.platform.servicelayer.cronjob.PerformResult;
 import com.sap.cx.boosters.commercedbsync.model.cron.FullMigrationCronJobModel;
+import de.hybris.platform.servicelayer.model.ModelService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -24,6 +27,12 @@ public class FullMigrationJob extends AbstractMigrationJobPerformable {
 
     private static final Logger LOG = LoggerFactory.getLogger(FullMigrationJob.class);
 
+    private final ModelService modelService;
+
+    public FullMigrationJob(final ModelService modelService) {
+        this.modelService = modelService;
+    }
+
     @Override
     public PerformResult perform(final CronJobModel cronJobModel) {
         FullMigrationCronJobModel fullMigrationCronJobModel;
@@ -54,9 +63,24 @@ public PerformResult perform(final CronJobModel cronJobModel) {
             incrementalMigrationContext.setIncrementalModeEnabled(false);
             incrementalMigrationContext
                     .setFullDatabaseMigrationEnabled(fullMigrationCronJobModel.isFullDatabaseMigration());
-            currentMigrationId = databaseMigrationService.startMigration(incrementalMigrationContext,
-                    createLaunchOptions(fullMigrationCronJobModel));
+            final LaunchOptions launchOptions = createLaunchOptions(fullMigrationCronJobModel);
 
+            if (fullMigrationCronJobModel.isResumeMigration()) {
+                currentMigrationId = fullMigrationCronJobModel.getMigrationId();
+                Preconditions.checkNotNull(currentMigrationId,
+                        "Migration ID must be present to resume failed migration job");
+                launchOptions.getPropertyOverrideMap().put(CommercedbsyncConstants.MIGRATION_SCHEDULER_RESUME_ENABLED,
+                        true);
+                databaseMigrationService.resumeUnfinishedMigration(incrementalMigrationContext, launchOptions,
+                        currentMigrationId);
+                LOG.info("Resumed Migration {}", currentMigrationId);
+            } else {
+                currentMigrationId = databaseMigrationService.startMigration(incrementalMigrationContext,
+                        launchOptions);
+                LOG.info("Started Migration {}", currentMigrationId);
+                fullMigrationCronJobModel.setMigrationId(currentMigrationId);
+                modelService.save(fullMigrationCronJobModel);
+            }
             waitForFinishCronjobs(incrementalMigrationContext, currentMigrationId, cronJobModel);
         } catch (final AbortCronJobException e) {
             return new PerformResult(CronJobResult.ERROR, CronJobStatus.ABORTED);
diff --git a/commercedbsync/src/com/sap/cx/boosters/commercedbsync/processors/impl/TransformFunctionGeneratorPreProcessor.java b/commercedbsync/src/com/sap/cx/boosters/commercedbsync/processors/impl/TransformFunctionGeneratorPreProcessor.java
@@ -34,18 +34,21 @@ public void process(final CopyContext context) {
     }
 
     private String getPlatformSpecificSQL(final DataBaseProvider databaseProvider) {
-        String platformSpecificSQL = "mssql-general.sql";
-        if (databaseProvider.isHanaUsed() || databaseProvider.isOracleUsed() || databaseProvider.isPostgreSqlUsed()) {
-            platformSpecificSQL = null;
+        String platformSpecificSQL = null;
+
+        if (databaseProvider.isMssqlUsed()) {
+            platformSpecificSQL = "mssql-general.sql";
         }
 
-        LOG.info("Identified platform specific transformation function SQL {}", platformSpecificSQL);
+        LOG.info("Identified platform specific transformation function SQL: {}",
+                StringUtils.defaultIfEmpty(platformSpecificSQL, "<none>"));
 
         return platformSpecificSQL;
     }
 
     @Override
     public boolean shouldExecute(CopyContext context) {
-        return context.getMigrationContext().isDataExportEnabled();
+        return context.getMigrationContext().isDataExportEnabled()
+                && context.getMigrationContext().getDataSourceRepository().getDatabaseProvider().isMssqlUsed();
     }
 }
diff --git a/commercedbsync/src/com/sap/cx/boosters/commercedbsync/processors/impl/TypeInfoTableGeneratorPreProcessor.java b/commercedbsync/src/com/sap/cx/boosters/commercedbsync/processors/impl/TypeInfoTableGeneratorPreProcessor.java
@@ -68,16 +68,19 @@ public void process(final CopyContext context) {
 
     @Override
     public boolean shouldExecute(CopyContext context) {
-        return context.getMigrationContext().isDataExportEnabled();
+        return context.getMigrationContext().isDataExportEnabled()
+                && context.getMigrationContext().getDataSourceRepository().getDatabaseProvider().isMssqlUsed();
     }
 
     private String getPlatformSpecificSQL(final DataBaseProvider databaseProvider) {
-        String platformSpecificSQL = "mssql-typeinfotable.sql";
-        if (databaseProvider.isHanaUsed() || databaseProvider.isOracleUsed() || databaseProvider.isPostgreSqlUsed()) {
-            platformSpecificSQL = null;
+        String platformSpecificSQL = null;
+
+        if (databaseProvider.isMssqlUsed()) {
+            platformSpecificSQL = "mssql-typeinfotable.sql";
         }
 
-        LOG.info("Identified platform specific typeinfo table SQL {}", platformSpecificSQL);
+        LOG.info("Identified platform specific typeinfo table SQL: {}",
+                StringUtils.defaultIfEmpty(platformSpecificSQL, "<none>"));
 
         return platformSpecificSQL;
     }
diff --git a/commercedbsync/src/com/sap/cx/boosters/commercedbsync/repository/impl/HanaDataRepository.java b/commercedbsync/src/com/sap/cx/boosters/commercedbsync/repository/impl/HanaDataRepository.java
@@ -96,7 +96,7 @@ public String getDatabaseTimezone() {
                 return rs.getString("VALUE");
             }
         } catch (Exception e) {
-            e.getMessage();
+            LOG.warn("Failed to check database timezone", e);
         }
         return null;
     }
diff --git a/commercedbsync/src/com/sap/cx/boosters/commercedbsync/repository/impl/MySQLDataRepository.java b/commercedbsync/src/com/sap/cx/boosters/commercedbsync/repository/impl/MySQLDataRepository.java
@@ -18,6 +18,8 @@
 import de.hybris.bootstrap.ddl.DatabaseSettings;
 import de.hybris.bootstrap.ddl.HybrisPlatform;
 import org.apache.ddlutils.Platform;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.core.io.Resource;
 import org.springframework.jdbc.datasource.init.ResourceDatabasePopulator;
 
@@ -28,6 +30,8 @@
 import java.util.List;
 
 public class MySQLDataRepository extends AbstractDataRepository {
+    private static final Logger LOG = LoggerFactory.getLogger(MySQLDataRepository.class);
+
     public MySQLDataRepository(MigrationContext migrationContext, DataSourceConfiguration dataSourceConfiguration,
             DatabaseMigrationDataTypeMapperService databaseMigrationDataTypeMapperService) {
         super(migrationContext, dataSourceConfiguration, databaseMigrationDataTypeMapperService);
@@ -149,7 +153,7 @@ public String getDatabaseTimezone() {
                 return rs.getString("timezone");
             }
         } catch (Exception e) {
-            e.getMessage();
+            LOG.warn("Failed to check database timezone", e);
         }
         return null;
     }
diff --git a/commercedbsync/src/com/sap/cx/boosters/commercedbsync/repository/impl/NullRepository.java b/commercedbsync/src/com/sap/cx/boosters/commercedbsync/repository/impl/NullRepository.java
@@ -240,7 +240,6 @@ public String buildBulkUpsertStatement(String table, List<String> columnsToCopy,
 
     @Override
     public String getDatabaseTimezone() {
-
         return null;
     }
 
diff --git a/commercedbsync/src/com/sap/cx/boosters/commercedbsync/repository/impl/OracleDataRepository.java b/commercedbsync/src/com/sap/cx/boosters/commercedbsync/repository/impl/OracleDataRepository.java
@@ -275,7 +275,7 @@ public String getDatabaseTimezone() {
                     return "Different timezone";
             }
         } catch (Exception e) {
-            e.getMessage();
+            LOG.warn("Failed to check database timezone", e);
         }
         return null;
     }
diff --git a/commercedbsync/src/com/sap/cx/boosters/commercedbsync/scheduler/impl/CustomClusterDatabaseCopyScheduler.java b/commercedbsync/src/com/sap/cx/boosters/commercedbsync/scheduler/impl/CustomClusterDatabaseCopyScheduler.java
@@ -122,16 +122,19 @@ public void schedule(CopyContext context) throws Exception {
     @Override
     public void resumeUnfinishedItems(CopyContext copyContext) throws Exception {
         databaseCopySchedulerAlgorithm.reset();
-        int ownNodeId = databaseCopySchedulerAlgorithm.getOwnNodeId();
         Set<DatabaseCopyTask> failedTasks = databaseCopyTaskRepository.findFailedTasks(copyContext);
+        if (failedTasks.isEmpty()) {
+            throw new IllegalStateException("No pending failed table copy tasks found to be resumed");
+        }
+
         for (DatabaseCopyTask failedTask : failedTasks) {
             databaseCopyTaskRepository.rescheduleTask(copyContext, failedTask.getPipelinename(),
                     databaseCopySchedulerAlgorithm.next());
         }
         databaseCopyTaskRepository.resetMigration(copyContext);
         startMonitorThread(copyContext);
-        final CopyDatabaseTableEvent event = new CopyDatabaseTableEvent(ownNodeId, copyContext.getMigrationId(),
-                copyContext.getPropertyOverrideMap());
+        final CopyDatabaseTableEvent event = new CopyDatabaseTableEvent(databaseCopySchedulerAlgorithm.getOwnNodeId(),
+                copyContext.getMigrationId(), copyContext.getPropertyOverrideMap());
         eventService.publishEvent(event);
     }
 
diff --git a/commercedbsync/src/com/sap/cx/boosters/commercedbsync/service/DatabaseCopyTaskRepository.java b/commercedbsync/src/com/sap/cx/boosters/commercedbsync/service/DatabaseCopyTaskRepository.java
@@ -143,6 +143,15 @@ Optional<DatabaseCopyTask> findPipeline(CopyContext context, CopyContext.DataCop
      */
     void markTaskCompleted(CopyContext context, CopyContext.DataCopyItem copyItem, String duration) throws Exception;
 
+    /**
+     * Mark all remaining table copy tasks as aborted, should be used when migration
+     * was stopped unexpectedly (for example after application crashed)
+     *
+     * @param context
+     * @throws Exception
+     */
+    void markRemainingTasksAborted(CopyContext context) throws Exception;
+
     void markTaskTruncated(CopyContext context, CopyContext.DataCopyItem copyItem) throws Exception;
 
     /**
diff --git a/commercedbsync/src/com/sap/cx/boosters/commercedbsync/service/DatabaseMigrationService.java b/commercedbsync/src/com/sap/cx/boosters/commercedbsync/service/DatabaseMigrationService.java
@@ -57,6 +57,18 @@ void resumeUnfinishedMigration(MigrationContext context, LaunchOptions launchOpt
      */
     void stopMigration(MigrationContext context, String migrationID) throws Exception;
 
+    /**
+     * Mark all remaining table copy tasks as aborted, should be used when migration
+     * was stopped unexpectedly (for example after application crashed)
+     *
+     * @param context
+     *            Migration configuration
+     * @param migrationID
+     *            ID of the migration process tasks that should be marked as aborted
+     * @throws Exception
+     */
+    void markRemainingTasksAborted(MigrationContext context, String migrationID) throws Exception;
+
     /**
      * Get current overall state without details
      *
diff --git a/commercedbsync/src/com/sap/cx/boosters/commercedbsync/service/impl/DefaultDatabaseCopyTaskRepository.java b/commercedbsync/src/com/sap/cx/boosters/commercedbsync/service/impl/DefaultDatabaseCopyTaskRepository.java
@@ -406,6 +406,19 @@ public synchronized void markTaskFailed(CopyContext context, CopyContext.DataCop
         mutePerformanceRecorder(context, copyItem);
     }
 
+    @Override
+    public synchronized void markRemainingTasksAborted(CopyContext context) throws Exception {
+        // spotless:off
+        String sql = "UPDATE " + TABLECOPYTASKS + " SET failure='1', duration='-1', error='Aborted', lastupdate=? WHERE migrationId=? AND duration IS NULL AND failure = '0'";
+        // spotless:on
+        try (Connection connection = getConnection(context);
+                PreparedStatement stmt = connection.prepareStatement(sql)) {
+            setTimestamp(stmt, 1, now());
+            stmt.setObject(2, context.getMigrationId());
+            stmt.executeUpdate();
+        }
+    }
+
     @Override
     public synchronized void markTaskTruncated(CopyContext context, CopyContext.DataCopyItem copyItem)
             throws Exception {
diff --git a/commercedbsync/src/com/sap/cx/boosters/commercedbsync/service/impl/DefaultDatabaseMigrationService.java b/commercedbsync/src/com/sap/cx/boosters/commercedbsync/service/impl/DefaultDatabaseMigrationService.java
@@ -109,12 +109,18 @@ public void stopMigration(MigrationContext context, String migrationID) throws E
         databaseCopyScheduler.abort(copyContext);
     }
 
+    @Override
+    public void markRemainingTasksAborted(MigrationContext context, String migrationID) throws Exception {
+        CopyContext copyContext = buildIdContext(context, migrationID);
+        databaseCopyTaskRepository.markRemainingTasksAborted(copyContext);
+    }
+
     private CopyContext buildCopyContext(MigrationContext context, String migrationID) throws Exception {
         Set<CopyContext.DataCopyItem> dataCopyItems = copyItemProvider.get(context);
         return new CopyContext(migrationID, context, dataCopyItems, performanceProfiler);
     }
 
-    private CopyContext buildIdContext(MigrationContext context, String migrationID) throws Exception {
+    private CopyContext buildIdContext(MigrationContext context, String migrationID) {
         // we use a lean implementation of the copy context to avoid calling the
         // provider which is not required for task management.
         return new CopyContext.IdCopyContext(migrationID, context, performanceProfiler);
diff --git a/commercedbsynchac/hac/resources/jsp/dataCopy.jsp b/commercedbsynchac/hac/resources/jsp/dataCopy.jsp
@@ -24,7 +24,7 @@
 </head>
 <body>
 <div class="prepend-top span-24" id="content">
-    <div id="migrationPanel" class="marginLeft colborder span-17">
+    <div id="migrationPanel" class="marginLeft colborder span-17" data-resumeUrl="<c:url value="/commercedbsynchac/resumeRunning"/>">
         <h2>Data Migration</h2>
         <c:if test="${!isDataExportEnabled}">
             <c:if test="${isIncremental}">
@@ -38,7 +38,7 @@
                 </hac:note>
                 <span id="timezoneCheckboxContainer"><input type="checkbox" id="timezoneCheckbox" name="timezoneCheckbox"  onchange="document.getElementById('buttonCopyData').disabled=!this.checked"> I am aware of timezone differences, proceed with migration</span>
             </c:if>
-            <div class="clearfix" id="buttonsContainer" data-resumeUrl="<c:url value="/commercedbsynchac/resumeRunning"/>">
+            <div class="clearfix" id="buttonsContainer">
                 <button id="buttonCopyData" class="control-button" data-url="<c:url value="/commercedbsynchac/copyData"/>">Start</button>
                 <button id="buttonStopCopyData" class="control-button" data-url="<c:url value="/commercedbsynchac/abortCopy"/>">Stop</button>
             </div>
diff --git a/commercedbsynchac/hac/resources/static/js/dataCopy.js b/commercedbsynchac/hac/resources/static/js/dataCopy.js
diff --git a/commercedbsynchac/hac/src/de/hybris/platform/hac/controller/CommercemigrationhacController.java b/commercedbsynchac/hac/src/de/hybris/platform/hac/controller/CommercemigrationhacController.java
diff --git a/docs/troubleshooting/TROUBLESHOOTING-GUIDE.md b/docs/troubleshooting/TROUBLESHOOTING-GUIDE.md

Original file line number	Diff line number	Diff line change
`@@ -34,18 +34,21 @@ public void process(final CopyContext context) {`
`34`	`34`	`}`
`35`	`35`
`36`	`36`	`private String getPlatformSpecificSQL(final DataBaseProvider databaseProvider) {`
`37`		`- String platformSpecificSQL = "mssql-general.sql";`
`38`		`- if (databaseProvider.isHanaUsed() \|\| databaseProvider.isOracleUsed() \|\| databaseProvider.isPostgreSqlUsed()) {`
`39`		`- platformSpecificSQL = null;`
	`37`	`+ String platformSpecificSQL = null;`
	`38`	`+`
	`39`	`+ if (databaseProvider.isMssqlUsed()) {`
	`40`	`+ platformSpecificSQL = "mssql-general.sql";`
`40`	`41`	`}`
`41`	`42`
`42`		`- LOG.info("Identified platform specific transformation function SQL {}", platformSpecificSQL);`
	`43`	`+ LOG.info("Identified platform specific transformation function SQL: {}",`
	`44`	`+ StringUtils.defaultIfEmpty(platformSpecificSQL, "<none>"));`
`43`	`45`
`44`	`46`	`return platformSpecificSQL;`
`45`	`47`	`}`
`46`	`48`
`47`	`49`	`@Override`
`48`	`50`	`public boolean shouldExecute(CopyContext context) {`
`49`		`- return context.getMigrationContext().isDataExportEnabled();`
	`51`	`+ return context.getMigrationContext().isDataExportEnabled()`
	`52`	`+ && context.getMigrationContext().getDataSourceRepository().getDatabaseProvider().isMssqlUsed();`
`50`	`53`	`}`
`51`	`54`	`}`
Original file line number	Diff line number	Diff line change
`@@ -96,7 +96,7 @@ public String getDatabaseTimezone() {`
`96`	`96`	`return rs.getString("VALUE");`
`97`	`97`	`}`
`98`	`98`	`} catch (Exception e) {`
`99`		`- e.getMessage();`
	`99`	`+ LOG.warn("Failed to check database timezone", e);`
`100`	`100`	`}`
`101`	`101`	`return null;`
`102`	`102`	`}`
Original file line number	Diff line number	Diff line change
`@@ -240,7 +240,6 @@ public String buildBulkUpsertStatement(String table, List<String> columnsToCopy,`
`240`	`240`
`241`	`241`	`@Override`
`242`	`242`	`public String getDatabaseTimezone() {`
`243`		`-`
`244`	`243`	`return null;`
`245`	`244`	`}`
`246`	`245`