如何使用redis设计关系数据库-阿里云开发者社区

开发者社区> 优惠码优惠> 正文

如何使用redis设计关系数据库

简介: 如何使用redis设计关系数据库目录 redis设计关系数据库前言设计用户信息表结构hash存储记录set存储id图示索引/查询:1、select查询所有记录 : 类似sql的select from table_name2、根据主键查询记录3、其他列索引c++ 实现小结redis设计关系数据库前言最近需要一张用户信息表,因为数据量并不大,想先放在内存中,等需求变更了,再移到磁盘上,或者往mysql塞,那么问题来了,怎么用redis的数据类型设计一个关系数据库呢。
+关注继续查看

如何使用redis设计关系数据库
目录

redis设计关系数据库
前言
设计用户信息表结构
hash存储记录
set存储id
图示
索引/查询:
1、select
查询所有记录 : 类似sql的select from table_name
2、根据主键查询记录
3、其他列索引
c++ 实现
小结
redis设计关系数据库
前言
最近需要一张用户信息表,因为数据量并不大,想先放在内存中,等需求变更了,再移到磁盘上,或者往mysql塞,那么问题来了,怎么用redis的数据类型设计一个关系数据库呢。

redis只有key-value这种存储结构,如果想利用它做成想其他数据库一样具备 增删改查等功能只能再设计了,这里分享一下我的设计方法,比较简单,我不知道算不算好,只是网上找了很久没找到一种通用的方法,如果有什么好的方法,还想请教一下各位,十分感谢。

设计用户信息表结构
hash存储记录
key值 : 域名:表名:主键
value值 :直接使用redis的Hash类型
如:

test:accounts_info:0 id 0 accounts ailumiyana_0 password 123456 nick_name sola_0
test:accounts_info:1 id 1 accounts ailumiyana_1 password 123456 nick_name sola_1
test:accounts_info:2 id 2 accounts ailumiyana_2 password 123456 nick_name sola_2
test:accounts_info:3 id 3 accounts ailumiyana_3 password 123456 nick_name sola_3
在这里插入图片描述

set存储id
另添加一个set集存放表主键, 也即id.
key值 : ids:域名:表名
value值: id
将已生成的用户id同时添加进set集合中.
我这里用了list演示,不设计类型的特殊方法的话,演示效果是一样的。
Alt text

图示
Alt text

索引/查询:
1、select
查询所有记录 : 类似sql的select from table_name
有了set表后我们就可以使用redis中sort的get方法,获取所有记录.
sort ids:test:accounts_info get test:accounts_info:->accounts get test:accounts_info:->nick_name
Alt text

2、根据主键查询记录
直接使用string类型建立主键到id的索引,其实id就是主键,但是我们一般不会用id去找记录,更多的使用account账号去找.
key值 : 域名:表名:列键名:列键值
这样我们直接用get 取得accounts的id 后再去hash中查找记录就行了.
在这里插入图片描述

3、其他列索引
最后可以根据表的需要建立一些其他索引,
方法同 2 ,使用类型不一定是set 哪个方便用哪个。
例如 我要统计最近登录的10个用户的信息, 那么我直接用list 的 lrange limit 0 10 就能取到.
Alt text

c++ 实现
以上设计的c++实现,其中的redis的客户端使用了cpp_redis库。

例程中 :
1、我创建了一张 account_info的表 默认使用accounts 作为主键

2、插入4个用户信息.

3、查询用户ailu_1的记录值.

