首页 > 数据库 > Mysql > mysql批量插入BulkCopy的实现

mysql批量插入BulkCopy的实现

福牛 3月 30, 2023 45 0

一、新建项目：SqlSugarDemo

  1.      <ItemGroup>
  2.      <PackageReference Include=“SqlSugarCore” Version=“5.1.3.52” />
  3.      </ItemGroup>

二、连接串未添加AllowLoadLocalInfile=true

-1

中文提示 : BulkCopy mysql连接字符串需要添加 AllowLoadLocalInfile=true; 添加后如果还不行Mysql数据库执行一下 SET GLOBAL local_infile=1
English Message : connection string add : AllowLoadLocalInfile=true

  1. show global variables like ‘local_infile’;
  2. SET GLOBAL local_infile=1

 三、Startup.cs

  1. using Microsoft.ASPNetCore.Builder;
  2. using Microsoft.AspNetCore.Hosting;
  3. using Microsoft.Extensions.Configuration;
  4. using Microsoft.Extensions.DependencyInjection;
  5. using Microsoft.Extensions.Hosting;
  6. using SqlSugar;
  7. using System;
  8. using System.Collections.Generic;
  9. using System.Linq;
  10. using System.Threading.Tasks;
  12. namespace WebApplication3
  13. {
  14.      public class Startup
  15.      {
  16.          public Startup(IConfiguration configuration)
  17.          {
  18.              Configuration = configuration;
  19.          }
  21.          public IConfiguration Configuration { get; }
  23.          // This method gets called by the runtime. Use this method to add services to the container.
  24.          public void ConfigureServices(IServiceCollection services)
  25.          {
  26.              services.AddSingleton<ISqlSugarClient>(s =>
  27.              {
  28.                  SqlSugarScope sqlSugar = new SqlSugarScope(new ConnectionConfig()
  29.                  {
  30.                      DbType = SqlSugar.DbType.MySql,
  31.                      ConnectionString = “Server=192.168.31.132;User ID=root;Password=123456;Database=sugar;port=3306;AllowLoadLocalInfile=true”,
  32.                      IsAutoCloseConnection = true,
  33.                  },
  34.                  db =>
  35.                  {
  36.                      //单例参数配置，所有上下文生效
  37.                      db.Aop.OnLogExecuting = (sql, pars) =>
  38.                      {
  39.                      };
  40.                  });
  41.                  return sqlSugar;
  42.              });
  44.              services.AddControllersWithViews();
  45.          }
  47.          // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
  48.          public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
  49.          {
  50.              if (env.IsDevelopment())
  51.              {
  52.                  app.UseDeveloperExceptionPage();
  53.              }
  54.              else
  55.              {
  56.                  app.UseExceptionHandler(“/Home/Error”);
  57.              }
  58.              app.UseStaticFiles();
  60.              app.UseRouting();
  62.              app.UseAuthorization();
  64.              app.UseEndpoints(endpoints =>
  65.              {
  66.                  endpoints.MapControllerRoute(
  67.                      name: “default”,
  68.                      pattern: “{controller=Home}/{action=Index}/{id?}”);
  69.              });
  70.          }
  71.      }
  72. }

HomeController.cs

  1. using Microsoft.AspNetCore.Mvc;
  2. using Microsoft.Extensions.Logging;
  3. using SqlSugar;
  4. using System;
  5. using System.Collections.Generic;
  6. using System.Diagnostics;
  7. using System.Linq;
  8. using System.Threading.Tasks;
  9. using WebApplication3.Models;
  11. namespace WebApplication3.Controllers
  12. {
  13.      public class HomeController : Controller
  14.      {
  15.          private readonly ILogger<HomeController> _logger;
  16.          private readonly ISqlSugarClient _sqlSugarClient;
  17.          public HomeController(ILogger<HomeController> logger, ISqlSugarClient sqlSugarClient)
  18.          {
  19.              _logger = logger;
  20.              _sqlSugarClient = sqlSugarClient;
  21.          }
  23.          public IActionResult Index()
  24.          {
  25.              _sqlSugarClient.Fastest<RealmAuctionDatum>().BulkCopy(GetList());
  26.              return View();
  27.          }
  28.          public List<RealmAuctionDatum> GetList()
  29.          {
  30.              var datas = new List<RealmAuctionDatum>();
  31.              for (int i = 0; i < 10000; i++)
  32.              {
  33.                  datas.Add(new RealmAuctionDatum { Name = Guid.NewGuid().ToString(“N”) });
  34.              }
  35.              return datas;
  36.          }
  37.      }
  38. }

-2

到此这篇关于mysql批量插入BulkCopy的实现的文章就介绍到这了,更多相关mysql批量插入BulkCopy内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！

标签

相关推荐

发表评论