.net 简单的数据库操作框架

1

2

3

4

5

6

publicclassDataDictionary

{

publicstringCode {get;set; }

publicstringName {get;set; }

publicstringType {get;set; }

}

1

2

3

4

5

6

7

8

9

10

11

vardb = GetInstance();

List<DataDictionary> datas =newList<DataDictionary>();

datas.Add(newDataDictionary() { Code="1", Name="男",Type="sex"});

datas.Add(newDataDictionary() { Code ="2", Name ="女", Type ="sex"});

datas.Add(newDataDictionary() { Code ="1", Name ="南通市", Type ="city"});

datas.Add(newDataDictionary() { Code ="2", Name ="苏州市", Type ="city"});

datas.Add(newDataDictionary() { Code ="1", Name ="江苏省", Type ="province"});

datas.Add(newDataDictionary() { Code ="2", Name ="湖南省", Type ="province"});

db.CodeFirst.InitTables<DataDictionary>();//这样就能根据实体建表了

db.Insertable(datas).ExecuteCommand();//这样就能把数据插进数据库了<br>

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

publicclassPerson

{

//数据库字段

[SqlSugar.SugarColumn(IsPrimaryKey =true,IsIdentity =true)]

publicintId {get;set; }

publicstringName {get;set; }

publicintSexId {get;set; }

publicintCityId {get;set; }

publicintProvinceId {get;set; }

//非数据库字段

[SqlSugar.SugarColumn(IsIgnore =true)]

publicstringSexName {get;set; }

[SqlSugar.SugarColumn(IsIgnore =true)]

publicstringCityName {get;set; }

[SqlSugar.SugarColumn(IsIgnore =true)]

publicstringProviceName {get;set; }

}

1

2

3

4

5

6

7

8

9

if(!db.ConfigQuery.Any())

{

vartypes= db.Queryable<DataDictionary>().Select(it => it.Type).Distinct().ToList();

foreach(vartypeintypes)

{

db.ConfigQuery.SetTable<DataDictionary>(it => it.Code, it => it.Name, type, it => it.Type == type);

}

//如果其中Code都是唯一值可以按 1.4中的用法使用循环都不要

}

1

2

3

4

5

6

7

8

9

varres=db.Queryable<Person>().Select(it =>newPerson()

{

Id=it.Id.SelectAll(),

SexName=it.SexId.GetConfigValue<DataDictionary>("sex"),

ProvinceName = it.ProvinceId.GetConfigValue<DataDictionary>("province"),

CityName = it.CityId.GetConfigValue<DataDictionary>("city"),

}).ToList();

//也支持支持写在Where或者Orderby

1

2

3

4

5

6

db.ConfigQuery.SetTable<Order>(it => it.Id, it => it.Name);//配置Order<br>

varlist3 = db.Queryable<OrderItem>().Select(it =>newOrderItem

{

ItemId = it.ItemId.SelectAll(),

OrderName = it.OrderId.GetConfigValue<Order>()//查询的时候直接用

}).ToList();

1

2

3

4

5

6

7

8

9

10

11

[TenantAttribute("1")]

publicclassC1Table

{

publicstringId {get;set; }

}

[TenantAttribute("2")]

publicclassC2Table

{

publicstringId {get;set; }

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

publicclassRepository<T> : SimpleClient<T>whereT :class,new()

{

publicRepository(ISqlSugarClient context =null) :base(context)//注意这里要有默认值等于null

{

if(context ==null)

{

vardb =newSqlSugarClient(newList<ConnectionConfig> {

newConnectionConfig()

{

ConfigId="1",

DbType = SqlSugar.DbType.SqlServer,

IsAutoCloseConnection =true,

ConnectionString = Config.ConnectionString

},

newConnectionConfig()

{

ConfigId="2",

DbType = SqlSugar.DbType.SqlServer,

IsAutoCloseConnection =true,

ConnectionString = Config.ConnectionString2

}

});

base.Context = db;

varconfigId =typeof(T).GetCustomAttribute<TenantAttribute>().configId;

db.ChangeDatabase(configId);

}

}

/// <summary>

/// 扩展方法，自带方法不能满足的时候可以添加新方法

/// </summary>

/// <returns></returns>

publicList<T> CommQuery(stringsql)

{

//base.Context.Queryable<T>().ToList();可以拿到SqlSugarClient 做复杂操作

returnbase.Context.Queryable<T>().Where(sql).ToList();

}

}

1

2

3

4

5

6

7

8

9

10

11

12

publicclassC1Service : Repository<C1Table>

{

publicvoidTest()

{

base.AsTenant().BeginTran();

base.GetList();//调用内部仓储方法

base.ChangeRepository<Repository<C2Table>>().GetList();//调用外部仓储

base.AsTenant().CommitTran();

}

}