Open.Database.Extensions/Source/SqlClient/ExpressiveSqlCommand.cs at master · Open-NET-Libraries/Open.Database.Extensions · GitHub

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
namespace Open.Database.Extensions;

/// <summary>
/// A specialized for SqlClient abstraction for executing commands on a database using best practices and simplified expressive syntax.
/// </summary>
public class ExpressiveSqlCommand : ExpressiveDbCommandBase<SqlConnection, SqlCommand, SqlDataReader, SqlDbType, ExpressiveSqlCommand>
{
	/// <summary>Constructs a <see cref="ExpressiveSqlCommand"/>.</summary>
	/// <inheritdoc />
	public ExpressiveSqlCommand(
		IDbConnectionPool<SqlConnection> connectionPool,
		CommandType type,
		string command,
		IEnumerable<Param>? @params = null)
		: base(connectionPool, type, command, @params)
	{
	}

	/// <summary>Constructs a <see cref="ExpressiveSqlCommand"/>.</summary>
	/// <inheritdoc />
	public ExpressiveSqlCommand(
		IDbConnectionFactory<SqlConnection> connFactory,
		CommandType type,
		string command,
		IEnumerable<Param>? @params = null)
		: base(connFactory, type, command, @params)
	{
	}

	/// <summary>Constructs a <see cref="ExpressiveSqlCommand"/>.</summary>
	/// <inheritdoc />
	public ExpressiveSqlCommand(
		SqlConnection connection,
		IDbTransaction? transaction,
		CommandType type,
		string command,
		IEnumerable<Param>? @params = null)
		: base(connection, transaction, type, command, @params)
	{
	}

	/// <summary>Constructs a <see cref="ExpressiveSqlCommand"/>.</summary>
	/// <inheritdoc />
	public ExpressiveSqlCommand(
		SqlConnection connection,
		CommandType type,
		string command,
		IEnumerable<Param>? @params = null)
		: base(connection, type, command, @params)
	{
	}

	/// <summary>Constructs a <see cref="ExpressiveSqlCommand"/>.</summary>
	/// <inheritdoc />
	public ExpressiveSqlCommand(
		IDbTransaction transaction,
		CommandType type,
		string command,
		IEnumerable<Param>? @params = null)
		: base(transaction, type, command, @params)
	{
	}

	/// <summary>
	/// Handles adding the list of parameters to a new command.
	/// </summary>
	protected override void AddParams(SqlCommand command)
	{
		if (command is null) throw new System.ArgumentNullException(nameof(command));
		Contract.EndContractBlock();

		foreach (Param p in Params)
		{
			SqlParameter np;
			if (p.Value is null)
			{
				np = command.CreateParameter();
				np.ParameterName = p.Name;
			}
			else
			{
				np = command.Parameters.AddWithValue(p.Name, p.Value);
			}

			np.Direction = p.Direction;
			if (p.Type.HasValue)
				np.SqlDbType = p.Type.Value;
		}
	}
}