using System;using System.Collections.Generic;using System.Data.Entity;using System.Data.Entity.Infrastructure;namespace My{ /// Entity Framework公共的增删改方法。返回的是受影响的行数 public class PublicStore { //新增 public static int InsertObject(object obj) { Type t = obj.GetType(); int effect = -1; using (MyContext con = new MyContext()) { DbSet set = con.Set(t); set.Add(obj); effect = con.SaveChanges(); return effect; } } //批量新增 public static int InsertObjects(IEnumerable objs) { int effect = 0; var et = objs.GetEnumerator(); if (et.MoveNext()) { Type t = et.Current.GetType(); using (MyContext con = new MyContext()) { DbSet set = con.Set(t); foreach (var o in objs) { set.Add(o); } effect = con.SaveChanges(); } } return effect; } //修改 public static int ModifyObject(object obj) { int effect = -1; using (MyContext con = new MyContext()) { DbEntityEntry entry = con.Entry(obj); entry.State = System.Data.EntityState.Modified; effect = con.SaveChanges(); return effect; } } //批量修改 public static int ModifyObjects(IEnumerable objs) { int effect = 0; var et = objs.GetEnumerator(); if (et.MoveNext()) { Type t = et.Current.GetType(); using (MyContext con = new MyContext()) { foreach (var o in objs) { DbEntityEntry entry = con.Entry(o); entry.State = System.Data.EntityState.Modified; } effect = con.SaveChanges(); } } return effect; } //删除 public static int DeleteObject(object obj) { int effect = -1; using (MyContext con = new MyContext()) { DbEntityEntry entry = con.Entry(obj); entry.State = System.Data.EntityState.Deleted; effect = con.SaveChanges(); return effect; } } //批量删除 public static int DeleteObjects(IEnumerable objs) { int effect = 0; var et = objs.GetEnumerator(); if (et.MoveNext()) { Type t = et.Current.GetType(); using (MyContext con = new MyContext()) { foreach (var o in objs) { DbEntityEntry entry = con.Entry(o); entry.State = System.Data.EntityState.Deleted; } effect = con.SaveChanges(); } } return effect; } }}