1 protected virtual void SubmitChanges()
 2        {
 3            ChangeSet cSet = DB.GetChangeSet();
 4            if (cSet.Inserts.Count > 0
 5                || cSet.Updates.Count > 0
 6                || cSet.Deletes.Count > 0)
 7            {
 8                try
 9                {
10                    DB.SubmitChanges(System.Data.Linq.ConflictMode.ContinueOnConflict);
11                }
12                catch (System.Data.Linq.ChangeConflictException ex)
13                {
14                    foreach (System.Data.Linq.ObjectChangeConflict occ in DB.ChangeConflicts)
15                    {
16       occ.Resolve(System.Data.Linq.RefreshMode.OverwriteCurrentValues);
17                        occ.Resolve(System.Data.Linq.RefreshMode.KeepCurrentValues);
18                        occ.Resolve(System.Data.Linq.RefreshMode.KeepChanges);
19                    }
20                    DB.SubmitChanges();
21                }
22            }
23        }
24 
25 //在(zai)Get Entity and MetaTable代碼(ma)段(duan)中，主(zhu)要是得(de)到(dao)簡(jian)單(dan)的實體(ti)結果集和(he)根據主(zhu)鍵獲(huo)得(de)一個實體(ti)對(dui)象的操作
26 
27  protected virtual TEntity Find<TEntity>(params object[] keyValues) where TEntity : class
28      {
29          var mapping = DB.Mapping.GetTable(typeof(TEntity));
30          var keys = mapping.RowType.IdentityMembers.Select((m, i) => m.Name + " = @" + i).ToArray();
31          TEntity entityTEntity = DB.GetTable<TEntity>().Where(String.Join(" && ", keys), keyValues).FirstOrDefault();
32          if (entityTEntity != null)
33              DB.Refresh(System.Data.Linq.RefreshMode.OverwriteCurrentValues, entityTEntity);
34          return entityTEntity;
35 
36      }
37  protected virtual IQueryable<TEntity> GetEntities<TEntity>(Expression<Func<TEntity, bool>> queryFunc) where TEntity : class
38      {
39          Debug.Assert(queryFunc != null, "expression passed in is null");
40          var results = DB.GetTable<TEntity>().Where(queryFunc);
41          return results;
42      }
43  protected virtual IQueryable<TEntity> GetEntities<TEntity>() where TEntity : class 
44 
45 {
46          return DB.GetTable<TEntity>();
47      }

 1 public class UserRepository : TESTRepositoryBase, IUserRepository
 2    {
 3 
 4        #region IUserRepository 成員
 5        public void RegisterUser(Entity.TEST.UserBases entity)
 6        {
 7            base.InsertEntity(entity);
 8        }
 9        public void UpdateUser(UserBases entity)
10        {
11            DB.SubmitChanges();
12        }
13 
14        #endregion
15 
16        #region IRepository<UserBases> 成é員±
17 
18        public void Update(UserBases entity)
19        {
20            base.UpdateEntity(entity);
21        }
22 
23        public void Update(IList<UserBases> list)
24        {
25            list.ToList().ForEach(entity => { this.Update(entity); });
26        }
27 
28        public void Insert(UserBases entity)
29        {
30            base.InsertEntity(entity);
31        }
32 
33        public void Insert(IList<UserBases> list)
34        {
35            list.ToList().ForEach(entity => { this.Insert(entity); });
36        }
37 
38        public UserBases InsertGetIDENTITY(UserBases entity)
39        {
40            base.InsertEntity(entity);
41            return base.Find<UserBases>(entity.UserID);
42        }
43 
44        public void Delete(UserBases entity)
45        {
46            base.DeleteEntity(entity);
47        }
48 
49        public void Delete(IList<UserBases> list)
50        {
51            list.ToList().ForEach(entity => { this.Delete(entity); });
52        }
53 
54        public IQueryable<UserBases> GetModel()
55        {
56            return base.GetEntities<UserBases>();
57        }
58 
59        public UserBases Find(params object[] keyValues)
60        {
61            return base.Find<UserBases>(keyValues);
62        }
63 
64        #endregion
65    }