diff --git a/core/modules/migrate/src/Plugin/migrate/source/SqlBase.php b/core/modules/migrate/src/Plugin/migrate/source/SqlBase.php
index c042260d2ae7f34457e578977068d9ab2c4a7487..eec7275b541de040d767e2237b31a969be4e5b35 100644
--- a/core/modules/migrate/src/Plugin/migrate/source/SqlBase.php
+++ b/core/modules/migrate/src/Plugin/migrate/source/SqlBase.php
@@ -135,7 +135,7 @@ protected function initializeIterator() {
       $delimiter = '';
       foreach ($this->getIds() as $field_name => $field_schema) {
         if (isset($field_schema['alias'])) {
-          $field_name = $field_schema['alias'] . '.' . $field_name;
+          $field_name = $field_schema['alias'] . '.' . $this->query->escapeField($field_name);
         }
         $map_join .= "$delimiter$field_name = map.sourceid" . $count++;
         $delimiter = ' AND ';