Skip to content

Commit 00158d0

Browse files
lausannellausannel
committed
fix samples build error
1 parent 9f53e36 commit 00158d0

File tree

7 files changed

+52
-35
lines changed

7 files changed

+52
-35
lines changed

‎samples/Apache.IoTDB.Samples/SessionPoolTest.AlignedRecord.cs‎

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -98,9 +98,10 @@ public async Task TestInsertAlignedStringRecord()
9898
Console.WriteLine(string.Format("total insert aligned string record time is {0}", end_ms - start_ms));
9999
var res = await session_pool.ExecuteQueryStatementAsync("select * from " + string.Format("{0}.{1}", testDatabaseName, testDevice));
100100
var res_cnt = 0;
101-
while (res.Next())
101+
while (res.HasNext())
102102
{
103103
res_cnt++;
104+
res.Next();
104105
}
105106
Console.WriteLine(res_cnt + " " + fetchSize * processedSize);
106107
System.Diagnostics.Debug.Assert(res_cnt == fetchSize * processedSize);
@@ -215,7 +216,7 @@ public async Task TestInsertAlignedRecords()
215216
res.ShowTableNames();
216217
var record_count = fetchSize * processedSize;
217218
var res_count = 0;
218-
while (res.Next())
219+
while (res.HasNext())
219220
{
220221
res_count += 1;
221222
Console.WriteLine(res.Next());
@@ -297,7 +298,7 @@ public async Task TestInsertAlignedStringRecords()
297298
"select * from " + string.Format("{0}.{1}", testDatabaseName, testDevice));
298299
res.ShowTableNames();
299300
var res_count = 0;
300-
while (res.Next())
301+
while (res.HasNext())
301302
{
302303
Console.WriteLine(res.Next());
303304
res_count += 1;
@@ -406,9 +407,10 @@ public async Task TestInsertAlignedRecordsOfOneDevice()
406407
res = await session_pool.ExecuteQueryStatementAsync(
407408
"select * from " + string.Format("{0}.{1}", testDatabaseName, testDevice));
408409
var res_count = 0;
409-
while (res.Next())
410+
while (res.HasNext())
410411
{
411412
res_count += 1;
413+
res.Next();
412414
}
413415

414416
await res.Close();
@@ -478,9 +480,10 @@ public async Task TestInsertAlignedStringRecordsOfOneDevice()
478480
res = await session_pool.ExecuteQueryStatementAsync(
479481
"select * from " + string.Format("{0}.{1}", testDatabaseName, testDevice));
480482
var res_count = 0;
481-
while (res.Next())
483+
while (res.HasNext())
482484
{
483485
res_count += 1;
486+
res.Next();
484487
}
485488

486489
await res.Close();

‎samples/Apache.IoTDB.Samples/SessionPoolTest.AlignedTablet.cs‎

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -83,9 +83,10 @@ public async Task TestInsertAlignedTablet()
8383
"select * from " + string.Format("{0}.{1}", testDatabaseName, testDevice));
8484
res.ShowTableNames();
8585
var res_count = 0;
86-
while (res.Next())
86+
while (res.HasNext())
8787
{
8888
res_count += 1;
89+
res.Next();
8990
}
9091

9192
await res.Close();
@@ -174,9 +175,10 @@ public async Task TestInsertAlignedTablets()
174175
"select * from " + string.Format("{0}.{1}", testDatabaseName, testDevices[1]));
175176
res.ShowTableNames();
176177
var res_count = 0;
177-
while (res.Next())
178+
while (res.HasNext())
178179
{
179180
res_count += 1;
181+
res.Next();
180182
}
181183

182184
await res.Close();

‎samples/Apache.IoTDB.Samples/SessionPoolTest.Record.cs‎

Lines changed: 15 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -111,9 +111,10 @@ public async Task TestInsertStringRecord()
111111
Console.WriteLine(string.Format("total insert string record time is {0}", end_ms - start_ms));
112112
var res = await session_pool.ExecuteQueryStatementAsync("select * from " + string.Format("{0}.{1}", testDatabaseName, testDevice));
113113
var res_cnt = 0;
114-
while (res.Next())
114+
while (res.HasNext())
115115
{
116116
res_cnt++;
117+
res.Next();
117118
}
118119
Console.WriteLine(res_cnt + " " + fetchSize * processedSize);
119120
System.Diagnostics.Debug.Assert(res_cnt == fetchSize * processedSize);
@@ -169,9 +170,10 @@ public async Task TestInsertStrRecord()
169170
res = await session_pool.ExecuteQueryStatementAsync(
170171
"select * from " + string.Format("{0}.{1}", testDatabaseName, testDevice));
171172
var res_count = 0;
172-
while (res.Next())
173+
while (res.HasNext())
173174
{
174175
res_count += 1;
176+
res.Next();
175177
}
176178

