count query && usage

Author: EvilLord666

WeatherControl/Wissance.WeatherControl.WebApi.V2/Helpers/EqlResolver.cs

@@ -7,6 +7,10 @@ namespace Wissance.WeatherControl.WebApi.V2.Helpers
 {
     public class EqlResolver
     {
+        public string GetQueryToCountItems(ModelType model)
+        {
+            return String.Format(_selectCountQueries[model]);
+        }
         public string GetQueryToFetchManyItems(ModelType model, int offset, int limit)
         {
             if (!_selectManyWithLimitsQueries.ContainsKey(model))
@@ -42,6 +46,14 @@ public string GetQueryToDeleteItem(ModelType model)
             return String.Format(_deleteQuery[model]);
         }
 
+        private readonly IDictionary<ModelType, string> _selectCountQueries = new Dictionary<ModelType, string>()
+        {
+            {ModelType.MeasureUnit, "SELECT COUNT (SELECT MeasureUnit {{id}})"},
+            {ModelType.Measurement, "SELECT COUNT (SELECT Measurement {{id}})"},
+            {ModelType.Sensor , "SELECT COUNT (SELECT Sensor {{id}})"},
+            {ModelType.MeteoStation, "SELECT COUNT (SELECT MeteoStation {{id}})" }
+        };
+
         private readonly IDictionary<ModelType, string> _selectManyWithLimitsQueries = new Dictionary<ModelType, string>()
         {
             {ModelType.MeasureUnit, "SELECT MeasureUnit {{id, Name, Abbreviation, Description}} OFFSET {0} LIMIT {1}"},

WeatherControl/Wissance.WeatherControl.WebApi.V2/Managers/EdgeDbManager.cs

@@ -107,14 +107,18 @@ public async Task<OperationResultDto<Tuple<IList<TRes>,long>>> GetAsync(int page
         {
             try
             {
-                // todo: mode to dictionary ...
-                string query = _resolver.GetQueryToFetchManyItems(_model, (page - 1) * size, size);
-                if (query == null)
-                    throw new NotSupportedException($"EQL queries for model {_model} are not ready");
-                IReadOnlyCollection<TObj> items = await _edgeDbClient.QueryAsync<TObj>(query);
+                string countQuery = _resolver.GetQueryToCountItems(_model);
+                if (countQuery == null)
+                    throw new NotSupportedException($"EQL count query for model {_model} is not ready");
+                long totalItems = await _edgeDbClient.QuerySingleAsync<long>(countQuery);
+                // todo: modve to dictionary ...
+                string getQuery = _resolver.GetQueryToFetchManyItems(_model, (page - 1) * size, size);
+                if (getQuery == null)
+                    throw new NotSupportedException($"EQL get query for model {_model} is not ready");
+                IReadOnlyCollection<TObj> items = await _edgeDbClient.QueryAsync<TObj>(getQuery);
                 IList<TRes> dtoItems = items.Select(i => _factory(i)).ToList();
                 return new OperationResultDto<Tuple<IList<TRes>, long>>(true, (int)HttpStatusCode.OK, String.Empty, 
-                    new Tuple<IList<TRes>, long>(dtoItems, 0));
+                    new Tuple<IList<TRes>, long>(dtoItems, totalItems));
             }
             catch (Exception e)
             {