Skip to content

Commit d1fb813

Browse files
author
hongwei.quhw
committed
split|defaultvalue testcase
1 parent d4c5793 commit d1fb813

File tree

1 file changed

+14
-1
lines changed

1 file changed

+14
-1
lines changed

rdf-file-core/src/test/java/com/alipay/rdf/file/codec/RowNosqlKVCodecWriterTest.java

Lines changed: 14 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22

33
import com.alipay.rdf.file.exception.RdfFileException;
44
import com.alipay.rdf.file.interfaces.FileFactory;
5+
import com.alipay.rdf.file.interfaces.FileReader;
56
import com.alipay.rdf.file.interfaces.FileWriter;
67
import com.alipay.rdf.file.model.FileConfig;
78
import com.alipay.rdf.file.model.StorageConfig;
@@ -291,8 +292,20 @@ public void test3() throws Exception {
291292
Assert.assertEquals("|fileEnd:OFDCFEND|",reader.readLine());
292293

293294
Assert.assertNull(reader.readLine());
294-
295295
reader.close();
296+
297+
FileReader fileReader = FileFactory.createReader(config);
298+
head = fileReader.readHead(HashMap.class);
299+
Assert.assertEquals(2L, head.get("totalCount"));
300+
301+
body = fileReader.readRow(HashMap.class);
302+
Assert.assertNull(body.get("seq"));
303+
Assert.assertEquals("303", body.get("instSeq"));
304+
Assert.assertNull(body.get("memo"));
305+
306+
Map<String, Object> tail = fileReader.readTail(HashMap.class);
307+
Assert.assertEquals("OFDCFEND", tail.get("fileEnd"));
308+
fileReader.close();
296309
}
297310

298311
@After

0 commit comments

Comments
 (0)