class table// : public redis::er_table
{
public:

//! ctor

table(void);
//! dtor
~table(void) = default;

//! copy ctor
table(const table&) = delete;
//! assignment operator
table& operator=(const table&) = delete;

public:
//! vector type to save table records.
typedef std::vector records_t;

//! vector type to save table records entitys.
typedef std::vector entitys_t;

public:
//! create table,
//! default primary key is the records_t vec[0], if primary_key is empty!
void create(const std::string& table_name, const records_t& vec, const std::string& primary_key = "");

public:
//! incr primary key id.
std::string incr_id();

//! insert new entity to table, pelease orderly insert refer to records vector !
//! return false while entity exits.
bool insert(const entitys_t& vec);

//! get entitys by primary key value.
entitys_t get_entitys_by_primary_key_value(const std::string& primary_key_value);

private:
//! get id by primary key value
//! retrun "" while primary key inexitences.
std::string get_id_by_primary_key_value(const std::string& primary_key_value);

private:
//! redis client
cpp_redis::client m_redis_client;

//!
records_t m_records;

//! records count.
std::size_t m_records_count;

//! ids set key
std::string m_ids;

//! table name
std::string m_table_name;

//! incr key
uint64_t m_incr_key;

//! primary key
std::string m_primary_key;
std::size_t m_primary_key_index;
};

table::table()
:m_records_count(0),
m_incr_key(0)
{
m_redis_client.connect();
m_redis_client.select(3);
m_redis_client.sync_commit();
}

void table::create(const std::string& table_name, const records_t& vec, const std::string& primary_key){
assert(m_records_count == 0);
m_ids = "ids:" + table_name;
m_table_name = table_name;
m_records = vec;
m_records_count = vec.size();
if(primary_key.empty()){

m_primary_key = vec[0];
m_primary_key_index = 0;

} else {

m_primary_key = primary_key;
auto iter = std::find(vec.begin(), vec.end(), primary_key);
if(iter == vec.end()){
  LOG_FATAL << "no such key.";
}
m_primary_key_index = iter - vec.begin();

}

}

std::string table::incr_id(){
return std::move(std::to_string(m_incr_key++));
}

std::string table::get_id_by_primary_key_value(const std::string& primary_key_value){

std::future fu = m_redis_client.get(primary_key_value);
m_redis_client.sync_commit();

cpp_redis::reply reply = fu.get();

if(!reply.is_null()){

return std::move(reply.as_string());

}

LOG_DEBUG << "primary_key " << primary_key_value << " inexitences. return "".";

return "";
}

bool table::insert(const entitys_t& vec){
assert(m_records_count != 0);
assert(m_records_count == vec.size());

std::string get_id = incr_id();

// check whether the primary key already exists.
std::string check_id = get_id_by_primary_key_value(vec[m_primary_key_index]);
if(!check_id.empty()){

return false;

}

// redis string type primary key to id index.
//LOG_DEBUG << m_table_name + ":" + m_records[m_primary_key_index] + ":" + vec[m_primary_key_index];
m_redis_client.set(m_table_name + ":" + m_records[m_primary_key_index] + ":" + vec[m_primary_key_index], get_id);

// redis set type to save id.
std::vector id_vec = {get_id};
m_redis_client.sadd(m_ids, id_vec);

// redis hash type to save records key-value.
std::vector> entitys_pair_vec;

for(std::size_t i = 0; i < m_records_count; i++){

entitys_pair_vec.emplace_back(make_pair(m_records[i], vec[i]));

}

m_redis_client.hmset(m_table_name + ":" + get_id, entitys_pair_vec);

m_redis_client.sync_commit();

return true;
}

table::entitys_t table::get_entitys_by_primary_key_value(const std::string& primary_key_value){
std::string id = get_id_by_primary_key_value(m_table_name + ":" + m_records[m_primary_key_index] + ":" + primary_key_value);

if(id == ""){

static entitys_t static_empty_entitys_vec;
return static_empty_entitys_vec;
LOG_ERROR << "no this entitys";

}

entitys_t vec;

std::future reply = m_redis_client.hgetall(m_table_name + ":" + id);
m_redis_client.sync_commit();

std::vector v = reply.get().as_array();
auto iter = v.begin();
for(iter++; iter < v.end(); iter += 2){

//LOG_DEBUG << (*iter).as_string();
vec.emplace_back((*iter).as_string());

}

return std::move(vec);
}

