implemented all verbs

Author: yorek

Controllers/ControllerQuery.cs

@@ -23,7 +23,7 @@ public ControllerQuery(IConfiguration config, ILogger<CustomersController> logge
             _config = config;
         }
 
-        protected async Task<JsonDocument> Query(string verb, Type entity)
+        protected async Task<JsonElement> Query(string verb, Type entity, int? id = null, JsonElement payload = default(JsonElement))
         {
             JsonDocument result = null;
 
@@ -37,14 +37,31 @@ protected async Task<JsonDocument> Query(string verb, Type entity)
             _logger.LogDebug($"Executing {procedure}");
 
             using(var conn = new SqlConnection(_config.GetConnectionString("DefaultConnection"))) {
-                var qr = await conn.ExecuteScalarAsync<string>(procedure, commandType: CommandType.StoredProcedure);
-                result = JsonDocument.Parse(qr);
+                DynamicParameters parameters = new DynamicParameters();
+
+                if (payload.ValueKind != default(JsonValueKind))
+                {
+                    var json = JsonSerializer.Serialize(payload);
+                    parameters.Add("Json", json);
+                }
+
+                if (id.HasValue)
+                    parameters.Add("Id", id.Value);
+
+                var qr = await conn.ExecuteScalarAsync<string>(
+                    sql: procedure, 
+                    param: parameters, 
+                    commandType: CommandType.StoredProcedure
+                );
+                
+                if (qr != null)
+                    result = JsonDocument.Parse(qr);
             };
 
             if (result == null) 
                 result = JsonDocument.Parse("[]");
 
-            return result;
+            return result.RootElement;
         }
     }
 }

Controllers/CustomerController.cs

@@ -4,31 +4,40 @@
 using System.Threading.Tasks;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Extensions.Logging;
-using Microsoft.Data.SqlClient;
-using Dapper;
+using System.Text.Json;
+using Microsoft.Extensions.Configuration;
 
 namespace AzureSamples.AzureSQL.Controllers
 {
     [ApiController]
     [Route("[controller]")]
-    public class CustomerController : ControllerBase
+    public class CustomerController : ControllerQuery
     {
-        private static readonly string[] Summaries = new[]
+        public CustomerController(IConfiguration config, ILogger<CustomersController> logger):
+            base(config, logger) {}
+
+        [HttpGet("{customerId}")]
+        public async Task<JsonElement> Get(int customerId)
         {
-            "Freezing", "Bracing", "Chilly", "Cool", "Mild", "Warm", "Balmy", "Hot", "Sweltering", "Scorching"
-        };
+            return await this.Query("get", this.GetType(), customerId);
+        }
 
-        private readonly ILogger<CustomerController> _logger;
+        [HttpPut]
+        public async Task<JsonElement> Put([FromBody]JsonElement payload)
+        {
+            return await this.Query("put", this.GetType(), payload: payload);
+        }
 
-        public CustomerController(ILogger<CustomerController> logger)
+        [HttpPatch("{customerId}")]
+        public async Task<JsonElement> Patch([FromBody]JsonElement payload, int customerId)
         {
-            _logger = logger;
+            return await this.Query("patch", this.GetType(), customerId, payload);
         }
 
-        [HttpGet]
-        public IEnumerable<dynamic> Get()
+        [HttpDelete("{customerId}")]
+        public async Task<JsonElement> Delete(int customerId)
         {
-           return null;
+            return await this.Query("delete", this.GetType(), customerId);
         }
     }
 }

Controllers/CustomersController.cs

@@ -5,9 +5,6 @@
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Extensions.Logging;
 using System.Text.Json;
-using System.Data;
-using Microsoft.Data.SqlClient;
-using Dapper;
 using Microsoft.Extensions.Configuration;
 
 namespace AzureSamples.AzureSQL.Controllers
@@ -20,7 +17,7 @@ public CustomersController(IConfiguration config, ILogger<CustomersController> l
             base(config, logger) {}
 
         [HttpGet]
-        public async Task<JsonDocument> Get()
+        public async Task<JsonElement> Get()
         {
             return await this.Query("get", this.GetType());
         }