Skip to content

Commit 9a10ed2

Browse files
FIx conversion.
1 parent 138e2b3 commit 9a10ed2

3 files changed

Lines changed: 20 additions & 9 deletions

File tree

src/PhenX.EntityFrameworkCore.BulkInsert.MySql/MySqlBulkInsertProvider.cs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@ namespace PhenX.EntityFrameworkCore.BulkInsert.MySql;
1111

1212
internal class MySqlBulkInsertProvider(ILogger<MySqlBulkInsertProvider>? logger = null) : BulkInsertProviderBase<MySqlServerDialectBuilder>(logger)
1313
{
14-
1514
//language=sql
1615
/// <inheritdoc />
1716
protected override string AddTableCopyBulkInsertId => $"ALTER TABLE {{0}} ADD {BulkInsertId} INT AUTO_INCREMENT PRIMARY KEY;";

src/PhenX.EntityFrameworkCore.BulkInsert.PostgreSql/PostgreSqlBulkInsertProvider.cs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@ namespace PhenX.EntityFrameworkCore.BulkInsert.PostgreSql;
1818
[UsedImplicitly]
1919
internal class PostgreSqlBulkInsertProvider(ILogger<PostgreSqlBulkInsertProvider>? logger = null) : BulkInsertProviderBase<PostgreSqlDialectBuilder>(logger)
2020
{
21-
2221
//language=sql
2322
/// <inheritdoc />
2423
protected override string AddTableCopyBulkInsertId => $"ALTER TABLE {{0}} ADD COLUMN {BulkInsertId} SERIAL PRIMARY KEY;";

src/PhenX.EntityFrameworkCore.BulkInsert.Sqlite/SqliteBulkInsertProvider.cs

Lines changed: 20 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -35,14 +35,27 @@ CancellationToken cancellationToken
3535
private static SqliteType GetSqliteType(ColumnMetadata column)
3636
{
3737
var storeType = column.Property.GetRelationalTypeMapping().StoreType;
38-
return storeType switch
38+
39+
if (string.Equals(storeType, "INTEGER", StringComparison.OrdinalIgnoreCase))
40+
{
41+
return SqliteType.Integer;
42+
}
43+
else if (string.Equals(storeType, "FLOAT", StringComparison.OrdinalIgnoreCase))
3944
{
40-
"INTEGER" => SqliteType.Integer,
41-
"FLOAT" => SqliteType.Real,
42-
"TEXT" => SqliteType.Text,
43-
"BLOB" => SqliteType.Blob,
44-
_ => throw new NotSupportedException($"Invalid store type '{storeType}' for property '{column.PropertyName}'"),
45-
};
45+
return SqliteType.Real;
46+
}
47+
else if (string.Equals(storeType, "TEXT", StringComparison.OrdinalIgnoreCase))
48+
{
49+
return SqliteType.Text;
50+
}
51+
else if (string.Equals(storeType, "BLOB", StringComparison.OrdinalIgnoreCase))
52+
{
53+
return SqliteType.Blob;
54+
}
55+
else
56+
{
57+
throw new NotSupportedException($"Invalid store type '{storeType}' for property '{column.PropertyName}'");
58+
}
4659
}
4760

4861
private static DbCommand GetInsertCommand(

0 commit comments

Comments
 (0)