From 90d7baa97e776f985c70ed35b92d68d32830ee1a Mon Sep 17 00:00:00 2001
From: Thomas Canava <canava.thomas@gmail.com>
Date: Sun, 16 Jun 2024 18:03:02 +0200
Subject: [PATCH] Prevent restart when named datasources are quoted, or
 unquoted

---
 .../DevServicesDatasourceProcessor.java       | 50 ++++++++++++++++---
 1 file changed, 42 insertions(+), 8 deletions(-)

diff --git a/extensions/datasource/deployment/src/main/java/io/quarkus/datasource/deployment/devservices/DevServicesDatasourceProcessor.java b/extensions/datasource/deployment/src/main/java/io/quarkus/datasource/deployment/devservices/DevServicesDatasourceProcessor.java
index bde32b21a071a..0129e211c4c79 100644
--- a/extensions/datasource/deployment/src/main/java/io/quarkus/datasource/deployment/devservices/DevServicesDatasourceProcessor.java
+++ b/extensions/datasource/deployment/src/main/java/io/quarkus/datasource/deployment/devservices/DevServicesDatasourceProcessor.java
@@ -2,6 +2,7 @@
 
 import java.io.Closeable;
 import java.util.ArrayList;
+import java.util.Collection;
 import java.util.Collections;
 import java.util.HashMap;
 import java.util.List;
@@ -50,7 +51,8 @@ public class DevServicesDatasourceProcessor {
 
     // list of devservices properties we should not check for restart
     // see issue #30390
-    private static final Set<String> EXCLUDED_PROPERTIES = Set.of("quarkus.datasource.devservices.enabled");
+    private static final Set<String> EXCLUDED_PROPERTIES = Set.of("quarkus.datasource.devservices.enabled",
+            "quarkus.datasource.devservices.reuse");
 
     static volatile List<RunningDevService> databases;
 
@@ -77,13 +79,17 @@ DevServicesDatasourceResultBuildItem launchDatabases(
         //if not and the DB's have already started we just return
         if (databases != null) {
             boolean restartRequired = false;
-            if (!restartRequired) {
-                for (Map.Entry<String, String> entry : cachedProperties.entrySet()) {
-                    if (!Objects.equals(entry.getValue(),
-                            trim(ConfigProvider.getConfig().getOptionalValue(entry.getKey(), String.class).orElse(null)))) {
-                        restartRequired = true;
-                        break;
-                    }
+            for (Map.Entry<String, String> entry : cachedProperties.entrySet()) {
+                String value = ConfigProvider.getConfig()
+                        .getOptionalValue(entry.getKey(), String.class)
+                        .orElse(null);
+                if (value == null) {
+                    value = getValueWithOrWithoutQuotes(entry.getKey(),
+                            dataSourcesBuildTimeConfig.dataSources().keySet());
+                }
+                if (!Objects.equals(entry.getValue(), trim(value))) {
+                    restartRequired = true;
+                    break;
                 }
             }
             if (!restartRequired) {
@@ -179,6 +185,34 @@ public void run() {
         return new DevServicesDatasourceResultBuildItem(results);
     }
 
+    /**
+     * Gets the value of the given key trying to quote the datasource if unquoted, and unquote it if quoted
+     *
+     * @param key key to get
+     * @param datasources datasources to try to quote and unqote
+     * @return the value or else otherwise
+     */
+    private static String getValueWithOrWithoutQuotes(String key, Collection<String> datasources) {
+        for (String datasource : datasources) {
+            if (!DataSourceUtil.isDefault(datasource) && key.contains(datasource)) {
+                String quoted = ".\"" + datasource + "\".";
+                String unquoted = "." + datasource + ".";
+                if (key.contains(quoted)) {
+                    String entryWithoutQuote = key.replace(quoted, unquoted);
+                    return ConfigProvider.getConfig()
+                            .getOptionalValue(entryWithoutQuote, String.class)
+                            .orElse(null);
+                } else {
+                    String entryWithQuotes = key.replace(unquoted, quoted);
+                    return ConfigProvider.getConfig()
+                            .getOptionalValue(entryWithQuotes, String.class)
+                            .orElse(null);
+                }
+            }
+        }
+        return null;
+    }
+
     private String trim(String optional) {
         if (optional == null) {
             return null;