一、新建项目：sqlsugardemo <itemgroup> <packagereference include="sqlsugarcore" version="5.1.3.52" /> </itemgroup>
二、连接串未添加allowloadlocalinfile=true
中文提示 : bulkcopy mysql连接字符串需要添加 allowloadlocalinfile=true; 添加后如果还不行mysql数据库执行一下 set global local_infile=1
english message : connection string add : allowloadlocalinfile=true
show global variables like 'local_infile';set global local_infile=1
三、startup.csusing microsoft.aspnetcore.builder;using microsoft.aspnetcore.hosting;using microsoft.extensions.configuration;using microsoft.extensions.dependencyinjection;using microsoft.extensions.hosting;using sqlsugar;using system;using system.collections.generic;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) { services.addsingleton<isqlsugarclient>(s => { sqlsugarscope sqlsugar = new sqlsugarscope(new connectionconfig() { dbtype = sqlsugar.dbtype.mysql, connectionstring = "server=192.168.31.132;user id=root;password=123456;database=sugar;port=3306;allowloadlocalinfile=true", isautocloseconnection = true, }, db => { //单例参数配置，所有上下文生效 db.aop.onlogexecuting = (sql, pars) => { }; }); return sqlsugar; }); services.addcontrollerswithviews(); } // 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(); } else { app.useexceptionhandler("/home/error"); } app.usestaticfiles(); app.userouting(); app.useauthorization(); app.useendpoints(endpoints => { endpoints.mapcontrollerroute( name: "default", pattern: "{controller=home}/{action=index}/{id?}"); }); } }}
homecontroller.cs
using microsoft.aspnetcore.mvc;using microsoft.extensions.logging;using sqlsugar;using system;using system.collections.generic;using system.diagnostics;using system.linq;using system.threading.tasks;using webapplication3.models; namespace webapplication3.controllers{ public class homecontroller : controller { private readonly ilogger<homecontroller> _logger; private readonly isqlsugarclient _sqlsugarclient; public homecontroller(ilogger<homecontroller> logger, isqlsugarclient sqlsugarclient) { _logger = logger; _sqlsugarclient = sqlsugarclient; } public iactionresult index() { _sqlsugarclient.fastest<realmauctiondatum>().bulkcopy(getlist()); return view(); } public list<realmauctiondatum> getlist() { var datas = new list<realmauctiondatum>(); for (int i = 0; i < 10000; i++) { datas.add(new realmauctiondatum { name = guid.newguid().tostring("n") }); } return datas; } }}
以上就是mysql批量插入bulkcopy如何实现的详细内容。