commit
98eefc9422
|
@ -261,11 +261,11 @@ JNIEXPORT jint JNICALL Java_com_taosdata_jdbc_TSDBJNIConnector_executeQueryImp(J
|
||||||
//todo handle error
|
//todo handle error
|
||||||
}
|
}
|
||||||
|
|
||||||
jniTrace("jobj:%p, conn:%p, sql:%s", jobj, tscon, sql);
|
jniTrace("jobj:%p, conn:%p, sql:%s", jobj, tscon, dst);
|
||||||
|
|
||||||
int code = taos_query(tscon, dst);
|
int code = taos_query(tscon, dst);
|
||||||
if (code != 0) {
|
if (code != 0) {
|
||||||
jniError("jobj:%p, conn:%p, code:%d, msg:%s, sql:%s", jobj, tscon, code, taos_errstr(tscon), dst);
|
jniError("jobj:%p, conn:%p, code:%d, msg:%s", jobj, tscon, code, taos_errstr(tscon));
|
||||||
free(dst);
|
free(dst);
|
||||||
return JNI_TDENGINE_ERROR;
|
return JNI_TDENGINE_ERROR;
|
||||||
} else {
|
} else {
|
||||||
|
@ -274,9 +274,9 @@ JNIEXPORT jint JNICALL Java_com_taosdata_jdbc_TSDBJNIConnector_executeQueryImp(J
|
||||||
|
|
||||||
if (pSql->cmd.command == TSDB_SQL_INSERT) {
|
if (pSql->cmd.command == TSDB_SQL_INSERT) {
|
||||||
affectRows = taos_affected_rows(tscon);
|
affectRows = taos_affected_rows(tscon);
|
||||||
jniTrace("jobj:%p, conn:%p, code:%d, affect rows:%d", jobj, tscon, code, affectRows, dst);
|
jniTrace("jobj:%p, conn:%p, code:%d, affect rows:%d", jobj, tscon, code, affectRows);
|
||||||
} else {
|
} else {
|
||||||
jniTrace("jobj:%p, conn:%p, code:%d", jobj, tscon, code, dst);
|
jniTrace("jobj:%p, conn:%p, code:%d", jobj, tscon, code);
|
||||||
}
|
}
|
||||||
|
|
||||||
free(dst);
|
free(dst);
|
||||||
|
@ -678,4 +678,4 @@ JNIEXPORT jint JNICALL Java_com_taosdata_jdbc_TSDBJNIConnector_validateCreateTab
|
||||||
|
|
||||||
JNIEXPORT jstring JNICALL Java_com_taosdata_jdbc_TSDBJNIConnector_getTsCharset(JNIEnv *env, jobject jobj) {
|
JNIEXPORT jstring JNICALL Java_com_taosdata_jdbc_TSDBJNIConnector_getTsCharset(JNIEnv *env, jobject jobj) {
|
||||||
return (*env)->NewStringUTF(env, (const char *)tsCharset);
|
return (*env)->NewStringUTF(env, (const char *)tsCharset);
|
||||||
}
|
}
|
||||||
|
|
|
@ -112,8 +112,8 @@ static tSQLSyntaxNode *tSQLSyntaxNodeCreate(SSchema *pSchema, int32_t numOfCols,
|
||||||
tSQLSyntaxNode *pNode = NULL;
|
tSQLSyntaxNode *pNode = NULL;
|
||||||
|
|
||||||
if (pToken->type == TK_ID || pToken->type == TK_TBNAME) {
|
if (pToken->type == TK_ID || pToken->type == TK_TBNAME) {
|
||||||
|
int32_t i = 0;
|
||||||
if (pToken->type == TK_ID) {
|
if (pToken->type == TK_ID) {
|
||||||
int32_t i = 0;
|
|
||||||
do {
|
do {
|
||||||
size_t len = strlen(pSchema[i].name);
|
size_t len = strlen(pSchema[i].name);
|
||||||
if (strncmp(pToken->z, pSchema[i].name, pToken->n) == 0 && pToken->n == len) break;
|
if (strncmp(pToken->z, pSchema[i].name, pToken->n) == 0 && pToken->n == len) break;
|
||||||
|
@ -326,8 +326,8 @@ static tSQLSyntaxNode *createSyntaxTree(SSchema *pSchema, int32_t numOfCols, cha
|
||||||
uint8_t localOptr = getBinaryExprOptr(&t0);
|
uint8_t localOptr = getBinaryExprOptr(&t0);
|
||||||
if (localOptr == 0) {
|
if (localOptr == 0) {
|
||||||
pError("not support binary operator:%d", t0.type);
|
pError("not support binary operator:%d", t0.type);
|
||||||
|
free(pBinExpr);
|
||||||
return NULL;
|
return NULL;
|
||||||
free(pBinExpr)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
return parseRemainStr(str, pBinExpr, pSchema, localOptr, numOfCols, i);
|
return parseRemainStr(str, pBinExpr, pSchema, localOptr, numOfCols, i);
|
||||||
|
@ -936,4 +936,4 @@ void tQueryResultClean(tQueryResultset *pRes) {
|
||||||
|
|
||||||
tfree(pRes->pRes);
|
tfree(pRes->pRes);
|
||||||
pRes->num = 0;
|
pRes->num = 0;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue