Basic implementation with EF Core

src/AzureIdentityLivestream.Web/AzureIdentityLivestream.Web.csproj

@@ -11,6 +11,7 @@
     <PackageReference Include="Dapper" Version="2.0.78" />
     <PackageReference Include="Microsoft.ApplicationInsights.AspNetCore" Version="2.16.0" />
     <PackageReference Include="Microsoft.Data.SqlClient" Version="2.1.1" />
+    <PackageReference Include="Microsoft.EntityFrameworkCore.SqlServer" Version="5.0.3" />
     <PackageReference Include="Scrutor" Version="3.3.0" />
   </ItemGroup>
 

src/AzureIdentityLivestream.Web/Services/Person.cs

@@ -1,4 +1,4 @@
 namespace AzureIdentityLivestream.Web.Services
 {
-    public record Person(string FirstName, string LastName, int Age);
+    public record Person(int Id, string FirstName, string LastName, int Age);
 }

src/AzureIdentityLivestream.Web/Services/Sql/EfCorePersonProvider.cs

@@ -0,0 +1,18 @@
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using Microsoft.EntityFrameworkCore;
+
+namespace AzureIdentityLivestream.Web.Services.Sql
+{
+    public class EfCorePersonProvider : IPersonProvider
+    {
+        private readonly LivestreamContext _livestreamContext;
+
+        public EfCorePersonProvider(LivestreamContext livestreamContext)
+        {
+            _livestreamContext = livestreamContext;
+        }
+
+        public async Task<IEnumerable<Person>> GetPeople() => await _livestreamContext.People.ToListAsync();
+    }
+}

src/AzureIdentityLivestream.Web/Services/Sql/LivestreamContext.cs

@@ -0,0 +1,22 @@
+using System.Diagnostics.CodeAnalysis;
+using Microsoft.EntityFrameworkCore;
+
+namespace AzureIdentityLivestream.Web.Services.Sql
+{
+    public class LivestreamContext : DbContext
+    {
+        public LivestreamContext([NotNull] DbContextOptions options) : base(options)
+        {
+        }
+
+        public DbSet<Person> People => Set<Person>();
+
+        protected override void OnModelCreating(ModelBuilder modelBuilder)
+        {
+            modelBuilder
+                .Entity<Person>()
+                .ToTable("Person")
+                .HasKey(x => x.Id);
+        }
+    }
+}

src/AzureIdentityLivestream.Web/Startup.cs

@@ -2,6 +2,7 @@
 using AzureIdentityLivestream.Web.Services.Sql;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Hosting;
+using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
@@ -21,17 +22,13 @@ public void ConfigureServices(IServiceCollection services)
         {
             services.AddApplicationInsightsTelemetry();
 
-            services.AddMemoryCache();
-            services.AddSingleton<IAzureSqlTokenProvider, AzureIdentityAzureSqlTokenProvider>();
-            services.Decorate<IAzureSqlTokenProvider, CacheAzureSqlTokenProvider>();
-
-            services.AddSingleton(provider =>
+            services.AddDbContext<LivestreamContext>(builder =>
             {
                 var sqlConnectionString = Configuration.GetValue<string>("SqlConnectionString");
-                return new SqlConnectionFactory(sqlConnectionString, provider.GetRequiredService<IAzureSqlTokenProvider>());
+                builder.UseSqlServer(sqlConnectionString, options => options.EnableRetryOnFailure());
             });
 
-            services.AddSingleton<IPersonProvider, DapperPersonProvider>();
+            services.AddScoped<IPersonProvider, EfCorePersonProvider>();
 
             services.AddRazorPages();
         }

src/AzureIdentityLivestream.Web/appsettings.json

@@ -1,6 +1,6 @@
 {
   "StorageConnectionString": "https://azureidentitylivestream.blob.core.windows.net",
-  "SqlConnectionString": "Data Source=tcp:azureidentitylivestream.database.windows.net,1433; Initial Catalog=azure-identity-livestream; Encrypt=True; TrustServerCertificate=False",
+  "SqlConnectionString": "Data Source=(localdb)\\azureidentitylivestream; Initial Catalog=azure-identity-livestream; Integrated Security=SSPI",
   "Logging": {
     "LogLevel": {
       "Default": "Information",