anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
heavyrain2012
2021-04-03 14:27:11 +08:00
parent 2421d02eb8
commit 6f24579c8e
1 changed files with 6 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/io/moquette/persistence/DatabaseStore.java
+6 -12
View File
@@ -1741,11 +1741,11 @@ public class DatabaseStore {
int count = statement.executeUpdate();
LOG.info("Update rows {}", count);
}
connection.commit();
connection.setAutoCommit(true);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
Utility.printExecption(LOG, e, RDBS_Exception);
} finally {
if (connection != null) {
try {
connection.commit();
@@ -1754,9 +1754,6 @@ public class DatabaseStore {
e1.printStackTrace();
}
}
e.printStackTrace();
Utility.printExecption(LOG, e, RDBS_Exception);
} finally {
DBUtil.closeDB(connection, statement);
}
}
@@ -3082,11 +3079,11 @@ public class DatabaseStore {
int count = statement.executeUpdate();
LOG.info("Update rows {}", count);
}
connection.commit();
connection.setAutoCommit(true);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
Utility.printExecption(LOG, e, RDBS_Exception);
} finally {
if (connection != null) {
try {
connection.commit();
@@ -3095,9 +3092,6 @@ public class DatabaseStore {
e1.printStackTrace();
}
}
e.printStackTrace();
Utility.printExecption(LOG, e, RDBS_Exception);
} finally {
DBUtil.closeDB(connection, statement);
}
});