Implementation added to GIT

Author: dev-sankhadip

DistributedCaching/Controllers/CachingController.cs

@@ -0,0 +1,66 @@
+using DistributedCaching.Model;
+using DistributedCaching.Service;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.Extensions.Configuration;
+using System.Collections.Generic;
+using System.Data.SqlClient;
+
+namespace DistributedCaching.Controllers
+{
+    [Route("api/caching")]
+    [ApiController]
+    public class CachingController : ControllerBase
+    {
+
+        private IConfiguration Configuration;
+        private readonly IMemoryCache mCache;
+
+        public CachingController(IConfiguration configuration, IMemoryCache memoryCache)
+        {
+            Configuration = configuration;
+            mCache = memoryCache;
+        }
+
+        [HttpGet("")]
+        public ActionResult GetResult()
+        {
+            string cString = Configuration.GetConnectionString("SqlServerCString");
+
+            List<Student> student = new List<Student>();
+
+            student = mCache.getCache<List<Student>>("student");
+
+            if (student == null)
+            {
+                using (SqlConnection con = new SqlConnection(cString))
+                {
+                    con.Open();
+
+                    List<Student> studentList = new List<Student>();
+
+                    string query = "select * from Student";
+
+                    SqlCommand cmd = new SqlCommand(query, con);
+                    SqlDataReader sqlDataReader = cmd.ExecuteReader();
+
+                    while (sqlDataReader.Read())
+                    {
+                        studentList.Add(new Student()
+                        {
+                            Id = (int)sqlDataReader["Id"],
+                            Name = (string)sqlDataReader["Name"],
+                            Age = (int)sqlDataReader["Age"]
+                        });
+                    }
+
+                    mCache.setCache<List<Student>>(studentList, "student");
+
+                    return Ok(studentList);
+
+                }
+            }
+            return Ok(student);
+        }
+
+    }
+}

DistributedCaching/DistributedCaching.csproj

@@ -0,0 +1,12 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <TargetFramework>netcoreapp3.1</TargetFramework>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="System.Data.SqlClient" Version="4.8.1" />
+  </ItemGroup>
+
+
+</Project>

DistributedCaching/DistributedCaching.csproj.user

@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="utf-8"?>
+<Project ToolsVersion="Current" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
+  <PropertyGroup>
+    <Controller_SelectedScaffolderID>ApiControllerEmptyScaffolder</Controller_SelectedScaffolderID>
+    <Controller_SelectedScaffolderCategoryPath>root/Controller</Controller_SelectedScaffolderCategoryPath>
+  </PropertyGroup>
+</Project>

DistributedCaching/Model/Student.cs

@@ -0,0 +1,12 @@
+using System;
+
+namespace DistributedCaching.Model
+{
+    [Serializable]
+    public class Student
+    {
+        public int Id { get; set; }
+        public string Name { get; set; }
+        public int Age { get; set; }
+    }
+}

DistributedCaching/Program.cs

@@ -0,0 +1,26 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.Hosting;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Hosting;
+using Microsoft.Extensions.Logging;
+
+namespace DistributedCaching
+{
+    public class Program
+    {
+        public static void Main(string[] args)
+        {
+            CreateHostBuilder(args).Build().Run();
+        }
+
+        public static IHostBuilder CreateHostBuilder(string[] args) =>
+            Host.CreateDefaultBuilder(args)
+                .ConfigureWebHostDefaults(webBuilder =>
+                {
+                    webBuilder.UseStartup<Startup>();
+                });
+    }
+}

DistributedCaching/Properties/launchSettings.json

