Use BinaryImporter WriteNullAsync

redbaty · Oct 2, 2023 · 8aaff52 · 8aaff52
1 parent c8a36a5
commit 8aaff52
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 4 deletions.
diff --git a/PgBulk.EFCore/PgBulk.EFCore.csproj b/PgBulk.EFCore/PgBulk.EFCore.csproj
@@ -6,7 +6,7 @@
  <Nullable>enable</Nullable>
  <LangVersion>10</LangVersion>
  <PackageProjectUrl>https://github.com/redbaty/PgBulk</PackageProjectUrl>
- <PackageVersion>1.1.9</PackageVersion>
+ <PackageVersion>1.1.10</PackageVersion>
  </PropertyGroup>
 
  <ItemGroup>

diff --git a/PgBulk/NpgsqlBinaryImporter.cs b/PgBulk/NpgsqlBinaryImporter.cs
@@ -33,8 +33,19 @@ public async Task<ulong> WriteToBinaryImporter(IEnumerable<T> entities)
  {
  await BinaryImporter.StartRowAsync();
 
- foreach (var columnValue in Columns.Select(i => i.GetValue(entity)))
- await BinaryImporter.WriteAsync(columnValue);
+ foreach (var column in Columns)
+ {
+ var value = column.GetValue(entity);
+
+ if (value == null)
+ {
+ await BinaryImporter.WriteNullAsync();
+ }
+ else
+ {
+ await BinaryImporter.WriteAsync(value);
+ }
+ }
 
  inserted++;
  }

diff --git a/PgBulk/PgBulk.csproj b/PgBulk/PgBulk.csproj
@@ -6,7 +6,7 @@
  <Nullable>enable</Nullable>
  <LangVersion>10</LangVersion>
  <PackageProjectUrl>https://github.com/redbaty/PgBulk</PackageProjectUrl>
- <PackageVersion>1.1.6</PackageVersion>
+ <PackageVersion>1.1.7</PackageVersion>
  </PropertyGroup>
 
  <ItemGroup Condition="'$(TargetFramework)' == 'net6.0'">