Merge pull request #296 from bjaminp/master

Support long for identity type in sqlite
borisdj · Mar 24, 2020 · 81aaa92 · 81aaa92
2 parents 760e2bd + 6ff5d5b
commit 81aaa92
Showing 1 changed file with 16 additions and 3 deletions.
diff --git a/EFCore.BulkExtensions/SqlBulkOperation.cs b/EFCore.BulkExtensions/SqlBulkOperation.cs
@@ -304,13 +304,26 @@ public static async Task InsertAsync<T>(DbContext context, IList<T> entities, Ta
                     {
                         command.CommandText = SqlQueryBuilderSqlite.SelectLastInsertRowId();
                         long lastRowIdScalar = (long)command.ExecuteScalar();
-                        int lastRowId = (int)lastRowIdScalar;
+                        var identityPropertyInteger = false;
                         var accessor = TypeAccessor.Create(typeof(T), true);
                         string identityPropertyName = tableInfo.PropertyColumnNamesDict.SingleOrDefault(a => a.Value == tableInfo.IdentityColumnName).Key;
+                        if (accessor.GetMembers().FirstOrDefault(x => x.Name == identityPropertyName)?.Type == typeof(int))
+                        {
+                            identityPropertyInteger = true;
+                        }
                         for (int i = entities.Count -1; i >= 0; i--)
                         {
-                            accessor[entities[i], identityPropertyName] = lastRowId;
-                            lastRowId--;
+                            if (identityPropertyInteger)
+                            {
+                                accessor[entities[i], identityPropertyName] = (int) lastRowIdScalar;
+
+                            }
+                            else
+                            {
+                                accessor[entities[i], identityPropertyName] = lastRowIdScalar;
+                            }
+
+                            lastRowIdScalar--;
                         }
                     }
                 }