| using System; |
| using System.Collections.Generic; |
| using System.Threading; |
| using System.Threading.Tasks; |
| using Apache.IoTDB.Data; |
| using Apache.IoTDB.DataStructure; |
| using ConsoleTableExt; |
| using System.Net.Sockets; |
| using System.Diagnostics; |
| |
| namespace Apache.IoTDB.Samples |
| { |
| public partial class SessionPoolTest |
| { |
| public string host = "localhost"; |
| public int port = 6667; |
| public string user = "root"; |
| public string passwd = "root"; |
| public List<string> node_urls = new(); |
| public int fetch_size = 500; |
| public int processed_size = 4; |
| public bool debug = false; |
| private int pool_size = 2; |
| public static string test_template_name = "TEST_CSHARP_CLIENT_TEMPLATE_97209"; |
| public static string test_group_name = "root.TEST_CSHARP_CLIENT_GROUP_97209"; |
| public static string test_device = "TEST_CSHARP_CLIENT_DEVICE"; |
| public static string test_measurement = "TEST_CSHARP_CLIENT_TS"; |
| public static List<int> device_count = new List<int>() { 0, 1, 2, 3 }; |
| public static List<int> measurement_count = new List<int>() { 0, 1, 2, 3, 4, 5, 6 }; |
| public static List<string> test_devices = new List<string>( |
| device_count.ConvertAll(x => test_device + x.ToString()).ToArray() |
| ); |
| public List<string> test_measurements = new List<string>( |
| measurement_count.ConvertAll(x => test_measurement + x.ToString()).ToArray() |
| ); |
| |
| |
| public SessionPoolTest(string _host = "localhost") |
| { |
| host = _host; |
| node_urls.Add(host + ":" + port); |
| } |
| |
| public async Task Test() |
| { |
| await TestOpenWithNodeUrls(); |
| |
| await TestOpenWith2NodeUrls(); |
| |
| await TestOpenWithNodeUrlsAndInsertOneRecord(); |
| |
| await TestInsertOneRecord(); |
| |
| await TestInsertAlignedRecord(); |
| |
| await TestInsertAlignedRecords(); |
| |
| await TestInsertAlignedStringRecords(); |
| |
| await TestInsertAlignedStringRecordsOfOneDevice(); |
| |
| await TestInsertStringRecord(); |
| |
| await TestInsertAlignedStringRecord(); |
| |
| await TestInsertStringRecords(); |
| |
| await TestInsertStringRecordsOfOneDevice(); |
| |
| await TestInsertAlignedRecordsOfOneDevice(); |
| |
| await TestInsertAlignedTablet(); |
| |
| await TestInsertAlignedTablets(); |
| |
| await TestInsertRecord(); |
| |
| await TestCreateMultiTimeSeries(); |
| |
| await TestInsertStrRecord(); |
| |
| await TestInsertRecords(); |
| |
| await TestInsertRecordsOfOneDevice(); |
| |
| await TestInsertTablet(); |
| |
| await TestInsertTabletWithNullValue(); |
| |
| await TestInsertTablets(); |
| |
| await TestSetAndUnsetSchemaTemplate(); |
| |
| await TestCreateAlignedTimeseries(); |
| |
| await TestCreateAndDropSchemaTemplate(); |
| |
| await TestGetTimeZone(); |
| |
| await TestSetAndDeleteStorageGroup(); |
| |
| await TestCreateTimeSeries(); |
| |
| await TestDeleteTimeSeries(); |
| |
| await TestDeleteStorageGroups(); |
| |
| await TestCheckTimeSeriesExists(); |
| |
| await TestSetTimeZone(); |
| |
| await TestDeleteData(); |
| |
| await TestNonSql(); |
| |
| await TestRawDataQuery(); |
| |
| await TestLastDataQuery(); |
| |
| await TestSqlQuery(); |
| |
| await TestNonSqlBy_ADO(); |
| } |
| public async Task TestOpenWithNodeUrls() |
| { |
| var session_pool = new SessionPool(node_urls, 8); |
| await session_pool.Open(false); |
| Debug.Assert(session_pool.IsOpen()); |
| if (debug) session_pool.OpenDebugMode(); |
| await session_pool.Close(); |
| Console.WriteLine("TestOpenWithNodeUrls Passed!"); |
| } |
| public async Task TestOpenWith2NodeUrls() |
| { |
| var session_pool = new SessionPool(new List<string>() { host + ":" + port, host + ":" + (port + 1) }, 8); |
| await session_pool.Open(false); |
| Debug.Assert(session_pool.IsOpen()); |
| if (debug) session_pool.OpenDebugMode(); |
| await session_pool.Close(); |
| |
| session_pool = new SessionPool(new List<string>() { host + ":" + (port + 1), host + ":" + port }, 8); |
| await session_pool.Open(false); |
| Debug.Assert(session_pool.IsOpen()); |
| if (debug) session_pool.OpenDebugMode(); |
| await session_pool.Close(); |
| Console.WriteLine("TestOpenWith2NodeUrls Passed!"); |
| } |
| public async Task TestOpenWithNodeUrlsAndInsertOneRecord() |
| { |
| var session_pool = new SessionPool(node_urls, 8); |
| await session_pool.Open(false); |
| if (debug) session_pool.OpenDebugMode(); |
| await session_pool.DeleteStorageGroupAsync(test_group_name); |
| var status = await session_pool.CreateTimeSeries( |
| string.Format("{0}.{1}.{2}", test_group_name, test_device, test_measurements[0]), |
| TSDataType.TEXT, TSEncoding.PLAIN, Compressor.SNAPPY); |
| status = await session_pool.CreateTimeSeries( |
| string.Format("{0}.{1}.{2}", test_group_name, test_device, test_measurements[1]), |
| TSDataType.TEXT, TSEncoding.PLAIN, Compressor.SNAPPY); |
| status = await session_pool.CreateTimeSeries( |
| string.Format("{0}.{1}.{2}", test_group_name, test_device, test_measurements[2]), |
| TSDataType.TEXT, TSEncoding.PLAIN, Compressor.SNAPPY); |
| var rowRecord = new RowRecord(1668404120807, new() { "1111111", "22222", "333333" }, new() { test_measurements[0], test_measurements[1], test_measurements[2] }); |
| status = await session_pool.InsertRecordsAsync(new List<string>() { string.Format("{0}.{1}", test_group_name, test_device) }, new List<RowRecord>() { rowRecord }); |
| Debug.Assert(status == 0); |
| Console.WriteLine("TestOpenWithNodeUrlsAndInsertOneRecord Passed!"); |
| } |
| public async Task TestInsertOneRecord() |
| { |
| var session_pool = new SessionPool(host, port, 1); |
| await session_pool.Open(false); |
| if (debug) session_pool.OpenDebugMode(); |
| await session_pool.DeleteStorageGroupAsync(test_group_name); |
| var status = await session_pool.CreateTimeSeries( |
| string.Format("{0}.{1}.{2}", test_group_name, test_device, test_measurements[0]), |
| TSDataType.TEXT, TSEncoding.PLAIN, Compressor.SNAPPY); |
| status = await session_pool.CreateTimeSeries( |
| string.Format("{0}.{1}.{2}", test_group_name, test_device, test_measurements[1]), |
| TSDataType.TEXT, TSEncoding.PLAIN, Compressor.SNAPPY); |
| status = await session_pool.CreateTimeSeries( |
| string.Format("{0}.{1}.{2}", test_group_name, test_device, test_measurements[2]), |
| TSDataType.TEXT, TSEncoding.PLAIN, Compressor.SNAPPY); |
| var rowRecord = new RowRecord(1668404120807, new() { "1111111", "22222", "333333" }, new() { test_measurements[0], test_measurements[1], test_measurements[2] }); |
| status = await session_pool.InsertRecordsAsync(new List<string>() { string.Format("{0}.{1}", test_group_name, test_device) }, new List<RowRecord>() { rowRecord }); |
| } |
| public async Task TestGetTimeZone() |
| { |
| var session_pool = new SessionPool(host, port, pool_size); |
| await session_pool.Open(false); |
| if (debug) session_pool.OpenDebugMode(); |
| |
| await session_pool.DeleteStorageGroupAsync(test_group_name); |
| System.Diagnostics.Debug.Assert(session_pool.IsOpen()); |
| var time_zone = await session_pool.GetTimeZone(); |
| System.Diagnostics.Debug.Assert(time_zone == "UTC+08:00"); |
| await session_pool.Close(); |
| Console.WriteLine("TestGetTimeZone Passed!"); |
| } |
| |
| |
| |
| public async Task TestSetAndDeleteStorageGroup() |
| { |
| var session_pool = new SessionPool(host, port, pool_size); |
| var status = 0; |
| await session_pool.Open(false); |
| if (debug) session_pool.OpenDebugMode(); |
| |
| status = await session_pool.DeleteStorageGroupAsync(test_group_name); |
| System.Diagnostics.Debug.Assert( |
| await session_pool.SetStorageGroup(test_group_name) == 0); |
| System.Diagnostics.Debug.Assert( |
| await session_pool.DeleteStorageGroupAsync(test_group_name) == 0); |
| await session_pool.Close(); |
| Console.WriteLine("TestSetAndDeleteStorageGroup Passed!"); |
| } |
| |
| public async Task TestDeleteStorageGroups() |
| { |
| var session_pool = new SessionPool(host, port, pool_size); |
| await session_pool.Open(false); |
| if (debug) session_pool.OpenDebugMode(); |
| |
| await session_pool.SetStorageGroup(string.Format("{0}{1}", test_group_name, "_01")); |
| await session_pool.SetStorageGroup(string.Format("{0}{1}", test_group_name, "_02")); |
| await session_pool.SetStorageGroup(string.Format("{0}{1}", test_group_name, "_03")); |
| await session_pool.SetStorageGroup(string.Format("{0}{1}", test_group_name, "_04")); |
| var group_names = new List<string>() { }; |
| group_names.Add(string.Format("{0}{1}", test_group_name, "_01")); |
| group_names.Add(string.Format("{0}{1}", test_group_name, "_02")); |
| group_names.Add(string.Format("{0}{1}", test_group_name, "_03")); |
| group_names.Add(string.Format("{0}{1}", test_group_name, "_04")); |
| System.Diagnostics.Debug.Assert(await session_pool.DeleteStorageGroupsAsync(group_names) == 0); |
| await session_pool.Close(); |
| Console.WriteLine("TestDeleteStorageGroups Passed!"); |
| } |
| |
| |
| public async Task TestSetTimeZone() |
| { |
| var session_pool = new SessionPool(host, port, pool_size); |
| await session_pool.Open(false); |
| if (debug) session_pool.OpenDebugMode(); |
| |
| await session_pool.DeleteStorageGroupAsync(test_group_name); |
| System.Diagnostics.Debug.Assert(session_pool.IsOpen()); |
| await session_pool.SetTimeZone("GMT+8:00"); |
| System.Diagnostics.Debug.Assert(await session_pool.GetTimeZone() == "GMT+8:00"); |
| await session_pool.Close(); |
| Console.WriteLine("TestSetTimeZone Passed!"); |
| } |
| |
| public async Task TestDeleteData() |
| { |
| var session_pool = new SessionPool(host, port, pool_size); |
| var status = 0; |
| await session_pool.Open(false); |
| if (debug) session_pool.OpenDebugMode(); |
| |
| System.Diagnostics.Debug.Assert(session_pool.IsOpen()); |
| status = await session_pool.DeleteStorageGroupAsync(test_group_name); |
| |
| status = await session_pool.CreateTimeSeries( |
| string.Format("{0}.{1}.{2}", test_group_name, test_device, test_measurements[1]), TSDataType.TEXT, |
| TSEncoding.PLAIN, Compressor.UNCOMPRESSED); |
| System.Diagnostics.Debug.Assert(status == 0); |
| status = await session_pool.CreateTimeSeries( |
| string.Format("{0}.{1}.{2}", test_group_name, test_device, test_measurements[2]), |
| TSDataType.BOOLEAN, TSEncoding.PLAIN, Compressor.UNCOMPRESSED); |
| System.Diagnostics.Debug.Assert(status == 0); |
| status = await session_pool.CreateTimeSeries( |
| string.Format("{0}.{1}.{2}", test_group_name, test_device, test_measurements[3]), |
| TSDataType.INT32, TSEncoding.PLAIN, Compressor.UNCOMPRESSED); |
| System.Diagnostics.Debug.Assert(status == 0); |
| |
| var measures = new List<string> |
| { |
| test_measurements[1], test_measurements[2], test_measurements[3] |
| }; |
| var values = new List<object> { "test_text", true, (int)123 }; |
| status = await session_pool.InsertRecordAsync( |
| string.Format("{0}.{1}", test_group_name, test_device), new RowRecord(1, values, measures)); |
| System.Diagnostics.Debug.Assert(status == 0); |
| status = await session_pool.InsertRecordAsync( |
| string.Format("{0}.{1}", test_group_name, test_device), new RowRecord(2, values, measures)); |
| System.Diagnostics.Debug.Assert(status == 0); |
| status = await session_pool.InsertRecordAsync( |
| string.Format("{0}.{1}", test_group_name, test_device), new RowRecord(3, values, measures)); |
| System.Diagnostics.Debug.Assert(status == 0); |
| status = await session_pool.InsertRecordAsync( |
| string.Format("{0}.{1}", test_group_name, test_device), new RowRecord(4, values, measures)); |
| System.Diagnostics.Debug.Assert(status == 0); |
| var res = await session_pool.ExecuteQueryStatementAsync( |
| "select * from " + string.Format("{0}.{1}", test_group_name, test_device) + " where time<10"); |
| res.ShowTableNames(); |
| while (res.HasNext()) Console.WriteLine(res.Next()); |
| |
| await res.Close(); |
| var ts_path_lst = new List<string>() |
| { |
| string.Format("{0}.{1}.{2}", test_group_name, test_device, test_measurements[1]), |
| string.Format("{0}.{1}.{2}", test_group_name, test_device, test_measurements[2]), |
| }; |
| await session_pool.DeleteDataAsync(ts_path_lst, 2, 3); |
| res = await session_pool.ExecuteQueryStatementAsync( |
| "select * from " + string.Format("{0}.{1}", test_group_name, test_device) + " where time<10"); |
| res.ShowTableNames(); |
| while (res.HasNext()) Console.WriteLine(res.Next()); |
| |
| await res.Close(); |
| status = await session_pool.DeleteStorageGroupAsync(test_group_name); |
| System.Diagnostics.Debug.Assert(status == 0); |
| await session_pool.Close(); |
| Console.WriteLine("TestDeleteData Passed!"); |
| } |
| |
| public async Task TestNonSql() |
| { |
| var session_pool = new SessionPool(host, port, pool_size); |
| var status = 0; |
| await session_pool.Open(false); |
| if (debug) session_pool.OpenDebugMode(); |
| |
| System.Diagnostics.Debug.Assert(session_pool.IsOpen()); |
| status = await session_pool.DeleteStorageGroupAsync(test_group_name); |
| await session_pool.ExecuteNonQueryStatementAsync( |
| "create timeseries " + string.Format("{0}.{1}", test_group_name, test_device) + ".status with datatype=BOOLEAN,encoding=PLAIN"); |
| await session_pool.ExecuteNonQueryStatementAsync( |
| "create timeseries " + string.Format("{0}.{1}", test_group_name, test_device) + ".temperature with datatype=FLOAT,encoding=PLAIN"); |
| await session_pool.ExecuteNonQueryStatementAsync( |
| "create timeseries " + string.Format("{0}.{1}", test_group_name, test_device) + ".hardware with datatype=TEXT,encoding=PLAIN"); |
| status = await session_pool.ExecuteNonQueryStatementAsync( |
| "insert into " + string.Format("{0}.{1}", test_group_name, test_device) + "(timestamp, status, temperature, hardware) VALUES (4, false, 20, 'yxl')"); |
| System.Diagnostics.Debug.Assert(status == 0); |
| await session_pool.ExecuteNonQueryStatementAsync( |
| "insert into " + string.Format("{0}.{1}", test_group_name, test_device) + "(timestamp, status, temperature, hardware) VALUES (5, true, 12, 'myy')"); |
| await session_pool.ExecuteNonQueryStatementAsync( |
| "insert into " + string.Format("{0}.{1}", test_group_name, test_device) + "(timestamp, status, temperature, hardware) VALUES (6, true, 21, 'lz')"); |
| await session_pool.ExecuteNonQueryStatementAsync( |
| "insert into " + string.Format("{0}.{1}", test_group_name, test_device) + "(timestamp, status, hardware) VALUES (7, true,'lz')"); |
| await session_pool.ExecuteNonQueryStatementAsync( |
| "insert into " + string.Format("{0}.{1}", test_group_name, test_device) + "(timestamp, status, hardware) VALUES (7, true,'lz')"); |
| var res = await session_pool.ExecuteQueryStatementAsync( |
| "select * from " + string.Format("{0}.{1}", test_group_name, test_device) + " where time<10"); |
| res.ShowTableNames(); |
| while (res.HasNext()) Console.WriteLine(res.Next()); |
| |
| await res.Close(); |
| status = await session_pool.DeleteStorageGroupAsync(test_group_name); |
| System.Diagnostics.Debug.Assert(status == 0); |
| await session_pool.Close(); |
| Console.WriteLine("TestNonSql Passed"); |
| } |
| |
| public async Task TestNonSqlBy_ADO() |
| { |
| var cnts = new IoTDB.Data.IoTDBConnectionStringBuilder(); |
| cnts.DataSource = host; |
| cnts.TimeOut = (int)TimeSpan.FromSeconds(20).TotalMilliseconds; |
| var cnt = new IoTDB.Data.IoTDBConnection(cnts.ConnectionString); |
| await cnt.OpenAsync(); |
| var session_pool = cnt.SessionPool; |
| System.Diagnostics.Debug.Assert(cnt.State == System.Data.ConnectionState.Open); |
| var status = await session_pool.DeleteStorageGroupAsync(test_group_name); |
| await cnt.CreateCommand( |
| "create timeseries " + string.Format("{0}.{1}", test_group_name, test_device) + ".status with datatype=BOOLEAN,encoding=PLAIN").ExecuteNonQueryAsync(); |
| await cnt.CreateCommand( |
| "create timeseries " + string.Format("{0}.{1}", test_group_name, test_device) + ".temperature with datatype=FLOAT,encoding=PLAIN").ExecuteNonQueryAsync(); |
| await cnt.CreateCommand( |
| "create timeseries " + string.Format("{0}.{1}", test_group_name, test_device) + ".hardware with datatype=TEXT,encoding=PLAIN").ExecuteNonQueryAsync(); |
| |
| status = await cnt.CreateCommand( |
| "insert into " + string.Format("{0}.{1}", test_group_name, test_device) + "(timestamp, status, temperature, hardware) VALUES (3, false, 20, '1yxl')").ExecuteNonQueryAsync(); |
| status = await cnt.CreateCommand( |
| "insert into " + string.Format("{0}.{1}", test_group_name, test_device) + "(timestamp, status, temperature, hardware) VALUES (4, false, 20, 'yxl')").ExecuteNonQueryAsync(); |
| System.Diagnostics.Debug.Assert(status == 0); |
| await cnt.CreateCommand( |
| "insert into " + string.Format("{0}.{1}", test_group_name, test_device) + "(timestamp, status, temperature, hardware) VALUES (5, true, 12, 'myy')").ExecuteNonQueryAsync(); |
| await cnt.CreateCommand( |
| "insert into " + string.Format("{0}.{1}", test_group_name, test_device) + "(timestamp, status, temperature, hardware) VALUES (6, true, 21, 'lz')").ExecuteNonQueryAsync(); |
| await cnt.CreateCommand( |
| "insert into " + string.Format("{0}.{1}", test_group_name, test_device) + "(timestamp, status, hardware) VALUES (7, true,'lz')").ExecuteNonQueryAsync(); |
| await cnt.CreateCommand( |
| "insert into " + string.Format("{0}.{1}", test_group_name, test_device) + "(timestamp, status, hardware) VALUES (7, true,'lz')").ExecuteNonQueryAsync(); |
| var reader = await cnt.CreateCommand( |
| "select * from " + string.Format("{0}.{1}", test_group_name, test_device) + " where time<10").ExecuteReaderAsync(); |
| ConsoleTableBuilder.From(reader.ToDataTable()).WithFormatter(0, fc => $"{fc:yyyy-MM-dd HH:mm:ss.fff}").WithFormat(ConsoleTableBuilderFormat.Default).ExportAndWriteLine(); |
| status = await session_pool.DeleteStorageGroupAsync(test_group_name); |
| await cnt.CloseAsync(); |
| |
| System.Diagnostics.Debug.Assert(status == 0); |
| |
| Console.WriteLine("TestNonSqlBy_ADO Passed"); |
| } |
| |
| public async Task TestSqlQuery() |
| { |
| var session_pool = new SessionPool(host, port, pool_size); |
| var status = 0; |
| await session_pool.Open(false); |
| if (debug) session_pool.OpenDebugMode(); |
| |
| System.Diagnostics.Debug.Assert(session_pool.IsOpen()); |
| status = await session_pool.DeleteStorageGroupAsync(test_group_name); |
| await session_pool.ExecuteNonQueryStatementAsync( |
| "create timeseries " + string.Format("{0}.{1}", test_group_name, test_device) + ".status with datatype=BOOLEAN,encoding=PLAIN"); |
| await session_pool.ExecuteNonQueryStatementAsync( |
| "create timeseries " + string.Format("{0}.{1}", test_group_name, test_device) + ".temperature with datatype=FLOAT,encoding=PLAIN"); |
| await session_pool.ExecuteNonQueryStatementAsync( |
| "create timeseries " + string.Format("{0}.{1}", test_group_name, test_device) + ".hardware with datatype=TEXT,encoding=PLAIN"); |
| await session_pool.ExecuteNonQueryStatementAsync( |
| "insert into " + string.Format("{0}.{1}", test_group_name, test_device) + "(timestamp, status, temperature, hardware) VALUES (4, false, 20, 'yxl')"); |
| await session_pool.ExecuteNonQueryStatementAsync( |
| "insert into " + string.Format("{0}.{1}", test_group_name, test_device) + "(timestamp, status, temperature, hardware) VALUES (5, true, 12, 'myy')"); |
| await session_pool.ExecuteNonQueryStatementAsync( |
| "insert into " + string.Format("{0}.{1}", test_group_name, test_device) + "(timestamp, status, temperature, hardware) VALUES (6, true, 21, 'lz')"); |
| await session_pool.ExecuteNonQueryStatementAsync( |
| "insert into " + string.Format("{0}.{1}", test_group_name, test_device) + "(timestamp, status, hardware) VALUES (7, true,'lz')"); |
| await session_pool.ExecuteNonQueryStatementAsync( |
| "insert into " + string.Format("{0}.{1}", test_group_name, test_device) + "(timestamp, status, hardware) VALUES (7, true,'lz')"); |
| |
| var res = await session_pool.ExecuteQueryStatementAsync("show timeseries root"); |
| res.ShowTableNames(); |
| while (res.HasNext()) Console.WriteLine(res.Next()); |
| |
| await res.Close(); |
| Console.WriteLine("SHOW TIMESERIES ROOT sql passed!"); |
| res = await session_pool.ExecuteQueryStatementAsync("show devices"); |
| res.ShowTableNames(); |
| while (res.HasNext()) Console.WriteLine(res.Next()); |
| |
| await res.Close(); |
| Console.WriteLine("SHOW DEVICES sql passed!"); |
| res = await session_pool.ExecuteQueryStatementAsync("COUNT TIMESERIES root"); |
| res.ShowTableNames(); |
| while (res.HasNext()) Console.WriteLine(res.Next()); |
| |
| await res.Close(); |
| Console.WriteLine("COUNT TIMESERIES root sql Passed"); |
| res = await session_pool.ExecuteQueryStatementAsync("select * from root.ln.wf01 where time<10"); |
| res.ShowTableNames(); |
| while (res.HasNext()) Console.WriteLine(res.Next()); |
| |
| await res.Close(); |
| Console.WriteLine("SELECT sql Passed"); |
| res = await session_pool.ExecuteQueryStatementAsync( |
| "select * from " + string.Format("{0}.{1}", test_group_name, test_device) + " where time<10"); |
| res.ShowTableNames(); |
| while (res.HasNext()) Console.WriteLine(res.Next()); |
| |
| await res.Close(); |
| 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() |
| { |
| var session_pool = new SessionPool(host, port, pool_size); |
| var status = 0; |
| await session_pool.Open(false); |
| if (debug) session_pool.OpenDebugMode(); |
| |
| System.Diagnostics.Debug.Assert(session_pool.IsOpen()); |
| status = await session_pool.DeleteStorageGroupAsync(test_group_name); |
| |
| var device_id = string.Format("{0}.{1}", test_group_name, test_device); |
| var measurements = new List<string> { test_measurements[0], test_measurements[1] }; |
| var data_type_lst = new List<TSDataType> { TSDataType.BOOLEAN, TSDataType.FLOAT }; |
| var encoding_lst = new List<TSEncoding> { TSEncoding.PLAIN, TSEncoding.PLAIN }; |
| var compressor_lst = new List<Compressor> { Compressor.SNAPPY, Compressor.SNAPPY }; |
| status = await session_pool.CreateAlignedTimeseriesAsync(device_id, measurements, data_type_lst, encoding_lst, compressor_lst); |
| |
| var records = new List<RowRecord>(); |
| var values = new List<object>() { true, 20.0f }; |
| var device_id_lst = new List<string>() { }; |
| for (int i = 1; i <= fetch_size * processed_size; i++) |
| { |
| var record = new RowRecord(i, values, measurements); |
| records.Add(record); |
| device_id_lst.Add(device_id); |
| } |
| status = await session_pool.InsertAlignedRecordsAsync(device_id_lst, records); |
| System.Diagnostics.Debug.Assert(status == 0); |
| |
| var paths = new List<string>() { string.Format("{0}.{1}", device_id, test_measurements[0]), string.Format("{0}.{1}", device_id, test_measurements[1]) }; |
| |
| var res = await session_pool.ExecuteRawDataQuery(paths, 10, fetch_size * processed_size); |
| var count = 0; |
| while (res.HasNext()) |
| { |
| var record = res.Next(); |
| count++; |
| } |
| Console.WriteLine(count + " " + (fetch_size * processed_size - 10)); |
| System.Diagnostics.Debug.Assert(count == fetch_size * processed_size - 10); |
| await res.Close(); |
| |
| status = await session_pool.DeleteStorageGroupAsync(test_group_name); |
| System.Diagnostics.Debug.Assert(status == 0); |
| await session_pool.Close(); |
| Console.WriteLine("RawDataQuery Passed"); |
| } |
| public async Task TestLastDataQuery() |
| { |
| var session_pool = new SessionPool(host, port, pool_size); |
| var status = 0; |
| await session_pool.Open(false); |
| if (debug) session_pool.OpenDebugMode(); |
| |
| System.Diagnostics.Debug.Assert(session_pool.IsOpen()); |
| status = await session_pool.DeleteStorageGroupAsync(test_group_name); |
| |
| var device_id = string.Format("{0}.{1}", test_group_name, test_device); |
| var measurements = new List<string> { test_measurements[0], test_measurements[1] }; |
| var data_type_lst = new List<TSDataType> { TSDataType.BOOLEAN, TSDataType.FLOAT }; |
| var encoding_lst = new List<TSEncoding> { TSEncoding.PLAIN, TSEncoding.PLAIN }; |
| var compressor_lst = new List<Compressor> { Compressor.SNAPPY, Compressor.SNAPPY }; |
| status = await session_pool.CreateAlignedTimeseriesAsync(device_id, measurements, data_type_lst, encoding_lst, compressor_lst); |
| |
| var records = new List<RowRecord>(); |
| var values = new List<object>() { true, 20.0f }; |
| var device_id_lst = new List<string>() { }; |
| for (int i = 1; i <= fetch_size * processed_size; i++) |
| { |
| var record = new RowRecord(i, values, measurements); |
| records.Add(record); |
| device_id_lst.Add(device_id); |
| } |
| status = await session_pool.InsertAlignedRecordsAsync(device_id_lst, records); |
| System.Diagnostics.Debug.Assert(status == 0); |
| |
| var paths = new List<string>() { string.Format("{0}.{1}", device_id, test_measurements[0]), string.Format("{0}.{1}", device_id, test_measurements[1]) }; |
| |
| var res = await session_pool.ExecuteLastDataQueryAsync(paths, fetch_size * processed_size - 10); |
| var count = 0; |
| while (res.HasNext()) |
| { |
| var record = res.Next(); |
| Console.WriteLine(record); |
| count++; |
| } |
| Console.WriteLine(count + " " + (fetch_size * processed_size - 10)); |
| System.Diagnostics.Debug.Assert(count == 2); |
| await res.Close(); |
| |
| status = await session_pool.DeleteStorageGroupAsync(test_group_name); |
| System.Diagnostics.Debug.Assert(status == 0); |
| await session_pool.Close(); |
| Console.WriteLine("LastDataQuery Passed"); |
| } |
| } |
| } |
