提交 bac441b3 编写于 作者: B Benguang Zhao

fix: create database with wal_retention_period in tmq_taosx_ci.c

上级 19883fde
...@@ -441,7 +441,7 @@ int32_t init_env() { ...@@ -441,7 +441,7 @@ int32_t init_env() {
taos_free_result(pRes); taos_free_result(pRes);
char sql[128] = {0}; char sql[128] = {0};
snprintf(sql, 128, "create database if not exists db_taosx vgroups %d", g_conf.dstVgroups); snprintf(sql, 128, "create database if not exists db_taosx vgroups %d wal_retention_period 3600", g_conf.dstVgroups);
pRes = taos_query(pConn, sql); pRes = taos_query(pConn, sql);
if (taos_errno(pRes) != 0) { if (taos_errno(pRes) != 0) {
printf("error in create db_taosx, reason:%s\n", taos_errstr(pRes)); printf("error in create db_taosx, reason:%s\n", taos_errstr(pRes));
...@@ -470,7 +470,7 @@ int32_t init_env() { ...@@ -470,7 +470,7 @@ int32_t init_env() {
} }
taos_free_result(pRes); taos_free_result(pRes);
snprintf(sql, 128, "create database if not exists abc1 vgroups %d", g_conf.srcVgroups); snprintf(sql, 128, "create database if not exists abc1 vgroups %d wal_retention_period 3600", g_conf.srcVgroups);
pRes = taos_query(pConn, sql); pRes = taos_query(pConn, sql);
if (taos_errno(pRes) != 0) { if (taos_errno(pRes) != 0) {
printf("error in create db, reason:%s\n", taos_errstr(pRes)); printf("error in create db, reason:%s\n", taos_errstr(pRes));
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册