forked from ThatRendle/Simple.Data
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathSimpleTransaction.cs
More file actions
185 lines (157 loc) · 6.71 KB
/
SimpleTransaction.cs
File metadata and controls
185 lines (157 loc) · 6.71 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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Dynamic;
using System.Linq;
using System.Text;
namespace Simple.Data
{
/// <summary>
/// Provides an abstraction over the underlying data adapter, if it is transaction-capable.
/// </summary>
public sealed class SimpleTransaction : DataStrategy, IDisposable
{
private readonly Database _database;
private readonly IAdapterWithTransactions _adapter;
private IAdapterTransaction _adapterTransaction;
private SimpleTransaction(IAdapterWithTransactions adapter, Database database)
{
if (adapter == null) throw new ArgumentNullException("adapter");
if (database == null) throw new ArgumentNullException("database");
_adapter = adapter;
_database = database;
}
private void Begin()
{
_adapterTransaction = _adapter.BeginTransaction();
}
private void Begin(string name)
{
_adapterTransaction = _adapter.BeginTransaction(name);
}
internal static SimpleTransaction Begin(Database database)
{
SimpleTransaction transaction = CreateTransaction(database);
transaction.Begin();
return transaction;
}
internal static SimpleTransaction Begin(Database database, string name)
{
SimpleTransaction transaction = CreateTransaction(database);
transaction.Begin(name);
return transaction;
}
private static SimpleTransaction CreateTransaction(Database database)
{
var adapterWithTransactions = database.GetAdapter() as IAdapterWithTransactions;
if (adapterWithTransactions == null) throw new NotSupportedException();
return new SimpleTransaction(adapterWithTransactions, database);
}
internal Database Database
{
get { return _database; }
}
/// <summary>
/// Gets the name assigned to the transaction.
/// </summary>
/// <value>The name.</value>
public string Name
{
get { return _adapterTransaction.Name; }
}
public IAdapterTransaction AdapterTransaction
{
get { return _adapterTransaction; }
}
/// <summary>
/// Commits all changes to the database and cleans up resources associated with the transaction.
/// </summary>
public void Commit()
{
_adapterTransaction.Commit();
}
/// <summary>
/// Rolls back all changes to the database and cleans up resources associated with the transaction.
/// </summary>
public void Rollback()
{
_adapterTransaction.Rollback();
}
internal override IDictionary<string, object> FindOne(string tableName, SimpleExpression criteria)
{
return Find(tableName, criteria).FirstOrDefault();
}
internal override int UpdateMany(string tableName, IList<IDictionary<string, object>> dataList)
{
return _adapter.UpdateMany(tableName, dataList, AdapterTransaction);
}
internal override int UpdateMany(string tableName, IList<IDictionary<string, object>> dataList, IEnumerable<string> criteriaFieldNames)
{
return _adapter.UpdateMany(tableName, dataList, criteriaFieldNames, AdapterTransaction);
}
internal override IEnumerable<IDictionary<string, object>> Find(string tableName, SimpleExpression criteria)
{
return _adapter.Find(tableName, criteria, AdapterTransaction);
}
internal override IDictionary<string, object> Insert(string tableName, IDictionary<string, object> data)
{
return _adapter.Insert(tableName, data, AdapterTransaction);
}
/// <summary>
/// Inserts a record into the specified "table".
/// </summary><param name="tableName">Name of the table.</param><param name="data">The values to insert.</param><returns>If possible, return the newly inserted row, including any automatically-set values such as primary keys or timestamps.</returns>
internal override IEnumerable<IDictionary<string, object>> Insert(string tableName, IEnumerable<IDictionary<string, object>> data)
{
return _adapter.InsertMany(tableName, data, AdapterTransaction);
}
internal override int Update(string tableName, IDictionary<string, object> data, SimpleExpression criteria)
{
return _adapter.Update(tableName, data, criteria, AdapterTransaction);
}
internal override int Update(string tableName, IDictionary<string, object> data)
{
return _adapter.Update(tableName, data, AdapterTransaction);
}
internal override int UpdateMany(string tableName, IList<IDictionary<string, object>> newValuesList, IList<IDictionary<string, object>> originalValuesList)
{
int count = 0;
for (int i = 0; i < newValuesList.Count; i++)
{
count += Update(tableName, newValuesList[i], originalValuesList[i]);
}
return count;
}
public override int Update(string tableName, IDictionary<string, object> newValuesDict, IDictionary<string, object> originalValuesDict)
{
SimpleExpression criteria = CreateCriteriaFromOriginalValues(tableName, newValuesDict, originalValuesDict);
var changedValuesDict = CreateChangedValuesDict(newValuesDict, originalValuesDict);
return _adapter.Update(tableName, changedValuesDict, criteria, AdapterTransaction);
}
internal override int Delete(string tableName, SimpleExpression criteria)
{
return _adapter.Delete(tableName, criteria, AdapterTransaction);
}
/// <summary>
/// Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
/// </summary>
public void Dispose()
{
try
{
_adapterTransaction.Dispose();
}
catch (Exception ex)
{
Trace.WriteLine("IAdapterTransaction Dispose threw exception: " + ex.Message);
}
}
public override Adapter GetAdapter()
{
return _adapter as Adapter;
}
protected internal override Database GetDatabase()
{
return _database;
}
}
}