-
-
Notifications
You must be signed in to change notification settings - Fork 524
Expand file tree
/
Copy pathSqlResult.cs
More file actions
100 lines (86 loc) · 2.96 KB
/
SqlResult.cs
File metadata and controls
100 lines (86 loc) · 2.96 KB
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
89
90
91
92
93
94
95
96
97
98
99
100
using System;
using System.Collections;
using System.Collections.Generic;
using System.Globalization;
using System.Linq;
namespace SqlKata
{
public class SqlResult
{
private string ParameterPlaceholder { get; set; }
private string EscapeCharacter { get; set; }
public SqlResult(string parameterPlaceholder, string escapeCharacter)
{
ParameterPlaceholder = parameterPlaceholder;
EscapeCharacter = escapeCharacter;
}
public Query Query { get; set; }
public string RawSql { get; set; } = "";
public List<object> Bindings { get; set; } = new List<object>();
public string Sql { get; set; } = "";
public Dictionary<string, object> NamedBindings = new Dictionary<string, object>();
private static readonly Type[] NumberTypes =
{
typeof(int),
typeof(long),
typeof(decimal),
typeof(double),
typeof(float),
typeof(short),
typeof(ushort),
typeof(ulong),
};
public override string ToString()
{
var deepParameters = Helper.Flatten(Bindings).ToList();
var subject = Helper.ReplaceAll(RawSql, ParameterPlaceholder, EscapeCharacter, i =>
{
if (i >= deepParameters.Count)
{
throw new Exception(
$"Failed to retrieve a binding at index {i}, the total bindings count is {Bindings.Count}");
}
var value = deepParameters[i];
if (value is NamedParameterVariable v)
{
return ChangeToSqlValue(v.Value);
}
return ChangeToSqlValue(value);
});
return Helper.RemoveEscapeCharacter(subject, ParameterPlaceholder, EscapeCharacter);
}
private string ChangeToSqlValue(object value)
{
if (value == null)
{
return "NULL";
}
if (Helper.IsArray(value))
{
return Helper.JoinArray(",", value as IEnumerable);
}
if (NumberTypes.Contains(value.GetType()))
{
return Convert.ToString(value, CultureInfo.InvariantCulture);
}
if (value is DateTime date)
{
if (date.Date == date)
{
return "'" + date.ToString("yyyy-MM-dd") + "'";
}
return "'" + date.ToString("yyyy-MM-dd HH:mm:ss") + "'";
}
if (value is bool vBool)
{
return vBool ? "true" : "false";
}
if (value is Enum vEnum)
{
return Convert.ToInt32(vEnum) + $" /* {vEnum} */";
}
// fallback to string
return "'" + value.ToString().Replace("'","''") + "'";
}
}
}