dbset.local 또는 데이터베이스에서 데이터를 가져 오는 리포지토리 패턴

Question

일부 데이터를 반복하고 데이터베이스에 레코드를 만드는 메서드를 작성 중이므로이 메서드는 리포지토리를 사용합니다.

가 원래 이런 식으로 뭔가이었다

///Lets assume that there is a string array called arr somewhere above this. 
var repo = new ItemRepository(); 

for (int i = 0; i<1000; i++) 
{ 
    if (repo.MyItems.Count(x=>x.ID == arr[i]) == 0) 
    { 
     //Doesn't Exist Create 
     repo.MyItems.Add(new Item(arr[i])); 
     repo.Save(); 
    } 
    else 
    { 
     //Here I will get an instance of the entity that already exists and do some updates to it 
    } 
} 

일을하지만 모든 반복으로 DB에 저장했기 때문에 그것은 아주 천천히, 그래서 제가하고 싶은 것은이 같은으로 변경입니다 :

var repo = new ItemRepository(); 

for (int i = 0; i<1000; i++) 
{ 
    if (repo.MyItems.Count(x=>x.ID == arr[i]) == 0) 
    { 
     //Doesn't Exist Create 
     repo.MyItems.Add(new Item(arr[i])); 
    } 
    else 
    { 
     //Here I will get an instance of the entity that already exists and do some updates to it 
    } 

} 

repo.Save(); 

따라서 모든 엔티티가 생성 된 후에 만 ​​저장되므로 수천 개가 아닌 하나의 큰 DB 삽입이 완료됩니다.

문제는 항목이 내 데이터베이스에 다시 저장되지 않았기 때문에 repo.MyItems.Count (x => x.ID == i)가 항목을 다시 가져 오지 않았기 때문입니다. dbset.Local 컬렉션

내 질문에 내 로컬 저장소와 데이터베이스를 쿼리 할 수 ​​있도록 내 리포지토리를 수정할 수있는 방법이 있습니다. 키커이거나 데이터베이스에 있거나 이미있을 수 있기 때문입니다. 저장소에 추가되고 데이터베이스에 삽입되지 않음

위 코드는 의사 코드이지만 일종의 표현은 저장소 방법이

와 같은 것입니다.

public int count(string val) 
{ 
    IQueryable<T> data = _dbSet; 

    return data.Count(x=>x.COLUMNNAME == val); 
} 

다시 이것은 내가 repo에서 가지고있는 것의 표현 일 뿐이지 만 내가 무엇을 할 것인지에 대한 약간의 아이디어를 제공해야합니다. 내가 문제를 정확하게 이해 바랍니다

Answer 1

중 하나에 관심이 있다면, 이것이 내가 구현 및 작동 듯 무엇, 그러나 나는 최대에 제공 끝났다 이것은 시스템의 나머지 부분에 영향을 미친 데이터의 "더티 읽기 (Dirty Reads)"를 허용 할 것이며, 다중 저장의 성능 저하가 시스템의 큰 부분을 재 작업하는 것보다 더 바람직하다는 결론을 얻었습니다. 또는 더티 읽기를 허용하는 repo 구현 ...

참고 : GetSingle은 내가 가지고있는 Count를 대체합니다. 위의 코드.

public T GetSingle(System.Linq.Expressions.Expression<Func<T, bool>> filter = null) 
    { 
     //Check the local collection first 

     IQueryable<T> localEntities = _dbset.Local.AsQueryable(); 

     if (filter != null) 
     { 
      localEntities = localEntities.Where(filter); 
     } 

     if (localEntities.Count() > 0) 
     { 
      return localEntities.FirstOrDefault(); 
     } 
     else 
     { 
      //A local version of this was not found - try the database. 

      IQueryable<T> query = this._dbset; 

      if (filter != null) 
      { 
       query = query.Where(filter); 
      } 

      return query.FirstOrDefault(); 
     }    
    } 

나는 정말 내가 그와 끝까지해야하는 I 아마 다시 발생 하겠어 문제 및 다음 시간으로 알고 싶습니다이 할 수있는 더 좋은 방법이 있다면 !

Answer 2

, 이것은 내가 일반적으로 할 것입니다 :

 var repo = new ItemRepository(); 

     Int32 index = 0; 
     Int32 localIndex = 0; 
     while (index < arr.Length) { 
      repo.MyItems.Add(new Item(arr[index])); 
      index++; 
      localIndex++; 
      if (localIndex == 1000) { 
       repo.Save(); 
       localIndex = 0; 
      } 
     } 
     if (localIndex > 0) { 
      repo.Save(); 
     }