aboutsummaryrefslogtreecommitdiff
path: root/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/TableInfo.cs
diff options
context:
space:
mode:
Diffstat (limited to 'docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/TableInfo.cs')
-rw-r--r--docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/TableInfo.cs27
1 files changed, 8 insertions, 19 deletions
diff --git a/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/TableInfo.cs b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/TableInfo.cs
index d2f48c6..61cd04f 100644
--- a/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/TableInfo.cs
+++ b/docker/crupest-api/CrupestApi/CrupestApi.Commons/Crud/TableInfo.cs
@@ -367,12 +367,7 @@ CREATE TABLE {tableName}(
var result = new DynamicParameters();
foreach (var param in parameters)
{
- if (param.Value is null)
- {
- continue;
- }
-
- if (param.Value is DbNullValue)
+ if (param.Value is null || param.Value is DbNullValue)
{
result.Add(param.Name, null);
continue;
@@ -455,17 +450,14 @@ CREATE TABLE {tableName}(
{
InsertItem? item = insert.Items.FirstOrDefault(i => i.ColumnName == column.ColumnName);
object? value = null;
- if (item is null || item.Value is null)
- {
- column.Hooks.BeforeInsert(column, , );
- }
if (item is null)
{
+ column.Hooks.BeforeInsert(column, ref value, false);
item = new InsertItem(column.ColumnName, value);
- insert.Items.Add(item);
}
else
{
+ column.Hooks.BeforeInsert(column, ref value, true);
item.Value = value;
}
@@ -490,19 +482,16 @@ CREATE TABLE {tableName}(
{
var (sql, parameters) = GenerateUpdateSql(where, update);
+ var readUpdateClause = UpdateClause.Create();
+
foreach (var column in ColumnInfos)
{
UpdateItem? item = update.Items.FirstOrDefault(i => i.ColumnName == column.ColumnName);
var value = item?.Value;
- column.Hooks.BeforeUpdate(column, ref value);
- if (item is null)
- {
- if (value is not null)
- update.Items.Add(new UpdateItem(column.ColumnName, value));
- }
- else
+ column.Hooks.BeforeUpdate(column, ref value, item is null ? false : true);
+ if (value is not null)
{
- item.Value = value;
+ readUpdateClause.Add(column.ColumnName, value);
}
}