sql server ef.core adapted

Author: mehmetozkaya

src/Ordering/Ordering.API/EventHandlers/BasketCheckoutEventHandler.cs

@@ -8,6 +8,10 @@
     <PackageReference Include="AutoMapper.Extensions.Microsoft.DependencyInjection" Version="7.0.0" />
     <PackageReference Include="MediatR" Version="8.0.1" />
     <PackageReference Include="MediatR.Extensions.Microsoft.DependencyInjection" Version="8.0.0" />
+    <PackageReference Include="Microsoft.EntityFrameworkCore.Design" Version="3.1.3">
+      <PrivateAssets>all</PrivateAssets>
+      <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
+    </PackageReference>
     <PackageReference Include="Swashbuckle.AspNetCore" Version="5.3.1" />
   </ItemGroup>
 

src/Ordering/Ordering.API/Ordering.API.csproj

@@ -45,9 +45,9 @@ private void ReceivedEvent(object sender, BasicDeliverEventArgs e)
                 var message = Encoding.UTF8.GetString(e.Body);
                 var basketCheckoutEvent = JsonConvert.DeserializeObject<BasketCheckoutEvent>(message);
 
-                // TODO : stuff
-                var command = _mapper.Map<CheckoutOrderCommand>(basketCheckoutEvent);                
-                var result = _mediator.Send(command);                
+                // Internal Checkout Operation Call
+                var command = _mapper.Map<CheckoutOrderCommand>(basketCheckoutEvent);
+                var result = _mediator.Send(command);
             }
         }
 

src/Ordering/Ordering.API/RabbitMQ/EventBusRabbitMQConsumer.cs

@@ -8,14 +8,15 @@
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 using Microsoft.OpenApi.Models;
-using Ordering.API.Extentions;
 using Ordering.API.RabbitMQ;
+using Ordering.Application.Handlers;
 using Ordering.Core.Repositories;
 using Ordering.Core.Repositories.Base;
 using Ordering.Infrastructure.Data;
 using Ordering.Infrastructure.Repository;
 using Ordering.Infrastructure.Repository.Base;
 using RabbitMQ.Client;
+using System.Reflection;
 
 namespace Ordering.API
 {
@@ -35,30 +36,29 @@ public void ConfigureServices(IServiceCollection services)
 
             #region SqlServer Dependencies
 
-            // use in-memory database
-            services.AddDbContext<OrderContext>(c =>
-                c.UseInMemoryDatabase("OrderConnection"));
-
-            //// use real database
-            //services.AddDbContext<AspnetRunContext>(c =>
-            //    c.UseSqlServer(Configuration.GetConnectionString("OrderConnection")));
+            //// use in-memory database
+            //services.AddDbContext<OrderContext>(c =>
+            //    c.UseInMemoryDatabase("OrderConnection"));
 
-            //TODO : burdasin -- connection string ekle
+            // use real database
+            services.AddDbContext<OrderContext>(c =>
+                c.UseSqlServer(Configuration.GetConnectionString("OrderConnection")));            
 
             #endregion
 
             #region Project Dependencies
 
             // Add Infrastructure Layer
             services.AddScoped(typeof(IRepository<>), typeof(Repository<>));
+            services.AddScoped(typeof(IOrderRepository), typeof(OrderRepository));
             services.AddScoped<IOrderRepository, OrderRepository>();
 
-            // Add MediatR
-            services.AddMediatR(this.GetType().Assembly);
-
             // Add AutoMapper
             services.AddAutoMapper(typeof(Startup));
 
+            // Add MediatR
+            services.AddMediatR(typeof(CheckoutOrderHandler).GetTypeInfo().Assembly);
+
             #endregion
 
             #region RabbitMQ Dependencies
@@ -114,8 +114,8 @@ public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
                 endpoints.MapControllers();
             });
 
-            //Initilize Rabbit Listener in ApplicationBuilderExtentions
-            app.UseRabbitListener();
+            ////Initilize Rabbit Listener in ApplicationBuilderExtentions
+            //app.UseRabbitListener();
 
             app.UseSwagger();
             app.UseSwaggerUI(c =>

src/Ordering/Ordering.API/Startup.cs

@@ -1,4 +1,7 @@
 {
+  "ConnectionStrings": {
+    "OrderConnection": "Server=(localdb)\\mssqllocaldb;Integrated Security=true;Initial Catalog=OrderDb;"
+  },
   "Logging": {
     "LogLevel": {
       "Default": "Information",

src/Ordering/Ordering.API/appsettings.json

@@ -5,7 +5,7 @@ namespace Ordering.Infrastructure.Data
 {
     public class OrderContext : DbContext
     {
-        public OrderContext(DbContextOptions options) : base(options)
+        public OrderContext(DbContextOptions<OrderContext> options) : base(options)
         {
         }
 

src/Ordering/Ordering.Application/Interfaces/IOrderService.cs

@@ -0,0 +1,42 @@
+using Microsoft.EntityFrameworkCore.Migrations;
+
+namespace Ordering.Infrastructure.Migrations
+{
+    public partial class Initial : Migration
+    {
+        protected override void Up(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.CreateTable(
+                name: "Orders",
+                columns: table => new
+                {
+                    Id = table.Column<int>(nullable: false)
+                        .Annotation("SqlServer:Identity", "1, 1"),
+                    UserName = table.Column<string>(nullable: true),
+                    TotalPrice = table.Column<decimal>(nullable: false),
+                    FirstName = table.Column<string>(nullable: true),
+                    LastName = table.Column<string>(nullable: true),
+                    EmailAddress = table.Column<string>(nullable: true),
+                    AddressLine = table.Column<string>(nullable: true),
+                    Country = table.Column<string>(nullable: true),
+                    State = table.Column<string>(nullable: true),
+                    ZipCode = table.Column<string>(nullable: true),
+                    CardName = table.Column<string>(nullable: true),
+                    CardNumber = table.Column<string>(nullable: true),
+                    Expiration = table.Column<string>(nullable: true),
+                    CVV = table.Column<string>(nullable: true),
+                    PaymentMethod = table.Column<int>(nullable: false)
+                },
+                constraints: table =>
+                {
+                    table.PrimaryKey("PK_Orders", x => x.Id);
+                });
+        }
+
+        protected override void Down(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.DropTable(
+                name: "Orders");
+        }
+    }
+}