change gen rule
This commit is contained in:
parent
dea0e3c261
commit
335867cd92
|
@ -282,7 +282,7 @@ void veriry_stmt(TAOS* taos) {
|
||||||
int32_t* bin_len = malloc(sizeof(int32_t) * 10);
|
int32_t* bin_len = malloc(sizeof(int32_t) * 10);
|
||||||
int32_t* blob_len = malloc(sizeof(int32_t) * 10);
|
int32_t* blob_len = malloc(sizeof(int32_t) * 10);
|
||||||
|
|
||||||
TAOS_STMT* stmt = taos_stmt_init(taos);
|
TAOS_STMT* stmt = taos_stmt_init_with_reqid(taos, genReqid());
|
||||||
TAOS_MULTI_BIND params[10];
|
TAOS_MULTI_BIND params[10];
|
||||||
char is_null[10] = {0};
|
char is_null[10] = {0};
|
||||||
|
|
||||||
|
|
|
@ -286,7 +286,7 @@ void *createRequest(uint64_t connId, int32_t type, int64_t reqid) {
|
||||||
}
|
}
|
||||||
|
|
||||||
pRequest->resType = RES_TYPE__QUERY;
|
pRequest->resType = RES_TYPE__QUERY;
|
||||||
pRequest->requestId = reqid <= 0 ? generateRequestId() : reqid;
|
pRequest->requestId = reqid == 0 ? generateRequestId() : reqid;
|
||||||
pRequest->metric.start = taosGetTimestampUs();
|
pRequest->metric.start = taosGetTimestampUs();
|
||||||
|
|
||||||
pRequest->body.resInfo.convertUcs4 = true; // convert ucs4 by default
|
pRequest->body.resInfo.convertUcs4 = true; // convert ucs4 by default
|
||||||
|
|
|
@ -14,7 +14,7 @@ static int32_t stmtCreateRequest(STscStmt* pStmt) {
|
||||||
if (pStmt->exec.pRequest == NULL) {
|
if (pStmt->exec.pRequest == NULL) {
|
||||||
code = buildRequest(pStmt->taos->id, pStmt->sql.sqlStr, pStmt->sql.sqlLen, NULL, false, &pStmt->exec.pRequest,
|
code = buildRequest(pStmt->taos->id, pStmt->sql.sqlStr, pStmt->sql.sqlLen, NULL, false, &pStmt->exec.pRequest,
|
||||||
pStmt->reqid);
|
pStmt->reqid);
|
||||||
if (pStmt->reqid > 0) {
|
if (pStmt->reqid != 0) {
|
||||||
pStmt->reqid++;
|
pStmt->reqid++;
|
||||||
}
|
}
|
||||||
if (TSDB_CODE_SUCCESS == code) {
|
if (TSDB_CODE_SUCCESS == code) {
|
||||||
|
|
Loading…
Reference in New Issue