AJ-518: fix deserialize get vector logic;

chengyitian · chengyitian · commit 9d81e0eddea7 · 2024-01-15T10:22:31.000+08:00
diff --git a/src/com/xxdb/streaming/client/StreamDeserializer.java b/src/com/xxdb/streaming/client/StreamDeserializer.java
@@ -148,7 +148,7 @@ public BasicAnyVector parse(byte[] data) throws Exception {
 //                ret.setEntity(i, basicEntityFactory.createEntity(Entity.DATA_FORM.DF_SCALAR, colTypes_.get(i), dataStream, false));
             for (int i = 0; i < columns; ++i) {
                 if (colTypes_.get(i).getValue() >= Entity.DATA_TYPE.DT_BOOL_ARRAY.getValue() && colTypes_.get(i).getValue() <= Entity.DATA_TYPE.DT_DECIMAL128_ARRAY.getValue()) {
-                    ret.setEntity(i, new BasicArrayVector(colTypes_.get(i), dataStream, 1, 0, -1));
+                    ret.setEntity(i, (new BasicArrayVector(colTypes_.get(i), dataStream, 1, 0, -1)).get(0));
                 } else {
                     ret.setEntity(i, basicEntityFactory.createEntity(Entity.DATA_FORM.DF_SCALAR, colTypes_.get(i), dataStream, false));
                 }

Original file line number	Diff line number	Diff line change
`@@ -148,7 +148,7 @@ public BasicAnyVector parse(byte[] data) throws Exception {`
`148`	`148`	`// ret.setEntity(i, basicEntityFactory.createEntity(Entity.DATA_FORM.DF_SCALAR, colTypes_.get(i), dataStream, false));`
`149`	`149`	`for (int i = 0; i < columns; ++i) {`
`150`	`150`	`if (colTypes_.get(i).getValue() >= Entity.DATA_TYPE.DT_BOOL_ARRAY.getValue() && colTypes_.get(i).getValue() <= Entity.DATA_TYPE.DT_DECIMAL128_ARRAY.getValue()) {`
`151`		`- ret.setEntity(i, new BasicArrayVector(colTypes_.get(i), dataStream, 1, 0, -1));`
	`151`	`+ ret.setEntity(i, (new BasicArrayVector(colTypes_.get(i), dataStream, 1, 0, -1)).get(0));`
`152`	`152`	`} else {`
`153`	`153`	`ret.setEntity(i, basicEntityFactory.createEntity(Entity.DATA_FORM.DF_SCALAR, colTypes_.get(i), dataStream, false));`
`154`	`154`	`}`