如何使用redis設計關係資料庫

来源:https://www.cnblogs.com/ailumiyana/archive/2019/04/07/10663833.html
-Advertisement-
Play Games

redis設計關係資料庫 [toc] 前言 最近需要一張用戶信息表,因為數據量並不大,想先放在記憶體中,等需求變更了,再移到磁碟上,或者往mysql塞,那麼問題來了,怎麼用redis的數據類型設計一個關係資料庫呢。 redis只有key value這種存儲結構,如果想利用它做成想其他資料庫一樣具備 等 ...


目錄

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<std::string> records_t;

  //! vector type to save table records entitys.
  typedef std::vector<std::string> 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<cpp_redis::reply> 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<std::string> id_vec = {get_id};
  m_redis_client.sadd(m_ids, id_vec);

  // redis hash type to save records key-value.
  std::vector<std::pair<std::string, std::string>> 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<cpp_redis::reply> reply = m_redis_client.hgetall(m_table_name + ":" + id);
  m_redis_client.sync_commit();

  std::vector<cpp_redis::reply> 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的資料庫設計還是比較靈活的,如何設計出最適合我們場景需求且高效的正是它難點所在。


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 中介者模式簡介 提供一個中介對象出來,用於封裝一系列對象的交互,從而使各對象不需要直接交互,進一步降低了對象間的耦合度。這是一種行為型設計模式。 由此可見,中介者模式主要解決的是對象間所存在的大量關係,我們都知道,對象間一旦關聯緊密,必然會導致系統的複雜性增加,一旦某個對象有所修改,其關聯對象也有可 ...
  • 如果您的孩子不適應編譯型語言怎麼辦? 如果您的孩子貪玩不想花多時間在編程上怎麼辦? 如果您還沒有孩子怎麼辦? 如果您夜晚兼職覺不夠睡又怎麼辦? 不妨試試 “ 拍 簧 片 ”。 媽了巴子的有點麻煩,但別怕,接下來我將用一把梭帶你把這個“場子“搭起來: 使用VSCode搭建“拍簧片”環境: 1、裝VsC ...
  • 項目說明 1. 目前支持WebForm文件下載,後續支持Mvc 2. 支持下載文件加密以及下載限速 3. 項目源碼: "MasterChief.DotNet.Framework.Download" 4. Nuget:Install Package MasterChief.DotNet.Framewo ...
  • 單例模式簡介 單例模式是GOF 23個設計模式中最簡單的模式了,它提供了一種創建唯一對象的最佳實現,註意此處的簡單隻是表述和意圖很簡單,但是實現起來,尤其是實現一個優美的單例模式卻沒有那麼簡單。 單例模式歸根結底就是要確保一個類只有一個實例,並提供一個全局方式來訪問該實例。具體而言,這種模式涉及到一 ...
  • linux 搭建squid代理伺服器 實驗環境: 一臺linux搭建Web伺服器,充當內網web伺服器(同時充當內網客戶端) 202.100.10.100 一臺linux系統充當網關伺服器,兩個網卡,開啟路由轉發 192.168.133.131和202.100.10.1 一臺linux搭建Web服務 ...
  • 在《Linux設備驅動程式》一書中讀到的內核模塊編譯Makefile,不是非常理解,在查詢很多資料後,在這裡做個總結。 書中Makefile代碼: 代碼解析: 1. 判斷變數KERNELRELEASE是否設置,該變數在linux內核頂層Makefile中會被設置。當然第一次執行makefile時,K ...
  • 1.下載npm軟體包 點擊鏈接進入下載頁面:npm下載 2.下載完成後將壓縮包放到家目錄下就可以(也可以放到其他地方) 3.解壓 tar -zxvf 壓縮包名稱,解壓後你會得到一個文件夾,進入後是這樣的。 4.然後我們進入scripts這個目錄。 可以看到這裡有一個文件的名稱叫install.sh. ...
  • 起因: 串口IAP升級在正點原子的常式中有講解,正點原子的方法是:在RAM中開闢一個120K的數據空間,用來存放bin文件,bin文件通過串口一次性發送到單片機,然後再實現程式的跳轉。但是這種方法在實際項目中並不實用,因為沒用文件校驗,不能保證bin文件的完整性,如果貿然跳轉,將會是設備陷入到永遠無 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...