Skip to content

Commit e0934c2

Browse files
eedalongeedalong
authored
Merge pull request #58 from eedalong/mwx/change_name
fix: change function names to pascal style
2 parents 1ebfbfd + 04f3990 commit e0934c2

File tree

7 files changed

+156
-156
lines changed

7 files changed

+156
-156
lines changed

‎samples/Apache.IoTDB.Samples/SessioonPoolTest.cs‎

Lines changed: 50 additions & 50 deletions
Original file line numberDiff line numberDiff line change
@@ -224,8 +224,8 @@ public async Task TestInsertStrRecord()
224224
System.Diagnostics.Debug.Assert(status == 0);
225225
var res = await session_pool.ExecuteQueryStatementAsync(
226226
"select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE where time<2");
227-
res.show_table_names();
228-
while (res.has_next()) Console.WriteLine(res.Next());
227+
res.ShowTableNames();
228+
while (res.HasNext()) Console.WriteLine(res.Next());
229229

230230
await res.Close();
231231

@@ -246,7 +246,7 @@ public async Task TestInsertStrRecord()
246246
res = await session_pool.ExecuteQueryStatementAsync(
247247
"select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE");
248248
var res_count = 0;
249-
while (res.has_next())
249+
while (res.HasNext())
250250
{
251251
res.Next();
252252
res_count += 1;
@@ -324,8 +324,8 @@ public async Task TestInsertRecords()
324324
System.Diagnostics.Debug.Assert(status == 0);
325325
var res = await session_pool.ExecuteQueryStatementAsync(
326326
"select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE where time<10");
327-
res.show_table_names();
328-
while (res.has_next()) Console.WriteLine(res.Next());
327+
res.ShowTableNames();
328+
while (res.HasNext()) Console.WriteLine(res.Next());
329329

330330
await res.Close();
331331
Console.WriteLine(status);
@@ -350,10 +350,10 @@ public async Task TestInsertRecords()
350350
Task.WaitAll(tasks.ToArray());
351351
res = await session_pool.ExecuteQueryStatementAsync(
352352
"select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE");
353-
res.show_table_names();
353+
res.ShowTableNames();
354354
var record_count = fetch_size * processed_size;
355355
var res_count = 0;
356-
while (res.has_next())
356+
while (res.HasNext())
357357
{
358358
res.Next();
359359
res_count += 1;
@@ -425,8 +425,8 @@ await session_pool.CreateTimeSeries(
425425
System.Diagnostics.Debug.Assert(status == 0);
426426
var res = await session_pool.ExecuteQueryStatementAsync(
427427
"select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE where time<10");
428-
res.show_table_names();
429-
while (res.has_next()) Console.WriteLine(res.Next());
428+
res.ShowTableNames();
429+
while (res.HasNext()) Console.WriteLine(res.Next());
430430

431431
await res.Close();
432432
// large data test
@@ -447,7 +447,7 @@ await session_pool.CreateTimeSeries(
447447
res = await session_pool.ExecuteQueryStatementAsync(
448448
"select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE");
449449
var res_count = 0;
450-
while (res.has_next())
450+
while (res.HasNext())
451451
{
452452
res.Next();
453453
res_count += 1;
@@ -485,8 +485,8 @@ public async Task TestInsertTablet()
485485
System.Diagnostics.Debug.Assert(status == 0);
486486
var res = await session_pool.ExecuteQueryStatementAsync(
487487
"select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE where time<15");
488-
res.show_table_names();
489-
while (res.has_next()) Console.WriteLine(res.Next());
488+
res.ShowTableNames();
489+
while (res.HasNext()) Console.WriteLine(res.Next());
490490

491491
await res.Close();
492492
// large data test
@@ -512,9 +512,9 @@ public async Task TestInsertTablet()
512512
Console.WriteLine(string.Format("total tablet insert time is {0}", end_ms - start_ms));
513513
res = await session_pool.ExecuteQueryStatementAsync(
514514
"select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE");
515-
res.show_table_names();
515+
res.ShowTableNames();
516516
var res_count = 0;
517-
while (res.has_next())
517+
while (res.HasNext())
518518
{
519519
res.Next();
520520
res_count += 1;
@@ -574,14 +574,14 @@ public async Task TestInsertTablets()
574574
// System.Diagnostics.Debug.Assert(status == 0);
575575
var res = await session_pool.ExecuteQueryStatementAsync(
576576
"select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE1 where time<15");
577-
res.show_table_names();
578-
while (res.has_next()) Console.WriteLine(res.Next());
577+
res.ShowTableNames();
578+
while (res.HasNext()) Console.WriteLine(res.Next());
579579

580580
await res.Close();
581581
res = await session_pool.ExecuteQueryStatementAsync(
582582
"select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE2 where time<15");
583-
res.show_table_names();
584-
while (res.has_next()) Console.WriteLine(res.Next());
583+
res.ShowTableNames();
584+
while (res.HasNext()) Console.WriteLine(res.Next());
585585

586586
await res.Close();
587587

@@ -607,9 +607,9 @@ public async Task TestInsertTablets()
607607
Task.WaitAll(tasks.ToArray());
608608
res = await session_pool.ExecuteQueryStatementAsync(
609609
"select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE1");
610-
res.show_table_names();
610+
res.ShowTableNames();
611611
var res_count = 0;
612-
while (res.has_next())
612+
while (res.HasNext())
613613
{
614614
res.Next();
615615
res_count += 1;
@@ -766,8 +766,8 @@ public async Task TestDeleteData()
766766
System.Diagnostics.Debug.Assert(status == 0);
767767
var res = await session_pool.ExecuteQueryStatementAsync(
768768
"select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE where time<10");
769-
res.show_table_names();
770-
while (res.has_next()) Console.WriteLine(res.Next());
769+
res.ShowTableNames();
770+
while (res.HasNext()) Console.WriteLine(res.Next());
771771

772772
await res.Close();
773773
var ts_path_lst = new List<string>()
@@ -778,8 +778,8 @@ public async Task TestDeleteData()
778778
await session_pool.DeleteDataAsync(ts_path_lst, 2, 3);
779779
res = await session_pool.ExecuteQueryStatementAsync(
780780
"select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE where time<10");
781-
res.show_table_names();
782-
while (res.has_next()) Console.WriteLine(res.Next());
781+
res.ShowTableNames();
782+
while (res.HasNext()) Console.WriteLine(res.Next());
783783

784784
await res.Close();
785785
status = await session_pool.DeleteStorageGroupAsync("root.97209_TEST_CSHARP_CLIENT_GROUP");
@@ -897,8 +897,8 @@ public async Task TestTestInsertRecords()
897897
// System.Diagnostics.Debug.Assert(status == 0);
898898
var res = await session_pool.ExecuteQueryStatementAsync(
899899
"select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE where time<10");
900-
res.show_table_names();
901-
while (res.has_next()) Console.WriteLine(res.Next());
900+
res.ShowTableNames();
901+
while (res.HasNext()) Console.WriteLine(res.Next());
902902

903903
await res.Close();
904904

@@ -922,10 +922,10 @@ public async Task TestTestInsertRecords()
922922
Task.WaitAll(tasks.ToArray());
923923
res = await session_pool.ExecuteQueryStatementAsync(
924924
"select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE");
925-
res.show_table_names();
925+
res.ShowTableNames();
926926
var record_count = fetch_size * processed_size;
927927
var res_count = 0;
928-
while (res.has_next())
928+
while (res.HasNext())
929929
{
930930
res.Next();
931931
res_count += 1;
@@ -963,8 +963,8 @@ public async Task TestTestInsertTablet()
963963
System.Diagnostics.Debug.Assert(status == 0);
964964
var res = await session_pool.ExecuteQueryStatementAsync(
965965
"select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE where time<15");
966-
res.show_table_names();
967-
while (res.has_next()) Console.WriteLine(res.Next());
966+
res.ShowTableNames();
967+
while (res.HasNext()) Console.WriteLine(res.Next());
968968

969969
await res.Close();
970970
// large data test
@@ -990,9 +990,9 @@ public async Task TestTestInsertTablet()
990990
Console.WriteLine(string.Format("total tablet insert time is {0}", end_ms - start_ms));
991991
res = await session_pool.ExecuteQueryStatementAsync(
992992
"select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE");
993-
res.show_table_names();
993+
res.ShowTableNames();
994994
var res_count = 0;
995-
while (res.has_next())
995+
while (res.HasNext())
996996
{
997997
res.Next();
998998
res_count += 1;
@@ -1051,14 +1051,14 @@ public async Task TestTestInsertTablets()
10511051
// System.Diagnostics.Debug.Assert(status == 0);
10521052
var res = await session_pool.ExecuteQueryStatementAsync(
10531053
"select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE1 where time<15");
1054-
res.show_table_names();
1055-
while (res.has_next()) Console.WriteLine(res.Next());
1054+
res.ShowTableNames();
1055+
while (res.HasNext()) Console.WriteLine(res.Next());
10561056

10571057
await res.Close();
10581058
res = await session_pool.ExecuteQueryStatementAsync(
10591059
"select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE2 where time<15");
1060-
res.show_table_names();
1061-
while (res.has_next()) Console.WriteLine(res.Next());
1060+
res.ShowTableNames();
1061+
while (res.HasNext()) Console.WriteLine(res.Next());
10621062

10631063
await res.Close();
10641064

@@ -1084,9 +1084,9 @@ public async Task TestTestInsertTablets()
10841084
Task.WaitAll(tasks.ToArray());
10851085
res = await session_pool.ExecuteQueryStatementAsync(
10861086
"select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE1");
1087-
res.show_table_names();
1087+
res.ShowTableNames();
10881088
var res_count = 0;
1089-
while (res.has_next())
1089+
while (res.HasNext())
10901090
{
10911091
res.Next();
10921092
res_count += 1;
@@ -1128,8 +1128,8 @@ await session_pool.ExecuteNonQueryStatementAsync(
11281128
"insert into root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE(timestamp, status, hardware) VALUES (7, true,'lz')");
11291129
var res = await session_pool.ExecuteQueryStatementAsync(
11301130
"select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE where time<10");
1131-
res.show_table_names();
1132-
while (res.has_next()) Console.WriteLine(res.Next());
1131+
res.ShowTableNames();
1132+
while (res.HasNext()) Console.WriteLine(res.Next());
11331133

11341134
await res.Close();
11351135
status = await session_pool.DeleteStorageGroupAsync("root.97209_TEST_CSHARP_CLIENT_GROUP");
@@ -1165,33 +1165,33 @@ await session_pool.ExecuteNonQueryStatementAsync(
11651165
"insert into root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE(timestamp, status, hardware) VALUES (7, true,'lz')");
11661166

11671167
var res = await session_pool.ExecuteQueryStatementAsync("show timeseries root");
1168-
res.show_table_names();
1169-
while (res.has_next()) Console.WriteLine(res.Next());
1168+
res.ShowTableNames();
1169+
while (res.HasNext()) Console.WriteLine(res.Next());
11701170

11711171
await res.Close();
11721172
Console.WriteLine("SHOW TIMESERIES ROOT sql passed!");
11731173
res = await session_pool.ExecuteQueryStatementAsync("show devices");
1174-
res.show_table_names();
1175-
while (res.has_next()) Console.WriteLine(res.Next());
1174+
res.ShowTableNames();
1175+
while (res.HasNext()) Console.WriteLine(res.Next());
11761176

11771177
await res.Close();
11781178
Console.WriteLine("SHOW DEVICES sql passed!");
11791179
res = await session_pool.ExecuteQueryStatementAsync("COUNT TIMESERIES root");
1180-
res.show_table_names();
1181-
while (res.has_next()) Console.WriteLine(res.Next());
1180+
res.ShowTableNames();
1181+
while (res.HasNext()) Console.WriteLine(res.Next());
11821182

11831183
await res.Close();
11841184
Console.WriteLine("COUNT TIMESERIES root sql Passed");
11851185
res = await session_pool.ExecuteQueryStatementAsync("select * from root.ln.wf01 where time<10");
1186-
res.show_table_names();
1187-
while (res.has_next()) Console.WriteLine(res.Next());
1186+
res.ShowTableNames();
1187+
while (res.HasNext()) Console.WriteLine(res.Next());
11881188

11891189
await res.Close();
11901190
Console.WriteLine("SELECT sql Passed");
11911191
res = await session_pool.ExecuteQueryStatementAsync(
11921192
"select * from root.97209_TEST_CSHARP_CLIENT_GROUP.TEST_CSHARP_CLIENT_DEVICE where time<10");
1193-
res.show_table_names();
1194-
while (res.has_next()) Console.WriteLine(res.Next());
1193+
res.ShowTableNames();
1194+
while (res.HasNext()) Console.WriteLine(res.Next());
11951195

11961196
await res.Close();
11971197
status = await session_pool.DeleteStorageGroupAsync("root.97209_TEST_CSHARP_CLIENT_GROUP");

0 commit comments

Comments
 (0)