diff --git a/samples/Apache.IoTDB.Samples/SessionPoolTest.cs b/samples/Apache.IoTDB.Samples/SessionPoolTest.cs index 54e3898..cf8322e 100644 --- a/samples/Apache.IoTDB.Samples/SessionPoolTest.cs +++ b/samples/Apache.IoTDB.Samples/SessionPoolTest.cs @@ -19,6 +19,7 @@ using System; using System.Collections.Generic; +using System.Linq; using System.Threading; using System.Threading.Tasks; using Apache.IoTDB.Data; @@ -468,10 +469,19 @@ await session_pool.ExecuteNonQueryStatementAsync( while (res.HasNext()) Console.WriteLine(res.Next()); await res.Close(); + Console.WriteLine("SELECT sql Passed"); + res = await session_pool.ExecuteQueryStatementAsync( + "select status, temperature, hardware from " + string.Format("{0}.{1}", test_group_name, test_device) + " where time<10"); + res.ShowTableNames(); + var columnNames = new List { "root.TEST_CSHARP_CLIENT_GROUP_97209.TEST_CSHARP_CLIENT_DEVICE.status", "root.TEST_CSHARP_CLIENT_GROUP_97209.TEST_CSHARP_CLIENT_DEVICE.temperature", "root.TEST_CSHARP_CLIENT_GROUP_97209.TEST_CSHARP_CLIENT_DEVICE.hardware" }; + System.Diagnostics.Debug.Assert(columnNames.SequenceEqual(res.ColumnNames)); + while (res.HasNext()) Console.WriteLine(res.Next()); + + await res.Close(); + Console.WriteLine("SELECT sql Passed"); status = await session_pool.DeleteStorageGroupAsync(test_group_name); System.Diagnostics.Debug.Assert(status == 0); await session_pool.Close(); - Console.WriteLine("SELECT sql Passed"); } public async Task TestRawDataQuery() { @@ -569,4 +579,4 @@ public async Task TestLastDataQuery() Console.WriteLine("LastDataQuery Passed"); } } -} \ No newline at end of file +}