diff --git a/broker/migrate/h2/V32__alter_setting_column_name.sql b/broker/migrate/h2/V32__alter_setting_column_name.sql new file mode 100755 index 00000000..71b04ba1 --- /dev/null +++ b/broker/migrate/h2/V32__alter_setting_column_name.sql @@ -0,0 +1,2 @@ +alter table `t_settings` change column `value` `_value` varchar(64) NOT NULL; +alter table `t_settings` change column `desc` `_desc` varchar(64) NOT NULL; diff --git a/broker/migrate/mysql/V37__alter_setting_column_name.sql b/broker/migrate/mysql/V37__alter_setting_column_name.sql new file mode 100755 index 00000000..71b04ba1 --- /dev/null +++ b/broker/migrate/mysql/V37__alter_setting_column_name.sql @@ -0,0 +1,2 @@ +alter table `t_settings` change column `value` `_value` varchar(64) NOT NULL; +alter table `t_settings` change column `desc` `_desc` varchar(64) NOT NULL; diff --git a/broker/src/main/java/io/moquette/persistence/DatabaseStore.java b/broker/src/main/java/io/moquette/persistence/DatabaseStore.java index eb25f4ee..2c310c8c 100644 --- a/broker/src/main/java/io/moquette/persistence/DatabaseStore.java +++ b/broker/src/main/java/io/moquette/persistence/DatabaseStore.java @@ -86,10 +86,10 @@ public class DatabaseStore { try { connection = DBUtil.getConnection(); String sql = "insert into t_settings " + - " (`id`, `value`, `desc`) values(?, ?, ?)" + + " (`id`, `_value`, `_desc`) values(?, ?, ?)" + " ON DUPLICATE KEY UPDATE " + - "`value` = ?," + - "`desc` = ?"; + "`_value` = ?," + + "`_desc` = ?"; statement = connection.prepareStatement(sql); @@ -120,7 +120,7 @@ public class DatabaseStore { try { connection = DBUtil.getConnection(); - String sql = "select `value`, `desc` from t_settings where `id` = ?"; + String sql = "select `_value`, `_desc` from t_settings where `id` = ?"; statement = connection.prepareStatement(sql); int index = 1;