s459315/Retail_manager
1
1
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Created a transaction

Browse Source 
compressed sale into one transaction, if something fails all changes in sale and saledetail are rollbacked.
This commit is contained in:
s459315 2022-07-30 15:26:54 +02:00
parent 7f6c33e87c
commit 57b456b1e1
2 changed files with 69 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
RMDataManagerLibrary/DataAcccess/SaleData.cs
View File

@ -53,24 +53,31 @@ namespace RMDataManagerLibrary.DataAcccess
sale.Total = sale.SubTotal + sale.Tax; sale.Total = sale.SubTotal + sale.Tax;
//save //save
SqlDataAccess sql = new SqlDataAccess(); using (SqlDataAccess sql = new SqlDataAccess())
sql.SaveData("dbo.spSaleInsert", sale, "RMData"); {
try
{
sql.StartTransaction("RMData");
// get id from saleModel sql.SaveDataInTransaction("spSaleInsert", sale);
sale.Id = sql.LoadData<int, dynamic>("spSaleLookUp",new { sale.CashierId, sale.SaleDate }, "RMData").FirstOrDefault(); sale.Id = sql.LoadDataInTransaction<int, dynamic>("spSaleLookUp", new { sale.CashierId, sale.SaleDate }).FirstOrDefault();
// finish filling up sale details // finish filling up sale details
foreach (var item in details) foreach (var item in details)
{ {
item.SaleId = sale.Id; item.SaleId = sale.Id;
// Save Details sql.SaveDataInTransaction("dbo.spSaleDetailInsert", item);
}
sql.SaveData("dbo.spSaleDetailInsert", item, "RMData"); }
catch
{
sql.RollBackTransaction();
throw;
}
} }
} }
} }
} }

48
RMDataManagerLibrary/Internal/DataAccess/SqlDataAccess.cs
View File

@ -10,7 +10,7 @@ using System.Threading.Tasks;
namespace RMDataManagerLibrary.Internal.DataAccess namespace RMDataManagerLibrary.Internal.DataAccess
{ {
public class SqlDataAccess internal class SqlDataAccess : IDisposable
{ {
public string GetConnectionString(string name) public string GetConnectionString(string name)
{ {
@ -40,5 +40,51 @@ namespace RMDataManagerLibrary.Internal.DataAccess
commandType: CommandType.StoredProcedure); commandType: CommandType.StoredProcedure);
} }
} }
private IDbConnection _connection;
private IDbTransaction _transaction;
public void StartTransaction(string connectionStringName)
{
string connectionString = GetConnectionString(connectionStringName);
_connection = new SqlConnection(connectionString);
_connection.Open();
_transaction = _connection.BeginTransaction();
}
public void SaveDataInTransaction<T>(string storedProcedure, T parameters)
{
_connection.Execute(storedProcedure, parameters,
commandType: CommandType.StoredProcedure, transaction: _transaction);
}
public List<T> LoadDataInTransaction<T, U>(string storedProcedure, U parameters)
{
List<T> rows = _connection.Query<T>(storedProcedure, parameters,
commandType: CommandType.StoredProcedure, transaction: _transaction).ToList();
return rows;
}
public void CommitTransaction()
{
_transaction?.Commit();
_connection?.Close();
}
public void RollBackTransaction()
{
_transaction?.Rollback();
_connection?.Close();
}
public void Dispose()
{
CommitTransaction();
}
} }
} }