我要发布

EntityFrameworkCore.SqlServer.SimpleBulks

Boss 开发教程

2025-12-07 0 873

EntityFrameworkCore.SqlServer.SimpleBulks

A very simple .net core library that can help to sync a large number of records in-memory into the database using the SqlBulkCopy class.

Overview

This library provides extension methods so that you can use with your EntityFrameworkCore DbContext instance DbContextExtensions.cs
or you can use SqlConnectionExtensions.cs to work directly with a SqlConnection instance without using EntityFrameworkCore.

Nuget

Database	Package	GitHub
SQL Server	EntityFrameworkCore.SqlServer.SimpleBulks	EntityFrameworkCore.SqlServer.SimpleBulks
PostgreSQL	EntityFrameworkCore.PostgreSQL.SimpleBulks	EntityFrameworkCore.PostgreSQL.SimpleBulks
MySQL	EntityFrameworkCore.MySQL.SimpleBulks	EntityFrameworkCore.MySQL.SimpleBulks

Features

Bulk Insert
Bulk Update
Bulk Delete
Bulk Merge
Bulk Match
Temp Table
Direct Insert
Direct Update
Direct Delete

Examples

EntityFrameworkCore.SqlServer.SimpleBulks.Demo

Update the connection string:

private const string _connectionString = \"Server=.;Database=SimpleBulks;User Id=xxx;Password=xxx\";

Build and run.

DbContextExtensions

Using Lambda Expression

using EntityFrameworkCore.SqlServer.SimpleBulks.BulkDelete;
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkInsert;
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkMerge;
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkUpdate;

// Insert all columns
dbct.BulkInsert(rows);
dbct.BulkInsert(compositeKeyRows);

// Insert selected columns only
dbct.BulkInsert(rows,
    row => new { row.Column1, row.Column2, row.Column3 });
dbct.BulkInsert(compositeKeyRows,
    row => new { row.Id1, row.Id2, row.Column1, row.Column2, row.Column3 });

dbct.BulkUpdate(rows,
    row => new { row.Column3, row.Column2 });
dbct.BulkUpdate(compositeKeyRows,
    row => new { row.Column3, row.Column2 });

dbct.BulkMerge(rows,
    row => row.Id,
    row => new { row.Column1, row.Column2 },
    row => new { row.Column1, row.Column2, row.Column3 });
dbct.BulkMerge(compositeKeyRows,
    row => new { row.Id1, row.Id2 },
    row => new { row.Column1, row.Column2, row.Column3 },
    row => new { row.Id1, row.Id2, row.Column1, row.Column2, row.Column3 });
                        
dbct.BulkDelete(rows);
dbct.BulkDelete(compositeKeyRows);

Using Dynamic String

using EntityFrameworkCore.SqlServer.SimpleBulks.BulkDelete;
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkInsert;
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkMerge;
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkUpdate;