177179
await res.Close();
@@ -283,9 +285,10 @@ public async Task TestInsertRecords()
283285

284286
res.ShowTableNames();
285287
var res_count = 0;
286-
while (res.Next())
288+
while (res.HasNext())
287289
{
288290
res_count += 1;
291+
res.Next();
289292
}
290293

291294
await res.Close();
@@ -297,9 +300,9 @@ public async Task TestInsertRecords()
297300
res = await session_pool.ExecuteQueryStatementAsync(sql);
298301
res.ShowTableNames();
299302
RowRecord row = null;
300-
while (res.Next())
303+
while (res.HasNext())
301304
{
302-
row = res.GetRow();
305+
row = res.Next();
303306
break;
304307
}
305308

@@ -380,7 +383,7 @@ public async Task TestInsertStringRecords()
380383
res.ShowTableNames();
381384
var record_count = fetchSize * processedSize;
382385
var res_count = 0;
383-
while (res.Next())
386+
while (res.HasNext())
384387
{
385388
Console.WriteLine(res.Next());
386389
res_count += 1;
@@ -485,9 +488,10 @@ public async Task TestInsertRecordsOfOneDevice()
485488
res = await session_pool.ExecuteQueryStatementAsync(
486489
"select * from " + string.Format("{0}.{1}", testDatabaseName, testDevice));
487490
var res_count = 0;
488-
while (res.Next())
491+
while (res.HasNext())
489492
{
490493
res_count += 1;
494+
res.Next();
491495
}
492496

493497
await res.Close();
@@ -563,9 +567,10 @@ public async Task TestInsertStringRecordsOfOneDevice()
563567
res = await session_pool.ExecuteQueryStatementAsync(
564568
"select * from " + string.Format("{0}.{1}", testDatabaseName, testDevice));
565569
var res_count = 0;
566-
while (res.Next())
570+
while (res.HasNext())
567571
{
568572
res_count += 1;
573+
res.Next();
569574
}
570575

571576
await res.Close();
@@ -643,9 +648,9 @@ public async Task TestInsertRecordsWithAllType()
643648
"select * from " + string.Format("{0}.{1}", testDatabaseName, testDevice));
644649
res.ShowTableNames();
645650
var res_count = 0;
646-
while (res.Next())
651+
while (res.HasNext())
647652
{
648-
Console.WriteLine(res.GetRow());
653+
Console.WriteLine(res.Next());
649654
res_count += 1;
650655
}
651656

‎samples/Apache.IoTDB.Samples/SessionPoolTest.Tablet.cs‎

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -83,9 +83,10 @@ public async Task TestInsertTablet()
8383
"select * from " + string.Format("{0}.{1}", testDatabaseName, testDevice));
8484
res.ShowTableNames();
8585
var res_count = 0;
86-
while (res.Next())
86+
while (res.HasNext())
8787
{
8888
res_count += 1;
89+
res.Next();
8990
}
9091

9192
await res.Close();
@@ -175,9 +176,10 @@ public async Task TestInsertTablets()
175176
"select * from " + string.Format("{0}.{1}", testDatabaseName, testDevices[1]));
176177
res.ShowTableNames();
177178
var res_count = 0;
178-
while (res.Next())
179+
while (res.HasNext())
179180
{
180181
res_count += 1;
182+
res.Next();
181183
}
182184

183185
await res.Close();
@@ -213,9 +215,9 @@ public async Task TestInsertTabletWithNullValue()
213215
"select * from " + string.Format("{0}.{1}", testDatabaseName, testDevice));
214216
res.ShowTableNames();
215217
var res_count = 0;
216-
while (res.Next())
218+
while (res.HasNext())
217219
{
218-
Console.WriteLine(res.GetRow());
220+
Console.WriteLine(res.Next());
219221
res_count += 1;
220222
}
221223

@@ -276,9 +278,9 @@ public async Task TestInsertTabletWithAllType()
276278
"select * from " + string.Format("{0}.{1}", testDatabaseName, testDevice));
277279
res.ShowTableNames();
278280
var res_count = 0;
279-
while (res.Next())
281+
while (res.HasNext())
280282
{
281-
Console.WriteLine(res.GetRow());
283+
Console.WriteLine(res.Next());
282284
res_count += 1;
283285
}
284286

‎samples/Apache.IoTDB.Samples/SessionPoolTest.TestNetwork.cs‎

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -171,9 +171,10 @@ public async Task TestTestInsertRecords()
171171
res.ShowTableNames();
172172
var record_count = fetchSize * processedSize;
173173
var res_count = 0;
174-
while (res.Next())
174+
while (res.HasNext())
175175
{
176176
res_count += 1;
177+
res.Next();
177178
}
178179

