Fix issue with inproper ndjson check in auto schema

manticoresoftware · Jan 17, 2025 · 31f1c0d · 31f1c0d
1 parent 9a30b3d
commit 31f1c0d
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/src/Plugin/Insert/QueryParser/JSONParser.php b/src/Plugin/Insert/QueryParser/JSONParser.php
@@ -27,9 +27,8 @@ abstract class JSONParser extends BaseParser implements JSONParserInterface {
 	 */
 	public function parse($query): array {
 		$this->cols = $this->colTypes = [];
-		$struct = Struct::fromJson($query);
-		$row = $struct->toArray();
-		if (!$row || !is_array($row)) {
+		$isNdJson = !Struct::isValid($query);
+		if ($isNdJson) {
 			// checking if query has ndjson format
 			$queries = static::parseNdJSON($query);
 			foreach ($queries as $query) {
@@ -42,6 +41,8 @@ public function parse($query): array {
 				$this->parseJSONRow($row);
 			}
 		} else {
+			$struct = Struct::fromJson($query);
+			$row = $struct->toArray();
 			$this->parseJSONRow($row);
 		}