Performance! EF is quite fast in many cases nowdays but doing CUD over many entities is slooooow. This is a solution for that.
EntityFramework.Utilities provides some batch operations for using EF that the EF team hasn't yet added for us. Suggestions are welcome! Pull requests are even more welcome:)
Right now it's mostly to targeted at EF on SQL server but adding providers should be simple.
###Example
Here is a small extract from the performance section later in the document.
Batch iteration with 25000 entities
Insert entities: 880ms
Update all entities with a: 189ms
Bulk update all with a random read: 153ms
delete all entities with a: 17ms
delete all entities: 282ms
Standard iteration with 25000 entities
Insert entities: 8599ms
Update all entities with a: 360ms
Update all with a random read: 5779ms
delete all entities with a: 254ms
delete all entities: 5634ms
You can do that by preferebly creating an issue here on GitHub or chat me up on twitter @MikaelEliasson
Right now this only works for DbContext. If anyone want to make a failing test or provide a sample project for any of the other variants it will probably be easy to fix.
You need to manually select any of the O.1.xxx packages as the later packages are for EF V6.
Nuget package https://www.nuget.org/packages/EFUtilities/
Any package from 0.2.0 and < 1.0.0
Newer version use the newer metadata apis and cannot be used
Nuget package https://www.nuget.org/packages/EFUtilities/
Any package from 0.2.0 and up should work.
Nuget package https://www.nuget.org/packages/EFUtilities/
These methods are small helpers that make certain things easier. Most of them work against context so they should be provider independent. It will be stated when this is not the case.
REQUIRES: using EntityFramework.Utilities;
db.AttachAndModify(item).Set(x => x.Property, "NewValue")A simpler API for working with disconnected entities and only updating single values. This is useful if you want to update a value on an entity without roundtripping the database. A typical usecase could be to update the number of reads of a blogpost. With this API it would look like this
using (var db = new YourDbContext())
{
db.AttachAndModify(new BlogPost { ID = postId }).Set(x => x.Reads, 10);
db.SaveChanges();
}The Set method is chainable so you could fluently add more properties to update.
This would send this single command to the database:
exec sp_executesql N'UPDATE [dbo].[BlogPosts]
SET [Reads] = @0
WHERE ([ID] = @1)
',N'@0 int,@1 int',@0=10,@1=1
REQUIRES: using EntityFramework.Utilities;
The standard EF Include is really really slow to use. They reason is that it cross joins the child records against the parent which means you load a significant amount of duplicate data. This means more data to transfer, more data to parse, more memory etc etc.
Include EFU on the other hand runs two parallel queries and stitch the data toghether in memory. For more information on the problem and numbers see http://mikee.se/Archive.aspx/Details/entity_framework_pitfalls,_include_20140101
A very basic query:
var result = db.Contacts
.IncludeEFU(db, c => c.PhoneNumbers)
.ToList();It's also possible to sort and filter the child collections
var result = db.Contacts
.IncludeEFU(db, x => x.PhoneNumbers
.Where(n => n.Number == "10134")
.OrderBy(p => p.ContactId)
.ThenByDescending(p => p.Number))
.ToList();VERY IMPORTANT: The plan was to add support for nested collections and projections but it seems like EF7 will have this problem fixed in the core so I dropped that functionality (it was hard to get right). What works right now is that you can include one or more child collections but only on the first level.
Also it's important to know that the queries are run AsNoTracking(). If you use this method you are after read performance so you shouldn't need the tracking. If you might need to update some of the entities I suggest you just attach them back to the context.
REQUIRES: using EntityFramework.Utilities;
PROVIDER DEPENDENT: This methods uses raw sql to drop connections so only works against sql server
Drops the mssql database even if it has connections open. Solves the problem when you are recreating the database in your tests and Management Studio has an open connection that earlier prevented dropping the database. Super useful for testscenarios where you recreate the DB for each test but still need to debug with management studio.
These methods all work outside the normal EF pipeline and are located on the EFBatchOperation class. The design decision behind this choice is to make it clear you are NOT working against the context when using these methods. That's means change tracking, and 2nd level cache or validation will NOT be run. This is for pure performance and nothing less. These methods are also highly provider dependent. Right now the only existing provider is for Sql Server but it should be easy to add others.
EFUtilities supports some simple global settings. You can enable logging and control if default fallbacks should be used and add new Providers.
This will let you delete all Entities matching the predicate. But instead of the normal way to do this with EF (Load them into memory then delete them one by one) this method will create a Sql Query that deletes all items in one single call to the database. Here is how a call looks:
var count = EFBatchOperation.For(db, db.BlogPosts).Where(b => b.Created < upper && b.Created > lower && b.Title == "T2.0").Delete();Limitations: This method works by parsing the SQL generated when the predicate was used in a where clause. Aliases are removed when creating the delete clause so joins/subqueries are NOT supported/tested. Feel free to test if it works an if you have any idea of how to make it work I'm interested in supporting it if it doesn't add too much complexity. No constraints are checked by EF (though sql constraints are)
Warning: Because you are removing items directly from the database the context might still think they exist. If you have made any changes to a tracked entity that is then deleted by the query you will see some issues if you call SaveChanges on the context.
Allows you to insert many entities in a very performant way instead of adding them one by one as you normally would do with EF. The benefit is superior performance, the disadvantage is that EF will no longer validate any contraits for you and you will not get the ids back if they are store generated. You cannot insert relationships this way either.
using (var db = new YourDbContext())
{
EFBatchOperation.For(db, db.BlogPosts).InsertAll(list);
}On my dev machine that runs at around 500ms instead of 10s using the 'out of the box method'(Optimised by disabling change tracking and validation) or 90s with changetracking and validation.
SqlBulkCopy is used under the covers if you are running against SqlServer. If you are not running against SqlServer it will default to doing the normal inserts.
Bulk insert should support TPH inheritance. The other inheritance models will most likely not work.
If your best choice is using TransactionScope. See example here MikaelEliasson#26
Profilers like MiniProfilers wrap the connection. EFUtilities need a "pure" connection. One of the arguments is a connection that you can supply.
Works just like InsertAll but for updates instead. You can chose exactly which columns to update too.
An example where I load all items from the database and update them with a random number of reads-
var commentsFromDb = db.Comments.AsNoTracking().ToList();
var rand = new Random();
foreach (var item in commentsFromDb)
{
item.Reads = rand.Next(0, 9999999);
}
EFBatchOperation.For(db, db.Comments).UpdateAll(commentsFromDb, x => x.ColumnsToUpdate(c => c.Reads));On my dev machine that runs at around 153ms instead of 6s using the 'out of the box method'
SqlBulkCopy is used under the covers if you are running against SqlServer. If you are not running against SqlServer it will default to doing the normal inserts.
Because you specify which columns to update you can do simple partial updates. In the example above I could have generated the list commentsFromDb from an import file for example. What I need to populate is the PrimaryKey and the columns I specify to update.
Example:
var lines = csv.ReadAllLines().Select(l => l.Split(";"));
var comments = lines.Select(line => new Comment{ Id = int.Parse(line[0]), Reads = int.Parse(line[1]) });
EFBatchOperation.For(db, db.Comments).UpdateAll(comments, x => x.ColumnsToUpdate(c => c.Reads));Not tested but most likely TPH will work as the code is very similar to InsertAll
If your best choice is using TransactionScope. See example here MikaelEliasson#26
Profilers like MiniProfilers wrap the connection. EFUtilities need a "pure" connection. One of the arguments is a connection that you can supply.
The SQL Server provider creates a temporary template. The login you are using must have permissions to create and drop a table.
Let you update many entities in one sql query instead of loading them into memory and, modifing them and saving back to db.
using (var db = new YourDbContext())
{
EFBatchOperation.For(db, db.Comments).Where(x => x.Text == "a").Update(x => x.Reads, x => x.Reads + 1);
}The modifications you can do should be what EF can support in it's queries. For example it's possible to do:
c#count = EFBatchOperation.For(db, db.BlogPosts).Where(b => b.Title == "T2").Update(b => b.Created, b => DbFunctions.AddDays(b.Created, 1));
To incrememt the day one step. This method should be able to handle any renamed columns but the pitfall here is that this works internally by running the modifier through a where clause to get the SQL and than this where clause is transformed to a set clause. The rules for set and where are different so this might not always be valid. This is the most fragile of the methods but you can always test and if it doesn't work open an issue on github and it might get fixed.
There are some special things to keep in mind when using EFUtilities. Here is a list.
- The bulk insert should be stable but remember if you use database assigned id's it will NOT return these like normal EF inserts do.
- Update and Delete is quite "hacky". They work by pretending it was a regular where and take the generated sql (not hitting db) then altering this sql for update or delete. If you use joins that might not work. It will work for simple things but if you are doing complex stuff it might not be powerful enough.
- All 3 methods works in a way that doesn't really align with the DbContext, things are saved before SaveChanges are called, validation is not done, new ids are not returned and changes aren't synced to entities loaded into the context. This is the reason the methods are placed on
EFBatchOperation, to make sure it's clear this is working outside the normal conventions. - Because particulary Update/Delete are implemented using hacks that depend on the generated sql from EF I would encourage you to add integrations tests whenever you use these methods. Actually I would encourage you to always do that but that is another story. With integrations tests you will be warned if an EF update break EFUtilities and avoid any unpleasant suprises in production.
These methods are all about performance. Measuring performance should always be done in your context but some simple numbers might give you a hint.
The standard iteration is optimized in the sense that AutoDetectChangedEnabled = false; It would not be reasonable to delete/insert 25000 entities otherwise.
Here is a test run with EntitityFramework.Utilities on my laptop doing operations on a really simple object Comment(Text:string,Date:DateTime,Id:int,Reads:int)
Batch iteration with 25 entities
Insert entities: 23ms
Update all entities with a: 4ms
delete all entities with a: 2ms
delete all entities: 1ms
Standard iteration with 25 entities
Insert entities: 12ms
Update all entities with a: 6ms
delete all entities with a: 3ms
delete all entities: 7ms
Batch iteration with 2500 entities
Insert entities: 47ms
Update all entities with a: 22ms
delete all entities with a: 5ms
delete all entities: 11ms
Standard iteration with 2500 entities
Insert entities: 905ms
Update all entities with a: 46ms
delete all entities with a: 22ms
delete all entities: 552ms
Batch iteration with 25000 entities
Insert entities: 281ms
Update all entities with a: 163ms
delete all entities with a: 18ms
delete all entities: 107ms
Standard iteration with 25000 entities
Insert entities: 9601ms
Update all entities with a: 457ms
delete all entities with a: 250ms
delete all entities: 5895ms
Batch iteration with 100000 entities
Insert entities: 1048ms
Update all entities with a: 442ms
delete all entities with a: 60ms
delete all entities: 292ms
This is on my ultrabook. Here I don't compare to anything so it's just to give you some overview about what to expect. Note that in the batchmode around 100k entities/sec are added when reaching larger datasets.