-
-
Notifications
You must be signed in to change notification settings - Fork 203
/
ReadOnlyDapperRepository.cs
97 lines (75 loc) · 2.73 KB
/
ReadOnlyDapperRepository.cs
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
using System;
using System.ComponentModel.DataAnnotations.Schema;
using System.Data;
using System.Linq.Expressions;
using System.Reflection;
using MicroOrm.Dapper.Repositories.Config;
using MicroOrm.Dapper.Repositories.SqlGenerator;
using MicroOrm.Dapper.Repositories.SqlGenerator.Filters;
namespace MicroOrm.Dapper.Repositories;
/// <summary>
/// Base ReadOnlyRepository
/// </summary>
public partial class ReadOnlyDapperRepository<TEntity> : IReadOnlyDapperRepository<TEntity>
where TEntity : class
{
private IDbConnection? _connection;
private FilterData? _filterData;
/// <summary>
/// Constructor
/// </summary>
public ReadOnlyDapperRepository(IDbConnection connection)
{
_connection = connection;
_filterData = new FilterData();
SqlGenerator = new SqlGenerator<TEntity>();
}
/// <summary>
/// Constructor
/// </summary>
public ReadOnlyDapperRepository(IDbConnection connection, ISqlGenerator<TEntity> sqlGenerator)
{
_connection = connection;
_filterData = new FilterData();
SqlGenerator = sqlGenerator;
}
public IDbConnection Connection => _connection ?? throw new ObjectDisposedException(GetType().FullName);
public FilterData FilterData => _filterData ?? throw new ObjectDisposedException(GetType().FullName);
public ISqlGenerator<TEntity> SqlGenerator { get; }
private static string GetProperty(Expression expression, Type type)
{
var field = (MemberExpression)expression;
var prop = type.GetProperty(field.Member.Name);
var declaringType = type.GetTypeInfo();
var tableAttribute = declaringType.GetCustomAttribute<TableAttribute>();
var tableName = MicroOrmConfig.TablePrefix + (tableAttribute != null ? tableAttribute.Name : declaringType.Name);
if (prop == null || prop.GetCustomAttribute<NotMappedAttribute>() != null)
return string.Empty;
var name = prop.GetCustomAttribute<ColumnAttribute>()?.Name ?? prop.Name;
return $"{tableName}.{name}";
}
public void Dispose()
{
_connection?.Dispose();
_connection = null;
if (_filterData == null)
return;
_filterData.Ordered = false;
if (_filterData.LimitInfo != null)
{
_filterData.LimitInfo = null;
}
if (_filterData.OrderInfo != null)
{
_filterData.OrderInfo.Columns?.Clear();
_filterData.OrderInfo.Columns = null;
_filterData.OrderInfo = null;
}
if (_filterData.SelectInfo != null)
{
_filterData.SelectInfo.Columns.Clear();
_filterData.SelectInfo = null;
}
_filterData = null;
}
}