找回密码
 立即注册

QQ登录

只需一步，快速开始

首页 › ActiveReportsJS专区 › 专题教程 › 查看内容
发新帖

Lenka.Guo 讲师达人认证 悬赏达人认证

超级版主

260

主题

4686

帖子

9486

积分

超级版主

Rank: 8Rank: 8

积分
9486

活字格认证讲师达人悬赏达人微信认证勋章元老葡萄

最新发帖

.Net Core API 连接Mysql数据库返回JSON 数据供ActiveReportsJS 使用

Lenka.Guo 讲师达人认证 悬赏达人认证
超级版主   /  发表于：2021-11-4 10:14  /   查看：2397  /  回复：0
示例源码：


操作步骤：

1. 使用Mysql工具创建我们需要的mysql database 表
  1. CREATE TABLE dbo.department(
  2.   DepartmentId int AUTO_INCREMENT,
  3.   DepartmentName nvarchar(500),
  4.   PRIMARY KEY (DepartmentId)
  5. )
复制代码
插入表：
  1. INSERT into dbo.Department (DepartmentName) VALUES ('IT')
  2. INSERT into dbo.Department (DepartmentName) VALUES ('Support')
复制代码


employee表：


  1. create table dbo.Employee(
  2. EmployeeId int AUTO_INCREMENT,
  3. EmployeeName nvarchar(500),
  4. Department nvarchar(500),
  5. DateOfJoining datetime,
  6. PhotoFileName nvarchar(500),
  7. PRIMARY KEY(EmployeeId)
  8. );

  10. insert into dbo.Employee(EmployeeName,Department,DateOfJoining,PhotoFileName)
  11. values                  ('Bob','IT','2021-06-21','anonymous.png');

  13. select * from dbo.Employee;
复制代码
2. 创建.Net Core Web API 项目


-> launchSettings.json ：文件包含了如何启动项目的细节描述
-> Controllers 文件夹：包含了API controler 方法
-> We generally keep the configuration details such as database details in appSettings.json.
-> program.cs 是程序的主入口 Main() 它还创建了网络主机，基本上可以帮助应用程序监听http请求。
-> startup类 class 类配置了我们的应用程序所需的所有服务。类配置了我们应用程序所需的所有服务。服务基本上是可重复使用的组件，可以使用依赖性在我们的应用程序中使用。


3. 配置允许跨域：


  1. using Microsoft.AspNetCore.Builder;
  2. using Microsoft.AspNetCore.Hosting;
  3. using Microsoft.AspNetCore.HttpsPolicy;
  4. using Microsoft.AspNetCore.Mvc;
  5. using Microsoft.Extensions.Configuration;
  6. using Microsoft.Extensions.DependencyInjection;
  7. using Microsoft.Extensions.Hosting;
  8. using Microsoft.Extensions.Logging;
  9. using Microsoft.OpenApi.Models;
  10. using System;
  11. using System.Collections.Generic;
  12. using System.Linq;
  13. using System.Threading.Tasks;

  15. namespace WebApplication11
  16. {
  17.     public class Startup
  18.     {
  19.         public Startup(IConfiguration configuration)
  20.         {
  21.             Configuration = configuration;
  22.         }

  24.         public IConfiguration Configuration { get; }

  26.         // This method gets called by the runtime. Use this method to add services to the container.
  27.         public void ConfigureServices(IServiceCollection services)
  28.         {
  29.             services.AddCors(c=> {
  30.                 c.AddPolicy("AllowOrigin",options=>options.AllowAnyOrigin().AllowAnyMethod().AllowAnyHeader());
  31.             });
  32.             services.AddControllers();
  33.             services.AddSwaggerGen(c =>
  34.             {
  35.                 c.SwaggerDoc("v1", new OpenApiInfo { Title = "WebApplication11", Version = "v1" });
  36.             });
  37.         }

  39.         // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
  40.         public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
  41.         {
  42.             if (env.IsDevelopment())
  43.             {
  44.                 app.UseDeveloperExceptionPage();
  45.                 app.UseSwagger();
  46.                 app.UseSwaggerUI(c => c.SwaggerEndpoint("/swagger/v1/swagger.json", "WebApplication11 v1"));
  47.             }

  49.             app.UseCors(options => options.AllowAnyOrigin().AllowAnyMethod().AllowAnyHeader());
  50.             app.UseHttpsRedirection();

  52.             app.UseRouting();

  54.             app.UseAuthorization();

  56.             app.UseEndpoints(endpoints =>
  57.             {
  58.                 endpoints.MapControllers();
  59.             });
  60.         }
  61.     }
  62. }
