This commit is contained in:
dmchen 2023-09-14 15:21:59 +08:00
parent 231ba12f70
commit 6dcd5cfae9
1 changed files with 6 additions and 2 deletions

View File

@ -45,7 +45,9 @@
#define ENCODESQL() \ #define ENCODESQL() \
do { \ do { \
if (tEncodeI32(&encoder, pReq->sqlLen) < 0) return -1; \ 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) } while (0)
#define FREESQL() \ #define FREESQL() \
@ -6843,7 +6845,9 @@ int tEncodeSVCreateTbReq(SEncoder *pCoder, const SVCreateTbReq *pReq) {
ASSERT(0); ASSERT(0);
} }
if (tEncodeI32(pCoder, pReq->sqlLen) < 0) return -1; 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); tEndEncode(pCoder);
return 0; return 0;