From 6dcd5cfae921741b94796bbcd610a66a9dc54a6c Mon Sep 17 00:00:00 2001
From: dmchen <cademfly@hotmail.com>
Date: Thu, 14 Sep 2023 15:21:59 +0800
Subject: [PATCH] null sql

---
 source/common/src/tmsg.c | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/source/common/src/tmsg.c b/source/common/src/tmsg.c
index 4b597d0a0f..b15e5dcb77 100644
--- a/source/common/src/tmsg.c
+++ b/source/common/src/tmsg.c
@@ -45,7 +45,9 @@
 #define ENCODESQL()                                              \
   do {                                                           \
     if (tEncodeI32(&encoder, pReq->sqlLen) < 0) return -1;       \
-    if (tEncodeCStr(&encoder, pReq->sql) < 0) return -1;         \
+    if (pReq->sqlLen > 0){                                       \
+      if (tEncodeCStr(&encoder, pReq->sql) < 0) return -1;       \
+    }                                                            \
   } while (0)
 
 #define FREESQL()                     \
@@ -6843,7 +6845,9 @@ int tEncodeSVCreateTbReq(SEncoder *pCoder, const SVCreateTbReq *pReq) {
     ASSERT(0);
   }
   if (tEncodeI32(pCoder, pReq->sqlLen) < 0) return -1;
-  if (tEncodeCStr(pCoder, pReq->sql) < 0) return -1;
+  if(pReq->sqlLen > 0) {
+    if (tEncodeCStr(pCoder, pReq->sql) < 0) return -1;
+  }
 
   tEndEncode(pCoder);
   return 0;