复制代码




4. 安装 JSON 序列化nuget 包 帮助我们提供JSON 序列化和反序列化的函数



Startup.cs 完整代码：
  1. using Microsoft.AspNetCore.Builder;
  2. using Microsoft.AspNetCore.Hosting;
  3. using Microsoft.AspNetCore.HttpsPolicy;
  4. using Microsoft.AspNetCore.Mvc;
  5. using Microsoft.Extensions.Configuration;
  6. using Microsoft.Extensions.DependencyInjection;
  7. using Microsoft.Extensions.FileProviders;
  8. using Microsoft.Extensions.Hosting;
  9. using Microsoft.Extensions.Logging;
  10. using Microsoft.OpenApi.Models;
  11. using Newtonsoft.Json.Serialization;
  12. using System;
  13. using System.Collections.Generic;
  14. using System.IO;
  15. using System.Linq;
  16. using System.Threading.Tasks;

  18. namespace WebApplication11
  19. {
  20.     public class Startup
  21.     {
  22.         public Startup(IConfiguration configuration)
  23.         {
  24.             Configuration = configuration;
  25.         }

  27.         public IConfiguration Configuration { get; }

  29.         // This method gets called by the runtime. Use this method to add services to the container.
  30.         public void ConfigureServices(IServiceCollection services)
  31.         {
  32.             services.AddCors(c=> {
  33.                 c.AddPolicy("AllowOrigin",options=>options.AllowAnyOrigin().AllowAnyMethod().AllowAnyHeader());
  34.             });
  35.             services.AddControllersWithViews().AddNewtonsoftJson(options =>
  36.             options.SerializerSettings.ReferenceLoopHandling = Newtonsoft.Json.ReferenceLoopHandling.Ignore)
  37.                 .AddNewtonsoftJson(options => options.SerializerSettings.ContractResolver
  38.                 = new DefaultContractResolver());

  40.             services.AddControllers();
  41.             services.AddControllers();
  42.             services.AddSwaggerGen(c =>
  43.             {
  44.                 c.SwaggerDoc("v1", new OpenApiInfo { Title = "WebApplication11", Version = "v1" });
  45.             });
  46.         }

  48.         // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
  49.         public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
  50.         {
  51.             if (env.IsDevelopment())
  52.             {
  53.                 app.UseDeveloperExceptionPage();
  54.                 app.UseSwagger();
  55.                 app.UseSwaggerUI(c => c.SwaggerEndpoint("/swagger/v1/swagger.json", "WebApplication11 v1"));
  56.             }

  58.             app.UseCors(options => options.AllowAnyOrigin().AllowAnyMethod().AllowAnyHeader());
  59.             app.UseHttpsRedirection();

  61.             app.UseRouting();

  63.             app.UseAuthorization();

  65.             app.UseEndpoints(endpoints =>
  66.             {
  67.                 endpoints.MapControllers();
  68.             });

  70.             app.UseStaticFiles(new StaticFileOptions
  71.             {
  72.                 FileProvider = new PhysicalFileProvider(
  73.                  Path.Combine(Directory.GetCurrentDirectory(), "Photos")),
  74.                 RequestPath = "/Photos"
  75.             });
  76.         }
  77.     }
  78. }
复制代码


以下代码是指定图像上传的地址：
  1. {
  2.                 FileProvider = new PhysicalFileProvider(
  3.                    Path.Combine(Directory.GetCurrentDirectory(), "Photos")),
  4.                 RequestPath = "/Photos"
  5.             });
复制代码



5. 为了连接Mysql 数据库，先安装MysqlData nuget包



6.  添加数据模型 Model:

Department.cs:
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Threading.Tasks;

  6. namespace WebApplication1.Models
  7. {
  8.     public class Department
  9.     {
  10.         public int DepartmentId { get; set; }

  12.         public string DepartmentName { get; set; }
  13.     }
  14. }
复制代码
Employee.cs:
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Threading.Tasks;

  6. namespace WebApplication1.Models
  7. {
  8.     public class Employee
  9.     {
  10.         public int EmployeeId { get; set; }
  11.         public string EmployeeName {get; set; }
  12.         public string Department { get; set; }

  14.         public string DateOfJoining { get; set; }

  16.         public string  PhotoFileName { get; set; }
  17.     }
  18. }
