blob: 35b7cc9ce08e5238fdc826438757771335965b52 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
|
using System.Text;
using Dapper;
namespace CrupestApi.Commons.Crud;
public class InsertItem
{
public InsertItem(string columnName, object? value)
{
ColumnName = columnName;
Value = value;
}
public InsertItem(KeyValuePair<string, object?> pair)
{
ColumnName = pair.Key;
Value = pair.Value;
}
public string ColumnName { get; set; }
public object? Value { get; set; }
public static implicit operator KeyValuePair<string, object?>(InsertItem item)
{
return new(item.ColumnName, item.Value);
}
public static implicit operator InsertItem(KeyValuePair<string, object?> pair)
{
return new(pair);
}
}
public class InsertClause
{
public List<InsertItem> Items { get; } = new List<InsertItem>();
public InsertClause(IEnumerable<InsertItem> items)
{
Items.AddRange(items);
}
public InsertClause(params InsertItem[] items)
{
Items.AddRange(items);
}
public InsertClause Add(params InsertItem[] items)
{
Items.AddRange(items);
return this;
}
public InsertClause Add(string column, object? value)
{
return Add(new InsertItem(column, value));
}
public static InsertClause Create(params InsertItem[] items)
{
return new InsertClause(items);
}
public List<string> GetRelatedColumns()
{
return Items.Select(i => i.ColumnName).ToList();
}
public string GenerateColumnListSql()
{
return string.Join(", ", Items.Select(i => i.ColumnName));
}
public string GenerateValueListSql(DynamicParameters parameters)
{
var sb = new StringBuilder();
for (var i = 0; i < Items.Count; i++)
{
var item = Items[i];
var parameterName = parameters.AddRandomNameParameter(item.Value);
sb.Append($"@{parameterName}");
if (i != Items.Count - 1)
sb.Append(", ");
}
return sb.ToString();
}
}
|
