【发布时间】：2015-12-03 13:01:13
【问题描述】：
我正在尝试学习 Cassandra，并且始终发现最好的方法是从创建一个非常简单且小型的应用程序开始。因此，我正在创建一个基本的消息传递应用程序，它将使用 Cassandra 作为后端。我想做以下事情：
- 用户将使用用户名、电子邮件和密码创建一个帐户。这 电子邮件和密码可以随时更改。
- 用户可以添加另一个用户作为他们的联系人。用户将添加一个 通过搜索他们的用户名或电子邮件联系。联系人不需要 如果我添加一个用户，他们是我的联系人，那么他们是相互的意思，我不 需要等待他们接受/批准 Facebook 中的任何内容。
- 一条消息从一个用户发送给另一个用户。发件人需要 能够看到他们发送的消息（按时间排序）和 发送给他们的消息（按时间排序）。当用户打开 我需要检查数据库是否有任何新消息的应用程序 用户。我还需要标记消息是否已阅读。
当我来自关系数据库的世界时，我的关系数据库看起来像这样：
UsersTable
username (text)
email (text)
password (text)
time_created (timestamp)
last_loggedIn (timestamp)
------------------------------------------------
ContactsTable
user_i_added (text)
user_added_me (text)
------------------------------------------------
MessagesTable
from_user (text)
to_user (text)
msg_body (text)
metadata (text)
has_been_read (boolean)
message_sent_time (timestamp)
阅读了几本 Cassandra 教科书，我想到了如何为数据库建模。我主要关心的是以非常有效的方式对数据库进行建模。因此，我试图避免诸如二级索引等之类的事情。到目前为止，这是我的模型：
CREATE TABLE users_by_username (
username text PRIMARY KEY,
email text,
password text
timeCreated timestamp
last_loggedin timestamp
)
CREATE TABLE users_by_email (
email text PRIMARY KEY,
username text,
password text
timeCreated timestamp
last_loggedin timestamp
)
为了均匀分布数据并读取最少的分区（希望只有一个），我可以根据用户名或电子邮件快速查找用户。这样做的缺点显然是我将数据翻了一番，但存储成本非常便宜，所以我发现它是一个很好的折衷方案，而不是使用二级索引。最后一次登录也需要写入两次，但 Cassandra 的写入效率很高，所以我相信这也是一个很好的权衡。
对于联系人，我想不出任何其他方法来对此进行建模，因此我对其进行建模的方式与我在关系数据库中的建模方式非常相似。这是一个相当非规范化的设计，我认为根据我读过的书应该有利于性能？
CREATE TABLE "user_follows" (
follower_username text,
followed_username text,
timeCreated timestamp,
PRIMARY KEY ("follower_username", "followed_username")
);
CREATE TABLE "user_followedBy" (
followed_username text,
follower_username text,
timeCreated timestamp,
PRIMARY KEY ("followed_username", "follower_username")
);
我被困在如何创建下一部分。对于消息传递，我正在考虑这个表，因为它创建了宽行，可以对消息进行排序。 我需要消息来回答两个问题。它首先需要能够向用户显示他们拥有的所有消息，并且还能够向用户显示 新消息和未读消息。这是一个基本模型，但不确定如何使其更有效？
CREATE TABLE messages (
message_id uuid,
from_user text,
to_user text,
body text,
hasRead boolean,
timeCreated timeuuid,
PRIMARY KEY ((to_user), timeCreated )
) WITH CLUSTERING ORDER BY (timeCreated ASC);
我也在考虑使用诸如 STATIC 列将用户和消息“粘合”在一起，以及使用 SETS 来存储联系人关系等内容，但从我目前的狭隘理解来看，我呈现的方式更有效。请问是否有任何想法可以提高这个模型的效率，是否有更好的实践来做我想做的事情，或者这个设计有什么隐藏的问题？
总之，我正在尝试围绕查询进行建模。如果我使用关系数据库，这些基本上就是我想要回答的查询：
To Login:
SELECT * FROM USERS WHERE (USERNAME = [MY_USERNAME] OR EMAIL = [MY_EMAIL]) AND PASSWORD = [MY_PASSWORD];
------------------------------------------------------------------------------------------------------------------------
Update user info:
UPDATE USERS (password) SET password = [NEW_PASSWORD] where username = [MY_USERNAME];
UPDATE USERS (email) SET password = [NEW_PASSWORD ] where username = [MY_USERNAME];
------------------------------------------------------------------------------------------------------------------------
To Add contact (If by username):
INSERT INTO followings(following,follower) VALUES([USERNAME_I_WANT_TO_FOLLOW],[MY_USERNAME]);
------------------------------------------------------------------------------------------------------------------------
To Add contact (If by email):
SELECT username FROM users where email = [CONTACTS_EMAIL];
Then application layer sends over another query with the username:
INSERT INTO followings(following,follower) VALUES([USERNAME_I_WANT_TO_FOLLOW],[MY_USERNAME]);
------------------------------------------------------------------------------------------------------------------------
To View contacts:
SELECT following FROM USERS WHERE follower = [MY_USERNAME];
------------------------------------------------------------------------------------------------------------------------
To Send Message:,
INSERT INTO MESSAGES (MSG_ID, FROM, TO, MSG, IS_MSG_NEW) VALUES (uuid, [FROM_USERNAME], [TO_USERNAME], 'MY MSG', true);
------------------------------------------------------------------------------------------------------------------------
To View All Messages (Some pagination type of technique where shows me the 10 recent messages, yet shows which ones are unread):
SELECT * FROM MESSAGES WHERE TO = [MY_USERNAME] LIMIT 10;
------------------------------------------------------------------------------------------------------------------------
Once Message is read:
UPDATE MESSAGES SET IS_MSG_NEW = false WHERE TO = [MY_USERNAME] AND MSG_ID = [MSG_ID];
干杯
【问题讨论】：
标签： database cassandra data-modeling cqlsh