179180
await res.Close();
@@ -240,9 +241,10 @@ public async Task TestTestInsertTablet()
240241
"select * from " + string.Format("{0}.{1}", testDatabaseName, testDevice));
241242
res.ShowTableNames();
242243
var res_count = 0;
243-
while (res.Next())
244+
while (res.HasNext())
244245
{
245246
res_count += 1;
247+
res.Next();
246248
}
247249

248250
await res.Close();
@@ -331,9 +333,10 @@ public async Task TestTestInsertTablets()
331333
"select * from " + string.Format("{0}.{1}", testDatabaseName, testDevices[1]));
332334
res.ShowTableNames();
333335
var res_count = 0;
334-
while (res.Next())
336+
while (res.HasNext())
335337
{
336338
res_count += 1;
339+
res.Next();
337340
}
338341

339342
await res.Close();

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

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -512,9 +512,10 @@ public async Task TestRawDataQuery()
512512

513513
var res = await session_pool.ExecuteRawDataQuery(paths, 10, fetchSize * processedSize);
514514
var count = 0;
515-
while (res.Next())
515+
while (res.HasNext())
516516
{
517517
count++;
518+
res.Next();
518519
}
519520
Console.WriteLine(count + " " + (fetchSize * processedSize - 10));
520521
System.Diagnostics.Debug.Assert(count == fetchSize * processedSize - 10);
@@ -558,9 +559,10 @@ public async Task TestLastDataQuery()
558559

559560
var res = await session_pool.ExecuteLastDataQueryAsync(paths, fetchSize * processedSize - 10);
560561
var count = 0;
561-
while (res.Next())
562+
while (res.HasNext())
562563
{
563564
Console.WriteLine(count);
565+
res.Next();
564566
count++;
565567
}
566568
Console.WriteLine(count + " " + (fetchSize * processedSize - 10));

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

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -73,14 +73,14 @@ await tableSessionPool.ExecuteNonQueryStatementAsync(
7373
// show tables from current database
7474
var res = await tableSessionPool.ExecuteQueryStatementAsync("SHOW TABLES");
7575
res.ShowTableNames();
76-
while (res.Next()) Console.WriteLine(res.GetRow());
76+
while (res.HasNext()) Console.WriteLine(res.Next());
7777
await res.Close();
7878

7979
// show tables by specifying another database
8080
// using SHOW tables FROM
8181
res = await tableSessionPool.ExecuteQueryStatementAsync("SHOW TABLES FROM test1");
8282
res.ShowTableNames();
83-
while (res.Next()) Console.WriteLine(res.GetRow());
83+
while (res.HasNext()) Console.WriteLine(res.Next());
8484
await res.Close();
8585

8686
var tableName = "testTable1";
@@ -123,7 +123,7 @@ await tableSessionPool.ExecuteNonQueryStatementAsync(
123123
res = await tableSessionPool.ExecuteQueryStatementAsync("select * from testTable1 "
124124
+ "where region_id = '1' and plant_id in ('3', '5') and device_id = '3'");
125125
res.ShowTableNames();
126-
while (res.Next()) Console.WriteLine(res.GetRow());
126+
while (res.HasNext()) Console.WriteLine(res.Next());
127127
await res.Close();
128128

129129
await tableSessionPool.Close();
@@ -148,15 +148,15 @@ public async Task TestUseDatabase()
148148
// show tables from current database
149149
var res = await tableSessionPool.ExecuteQueryStatementAsync("SHOW TABLES");
150150
res.ShowTableNames();
151-
while (res.Next()) Console.WriteLine(res.GetRow());
151+
while (res.HasNext()) Console.WriteLine(res.Next());
152152
await res.Close();
153153

154154
await tableSessionPool.ExecuteNonQueryStatementAsync("use test2");
155155

156156
// show tables from current database
157157
res = await tableSessionPool.ExecuteQueryStatementAsync("SHOW TABLES");
158158
res.ShowTableNames();
159-
while (res.Next()) Console.WriteLine(res.GetRow());
159+
while (res.HasNext()) Console.WriteLine(res.Next());
160160
await res.Close();
161161

162162
await tableSessionPool.Close();
@@ -225,9 +225,9 @@ await tableSessionPool.ExecuteNonQueryStatementAsync(
225225

226226

227227
var res = await tableSessionPool.ExecuteQueryStatementAsync("select count(*) from " + tableName + " where f1 is null");
228-
while (res.Next())
228+
while (res.HasNext())
229229
{
230-
var row = res.GetRow();
230+
var row = res.Next();
231231
Console.WriteLine(row);
232232
var value = row.Values[0];
233233
if (value is long longValue)

0 commit comments

Comments
 (0)