From da73c0869b42c3c16cce0cc51cf9ebe9bd13963b Mon Sep 17 00:00:00 2001
From: liuyq-617 <yqliu@taosdata.com>
Date: Wed, 3 Mar 2021 10:56:06 +0800
Subject: [PATCH] [TD-3151]<feature> support config cachelast

---
 src/kit/taosdemo/taosdemo.c | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

diff --git a/src/kit/taosdemo/taosdemo.c b/src/kit/taosdemo/taosdemo.c
index 78a0593e61..9549c72429 100644
--- a/src/kit/taosdemo/taosdemo.c
+++ b/src/kit/taosdemo/taosdemo.c
@@ -335,6 +335,7 @@ typedef struct SDbCfg_S {
   int       maxRows;
   int       comp;
   int       walLevel;
+  int       cacheLast;
   int       fsync;  
   int       replica;
   int       update;
@@ -2022,6 +2023,9 @@ static int createDatabases() {
     if (g_Dbs.db[i].dbCfg.walLevel > 0) {
       dataLen += snprintf(command + dataLen, BUFFER_SIZE - dataLen, "wal %d ", g_Dbs.db[i].dbCfg.walLevel);
     }
+    if (g_Dbs.db[i].dbCfg.cacheLast > 0) {
+      dataLen += snprintf(command + dataLen, BUFFER_SIZE - dataLen, "cachelast %d ", g_Dbs.db[i].dbCfg.cacheLast);
+    }
     if (g_Dbs.db[i].dbCfg.fsync > 0) {
       dataLen += snprintf(command + dataLen, BUFFER_SIZE - dataLen, "fsync %d ", g_Dbs.db[i].dbCfg.fsync);
     }
@@ -2722,6 +2726,16 @@ static bool getMetaFromInsertJsonFile(cJSON* root) {
      goto PARSE_OVER;
     }
 
+    cJSON* cacheLast= cJSON_GetObjectItem(dbinfo, "cachelast");
+    if (cacheLast && cacheLast->type == cJSON_Number) {
+      g_Dbs.db[i].dbCfg.cacheLast = cacheLast->valueint;
+    } else if (!cacheLast) {
+      g_Dbs.db[i].dbCfg.cacheLast = -1;
+    } else {
+     printf("failed to read json, cacheLast not found");
+     goto PARSE_OVER;
+    }
+
     cJSON* quorum= cJSON_GetObjectItem(dbinfo, "quorum");
     if (quorum && quorum->type == cJSON_Number) {
       g_Dbs.db[i].dbCfg.quorum = quorum->valueint;
-- 
GitLab