Dos.C#.Net使用
Dos.ORM（原Hxj.Data）于2009年发布，并发布实体生成工具。在开发过程参考了多个ORM框架，特别是NBear，MySoft、EF、Dapper等。吸取了他们的一些精华，加入自己的新思想。该组件已在上百个成熟企业项目中应用
为什么选择Dos.ORM（原Hxj.Data）?
- 上手简单，0学习成本。使用方便，按照sql书写习惯编写C#.NET代码。功能强大
- 高性能（与Dapper媲美，接近手写Sql）
- 体积小（不到150kb，仅一个dll）
- 完美支持Sql Server(2000至最新版),MySql,Oracle,Access,Sqlite等数据库
- 支持大量Lambda表达式写法，国产ORM支持度最高，开源中国ORM排行前三
- 不需要像NHibernate的XML配置，不需要像EF的各种数据库连接驱动
- 众多成熟企业软件、互联网项目已应用此框架
- 遵循MIT开源协议，除不允许改名，其它随意定制修改
- Dos团队持续更新升级，任何Bug反馈都会立即得到解决
首先·在 App.config文件中配置连接数据库字符串。或者在程序中指定
1 <connectionStrings> 2 <add name="School" connectionString="Data Source=.;Initial Catalog=School;User ID=sa;Pwd=123;"></add> 3 </connectionStrings>
然后，进行增删改操作。如下：
1 using System;
2 using System.Collections.Generic;
3 using System.Linq;
4 using System.Text;
5 using System.Threading.Tasks;
6 using Hxj.Data;
7 using Hxj.Data.Sqlite;
8 using System.Data;
9
10 namespace cn.School
11 {
12 class Test
13 {
14 static void Main(string[] args)
15 {
16
17 // <connectionStrings>
18 //<add name="School" connectionString="Data Source=.;Initial Catalog=School;User ID=sa;Pwd=123;"></add>
19 //</connectionStrings>
20
21 //不同的数据库可构造不同的DbSession DbSession(connectionStrings节点的name)
22 //DbSession dbs = new DbSession("School");
23 DbSession dbs2 = new DbSession(DatabaseType.SqlServer, "Data Source=.;Initial Catalog=School;User ID=sa;Pwd=123;");
24
25 //TestSelDB();
26
27 //addTestDB();
28
29 //Updata();
30
31 //DelData();
32
33 //sqlFrom();
34
35 assistmethod();
36 }
37
38 /// <summary>
39 /// 查询操作
40 /// </summary>
41 public static void TestSelDB()
42 {
43 //查询Student表中第一条数据并返回实体，代码如下。
44 Student st = DbSession.Default.From<Student>()
45 //.Select(Products._.ProductID) //查询返回ProductID字段
46 //.GroupBy(Products._.CategoryID.GroupBy && Products._.ProductName.GroupBy)//按照CategoryID，ProductName分组
47 //.InnerJoin<Suppliers>(Suppliers._.SupplierID == Products._.SupplierID)//关联Suppliers表 --CrossJoin FullJoin LeftJoin RightJoin 同理
48 //.OrderBy(Products._.ProductID.Asc)//按照ProductID正序排序
49 //.Where((Products._.ProductName.Contain("apple") && Products._.UnitPrice > 1) || Products._.CategoryID == 2)//设置条件ProductName包含”apple”并且UnitPrice>1 或者CategoryID =2
50 //.UnionAll(DbSession.Default.From<Products>().Select(Products._.ProductID))//union all查询
51 //.Distinct() // Distinct
52 //.Top(5) //读取前5条
53 //.Page(10, 2)//分页返回结果 每页10条返回第2页数据
54 //.ToDataSet(); //返回DataSet
55 //.ToDataReader(); //返回IDataReader
56 //.ToDataTable(); //返回DataTable
57 //.ToScalar(); //返回单个值
58 .ToFirst();
59
60 //分字段查询
61 DbSession.Default.From<Student>()
62 .Select(Student._.Stu_ID, Student._.Stu_name)
63 .ToDataTable();
64
65 //分字段查询取别名
66 DbSession.Default.From<Student>()
67 .Select(Student._.Stu_ID, Student._.Stu_name.As("pname"))
68 .ToDataTable();
69
70 //排序倒叙排列
71 DataTable dt = DbSession.Default.From<Student>().OrderBy(Student._.Stu_ID.Desc).ToDataTable();
72
73 }
74
75 /// <summary>
76 /// 模糊查询
77 /// 子查询
78 /// in 查询
79 /// not iN查询
80 /// </summary>
81 public static void demoSelet()
82 {
83
84 //Contain完全模糊查询
85 DbSession.Default.From<Student>().Where(Student._.Stu_ID.Contain(41500));
86
87 //查找Stu_ID列中所有以41500开头的。
88 DbSession.Default.From<Student>().Where(Student._.Stu_ID.BeginWith(41500));
89
90 //查找Stu_ID列中所有以41500结尾的。
91 DbSession.Default.From<Student>().Where(Student._.Stu_ID.EndWith(41500));
92
93 //in 查询
94 DbSession.Default.From<Student>()
95 .Where(Student._.Stu_ID.SelectIn(1, 2, 3))
96 .ToList();
97
98 //not in查询
99 DbSession.Default.From<Student>()
100 .Where(Student._.Stu_ID.SelectNotIn<int>(1, 2, 3))
101 .ToList();
102
103 //子查询
104
105 //SubQueryEqual =
106 //SubQueryNotEqual <>
107 //SubQueryLess <
108 //SubQueryLessOrEqual <=
109 //SubQueryGreater >
110 //SubQueryGreaterOrEqual >=
111 //SubQueryIn in
112 //SubQueryNotIn not in
113 DbSession.Default.From<Student>()
114 .Where(Student._.Stu_ID
115 .SubQueryEqual(DbSession.Default.From<Student>().Where(Student._.Stu_ID == "Produce").Select(Student._.Stu_ID).Top(1)))
116 .ToList();
117 }
118
119 /// <summary>
120 /// 联合查询
121 /// </summary>
122 public static void likeSel()
123 {
124 //InnerJoin inner join
125 //LeftJoin left join
126 //RightJoin right join
127 //CrossJoin cross join
128 //FullJoin full join
129 //Union union
130 //UnionAll union all
131 DbSession.Default.From<Student>()
132 .InnerJoin<Gread>(Student._.gr_id == Gread._.gr_id)
133 .ToDataTable();
134 //联合查询带条件
135 DbSession.Default.From<Student>()
136 .LeftJoin<Gread>(Student._.gr_id == Gread._.gr_id)
137 .Where(Student._.gr_id == 1)
138 .ToDataTable();
139
140 //这两个是两个结果的合集，union会区分结果排除相同的，union all 则直接合并结果集合。
141
142 DbSession.Default.From<Student>().Where(Student._.gr_id == 4522)
143 .UnionAll(DbSession.Default.From<Gread>().Where(Gread._.gr_id == 1))
144 .ToList();
145 }
146
147 /// <summary>
148 /// 增加操作
149 /// </summary>
150 public static void addTestDB()
151 {
152 //新建一个实体
153 Student stu = new Student();
154 stu.Stu_name = "小黑";
155 stu.stu_phon = "1254555";
156 stu.stu_Sex = "男";
157 stu.stu_Age = 25;
158 stu.gr_id = 1;
159
160 //开启修改 (开启修改后的添加操作将只insert赋值过的字段)
161 stu.Attach();
162
163 //返回值 如果有自增长字段，则返回自增长字段的值
164 int result = DbSession.Default.Insert<Student>(stu);
165
166 //将插入的数据查询出来
167 List<Student> listStu = DbSession.Default.From<Student>().Where(Student._.Stu_ID == result).ToList();
168 }
169
170 /// <summary>
171 /// 修改操作
172 /// </summary>
173 public static void Updata()
174 {
175 //先查询一个Student对象
176 Student stu = DbSession.Default.From<Student>().Where(Student._.Stu_ID.Contain(41500)).ToFirst();
177
178 //开启修改 (修改操作之前 必须执行此方法)
179 stu.Attach();
180
181 stu.Stu_name = "王五";
182 List<ModifyField> list = stu.GetModifyFields();
183 //清除修改记录 (清除后更新操作无效)
184 //stu.ClearModifyFields();
185 //返回0表示更新失败 组件有事务会自动回滚
186 //返回1表示更新成功
187 //更新成功返回值就是受影响的条数
188 int num = DbSession.Default.Update<Student>(stu);
189
190
191 //简单的修改方法，修改一个值的时候使用
192 //int nums = DbSession.Default.Update<Student>(Student._.Stu_name, "九九", Student._.Stu_ID == 41501);
193
194
195 //修改多个值的时候
196 //Dictionary<Field, object> st = new Dictionary<Field, object>();
197 //st.Add(Student._.stu_Sex, "男");
198 //st.Add(Student._.Stu_name, "小徐");
199 //int returnvalue = DbSession.Default.Update<Student>(st, Student._.Stu_ID == 41501);
200 }
201
202
203 /// <summary>
204 /// 删除操作
205 /// </summary>
206 public static void DelData()
207 {
208
209 int returnValue = DbSession.Default.Delete<Student>(Student._.Stu_ID == 41504);
210 //与上面等效的删除语句
211 //int returnvalue = DbSession.Default.Delete<Student>(2);
212
213
214 //删除一个对象
215 //Student stu = DbSession.Default.From<Student>().ToFirst();
216 //int returnvalue = DbSession.Default.Delete<Student>(stu);
217 }
218
219
220 /// <summary>
221 /// 使用SQL语句查询
222 /// </summary>
223 public static void sqlFrom()
224 {
225
226 //直接使用SQL语句查询
227 DataTable dt = DbSession.Default.FromSql("select * from Student").ToDataTable();
228
229 //参数化SQL语句
230 //DataTable dt1 = DbSession.Default.FromSql("select * from Student where stu_id=id").AddInParameter("id", DbType.Int32, 41500).ToDataTable();
231
232 //多个参数查询
233 //DataTable dt2 = DbSession.Default.FromSql("select * from Student where stu_id=id or stu_name=name")
234 // .AddInParameter("id", DbType.Int32, 41500)
235 // .AddInParameter("name", DbType.String, "张三")
236 // .ToDataTable();
237 }
238
239
240 /// <summary>
241 /// 存储过程
242 /// </summary>
243 public static void ProcDemo()
244 {
245 //"ProcName"就是存储过程名称。
246 DataTable dt = DbSession.Default.FromProc("ProcName").ToDataTable();
247
248
249 //执行带参数的存储过程
250 DataTable dt1 = DbSession.Default.FromProc("ProcName")
251 .AddInParameter("parameterName", DbType.DateTime, "1995-01-01")
252 .AddInParameter("parameterName1", DbType.DateTime, "1996-12-01")
253 .ToDataTable();
254
255
256
257 //AddInputOutputParameter 方法添加输入输出参数
258 //AddOutParameter 方法添加输出参数
259 //AddReturnValueParameter 方法添加返回参数
260
261 ProcSection proc = DbSession.Default.FromProc("testoutstore")
262 .AddInParameter("in1", System.Data.DbType.Int32, 1)
263 .AddOutParameter("out2", System.Data.DbType.String, 100);
264 proc.ExecuteNonQuery();
265
266 Dictionary<string, object> returnValue = proc.GetReturnValues();
267
268 foreach (KeyValuePair<string, object> kv in returnValue)
269 {
270 Console.WriteLine("ParameterName:" + kv.Key + " ;ReturnValue:" + Convert.ToString(kv.Value));
271 }
272 }
273
274 /// <summary>
275 /// 辅助方法
276 /// </summary>
277 public static void assistmethod()
278 {
279 //返回 Student._.Stu_name == "小黑" 的Student._.gr_id合计。
280 int? sum = (int?)DbSession.Default.Sum<Student>(Student._.gr_id, Student._.Stu_name == "小黑");
281
282 //返回 Student._.Stu_ID == 2 的Stu_ID平均值。
283 DbSession.Default.Avg<Student>(Student._.Stu_ID, Student._.Stu_ID == 2);
284
285 //返回 Student._.Stu_ID == 2 的Stu_ID个数。
286 DbSession.Default.Count<Student>(Student._.Stu_ID, Student._.Stu_ID == 2);
287
288 //返回 Student._.Stu_ID == 2 的Stu_ID最大值。
289 DbSession.Default.Max<Student>(Student._.Stu_ID, Student._.Stu_ID == 2);
290
291 //返回 Student._.Stu_ID == 2 的Stu_ID最小值。
292 DbSession.Default.Min<Student>(Student._.Stu_ID, Student._.Stu_ID == 2);
293
294 }
295
296
297 /// <summary>
298 /// 添加事务处理
299 /// </summary>
300 public static void TestTrans()
301 {
302
303 DbTrans trans = DbSession.Default.BeginTransaction();
304 try
305 {
306 DbSession.Default.Update<Student>(Student._.Stu_name, "apple", Student._.Stu_ID == 1, trans);
307 DbSession.Default.Update<Student>(Student._.Stu_name, "egg", Student._.Stu_ID == 2, trans);
308 trans.Commit();
309 }
310 catch
311 {
312 trans.Rollback();
313 }
314 finally
315 {
316 trans.Close();
317 }
318
319 //存储过程中的事务 （ProcName表示存储过程名称）
320 DbTrans trans1 = DbSession.Default.BeginTransaction();
321 DbSession.Default.FromProc("ProcName").SetDbTransaction(trans);
322
323 }
324
325
326 /// <summary>
327 /// 批处理
328 /// </summary>
329 public static void batingTest()
330 {
331 //默认是10条sql执行一次。也可以自定义。
332 //DbBatch batch = DbSession.Default.BeginBatchConnection(20)
333
334 using (DbBatch batch = DbSession.Default.BeginBatchConnection())
335 {
336 batch.Update<Student>(Student._.Stu_name, "apple", Student._.Stu_ID == 1);
337 batch.Update<Student>(Student._.Stu_name, "pear", Student._.Stu_ID == 2);
338 //执行batch.Execute()，就会将之前的sql脚本先提交。
339 //batch.Execute();
340 batch.Update<Student>(Student._.Stu_name, "orange", Student._.Stu_ID == 3);
341 }
342 }
343
344
345 /// <summary>
346 /// 缓存
347 /// </summary>
348 public static void SetCacheTimeOutDemo() {
349
350 //SetCacheTimeOut设置查询的缓存为180秒
351 DbSession.Default.From<Student>().Where(Student._.Stu_ID == 1).SetCacheTimeOut(180).ToFirst();
352
353
354
355 }
356
357
358
359 }
360 }
工具生成的实体类如下：
//------------------------------------------------------------------------------
// <auto-generated>
// 此代码由工具生成。
// 运行时版本:2.0.50727.5485
// Support: http://www.cnblogs.com/huxj
// 对此文件的更改可能会导致不正确的行为，并且如果
// 重新生成代码，这些更改将会丢失。
// </auto-generated>
//------------------------------------------------------------------------------
using System;
using System.Data;
using System.Data.Common;
using Hxj.Data;
using Hxj.Data.Common;
namespace cn.School
{
/// <summary>
/// 实体类Student 。(属性说明自动提取数据库字段的描述信息)
/// </summary>
[Serializable]
public class Student : Entity
{
public Student():base("Student") {}
#region Model
private int _Stu_ID;
private string _Stu_name;
private int? _stu_Age;
private string _stu_Sex;
private string _stu_phon;
private int _gr_id;
/// <summary>
///
/// </summary>
public int Stu_ID
{
get{ return _Stu_ID; }
set
{
this.OnPropertyValueChange(_.Stu_ID,_Stu_ID,value);
this._Stu_ID=value;
}
}
/// <summary>
///
/// </summary>
public string Stu_name
{
get{ return _Stu_name; }
set
{
this.OnPropertyValueChange(_.Stu_name,_Stu_name,value);
this._Stu_name=value;
}
}
/// <summary>
///
/// </summary>
public int? stu_Age
{
get{ return _stu_Age; }
set
{
this.OnPropertyValueChange(_.stu_Age,_stu_Age,value);
this._stu_Age=value;
}
}
/// <summary>
///
/// </summary>
public string stu_Sex
{
get{ return _stu_Sex; }
set
{
this.OnPropertyValueChange(_.stu_Sex,_stu_Sex,value);
this._stu_Sex=value;
}
}
/// <summary>
///
/// </summary>
public string stu_phon
{
get{ return _stu_phon; }
set
{
this.OnPropertyValueChange(_.stu_phon,_stu_phon,value);
this._stu_phon=value;
}
}
/// <summary>
///
/// </summary>
public int gr_id
{
get{ return _gr_id; }
set
{
this.OnPropertyValueChange(_.gr_id,_gr_id,value);
this._gr_id=value;
}
}
#endregion
#region Method
/// <summary>
/// 获取实体中的标识列
/// </summary>
public override Field GetIdentityField()
{
return _.Stu_ID;
}
/// <summary>
/// 获取实体中的主键列
/// </summary>
public override Field[] GetPrimaryKeyFields()
{
return new Field[] {
_.Stu_ID};
}
/// <summary>
/// 获取列信息
/// </summary>
public override Field[] GetFields()
{
return new Field[] {
_.Stu_ID,
_.Stu_name,
_.stu_Age,
_.stu_Sex,
_.stu_phon,
_.gr_id};
}
/// <summary>
/// 获取值信息
/// </summary>
public override object[] GetValues()
{
return new object[] {
this._Stu_ID,
this._Stu_name,
this._stu_Age,
this._stu_Sex,
this._stu_phon,
this._gr_id};
}
/// <summary>
/// 给当前实体赋值
/// </summary>
public override void SetPropertyValues(IDataReader reader)
{
this._Stu_ID = DataUtils.ConvertValue<int>(reader["Stu_ID"]);
this._Stu_name = DataUtils.ConvertValue<string>(reader["Stu_name"]);
this._stu_Age = DataUtils.ConvertValue<int?>(reader["stu_Age"]);
this._stu_Sex = DataUtils.ConvertValue<string>(reader["stu_Sex"]);
this._stu_phon = DataUtils.ConvertValue<string>(reader["stu_phon"]);
this._gr_id = DataUtils.ConvertValue<int>(reader["gr_id"]);
}
/// <summary>
/// 给当前实体赋值
/// </summary>
public override void SetPropertyValues(DataRow row)
{
this._Stu_ID = DataUtils.ConvertValue<int>(row["Stu_ID"]);
this._Stu_name = DataUtils.ConvertValue<string>(row["Stu_name"]);
this._stu_Age = DataUtils.ConvertValue<int?>(row["stu_Age"]);
this._stu_Sex = DataUtils.ConvertValue<string>(row["stu_Sex"]);
this._stu_phon = DataUtils.ConvertValue<string>(row["stu_phon"]);
this._gr_id = DataUtils.ConvertValue<int>(row["gr_id"]);
}
#endregion
#region _Field
/// <summary>
/// 字段信息
/// </summary>
public class _
{
/// <summary>
/// *
/// </summary>
public readonly static Field All = new Field("*","Student");
/// <summary>
///
/// </summary>
public readonly static Field Stu_ID = new Field("Stu_ID","Student","Stu_ID");
/// <summary>
///
/// </summary>
public readonly static Field Stu_name = new Field("Stu_name","Student","Stu_name");
/// <summary>
///
/// </summary>
public readonly static Field stu_Age = new Field("stu_Age","Student","stu_Age");
/// <summary>
///
/// </summary>
public readonly static Field stu_Sex = new Field("stu_Sex","Student","stu_Sex");
/// <summary>
///
/// </summary>
public readonly static Field stu_phon = new Field("stu_phon","Student","stu_phon");
/// <summary>
///
/// </summary>
public readonly static Field gr_id = new Field("gr_id","Student","gr_id");
}
#endregion
}
}
//------------------------------------------------------------------------------
// <auto-generated>
// 此代码由工具生成。
// 运行时版本:2.0.50727.5485
// Support: http://www.cnblogs.com/huxj
// 对此文件的更改可能会导致不正确的行为，并且如果
// 重新生成代码，这些更改将会丢失。
// </auto-generated>
//------------------------------------------------------------------------------
using System;
using System.Data;
using System.Data.Common;
using Hxj.Data;
using Hxj.Data.Common;
namespace cn.School
{
/// <summary>
/// 实体类Gread 。(属性说明自动提取数据库字段的描述信息)
/// </summary>
[Serializable]
public class Gread : Entity
{
public Gread():base("Gread") {}
#region Model
private int _gr_id;
private string _gr_name;
/// <summary>
///
/// </summary>
public int gr_id
{
get{ return _gr_id; }
set
{
this.OnPropertyValueChange(_.gr_id,_gr_id,value);
this._gr_id=value;
}
}
/// <summary>
///
/// </summary>
public string gr_name
{
get{ return _gr_name; }
set
{
this.OnPropertyValueChange(_.gr_name,_gr_name,value);
this._gr_name=value;
}
}
#endregion
#region Method
/// <summary>
/// 获取实体中的标识列
/// </summary>
public override Field GetIdentityField()
{
return _.gr_id;
}
/// <summary>
/// 获取实体中的主键列
/// </summary>
public override Field[] GetPrimaryKeyFields()
{
return new Field[] {
_.gr_id};
}
/// <summary>
/// 获取列信息
/// </summary>
public override Field[] GetFields()
{
return new Field[] {
_.gr_id,
_.gr_name};
}
/// <summary>
/// 获取值信息
/// </summary>
public override object[] GetValues()
{
return new object[] {
this._gr_id,
this._gr_name};
}
/// <summary>
/// 给当前实体赋值
/// </summary>
public override void SetPropertyValues(IDataReader reader)
{
this._gr_id = DataUtils.ConvertValue<int>(reader["gr_id"]);
this._gr_name = DataUtils.ConvertValue<string>(reader["gr_name"]);
}
/// <summary>
/// 给当前实体赋值
/// </summary>
public override void SetPropertyValues(DataRow row)
{
this._gr_id = DataUtils.ConvertValue<int>(row["gr_id"]);
this._gr_name = DataUtils.ConvertValue<string>(row["gr_name"]);
}
#endregion
#region _Field
/// <summary>
/// 字段信息
/// </summary>
public class _
{
/// <summary>
/// *
/// </summary>
public readonly static Field All = new Field("*","Gread");
/// <summary>
///
/// </summary>
public readonly static Field gr_id = new Field("gr_id","Gread","gr_id");
/// <summary>
///
/// </summary>
public readonly static Field gr_name = new Field("gr_name","Gread","gr_name");
}
#endregion
}
}
时间： 2024-10-20 01:32:24