Message and Message Database updated based on new init.sql.

This commit is contained in:
Asal Lotfi
2025-08-05 21:08:29 +03:30
parent c5b1e6f9ee
commit b6230155a7
2 changed files with 30 additions and 3 deletions
@@ -172,7 +172,8 @@ public class MessageDatabase {
rs.getBoolean("is_edited"),
rs.getObject("original_message_id") != null ? UUID.fromString(rs.getString("original_message_id")) : null,
rs.getObject("forwarded_by") != null ? UUID.fromString(rs.getString("forwarded_by")) : null,
rs.getObject("forwarded_from") != null ? UUID.fromString(rs.getString("forwarded_from")) : null
rs.getObject("forwarded_from") != null ? UUID.fromString(rs.getString("forwarded_from")) : null,
rs.getBoolean("is_deleted_globally")
));
}
@@ -273,7 +274,8 @@ public class MessageDatabase {
rs.getBoolean("is_edited"),
(UUID) rs.getObject("original_message_id"),
(UUID) rs.getObject("forwarded_by"),
(UUID) rs.getObject("forwarded_from")
(UUID) rs.getObject("forwarded_from"),
rs.getBoolean("is_deleted_globally")
);
}
@@ -480,5 +482,21 @@ public class MessageDatabase {
return messages;
}
public static boolean insertSavedMessage(Message message) {
String sql = "INSERT INTO messages (message_id, sender_id, receiver_type, receiver_id, content, message_type, status) " +
"VALUES (?, ?, ?, ?, ?, ?, ?)";
try (Connection conn = ConnectionDb.connect();
PreparedStatement ps = conn.prepareStatement(sql)) {
return ps.executeUpdate() > 0;
} catch (SQLException e) {
e.printStackTrace();
return false;
}
}
}