注.建立.net core的webapi项目参看：
http://blog.csdn.net/zzzili/article/details/75307308
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;" },
*******************************************************************************另一种写法，可以在使用MyDBContext时，直接new
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
***************************************************************************************************************************************************************************************************
完整文件
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; } } }
