This commit is contained in:
@@ -524,6 +524,7 @@ namespace MarketData.DataAccess
|
||||
try
|
||||
{
|
||||
if (null == analystRatings || 0 == analystRatings.Count) return true;
|
||||
analystRatings = new AnalystRatings(analystRatings.DistinctBy(x => new {x.Symbol, x.Date.Date, x.BrokerageFirm}).ToList());
|
||||
sqlConnection = SqlUtils.CreateMySqlConnection(MainDataSource.Instance.LocateDataSource("market_data"));
|
||||
sqlTransaction = sqlConnection.BeginTransaction(System.Data.IsolationLevel.ReadCommitted);
|
||||
DeleteAnalystRatings(analystRatings, sqlConnection, sqlTransaction);
|
||||
|
||||
Reference in New Issue
Block a user