.Net Core 的WebApi项目使用mysql的EF CodeFirst模式

青旅半醒 2023-10-17 18:02 17阅读 0赞

注.建立.net core的webapi项目参看：

[http://blog.csdn.net/zzzili/article/details/75307308][http_blog.csdn.net_zzzili_article_details_75307308]

1.需要引用的库有

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p6emlsaQ_size_16_color_FFFFFF_t_70][]

或者

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p6emlsaQ_size_16_color_FFFFFF_t_70 1][]

2.在项目中添加MyDBContext类和实体类User

using System;
    using System.Collections.Generic;
    using System.ComponentModel.DataAnnotations;
    using System.Linq;
    using System.Text;
    using System.Threading.Tasks;
    
    namespace DataCore
    {
        public class User
        {
            public int id { set; get; }        
            public string remark1 { set; get; }
            public string name { set; get; }
            public int age { set; get; }
            public string remark2 { set; get; }
            public DateTime updateTime { set; get; }
            public DateTime createTime { set; get; }
            public bool isEnable { set; get; }        
        }
    }

using Microsoft.EntityFrameworkCore;
    using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Threading.Tasks;
    
    namespace DataCore
    {
        public class MyDBContext : DbContext
        {
            public MyDBContext(DbContextOptions<MyDBContext> options)
             : base(options)
            {
            }
    
            public DbSet<User> User { get; set; }
        }
    }

3.在Startup类中的ConfigureServices方法添加如下代码:

public void ConfigureServices(IServiceCollection services)
            {
                // Replace with your connection string.
                var connectionString= Configuration["ConnectionStrings:DefaultConnection"];
    
                //Pomelo时这样写
                var serverVersion = new MySqlServerVersion(new Version(5, 6, 22));
                services.AddDbContext<MyDBContext>(options =>options.UseMySql(connectionString,serverVersion));
                
                //或者用mysql ef core时这样写
               services.AddDbContext<MyDBContext>(options =>options.UseMySQL(connectionString));
    
                services.AddControllers();
            }

appsetting.json中添加：

"ConnectionStrings": {
        "DefaultConnection": "server=localhost;user id=root;pwd=root;database=testcore;"
      },

using Microsoft.EntityFrameworkCore;
    using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Threading.Tasks;
    
    namespace DataCore
    {
        public class MyDBContext : DbContext
        {
            public static string connectionString = null;
            public MyDBContext()
            {
            }
            protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
            {
                optionsBuilder.UseMySQL(connectionString);
            }
    
            public DbSet<User> User { get; set; }
        }
    }

//Startup中这样配置，把连接字符串赋值给MyDBContext的静态变量        
    public void ConfigureServices(IServiceCollection services)
            {
                // Replace with your connection string.
                var connectionString = Configuration["ConnectionStrings:DefaultConnection"];
                MyDBContext.connectionString = connectionString;            
    
                services.AddControllers();
            }

\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*

4.控制台内执行

Add-Migration xxx

Update-Database

5.使用swagger

添加引用：Swashbuckle.AspNetCore

public void ConfigureServices(IServiceCollection services)
            {
                //使用mysql
                var connectionString= Configuration["ConnectionStrings:DefaultConnection"];
                var serverVersion = new MySqlServerVersion(new Version(5, 6, 22));
                services.AddDbContext<MyDBContext>(options =>
                options.UseMySql(connectionString,serverVersion));
    
                //Init Swagger
                services.AddSwaggerGen(c =>
                {
                    c.SwaggerDoc("v1", new OpenApiInfo { Title = "My API", Version = "v1" });
                });
    
                services.AddControllers();
            }

public void Configure(IApplicationBuilder app, IHostingEnvironment env)
            {
                if (env.IsDevelopment())
                {
                    app.UseDeveloperExceptionPage();
                }
    
                //InitSwagger
                app.UseSwagger();
                app.UseSwaggerUI(c =>
                {
                    c.SwaggerEndpoint("v1/swagger.json", "My API V1");
                });
    
                app.UseMvc();
            }

6.TestController