int main()
{
table accounts_info;
table::records_t records_vec = {"id", "accounts", "password", "nick_name"};
accounts_info.create("sip:accounts_info", records_vec, "accounts");

table::entitys_t entitys_vec0 = {"0", "ailu_0", "123", "sola_0"};
accounts_info.insert(entitys_vec0);

table::entitys_t entitys_vec1 = {"1", "ailu_1", "123", "sola_1"};
accounts_info.insert(entitys_vec1);

table::entitys_t entitys_vec2 = {"2", "ailu_2", "123", "sola_2"};
accounts_info.insert(entitys_vec2);

table::entitys_t entitys_vec3 = {"3", "ailu_3", "123", "sola_3"};
accounts_info.insert(entitys_vec3);

table::entitys_t ailu_1_accounts = accounts_info.get_entitys_by_primary_key_value("ailu_1");

auto it = ailu_1_accounts.begin();
while(it != ailu_1_accounts.end()){

std::cout << *it << std::endl;
it++;

}

getchar();
return 0;
}
Alt text

Alt text

小结
目前给出了redis增查简单设计方法,更新和删除也是通过redis的基本方法对应设计即可,这里不再详述。
此外,可以看出redis的数据库设计还是比较灵活的,如何设计出最适合我们场景需求且高效的正是它难点所在。

作者 —— 艾露米婭娜

出处:http://www.cnblogs.com/ailumiyana/

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
iOS数据持久化-SQLite数据库使用详解
<h1><strong>使用SQLite数据库</strong></h1> <h2><strong>创建数据库</strong></h2> <p>创建数据库过程需要3个步骤:</p> <p>1、使用sqlite3_open函数打开数据库;</p> <p>2、使用sqlite3_exec函数执行Create Table语句,创建数据库表;</p> <p>3、使用sqlite3_close函数释放
967 0
使用Redis搭建持久化K-V存储
最近在项目中需要在多机之间共享一些集合,Hash等有类型的数据结构,如果基于Mysql来存储的话需要预先定义一系列表结构并维护表结构和数据结构的一致性,后续还需要根据时间对数据库做旧数据清理工作,所以开始调研一些能满足下列需求的存储引擎。 具有高可用,持久化的特性。 数据可以设置失效时间,方便自动数据清理。 支持常用数据结构,如集合,有序集合,Hash map,列表等。 支持事务操作,
4329 0
如何使用SecureCRT连接ubuntu
1. 首先要明白什么是ssh? 可以把ssh看做是telnet的加强版,telnet的密码和信息都是不加密的,而ssh则加密。 .2. 开启ubuntu上的ssh功能 先安装,安装后就自动开启了.
860 0
对象的继承关系在数据库中的实现方式和PowerDesigner设计
原文:对象的继承关系在数据库中的实现方式和PowerDesigner设计 在面向对象的编程中,使用对象的继承是一个非常普遍的做法,但是在关系数据库管理系统RDBMS中,使用的是外键表示实体(表)之间的关系,那么对于继承关系,该怎么在RDBMS中表示呢?一般来说有3种实现方式: Concrete ...
769 0
【需求设计】从一个小需求感受Redis的独特魅力
从一个小小的需求看Redis在实际项目是如何使用的
442 0
云计算是否真的抛弃关系数据库了
本文讲的是云计算是否真的抛弃关系数据库了,“在云计算计划里将找不到关系数据库的影子,这并非偶然,因为关系数据库不适合用于云计算环境“Geir Magnusson,10Gen工程副总裁这样认为。10Gen是一家按需平台服务供应商。
967 0
Node.js使用mongodb操作MongoDB数据库
Node.js使用mongodb操作MongoDB数据库
24 0
+关注
优惠码优惠
阿里云优惠码阿里云推荐券bieryun.com
176
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
文娱运维技术
立即下载
《SaaS模式云原生数据仓库应用场景实践》
立即下载
《看见新力量:二》电子书
立即下载