Skip to content

Commit e988dca

Browse files
eedalongeedalong
authored
Merge pull request #19 from eedalong/develop
Develop
2 parents 4154a46 + 03d2f43 commit e988dca

File tree

6 files changed

+331
-102
lines changed

6 files changed

+331
-102
lines changed

‎client/Session.cs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -694,7 +694,7 @@ public int execute_non_query_statement(string sql){
694694

695695
public byte[] value_to_bytes(List<TSDataType> data_types, List<string> values){
696696

697-
ByteBuffer buffer = new ByteBuffer(new byte[]{});
697+
ByteBuffer buffer = new ByteBuffer(values.Count);
698698
for(int i = 0;i < data_types.Count(); i++){
699699
buffer.add_char((char)data_types[i]);
700700
switch(data_types[i]){

‎client/SessionTest.cs‎

Lines changed: 191 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -161,6 +161,18 @@ public void TestInsertStrRecord(){
161161
while(res.has_next()){
162162
Console.WriteLine(res.next());
163163
}
164+
165+
// large data test
166+
for(int timestamp = 2; timestamp <=fetch_size * 4; timestamp++){
167+
session.insert_record("root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE", measures, values, timestamp);
168+
}
169+
res = session.execute_query_statement("select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE");
170+
int res_count = 0;
171+
while(res.has_next()){
172+
res.next();
173+
res_count += 1;
174+
}
175+
System.Diagnostics.Debug.Assert(res_count == fetch_size * 4);
164176
session.delete_storage_group("root.97209_TEST_CSHARP_CLIENT_GROUP");
165177
session.close();
166178
Console.WriteLine("TestInsertStrRecord Passed!");
@@ -197,6 +209,18 @@ public void TestInsertRecord(){
197209
while(res.has_next()){
198210
Console.WriteLine(res.next());
199211
}
212+
213+
// large data test
214+
for(int timestamp = 5; timestamp <= fetch_size * 4; timestamp++){
215+
session.insert_record("root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE", measures, values, types, timestamp);
216+
}
217+
res = session.execute_query_statement("select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE");
218+
int res_count = 0;
219+
while(res.has_next()){
220+
res.next();
221+
res_count += 1;
222+
}
223+
System.Diagnostics.Debug.Assert(res_count == fetch_size * 4);
200224
session.delete_storage_group("root.97209_TEST_CSHARP_CLIENT_GROUP");
201225
session.close();
202226
Console.WriteLine("TestInsertRecord Passed!");
@@ -248,6 +272,31 @@ public void TestInsertRecords(){
248272
Console.WriteLine(res.next());
249273
}
250274
Console.WriteLine(status);
275+
276+
// large data test
277+
device_id = new List<string>(){};
278+
values_lst = new List<List<string>>(){};
279+
measurements_lst = new List<List<string>>(){};
280+
datatype_lst = new List<List<TSDataType>>(){};
281+
timestamp_lst = new List<long>(){};
282+
for(int timestamp = 4;timestamp <= fetch_size * 4;timestamp++){
283+
device_id.Add("root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE");
284+
values_lst.Add(new List<string>(){"true", 123.ToString()});
285+
measurements_lst.Add(new List<string>(){"TEST_CSHARP_CLIENT_TS1", "TEST_CSHARP_CLIENT_TS2"});
286+
datatype_lst.Add(new List<TSDataType>(){TSDataType.BOOLEAN, TSDataType.INT32});
287+
timestamp_lst.Add(timestamp);
288+
}
289+
status = session.insert_records(device_id, measurements_lst, values_lst, datatype_lst, timestamp_lst);
290+
res = session.execute_query_statement("select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE");
291+
res.show_table_names();
292+
int record_count = fetch_size * 4;
293+
int res_count = 0;
294+
while(res.has_next()){
295+
res.next();
296+
res_count += 1;
297+
}
298+
System.Diagnostics.Debug.Assert(res_count == record_count);
299+
System.Diagnostics.Debug.Assert(status == 0);
251300
status = session.delete_storage_group("root.97209_TEST_CSHARP_CLIENT_GROUP");
252301
System.Diagnostics.Debug.Assert(status == 0);
253302
session.close();
@@ -282,6 +331,17 @@ public void TestTestInsertRecord(){
282331
while(res.has_next()){
283332
Console.WriteLine(res.next());
284333
}
334+
// large data test
335+
for(int timestamp = 5; timestamp <= fetch_size * 4; timestamp++){
336+
session.test_insert_record("root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE", measures, values, types, timestamp);
337+
}
338+
res = session.execute_query_statement("select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE");
339+
int res_count = 0;
340+
while(res.has_next()){
341+
res.next();
342+
res_count += 1;
343+
}
344+
System.Diagnostics.Debug.Assert(res_count == 0);
285345
status = session.delete_storage_group("root.97209_TEST_CSHARP_CLIENT_GROUP");
286346
System.Diagnostics.Debug.Assert(status == 0);
287347
session.close();
@@ -329,6 +389,29 @@ public void TestTestInsertRecords(){
329389
while(res.has_next()){
330390
Console.WriteLine(res.next());
331391
}
392+
393+
// large data test
394+
device_id = new List<string>(){};
395+
values_lst = new List<List<string>>(){};
396+
measurements_lst = new List<List<string>>(){};
397+
datatype_lst = new List<List<TSDataType>>(){};
398+
timestamp_lst = new List<long>(){};
399+
for(int timestamp = 4;timestamp <= fetch_size * 4;timestamp++){
400+
device_id.Add("root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE");
401+
values_lst.Add(new List<string>(){"true", 123.ToString()});
402+
measurements_lst.Add(new List<string>(){"TEST_CSHARP_CLIENT_TS1", "TEST_CSHARP_CLIENT_TS2"});
403+
datatype_lst.Add(new List<TSDataType>(){TSDataType.BOOLEAN, TSDataType.INT32});
404+
timestamp_lst.Add(timestamp);
405+
}
406+
status = session.test_insert_records(device_id, measurements_lst, values_lst, datatype_lst, timestamp_lst);
407+
res = session.execute_query_statement("select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE");
408+
res.show_table_names();
409+
int res_count = 0;
410+
while(res.has_next()){
411+
res.next();
412+
res_count += 1;
413+
}
414+
System.Diagnostics.Debug.Assert(res_count == 0);
332415
status = session.delete_storage_group("root.97209_TEST_CSHARP_CLIENT_GROUP");
333416
System.Diagnostics.Debug.Assert(status == 0);
334417
session.close();
@@ -371,6 +454,26 @@ public void TestInsertRecordsOfOneDevice(){
371454
while(res.has_next()){
372455
Console.WriteLine(res.next());
373456
}
457+
458+
// large data test
459+
measurements_lst = new List<List<string>>(){};
460+
values_lst = new List<List<string>>(){};
461+
datatype_lst = new List<List<TSDataType>>(){};
462+
timestamp_lst = new List<long>(){};
463+
for(int timestamp = 4; timestamp <= fetch_size * 4;timestamp++){
464+
measurements_lst.Add(new List<string>(){"TEST_CSHARP_CLIENT_TS1", "TEST_CSHARP_CLIENT_TS2", "TEST_CSHARP_CLIENT_TS3", "TEST_CSHARP_CLIENT_TS4", "TEST_CSHARP_CLIENT_TS5", "TEST_CSHARP_CLIENT_TS6"});
465+
values_lst.Add(new List<string>(){"true", 123.ToString(), 456.ToString(), 1.1.ToString(), 10001.1.ToString(), "test_record"});
466+
datatype_lst.Add(new List<TSDataType>(){TSDataType.BOOLEAN, TSDataType.INT32, TSDataType.INT64, TSDataType.DOUBLE, TSDataType.FLOAT, TSDataType.TEXT});
467+
timestamp_lst.Add(timestamp);
468+
}
469+
session.insert_records_of_one_device(device_id, timestamp_lst, measurements_lst, datatype_lst, values_lst);
470+
res = session.execute_query_statement("select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE");
471+
int res_count = 0;
472+
while(res.has_next()){
473+
res.next();
474+
res_count += 1;
475+
}
476+
System.Diagnostics.Debug.Assert(res_count == fetch_size * 4);
374477
status = session.delete_storage_group("root.97209_TEST_CSHARP_CLIENT_GROUP");
375478
System.Diagnostics.Debug.Assert(status == 0);
376479
session.close();
@@ -553,6 +656,24 @@ public void TestInsertTablet(){
553656
while(res.has_next()){
554657
Console.WriteLine(res.next());
555658
}
659+
// large data test
660+
value_lst = new List<List<string>>(){};
661+
timestamp_lst = new List<long>(){};
662+
for (int timestamp = 4; timestamp <= fetch_size * 4; timestamp++){
663+
timestamp_lst.Add(timestamp);
664+
value_lst.Add(new List<string>(){"iotdb", true.ToString(), timestamp.ToString()});
665+
}
666+
tablet = new Tablet(device_id, measurement_lst, datatype_lst, value_lst, timestamp_lst);
667+
status = session.insert_tablet(tablet);
668+
res = session.execute_query_statement("select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE");
669+
res.show_table_names();
670+
int res_count = 0;
671+
while(res.has_next()){
672+
res.next();
673+
res_count += 1;
674+
}
675+
676+
System.Diagnostics.Debug.Assert(res_count == fetch_size * 4);
556677
status = session.delete_storage_group("root.97209_TEST_CSHARP_CLIENT_GROUP");
557678
System.Diagnostics.Debug.Assert(status == 0);
558679
session.close();
@@ -577,6 +698,24 @@ public void TestTestInsertTablet(){
577698
while(res.has_next()){
578699
Console.WriteLine(res.next());
579700
}
701+
702+
// large data test
703+
value_lst = new List<List<string>>(){};
704+
timestamp_lst = new List<long>(){};
705+
for (int timestamp = 4; timestamp <= fetch_size * 4; timestamp++){
706+
timestamp_lst.Add(timestamp);
707+
value_lst.Add(new List<string>(){"iotdb", true.ToString(), timestamp.ToString()});
708+
}
709+
tablet = new Tablet(device_id, measurement_lst, datatype_lst, value_lst, timestamp_lst);
710+
status = session.test_insert_tablet(tablet);
711+
res = session.execute_query_statement("select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE");
712+
res.show_table_names();
713+
int res_count = 0;
714+
while(res.has_next()){
715+
res.next();
716+
res_count += 1;
717+
}
718+
System.Diagnostics.Debug.Assert(res_count == 0);
580719
session.delete_storage_group("root.97209_TEST_CSHARP_CLIENT_GROUP");
581720
System.Diagnostics.Debug.Assert(status == 0);
582721
session.close();
@@ -610,6 +749,32 @@ public void TestInsertTablets(){
610749
while(res.has_next()){
611750
Console.WriteLine(res.next());
612751
}
752+
753+
// large data test
754+
device_id = new List<string>(){};
755+
measurements_lst = new List<List<string>>(){};
756+
values_lst = new List<List<List<string>>>(){};
757+
datatypes_lst = new List<List<TSDataType>>(){};
758+
timestamp_lst = new List<List<long>>(){};
759+
tablets = new List<Tablet>(){};
760+
for(int timestamp = 4;timestamp <= 4 * fetch_size; timestamp++){
761+
device_id.Add("root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE1");
762+
measurements_lst.Add(new List<string>(){"TS1", "TS2", "TS3"});
763+
values_lst.Add(new List<List<string>>(){new List<string>(){"iotdb", true.ToString(), timestamp.ToString()}});
764+
datatypes_lst.Add(new List<TSDataType>(){TSDataType.TEXT, TSDataType.BOOLEAN, TSDataType.INT32});
765+
timestamp_lst.Add(new List<long>(){timestamp});
766+
Tablet tablet = new Tablet(device_id[timestamp-4], measurements_lst[timestamp-4], datatypes_lst[timestamp-4], values_lst[timestamp-4], timestamp_lst[timestamp-4]);
767+
tablets.Add(tablet);
768+
}
769+
session.insert_tablets(tablets);
770+
res = session.execute_query_statement("select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE1");
771+
res.show_table_names();
772+
int res_count = 0;
773+
while(res.has_next()){
774+
res.next();
775+
res_count += 1;
776+
}
777+
System.Diagnostics.Debug.Assert(res_count == fetch_size * 4);
613778
status = session.delete_storage_group("root.97209_TEST_CSHARP_CLIENT_GROUP");
614779
System.Diagnostics.Debug.Assert(status == 0);
615780
session.close();
@@ -643,6 +808,32 @@ public void TestTestInsertTablets(){
643808
while(res.has_next()){
644809
Console.WriteLine(res.next());
645810
}
811+
812+
// large data test
813+
device_id = new List<string>(){};
814+
measurements_lst = new List<List<string>>(){};
815+
values_lst = new List<List<List<string>>>(){};
816+
datatypes_lst = new List<List<TSDataType>>(){};
817+
timestamp_lst = new List<List<long>>(){};
818+
tablets = new List<Tablet>(){};
819+
for(int timestamp = 4;timestamp <= 4 * fetch_size; timestamp++){
820+
device_id.Add("root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE1");
821+
measurements_lst.Add(new List<string>(){"TS1", "TS2", "TS3"});
822+
values_lst.Add(new List<List<string>>(){new List<string>(){"iotdb", true.ToString(), timestamp.ToString()}});
823+
datatypes_lst.Add(new List<TSDataType>(){TSDataType.TEXT, TSDataType.BOOLEAN, TSDataType.INT32});
824+
timestamp_lst.Add(new List<long>(){timestamp});
825+
Tablet tablet = new Tablet(device_id[timestamp-4], measurements_lst[timestamp-4], datatypes_lst[timestamp-4], values_lst[timestamp-4], timestamp_lst[timestamp-4]);
826+
tablets.Add(tablet);
827+
}
828+
session.test_insert_tablets(tablets);
829+
res = session.execute_query_statement("select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE1");
830+
res.show_table_names();
831+
int res_count = 0;
832+
while(res.has_next()){
833+
res.next();
834+
res_count += 1;
835+
}
836+
System.Diagnostics.Debug.Assert(res_count == 0);
646837
session.delete_storage_group("root.97209_TEST_CSHARP_CLIENT_GROUP");
647838
session.close();
648839
Console.WriteLine("TestTestInsertTablets Passed!");

0 commit comments

Comments
 (0)