如何在聊天应用程序中按最后回复时间排序房间实体?
How to order room entity by last reply time in a chat application?
我正在 Apache Cassandra 中设计一个聊天应用程序的数据库模式,但我无法解决这个问题。
到目前为止,这是我的架构:
CREATE TABLE users(
user_id bigint,
nickname text,
email text,
chat_rooms set<timeuuid>,
PRIMARY KEY(user_id)
);
CREATE TABLE rooms(
room_id timeuuid,
creation_date timestamp,
creator_id bigint,
participants set<bigint>,
PRIMARY KEY(room_id)
);
CREATE TABLE messages(
message_id timeuuid,
room_id timeuuid,
author_id bigint,
time_bucket int,
content text,
PRIMARY KEY((room_id, time_bucket), message_id)
) WITH CLUSTERING ORDER BY (message_id DESC);
我想获得一个按用户 ID 按最后回复时间排序的房间列表,类似于 Facebook Messenger 和 Telegram。
我正在考虑将新列 last_reply_time
添加到 rooms
,将其用作聚类键并在房间中有新消息时更新它。然而,在 Cassandra 中更新集群键值是不可能的。我应该如何对此进行建模?
我查看了 KillrChat example and Discord's wonderful piece 他们的 Cassandra 实现,但他们没有提到与我的问题相关的任何内容。
提前致谢!
你可以有这样的table
create table test (
creator_id bigint ,
room_id timeuuid ,
last_reply_time timestamp,
primary KEY ((creator_id), room_id))
with CLUSTERING ORDER BY
(room_id ASC );
您可以将所有 last_reply_time 和 select 数据插入其中
select * from test where creator_id = ? and room_id = ?
您将只执行更新数据库中相同条目的插入操作,因为您将拥有相同的 creator_id 和 room_id。
我正在 Apache Cassandra 中设计一个聊天应用程序的数据库模式,但我无法解决这个问题。
到目前为止,这是我的架构:
CREATE TABLE users(
user_id bigint,
nickname text,
email text,
chat_rooms set<timeuuid>,
PRIMARY KEY(user_id)
);
CREATE TABLE rooms(
room_id timeuuid,
creation_date timestamp,
creator_id bigint,
participants set<bigint>,
PRIMARY KEY(room_id)
);
CREATE TABLE messages(
message_id timeuuid,
room_id timeuuid,
author_id bigint,
time_bucket int,
content text,
PRIMARY KEY((room_id, time_bucket), message_id)
) WITH CLUSTERING ORDER BY (message_id DESC);
我想获得一个按用户 ID 按最后回复时间排序的房间列表,类似于 Facebook Messenger 和 Telegram。
我正在考虑将新列 last_reply_time
添加到 rooms
,将其用作聚类键并在房间中有新消息时更新它。然而,在 Cassandra 中更新集群键值是不可能的。我应该如何对此进行建模?
我查看了 KillrChat example and Discord's wonderful piece 他们的 Cassandra 实现,但他们没有提到与我的问题相关的任何内容。
提前致谢!
你可以有这样的table
create table test (
creator_id bigint ,
room_id timeuuid ,
last_reply_time timestamp,
primary KEY ((creator_id), room_id))
with CLUSTERING ORDER BY
(room_id ASC );
您可以将所有 last_reply_time 和 select 数据插入其中
select * from test where creator_id = ? and room_id = ?
您将只执行更新数据库中相同条目的插入操作,因为您将拥有相同的 creator_id 和 room_id。