diff --git a/commands/sql/sync.sql.inc b/commands/sql/sync.sql.inc
index c0629e4..6f34795 100644
--- a/commands/sql/sync.sql.inc
+++ b/commands/sql/sync.sql.inc
@@ -110,14 +110,14 @@ function sql_drush_sql_sync_sanitize($site) {
       $db_driver = $databases['default']['default']['driver'];
       if ($db_driver == 'pgsql') {
         $email_map = array('%uid' => "' || uid || '", '%mail' => "' || replace(mail, '@', '_') || '", '%name' => "' || replace(name, ' ', '_') || '");
-        $newmail =  "'" . str_replace(array_keys($email_map), array_values($email_map), $newemail) . "'";
+        $newemail =  str_replace(array_keys($email_map), array_values($email_map), $newemail);
       }
       else {
         $email_map = array('%uid' => "', uid, '", '%mail' => "', replace(mail, '@', '_'), '", '%name' => "', replace(name, ' ', '_'), '");
-        $newmail =  "concat('" . str_replace(array_keys($email_map), array_values($email_map), $newemail) . "')";
+        $newemail =  "concat('" . str_replace(array_keys($email_map), array_values($email_map), $newemail) . "')";
       }
     }
-    $user_table_updates[] = "mail = $newmail";
+    $user_table_updates[] = "mail = '$newemail'";
     $message_list[] = 'email addresses';
   }