复制代码


7. 在appSettings.json 文件中添加数据库连接字符串：


8. 添加对应Model的controller:
DepartmentController.cs:
  1. using Microsoft.AspNetCore.Http;
  2. using Microsoft.AspNetCore.Mvc;
  3. using Microsoft.Extensions.Configuration;
  4. using MySql.Data.MySqlClient;
  5. using System;
  6. using System.Collections.Generic;
  7. using System.Data;
  8. using System.Linq;
  9. using System.Threading.Tasks;
  10. using WebApplication1.Models;

  12. namespace WebApplication1.Controllers
  13. {
  14.     [Route("api/[controller]")]
  15.     [ApiController]
  16.     public class DepartmentController : ControllerBase
  17.     {
  18.         private readonly IConfiguration _configuration;
  19.         public DepartmentController(IConfiguration configuration)
  20.         {
  21.             _configuration = configuration;
  22.         }

  24.         [HttpGet]
  25.         public JsonResult Get()
  26.         {
  27.             string query = @"
  28.                         select DepartmentId,DepartmentName from
  29.                         dbo.Department
  30.             ";

  32.             DataTable table = new DataTable();
  33.             string sqlDataSource = _configuration.GetConnectionString("EmployeeAppCon");
  34.             MySqlDataReader myReader;
  35.             using(MySqlConnection mycon=new MySqlConnection(sqlDataSource))
  36.             {
  37.                 mycon.Open();
  38.                 using(MySqlCommand myCommand=new MySqlCommand(query, mycon))
  39.                 {
  40.                     myReader = myCommand.ExecuteReader();
  41.                     table.Load(myReader);

  43.                     myReader.Close();
  44.                     mycon.Close();
  45.                 }
  46.             }

  48.             return new JsonResult(table);
  49.         }


  52.         [HttpPost]
  53.         public JsonResult Post(Department dep)
  54.         {
  55.             string query = @"
  56.                         insert into dbo.Department (DepartmentName) values
  57.                                                     (@DepartmentName);
  58.                         
  59.             ";

  61.             DataTable table = new DataTable();
  62.             string sqlDataSource = _configuration.GetConnectionString("EmployeeAppCon");
  63.             MySqlDataReader myReader;
  64.             using (MySqlConnection mycon = new MySqlConnection(sqlDataSource))
  65.             {
  66.                 mycon.Open();
  67.                 using (MySqlCommand myCommand = new MySqlCommand(query, mycon))
  68.                 {
  69.                     myCommand.Parameters.AddWithValue("@DepartmentName", dep.DepartmentName);
  70.                     
  71.                     myReader = myCommand.ExecuteReader();
  72.                     table.Load(myReader);

  74.                     myReader.Close();
  75.                     mycon.Close();
  76.                 }
  77.             }

  79.             return new JsonResult("Added Successfully");
  80.         }


  83.         [HttpPut]
  84.         public JsonResult Put(Department dep)
  85.         {
  86.             string query = @"
  87.                         update dbo.Department set
  88.                         DepartmentName =@DepartmentName
  89.                         where DepartmentId=@DepartmentId;
  90.                         
  91.             ";

  93.             DataTable table = new DataTable();
  94.             string sqlDataSource = _configuration.GetConnectionString("EmployeeAppCon");
  95.             MySqlDataReader myReader;
  96.             using (MySqlConnection mycon = new MySqlConnection(sqlDataSource))
  97.             {
  98.                 mycon.Open();
  99.                 using (MySqlCommand myCommand = new MySqlCommand(query, mycon))
  100.                 {
  101.                     myCommand.Parameters.AddWithValue("@DepartmentId", dep.DepartmentId);
  102.                     myCommand.Parameters.AddWithValue("@DepartmentName", dep.DepartmentName);

  104.                     myReader = myCommand.ExecuteReader();
  105.                     table.Load(myReader);

  107.                     myReader.Close();
  108.                     mycon.Close();
  109.                 }
  110.             }

  112.             return new JsonResult("Updated Successfully");
  113.         }



  117.         [HttpDelete("{id}")]
  118.         public JsonResult Delete(int id)
  119.         {
  120.             string query = @"
  121.                         delete from dbo.Department
  122.                         where DepartmentId=@DepartmentId;
  123.                         
  124.             ";

  126.             DataTable table = new DataTable();
  127.             string sqlDataSource = _configuration.GetConnectionString("EmployeeAppCon");
  128.             MySqlDataReader myReader;
  129.             using (MySqlConnection mycon = new MySqlConnection(sqlDataSource))
  130.             {
  131.                 mycon.Open();
  132.                 using (MySqlCommand myCommand = new MySqlCommand(query, mycon))
  133.                 {
  134.                     myCommand.Parameters.AddWithValue("@DepartmentId", id);

  136.                     myReader = myCommand.ExecuteReader();
  137.                     table.Load(myReader);

  139.                     myReader.Close();
  140.                     mycon.Close();
  141.                 }
  142.             }

  144.             return new JsonResult("Deleted Successfully");
  145.         }

  147.     }
  148. }
