feat: add async logic for schemaless
This commit is contained in:
parent
9333120d42
commit
2cb998a566
|
@ -199,10 +199,7 @@ TAOS_RES *taos_query(TAOS *taos, const char *sql) {
|
||||||
taos_query_a(pTscObj, sql, syncQueryFn, param);
|
taos_query_a(pTscObj, sql, syncQueryFn, param);
|
||||||
tsem_wait(¶m->sem);
|
tsem_wait(¶m->sem);
|
||||||
|
|
||||||
TAOS_RES *request = param->pRequest;
|
return param->pRequest;
|
||||||
tsem_destroy(¶m->sem);
|
|
||||||
taosMemoryFree(param);
|
|
||||||
return request;
|
|
||||||
#else
|
#else
|
||||||
size_t sqlLen = strlen(sql);
|
size_t sqlLen = strlen(sql);
|
||||||
if (sqlLen > (size_t)TSDB_MAX_ALLOWED_SQL_LEN) {
|
if (sqlLen > (size_t)TSDB_MAX_ALLOWED_SQL_LEN) {
|
||||||
|
|
|
@ -72,7 +72,7 @@ for (int i = 1; i < keyLen; ++i) { \
|
||||||
#define NCHAR_ADD_LEN 3 // L"nchar" 3 means L" "
|
#define NCHAR_ADD_LEN 3 // L"nchar" 3 means L" "
|
||||||
|
|
||||||
#define MAX_RETRY_TIMES 5
|
#define MAX_RETRY_TIMES 5
|
||||||
#define LINE_BATCH 20
|
#define LINE_BATCH 20000
|
||||||
//=================================================================================================
|
//=================================================================================================
|
||||||
typedef TSDB_SML_PROTOCOL_TYPE SMLProtocolType;
|
typedef TSDB_SML_PROTOCOL_TYPE SMLProtocolType;
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue