Merge pull request #14975 from taosdata/fix/TD-17339

fix(driver): jdbc get meta

source/client/jni/com_taosdata_jdbc_tmq_TMQConnector.h

@@ -161,7 +161,7 @@ JNIEXPORT jstring JNICALL Java_com_taosdata_jdbc_tmq_TMQConnector_tmqGetTableNam
  * Signature: (JJLcom/taosdata/jdbc/TSDBResultSetBlockData;ILjava/util/List;)I
  */
 JNIEXPORT jint JNICALL Java_com_taosdata_jdbc_tmq_TMQConnector_fetchRawBlockImp(JNIEnv *, jobject, jlong, jlong,
-                                                                                jobject, jint, jobject);
+                                                                                jobject, jobject);
 
 #ifdef __cplusplus
 }

source/client/src/TMQConnector.c

@@ -278,7 +278,7 @@ JNIEXPORT jstring JNICALL Java_com_taosdata_jdbc_tmq_TMQConnector_tmqGetTableNam
 }
 
 JNIEXPORT jint JNICALL Java_com_taosdata_jdbc_tmq_TMQConnector_fetchRawBlockImp(JNIEnv *env, jobject jobj, jlong con,
-                                                                                jlong res, jobject rowobj, jint flag,
+                                                                                jlong res, jobject rowobj,
                                                                                 jobject arrayListObj) {
   TAOS   *tscon = (TAOS *)con;
   int32_t code = check_for_params(jobj, con, res);
@@ -309,7 +309,6 @@ JNIEXPORT jint JNICALL Java_com_taosdata_jdbc_tmq_TMQConnector_fetchRawBlockImp(
 
   TAOS_FIELD *fields = taos_fetch_fields(tres);
   jniDebug("jobj:%p, conn:%p, resultset:%p, fields size is %d", jobj, tscon, tres, numOfFields);
-  if (flag) {
   for (int i = 0; i < numOfFields; ++i) {
     jobject metadataObj = (*env)->NewObject(env, g_metadataClass, g_metadataConstructFp);
     (*env)->SetIntField(env, metadataObj, g_metadataColtypeField, fields[i].type);
@@ -319,7 +318,6 @@ JNIEXPORT jint JNICALL Java_com_taosdata_jdbc_tmq_TMQConnector_fetchRawBlockImp(
     (*env)->SetObjectField(env, metadataObj, g_metadataColnameField, metadataObjColname);
     (*env)->CallBooleanMethod(env, arrayListObj, g_arrayListAddFp, metadataObj);
   }
-  }
 
   (*env)->CallVoidMethod(env, rowobj, g_blockdataSetNumOfRowsFp, (jint)numOfRows);
   (*env)->CallVoidMethod(env, rowobj, g_blockdataSetNumOfColsFp, (jint)numOfFields);