dbct.BulkUpdate(rows,
    [ \"Column3\", \"Column2\" ]);
dbct.BulkUpdate(compositeKeyRows,
    [ \"Column3\", \"Column2\" ]);

dbct.BulkMerge(rows,
    \"Id\",
    [ \"Column1\", \"Column2\" ],
    [ \"Column1\", \"Column2\", \"Column3\" ]);
dbct.BulkMerge(compositeKeyRows,
    [ \"Id1\", \"Id2\" ],
    [ \"Column1\", \"Column2\", \"Column3\" ],
    [ \"Id1\", \"Id2\", \"Column1\", \"Column2\", \"Column3\" ]);

Using Builder Approach in case you need to mix both Dynamic & Lambda Expression

new BulkInsertBuilder<Row>(dbct.GetSqlConnection())
	.WithColumns(row => new { row.Column1, row.Column2, row.Column3 })
	// or .WithColumns([ \"Column1\", \"Column2\", \"Column3\" ])
	.WithOutputId(row => row.Id)
	// or .WithOutputId(\"Id\")
	.ToTable(dbct.GetTableName(typeof(Row)))
	// or .ToTable(\"Rows\")
	.Execute(rows);

SqlConnectionExtensions

Using Lambda Expression

using EntityFrameworkCore.SqlServer.SimpleBulks.BulkDelete;
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkInsert;
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkMerge;
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkUpdate;

// Register Type - Table Name globaly
TableMapper.Register(typeof(Row), \"Rows\");
TableMapper.Register(typeof(CompositeKeyRow), \"CompositeKeyRows\");

connection.BulkInsert(rows,
           row => new { row.Column1, row.Column2, row.Column3 });
connection.BulkInsert(compositeKeyRows,
           row => new { row.Id1, row.Id2, row.Column1, row.Column2, row.Column3 });

connection.BulkUpdate(rows,
           row => row.Id,
           row => new { row.Column3, row.Column2 });
connection.BulkUpdate(compositeKeyRows,
           row => new { row.Id1, row.Id2 },
           row => new { row.Column3, row.Column2 });

connection.BulkMerge(rows,
           row => row.Id,
           row => new { row.Column1, row.Column2 },
           row => new { row.Column1, row.Column2, row.Column3 });
connection.BulkMerge(compositeKeyRows,
           row => new { row.Id1, row.Id2 },
           row => new { row.Column1, row.Column2, row.Column3 },
           row => new { row.Id1, row.Id2, row.Column1, row.Column2, row.Column3 });
                        
connection.BulkDelete(rows, row => row.Id);
connection.BulkDelete(compositeKeyRows, row => new { row.Id1, row.Id2 });

Using Dynamic String

using EntityFrameworkCore.SqlServer.SimpleBulks.BulkDelete;
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkInsert;
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkMerge;
using EntityFrameworkCore.SqlServer.SimpleBulks.BulkUpdate;

connection.BulkInsert(rows, \"Rows\",
           [ \"Column1\", \"Column2\", \"Column3\" ]);
connection.BulkInsert(rows.Take(1000), \"Rows\",
           typeof(Row).GetDbColumnNames(\"Id\"));
connection.BulkInsert(compositeKeyRows, \"CompositeKeyRows\",
           [ \"Id1\", \"Id2\", \"Column1\", \"Column2\", \"Column3\" ]);

connection.BulkUpdate(rows, \"Rows\",
           \"Id\",
           [ \"Column3\", \"Column2\" ]);
connection.BulkUpdate(compositeKeyRows, \"CompositeKeyRows\",
           [ \"Id1\", \"Id2\" ],
           [ \"Column3\", \"Column2\" ]);

connection.BulkMerge(rows, \"Rows\",
           \"Id\",
           [ \"Column1\", \"Column2\" ],
           [ \"Column1\", \"Column2\", \"Column3\" ]);
connection.BulkMerge(compositeKeyRows, \"CompositeKeyRows\",
           [ \"Id1\", \"Id2\" ],
           [ \"Column1\", \"Column2\", \"Column3\" ],
           [ \"Id1\", \"Id2\", \"Column1\", \"Column2\", \"Column3\" ]);

connection.BulkDelete(rows, \"Rows\", \"Id\");
connection.BulkDelete(compositeKeyRows, \"CompositeKeyRows\", [ \"Id1\", \"Id2\" ]);

Using Builder Approach in case you need to mix both Dynamic & Lambda Expression

new BulkInsertBuilder<Row>(connection)
	.WithColumns(row => new { row.Column1, row.Column2, row.Column3 })
	// or .WithColumns([ \"Column1\", \"Column2\", \"Column3\" ])
	.WithOutputId(row => row.Id)
	// or .WithOutputId(\"Id\")
	.ToTable(\"Rows\")
	.Execute(rows);

Configuration

BulkInsert

_context.BulkInsert(rows,
    row => new { row.Column1, row.Column2, row.Column3 },
    options =>
    {
        options.KeepIdentity = false;
        options.BatchSize = 0;
        options.Timeout = 30;
        options.LogTo = Console.WriteLine;
    });

BulkUpdate

_context.BulkUpdate(rows,
    row => new { row.Column3, row.Column2 },
    options =>
    {
        options.BatchSize = 0;
        options.Timeout = 30;
        options.LogTo = Console.WriteLine;
    });

BulkDelete

_context.BulkDelete(rows,
    options =>
    {
        options.BatchSize = 0;
        options.Timeout = 30;
        options.LogTo = Console.WriteLine;
    });

BulkMerge

_context.BulkMerge(rows,
    row => row.Id,
    row => new { row.Column1, row.Column2 },
    row => new { row.Column1, row.Column2, row.Column3 },
    options =>
    {
        options.BatchSize = 0;
        options.Timeout = 30;
        options.WithHoldLock = false;
        options.ReturnDbGeneratedId = true;
        options.LogTo = Console.WriteLine;
    });

BulkMatch

var contactsFromDb = _context.BulkMatch(matchedContacts,
    x => new { x.CustomerId, x.CountryIsoCode },
    options =>
    {
        options.BatchSize = 0;
        options.Timeout = 30;
        options.LogTo = Console.WriteLine;
    });

TempTable

var customerTableName = _context.CreateTempTable(customers,
    x => new
    {
        x.IdNumber,
        x.FirstName,
        x.LastName,
        x.CurrentCountryIsoCode
    },
    options =>
    {
        options.BatchSize = 0;
        options.Timeout = 30;
        options.LogTo = Console.WriteLine;
    });

DirectInsert

_context.DirectInsert(row,
    row => new { row.Column1, row.Column2, row.Column3 },
    options =>
    {
        options.Timeout = 30;
        options.LogTo = Console.WriteLine;
    });

DirectUpdate

_context.DirectUpdate(row,
    row => new { row.Column3, row.Column2 },
    options =>
    {
        options.Timeout = 30;
        options.LogTo = Console.WriteLine;
    });

DirectDelete

_context.DirectDelete(row,
    options =>
    {
        options.Timeout = 30;
        options.LogTo = Console.WriteLine;
    });

Returned Result

BulkUpdate

var updateResult = dbct.BulkUpdate(rows, row => new { row.Column3, row.Column2 });

Console.WriteLine($\"Updated: {updateResult.AffectedRows} row(s)\");

BulkDelete

var deleteResult = dbct.BulkDelete(rows);

Console.WriteLine($\"Deleted: {deleteResult.AffectedRows} row(s)\");

BulkMerge

var mergeResult = dbct.BulkMerge(rows,

    row => row.Id,

    row => new { row.Column1, row.Column2 },

    row => new { row.Column1, row.Column2, row.Column3 });
Console.WriteLine($\"Updated: {mergeResult.UpdatedRows} row(s)\");

Console.WriteLine($\"Inserted: {mergeResult.InsertedRows} row(s)\"</

下载源码

从 GitHub 克隆

通过命令行克隆项目:

git clone https://github.com/phongnguyend/EntityFrameworkCore.SqlServer.SimpleBulks.git

收藏 (0) 打赏

感谢您的支持，我会继续努力的!

打开微信/支付宝扫一扫，即可进行扫码打赏哦，分享从这里开始，精彩与您同在

申明：本文由第三方发布，内容仅代表作者观点，与本网站无关。对本文以及其中全部或者部分内容的真实性、完整性、及时性本站不作任何保证或承诺，请读者仅作参考，并请自行核实相关内容。本网发布或转载文章出于传递更多信息之目的，并不意味着赞同其观点或证实其描述，也不代表本网对其真实性负责。

左子网开发教程 EntityFrameworkCore.SqlServer.SimpleBulks https://www.zuozi.net/31349.html

Boss

上一篇： csharpworkshop

下一篇： LPU Java 2022 1

常见问题

发货方式是什么？

1、自动：拍下后，点击（下载）链接即可下载；2、手动：拍下后，联系卖家发放即可或者联系官方找开发者发货。

查看详情

交易周期是多久呢？

1、源码默认交易周期：手动发货商品为1-3天，并且用户付款金额将会进入平台担保直到交易完成或者3-7天即可发放，如遇纠纷无限期延长收款金额直至纠纷解决或者退款！；

查看详情

能退款么？

1、描述：源码描述(含标题)与实际源码不一致的（例：货不对板）； 2、演示：有演示站时，与实际源码小于95%一致的（但描述中有”不保证完全一样、有变化的可能性”类似显著声明的除外）； 3、发货：不发货可无理由退款； 4、安装：免费提供安装服务的源码但卖家不履行的； 5、收费：价格虚标，额外收取其他费用的（但描述中有显著声明或双方交易前有商定的除外）； 6、其他：如质量方面的硬性常规问题BUG等。注：经核实符合上述任一，均支持退款，但卖家予以积极解决问题则除外。

查看详情

注意事项

1、左子会对双方交易的过程及交易商品的快照进行永久存档，以确保交易的真实、有效、安全！ 2、左子无法对如“永久包更新”、“永久技术支持”等类似交易之后的商家承诺做担保，请买家自行鉴别； 3、在源码同时有网站演示与图片演示，且站演与图演不一致时，默认按图演作为纠纷评判依据（特别声明或有商定除外）； 4、在没有”无任何正当退款依据”的前提下，商品写有”一旦售出，概不支持退款”等类似的声明，视为无效声明； 5、在未拍下前，双方在QQ上所商定的交易内容，亦可成为纠纷评判依据（商定与描述冲突时，商定为准）； 6、因聊天记录可作为纠纷评判依据，故双方联系时，只与对方在左子上所留的QQ、手机号沟通，以防对方不承认自我承诺。 7、虽然交易产生纠纷的几率很小，但一定要保留如聊天记录、手机短信等这样的重要信息，以防产生纠纷时便于左子介入快速处理。

查看详情

左子网

分享最新WordPress教程共同学习，共同进步，共同成长！

QQ交流群

EntityFrameworkCore.SqlServer.SimpleBulks

Overview

Nuget

Features

Examples

DbContextExtensions

Using Lambda Expression

Using Dynamic String

Using Builder Approach in case you need to mix both Dynamic & Lambda Expression

SqlConnectionExtensions

Using Lambda Expression

Using Dynamic String

Using Builder Approach in case you need to mix both Dynamic & Lambda Expression

Configuration

BulkInsert

BulkUpdate

BulkDelete

BulkMerge

BulkMatch

TempTable

DirectInsert

DirectUpdate

DirectDelete

Returned Result

BulkUpdate

BulkDelete

BulkMerge

相关文章

微信

左子网

QQ交流群