Closed magiboys closed 5 months ago
using (IUnitOfWork unitOfWork = _unitOfWorkManager.CreateDbContext(false)) { IStockDailyMarketRepository stockDailyMarketRepository = unitOfWork.ServiceProvider.GetRequiredService(); StockDailyMarket? market = await stockDailyMarketRepository.FindByDateAsync(stock.Id, input.tdate); if (market != null) { await stockDailyMarketRepository.RemoveAsync(market); } await unitOfWork.SaveChangesAsync(); await unitOfWork.CommitAsync(); }
//后面有个逻辑拦截 if (await _stockDailyMarketRepository.IsExistsAsync(stock.Id, date)) { throw new UserFriendlyException($"股票`{stock.Code}-{stock.Name}`已存在`{date:yyyy-MM-dd}`行情数据"); } //重新插入数据库操作 _stockDailyMarketRepository.AddAsync(......); 我想把删除操作提前提交到数据库,但发现程序会时不时报死锁错误
No response
Description
using (IUnitOfWork unitOfWork = _unitOfWorkManager.CreateDbContext(false)) { IStockDailyMarketRepository stockDailyMarketRepository = unitOfWork.ServiceProvider.GetRequiredService();
StockDailyMarket? market = await stockDailyMarketRepository.FindByDateAsync(stock.Id, input.tdate);
if (market != null)
{
await stockDailyMarketRepository.RemoveAsync(market);
}
await unitOfWork.SaveChangesAsync();
await unitOfWork.CommitAsync();
}
.NET version
No response
MASA Framework version
No response