using DataCore;
    using Microsoft.AspNetCore.Http;
    using Microsoft.AspNetCore.Mvc;
    using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Threading.Tasks;
    
    namespace WebApplication3.Controllers
    {
        public class TestInput
        {
            public string str1 { set; get; }
            public string str2 { set; get; }
        }
        [Route("api/[controller]/[action]")]
        [ApiController]
        public class TestController : ControllerBase
        {
            [HttpPost]
            public string test2(TestInput input)
            {
                return input.str1+input.str2;
            }
            private readonly MyDBContext dbContext = new MyDBContext();
           [HttpGet]
            public object testmysql()
            {
                User u = new User();
                u.remark1 = "1";
                u.createTime = DateTime.Now;
                dbContext.User.Add(u);
                dbContext.SaveChanges();
    
                var list = dbContext.User.ToList();
                return list;
            }
        }
    }

7.发布到Linux环境，参考文章：[http://blog.csdn.net/zzzili/article/details/79213001][http_blog.csdn.net_zzzili_article_details_79213001]

\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*\*

完整文件

MyDBContext.cs

using Microsoft.EntityFrameworkCore;
    using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Threading.Tasks;
    
    namespace DataCore
    {
        public class MyDBContext : DbContext
        {
            public static string connectionString = null;
            public MyDBContext()
            {
            }
            protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
            {
                optionsBuilder.UseMySQL(connectionString);
            }
    
            public DbSet<User> User { get; set; }
            public DbSet<UserOrder> UserOrder { get; set; }
        }
    }

Startup.cs

using DataCore;
    using Microsoft.AspNetCore.Builder;
    using Microsoft.AspNetCore.Hosting;
    using Microsoft.AspNetCore.Mvc;
    using Microsoft.EntityFrameworkCore;
    using Microsoft.Extensions.Configuration;
    using Microsoft.Extensions.DependencyInjection;
    using Microsoft.Extensions.Hosting;
    using Microsoft.Extensions.Logging;
    using Microsoft.OpenApi.Models;
    using System;
    using System.Collections.Generic;
    using System.IO;
    using System.Linq;
    using System.Threading.Tasks;
    
    namespace WebApplication3
    {
        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)
            {
                // Replace with your connection string.
                var connectionString = Configuration["ConnectionStrings:DefaultConnection"];
                MyDBContext.connectionString = connectionString;            
    
                services.AddControllers();
            }
    
    
            // 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.UseRouting();
    
                app.UseAuthorization();
    
                //InitSwagger
                app.UseSwagger();
                app.UseSwaggerUI(c =>
                {
                    c.SwaggerEndpoint("v1/swagger.json", "My API V1");
                });
    
                app.UseEndpoints(endpoints =>
                {
                    endpoints.MapControllers();
                });
            }
        }
    }

TestController.cs

using DataCore;
    using Microsoft.AspNetCore.Http;
    using Microsoft.AspNetCore.Mvc;
    using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Threading.Tasks;
    
    namespace WebApplication3.Controllers
    {
        public class TestInput
        {
            public string str1 { set; get; }
            public string str2 { set; get; }
        }
        [Route("api/[controller]/[action]")]
        [ApiController]
        public class TestController : ControllerBase
        {
            [HttpPost]
            public string test2(TestInput input)
            {
                return input.str1+input.str2;
            }
            private readonly MyDBContext dbContext = new MyDBContext();
           [HttpGet]
            public object testmysql()
            {
                UserOrder u = new UserOrder();
                u.userId =1;
                u.orderNo = "11111";
                dbContext.UserOrder.Add(u);
                dbContext.SaveChanges();
    
                var query = from user in dbContext.User
                            join o in dbContext.UserOrder on
                            u.id equals o.userId
                            select new { user,o};
    
                var list = query.ToList();
                return list;
            }
        }
    }

[http_blog.csdn.net_zzzili_article_details_75307308]: http://blog.csdn.net/zzzili/article/details/75307308
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p6emlsaQ_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/2021051915414488.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p6emlsaQ==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p6emlsaQ_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20210519155040951.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p6emlsaQ==,size_16,color_FFFFFF,t_70
[http_blog.csdn.net_zzzili_article_details_79213001]: http://blog.csdn.net/zzzili/article/details/79213001