From 9e007185ba1fcbbeb01f72c45068bc3920f3ec69 Mon Sep 17 00:00:00 2001 From: imndx Date: Fri, 27 Nov 2020 19:00:34 +0800 Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3sql=E8=AF=AD=E6=B3=95?= =?UTF-8?q?=E9=94=99=E8=AF=AF.=20fix=20#305?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/io/moquette/persistence/DatabaseStore.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/broker/src/main/java/io/moquette/persistence/DatabaseStore.java b/broker/src/main/java/io/moquette/persistence/DatabaseStore.java index b9174314..bfe43fb0 100644 --- a/broker/src/main/java/io/moquette/persistence/DatabaseStore.java +++ b/broker/src/main/java/io/moquette/persistence/DatabaseStore.java @@ -203,10 +203,9 @@ public class DatabaseStore { } if (page > 0) { - sql += "offset = '" + page * 20 + "'"; + sql += " offset " + page * 20; } - statement = connection.prepareStatement(sql); int index = 1; @@ -3146,10 +3145,9 @@ public class DatabaseStore { if (page > 0) { - sql += "offset = '" + page * 20 + "'"; + sql += " offset " + page * 20; } - statement = connection.prepareStatement(sql); int index = 1; if (buzzy) {