From ace743572627a98d23680ef9fd230b7498ef0551 Mon Sep 17 00:00:00 2001 From: heavyrian2012 Date: Thu, 9 Dec 2021 10:14:03 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=AD=A3=E7=A6=81=E6=AD=A2=E5=AD=98?= =?UTF-8?q?=E5=82=A8=E6=B6=88=E6=81=AFsearchable=E5=AD=97=E6=AE=B5?= =?UTF-8?q?=E7=9A=84=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- broker/src/main/java/io/moquette/persistence/DatabaseStore.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/broker/src/main/java/io/moquette/persistence/DatabaseStore.java b/broker/src/main/java/io/moquette/persistence/DatabaseStore.java index a5529eab..41877eb0 100644 --- a/broker/src/main/java/io/moquette/persistence/DatabaseStore.java +++ b/broker/src/main/java/io/moquette/persistence/DatabaseStore.java @@ -519,7 +519,7 @@ public class DatabaseStore { String sql; if (disableRemoteMessageSearch) { sql = "insert into " + table + - " (`_mid`, `_from`, `_type`, `_target`, `_line`, `_data`, `_dt`, `_content_type`, `_to`) values(?, ?, ?, ?, ?, ?, ?, ?, ?, ?)" + + " (`_mid`, `_from`, `_type`, `_target`, `_line`, `_data`, `_dt`, `_content_type`, `_to`) values(?, ?, ?, ?, ?, ?, ?, ?, ?)" + " ON DUPLICATE KEY UPDATE " + "`_data` = ?," + "`_dt` = ?," +