feat(example): use Dapper and Npgsql in NoEF example

Author: jaredcnance

src/NoEntityFrameworkExample/Controllers/MyModelsController.cs renamed to src/NoEntityFrameworkExample/Controllers/CustomTodoItemsController.cs

@@ -1,15 +1,15 @@
 using JsonApiDotNetCore.Controllers;
 using JsonApiDotNetCore.Services;
+using JsonApiDotNetCoreExample.Models;
 using Microsoft.Extensions.Logging;
-using NoEntityFrameworkExample.Models;
 
 namespace NoEntityFrameworkExample.Controllers
 {
-    public class MyModelsController : JsonApiController<MyModel>
+    public class CustomTodoItemsController : JsonApiController<TodoItem>
     {
-        public MyModelsController(
+        public CustomTodoItemsController(
             IJsonApiContext jsonApiContext, 
-            IResourceService<MyModel> resourceService, 
+            IResourceService<TodoItem> resourceService, 
             ILoggerFactory loggerFactory) 
             : base(jsonApiContext, resourceService, loggerFactory)
         { }

src/NoEntityFrameworkExample/Models/MyModel.cs

@@ -10,12 +10,15 @@
 
   <ItemGroup>
     <ProjectReference Include="../JsonApiDotNetCore/JsonApiDotNetCore.csproj" />
+    <ProjectReference Include="../JsonApiDotNetCoreExample/JsonApiDotNetCoreExample.csproj" />
   </ItemGroup>
 
   <ItemGroup>
     <PackageReference Include="Microsoft.AspNetCore" Version="1.1.1" />
     <PackageReference Include="Microsoft.AspNetCore.Mvc" Version="1.1.2" />
     <PackageReference Include="Microsoft.Extensions.Logging.Debug" Version="1.1.1" />
+    <PackageReference Include="Npgsql" Version="3.2.2" />
+    <PackageReference Include="Dapper" Version="1.50.2" />
   </ItemGroup>
 
 </Project>

src/NoEntityFrameworkExample/NoEntityFrameworkExample.csproj

@@ -0,0 +1,87 @@
+using System;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using JsonApiDotNetCore.Models;
+using JsonApiDotNetCore.Services;
+using Microsoft.Extensions.Configuration;
+using Npgsql;
+using Dapper;
+using System.Data;
+using JsonApiDotNetCoreExample.Models;
+using System.Linq;
+
+namespace NoEntityFrameworkExample.Services
+{
+    public class TodoItemService : IResourceService<TodoItem>
+    {
+        private readonly string _connectionString;
+
+        public TodoItemService(IConfiguration config)
+        {
+            _connectionString = config.GetValue<string>("Data:DefaultConnection");
+        }
+
+        private IDbConnection Connection
+        {
+            get
+            {
+                return new NpgsqlConnection(_connectionString);
+            }
+        }
+
+        private async Task<IEnumerable<T>> QueryAsync<T>(Func<IDbConnection, Task<IEnumerable<T>>> query)
+        {
+            using (IDbConnection dbConnection = Connection)
+            {
+                dbConnection.Open();
+                return await query(dbConnection);
+            }
+        }
+
+        public async Task<IEnumerable<TodoItem>> GetAsync()
+        {
+            return await QueryAsync<TodoItem>(async connection =>
+            {
+                return await connection.QueryAsync<TodoItem>("select * from \"TodoItems\"");
+            });
+        }
+
+        public async Task<TodoItem> GetAsync(int id)
+        {
+            return (await QueryAsync<TodoItem>(async connection =>
+            {
+                return await connection.QueryAsync<TodoItem>("select * from \"TodoItems\" where \"Id\"= @id", new { id });
+            })).SingleOrDefault();
+        }
+
+        public Task<object> GetRelationshipAsync(int id, string relationshipName)
+        {
+            throw new NotImplementedException();
+        }
+
+        public Task<object> GetRelationshipsAsync(int id, string relationshipName)
+        {
+            throw new NotImplementedException();
+        }
+
+        public Task<TodoItem> CreateAsync(TodoItem entity)
+        {
+            throw new NotImplementedException();
+        }
+
+        public Task<bool> DeleteAsync(int id)
+        {
+            throw new NotImplementedException();
+        }
+
+        public Task<TodoItem> UpdateAsync(int id, TodoItem entity)
+        {
+            throw new NotImplementedException();
+        }
+
+        public Task UpdateRelationshipsAsync(int id, string relationshipName, List<DocumentData> relationships)
+        {
+            throw new NotImplementedException();
+        }
+    }
+}

src/NoEntityFrameworkExample/Services/MyModelService.cs

@@ -1,12 +1,11 @@
 using JsonApiDotNetCore.Extensions;
 using JsonApiDotNetCore.Services;
+using JsonApiDotNetCoreExample.Models;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Hosting;
-using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Logging;
-using NoEntityFrameworkExample.Models;
 using NoEntityFrameworkExample.Services;
 
 namespace NoEntityFrameworkExample
@@ -34,11 +33,12 @@ public void ConfigureServices(IServiceCollection services)
             services.AddJsonApi(options => {
                 options.Namespace = "api/v1";
                 options.BuildContextGraph((builder) => {
-                    builder.AddResource<MyModel>("my-models");
+                    builder.AddResource<TodoItem>("custom-todo-items");
                 });
             }, mvcBuilder);
 
-            services.AddScoped<IResourceService<MyModel>, MyModelService>();
+            services.AddScoped<IResourceService<TodoItem>, TodoItemService>();
+            services.AddSingleton<IConfiguration>(Configuration);
         }
 
         // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.

src/NoEntityFrameworkExample/Services/TodoItemService.cs

@@ -1,4 +1,7 @@
 {
+  "Data": {
+    "DefaultConnection": "Host=localhost;Port=5432;Database=JsonApiDotNetCoreExample;User ID=postgres;Password=password"
+  },
   "Logging": {
     "IncludeScopes": false,
     "LogLevel": {

src/NoEntityFrameworkExample/Startup.cs

@@ -5,13 +5,9 @@
 using NoEntityFrameworkExample;
 using System.Net.Http;
 using JsonApiDotNetCoreExampleTests.Helpers.Extensions;
-using NoEntityFrameworkExample.Models;
 using System.Threading.Tasks;
 using System.Net;
-using System;
-using Newtonsoft.Json;
-using JsonApiDotNetCore.Models;
-using System.Collections.Generic;
+using JsonApiDotNetCoreExample.Models;
 
 namespace JsonApiDotNetCoreExampleTests.Acceptance.Extensibility
 {
@@ -23,39 +19,25 @@ public async Task Can_Implement_Custom_IResourceService_Without_EFAsync()
             // arrange
             var builder = new WebHostBuilder()
                 .UseStartup<Startup>();
+
             var server = new TestServer(builder);
             var client = server.CreateClient();
 
             var httpMethod = new HttpMethod("GET");
-            var route = $"/api/v1/my-models";
+            var route = $"/api/v1/custom-todo-items";
 
             var request = new HttpRequestMessage(httpMethod, route);
 
             // act
             var response = await client.SendAsync(request);
             var responseBody = await response.Content.ReadAsStringAsync();
             var deserializedBody = server.GetService<IJsonApiDeSerializer>()
-                .DeserializeList<MyModel>(responseBody);
-                
-            var expectedBody = JsonConvert.SerializeObject(new Documents {
-                Data = new List<DocumentData> {
-                    new DocumentData {
-                        Id = "1",
-                        Type = "my-models",
-                        Attributes = new Dictionary<string, object> {
-                            {"description", "description"}
-                        }
-                    }
-                }
-            }, new JsonSerializerSettings {
-                NullValueHandling = NullValueHandling.Ignore
-            })
-            .Replace(" ", string.Empty)
-            .ToLower();
+                .DeserializeList<TodoItem>(responseBody);
 
             // assert
             Assert.Equal(HttpStatusCode.OK, response.StatusCode);
-            Assert.Equal(expectedBody, responseBody);
+            Assert.NotNull(deserializedBody);
+            Assert.NotEmpty(deserializedBody);
         }
     }
 }