@@ -0,0 +1,30 @@
+{
+  "$schema": "http://json.schemastore.org/launchsettings.json",
+  "iisSettings": {
+    "windowsAuthentication": false,
+    "anonymousAuthentication": true,
+    "iisExpress": {
+      "applicationUrl": "http://localhost:54486",
+      "sslPort": 44300
+    }
+  },
+  "profiles": {
+    "IIS Express": {
+      "commandName": "IISExpress",
+      "launchBrowser": false,
+      "launchUrl": "weatherforecast",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "DistributedCaching": {
+      "commandName": "Project",
+      "launchBrowser": false,
+      "launchUrl": "weatherforecast",
+      "applicationUrl": "https://localhost:5001;http://localhost:5000",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    }
+  }
+}

DistributedCaching/Service/IMemoryCache.cs

@@ -0,0 +1,9 @@
+namespace DistributedCaching.Service
+{
+    public interface IMemoryCache
+    {
+        void setCache<T>(T values, string key);
+        T getCache<T>(string key) where T : class;
+        void removeCache(string key);
+    }
+}

DistributedCaching/Service/MemoryCache.cs

@@ -0,0 +1,77 @@
+using Microsoft.Extensions.Caching.Distributed;
+using System;
+using System.IO;
+using System.Runtime.Serialization.Formatters.Binary;
+
+namespace DistributedCaching.Service
+{
+    public class MemoryCache : IMemoryCache
+    {
+        public IDistributedCache _cache;
+        public BinaryFormatter binFormatter;
+
+        public MemoryCache(IDistributedCache _cache)
+        {
+            this.binFormatter = new BinaryFormatter();
+            this._cache = _cache;
+        }
+
+        public T getCache<T>(string key) where T : class
+        {
+            try
+            {
+                byte[] values = _cache.Get(key);
+
+                if (values == null) return null;
+
+                BinaryFormatter binaryFormatter = new BinaryFormatter();
+                using (MemoryStream memoryStream = new MemoryStream(values))
+                {
+                    return binaryFormatter.Deserialize(memoryStream) as T;
+                }
+            }
+            catch (Exception ex)
+            {
+                throw ex;
+            }
+        }
+
+        public void setCache<T>(T values, string key)
+        {
+            try
+            {
+                MemoryStream mStream = new MemoryStream();
+
+                binFormatter.Serialize(mStream, values);
+
+                mStream.ToArray();
+
+                DistributedCacheEntryOptions cacheOptions = new DistributedCacheEntryOptions()
+                {
+                    AbsoluteExpiration = DateTime.Now.AddDays(7),
+                    SlidingExpiration = TimeSpan.FromSeconds(30)
+                };
+
+                _cache.Set(key, mStream.ToArray());
+
+                mStream.Close();
+            }
+            catch (Exception ex)
+            {
+                throw ex;
+            }
+        }
+
+        public void removeCache(string key)
+        {
+            try
+            {
+                _cache.Remove(key);
+            }
+            catch (Exception ex)
+            {
+                throw ex;
+            }
+        }
+    }
+}

DistributedCaching/Startup.cs

@@ -0,0 +1,49 @@
+using DistributedCaching.Service;
+using Microsoft.AspNetCore.Builder;
+using Microsoft.AspNetCore.Hosting;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
+
+namespace DistributedCaching
+{
+    public class Startup
+    {
+        public Startup(IConfiguration configuration)
+        {
+            Configuration = configuration;
+        }
+
+        public IConfiguration Configuration { get; }
+
+        // This method gets called by the runtime. Use this method to add services to the container.
+        public void ConfigureServices(IServiceCollection services)
+        {
+            services.AddControllers();
+
+            services.AddDistributedMemoryCache();
+
+            services.AddScoped<IMemoryCache, MemoryCache>();
+        }
+
+        // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
+        public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
+        {
+            if (env.IsDevelopment())
+            {
+                app.UseDeveloperExceptionPage();
+            }
+
+            app.UseHttpsRedirection();
+
+            app.UseRouting();
+
+            app.UseAuthorization();
+
+            app.UseEndpoints(endpoints =>
+            {
+                endpoints.MapControllers();
+            });
+        }
+    }
+}

DistributedCaching/appsettings.Development.json

@@ -0,0 +1,9 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft": "Warning",
+      "Microsoft.Hosting.Lifetime": "Information"
+    }
+  }
+}

DistributedCaching/appsettings.json

@@ -0,0 +1,13 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft": "Warning",
+      "Microsoft.Hosting.Lifetime": "Information"
+    }
+  },
+  "AllowedHosts": "*",
+  "ConnectionStrings": {
+    "SqlServerCString": "Data Source=localhost;Initial Catalog=caching;Persist Security Info=True;User ID=sa;Password=sankhadip2017..;"
+  }
+}