复制代码
EmployeeController.cs:
  1. using Microsoft.AspNetCore.Hosting;
  2. using Microsoft.AspNetCore.Http;
  3. using Microsoft.AspNetCore.Mvc;
  4. using Microsoft.Extensions.Configuration;
  5. using MySql.Data.MySqlClient;
  6. using System;
  7. using System.Collections.Generic;
  8. using System.Data;
  9. using System.IO;
  10. using System.Linq;
  11. using System.Threading.Tasks;
  12. using WebApplication1.Models;

  14. namespace WebApplication1.Controllers
  15. {
  16.     [Route("api/[controller]")]
  17.     [ApiController]
  18.     public class EmployeeController : ControllerBase
  19.     {
  20.         private readonly IConfiguration _configuration;
  21.         private readonly IWebHostEnvironment _env;
  22.         public EmployeeController(IConfiguration configuration,IWebHostEnvironment env)
  23.         {
  24.             _configuration = configuration;
  25.             _env = env;
  26.         }

  28.         [HttpGet]
  29.         public JsonResult Get()
  30.         {
  31.             string query = @"
  32.                         select EmployeeId,EmployeeName,Department,
  33.                         DATE_FORMAT(DateOfJoining,'%Y-%m-%d') as DateOfJoining,
  34.                         PhotoFileName
  35.                         from
  36.                         dbo.Employee
  37.             ";

  39.             DataTable table = new DataTable();
  40.             string sqlDataSource = _configuration.GetConnectionString("EmployeeAppCon");
  41.             MySqlDataReader myReader;
  42.             using (MySqlConnection mycon = new MySqlConnection(sqlDataSource))
  43.             {
  44.                 mycon.Open();
  45.                 using (MySqlCommand myCommand = new MySqlCommand(query, mycon))
  46.                 {
  47.                     myReader = myCommand.ExecuteReader();
  48.                     table.Load(myReader);

  50.                     myReader.Close();
  51.                     mycon.Close();
  52.                 }
  53.             }

  55.             return new JsonResult(table);
  56.         }


  59.         [HttpPost]
  60.         public JsonResult Post(Employee emp)
  61.         {
  62.             string query = @"
  63.                         insert into dbo.Employee
  64.                         (EmployeeName,Department,DateOfJoining,PhotoFileName)
  65.                         values
  66.                          (@EmployeeName,@Department,@DateOfJoining,@PhotoFileName) ;
  67.                         
  68.             ";

  70.             DataTable table = new DataTable();
  71.             string sqlDataSource = _configuration.GetConnectionString("EmployeeAppCon");
  72.             MySqlDataReader myReader;
  73.             using (MySqlConnection mycon = new MySqlConnection(sqlDataSource))
  74.             {
  75.                 mycon.Open();
  76.                 using (MySqlCommand myCommand = new MySqlCommand(query, mycon))
  77.                 {
  78.                     myCommand.Parameters.AddWithValue("@EmployeeName", emp.EmployeeName);
  79.                     myCommand.Parameters.AddWithValue("@Department", emp.Department);
  80.                     myCommand.Parameters.AddWithValue("@DateOfJoining", emp.DateOfJoining);
  81.                     myCommand.Parameters.AddWithValue("@PhotoFileName", emp.PhotoFileName);

  83.                     myReader = myCommand.ExecuteReader();
  84.                     table.Load(myReader);

  86.                     myReader.Close();
  87.                     mycon.Close();
  88.                 }
  89.             }

  91.             return new JsonResult("Added Successfully");
  92.         }


  95.         [HttpPut]
  96.         public JsonResult Put(Employee emp)
  97.         {
  98.             string query = @"
  99.                         update dbo.Employee set
  100.                         EmployeeName =@EmployeeName,
  101.                         Department =@Department,
  102.                         DateOfJoining =@DateOfJoining,
  103.                         PhotoFileName =@PhotoFileName
  104.                         where EmployeeId=@EmployeeId;
  105.                         
  106.             ";

  108.             DataTable table = new DataTable();
  109.             string sqlDataSource = _configuration.GetConnectionString("EmployeeAppCon");
  110.             MySqlDataReader myReader;
  111.             using (MySqlConnection mycon = new MySqlConnection(sqlDataSource))
  112.             {
  113.                 mycon.Open();
  114.                 using (MySqlCommand myCommand = new MySqlCommand(query, mycon))
  115.                 {
  116.                     myCommand.Parameters.AddWithValue("@EmployeeId", emp.EmployeeId);
  117.                     myCommand.Parameters.AddWithValue("@EmployeeName", emp.EmployeeName);
  118.                     myCommand.Parameters.AddWithValue("@Department", emp.Department);
  119.                     myCommand.Parameters.AddWithValue("@DateOfJoining", emp.DateOfJoining);
  120.                     myCommand.Parameters.AddWithValue("@PhotoFileName", emp.PhotoFileName);

  122.                     myReader = myCommand.ExecuteReader();
  123.                     table.Load(myReader);

  125.                     myReader.Close();
  126.                     mycon.Close();
  127.                 }
  128.             }

  130.             return new JsonResult("Updated Successfully");
  131.         }



  135.         [HttpDelete("{id}")]
  136.         public JsonResult Delete(int id)
  137.         {
  138.             string query = @"
  139.                         delete from dbo.Employee
  140.                         where EmployeeId=@EmployeeId;
  141.                         
  142.             ";

  144.             DataTable table = new DataTable();
  145.             string sqlDataSource = _configuration.GetConnectionString("EmployeeAppCon");
  146.             MySqlDataReader myReader;
  147.             using (MySqlConnection mycon = new MySqlConnection(sqlDataSource))
  148.             {
  149.                 mycon.Open();
  150.                 using (MySqlCommand myCommand = new MySqlCommand(query, mycon))
  151.                 {
  152.                     myCommand.Parameters.AddWithValue("@EmployeeId", id);

  154.                     myReader = myCommand.ExecuteReader();
  155.                     table.Load(myReader);

  157.                     myReader.Close();
  158.                     mycon.Close();
  159.                 }
  160.             }

  162.             return new JsonResult("Deleted Successfully");
  163.         }


  166.         [Route("SaveFile")]
  167.         [HttpPost]
  168.         public JsonResult SaveFile()
  169.         {
  170.             try
  171.             {

  173.                 var httpReuest = Request.Form;
  174.                 var postedFile = httpReuest.Files[0];
  175.                 string filename = postedFile.FileName;
  176.                 var physicalPath = _env.ContentRootPath + "/Photos/" + filename;

  178.                 using(var stream=new FileStream(physicalPath, FileMode.Create))
  179.                 {
  180.                     postedFile.CopyTo(stream);
  181.                 }

  183.                 return new JsonResult(filename);
  184.             }
  185.             catch (Exception)
  186.             {

  188.                 return new JsonResult("anonymous.png");
  189.             }
  190.         }
  191.     }
  192. }
复制代码


运行编译即可启动 WebAPI 并在其他项目中调用了。

本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有帐号？立即注册

x

0 个回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册
产品与服务
活字格低代码平台
Wyn 商业智能软件
SpreadJS纯前端表格控件
技术服务体系
技术博客
低代码技术
客户与案例
典型客户
成功案例
用户访谈
合作与生态
合作伙伴网络
葡萄城市场
葡萄城与国产化
活字格用友客开工具
品牌活动
葡萄城公开课
品牌战略发布会
赋能开发者高峰论坛
企业级低代码发展研讨会
企业级低代码应用大赛
表格技术研讨会
了解葡萄城
葡萄城简介
愿景使命
研发与创新
荣誉奖项
加入我们
联系方式
联系我们
400-657-6008

葡萄城社区二维码

关注“葡萄城社区”

赋能开发者

西安葡萄城软件有限公司
专业的软件开发技术和低代码平台提供商

陕ICP备2020018819号  |   陕公网安备：61019002000258  |   隐私政策  |   网站地图  

邮箱： info.xa@grapecity.com  |  © 2024 葡萄城软件，保留所有权利

Archiver| 手机版| 小黑屋|

返回顶部