WangSql 1.0源码共享
2018-06-18 01:26:54来源:未知 阅读 ()
WangSql 3.0 已发布:WangSql 3.0源码共享(WangSql 1.0重大升级到3.0)
一,项目背景
现在基本上大大小小的项目都需要和数据库打交道,自然而然数据库操作会有很多地方,而使用传统ADO.NET整个流程有点麻烦,出参都需要手动转换为对象。基于以上,我们需要一个SQL执行工具,能简化上诉步骤,而不失对SQL控制权。
二,核心技术
最底层是ADO.NET,基于ADO.NET开发的工具。
1、支持多数据库
2、支持增删改查事务过程等常用SQL操作
3、支持参数统一化
4、支持入参多样化,且自动转换成SQL参数
5、支持出参多样化,且自动转换成对象
6、缓存方案(未完成)
7、并发控制(未完成)
8、支持表达式组件(未完成)
三,功能详解
以下内容及源码都仅供参考,勿用于生成环境。
1、多数据支持&扩展
以SQLite为例
1 public class SQLiteConn : ISqlConn 2 { 3 public SQLiteConn(string connectionString) 4 { 5 this.DbType = DbType.SQLITE; 6 this.ConnectionString = connectionString; 7 } 8 public DbType DbType { get; set; } 9 public string ConnectionString { get; set; } 10 public IDbConnection CreateDbConnection() 11 { 12 IDbConnection conn = new SQLiteConnection(); 13 conn.ConnectionString = this.ConnectionString; 14 return conn; 15 } 16 }
1 public class SQLiteFactory : SQLiteConn, IFactory 2 { 3 public SQLiteFactory(string connectionString) 4 : base(connectionString) 5 { 6 this.DbDataParameterPrefix = "@"; 7 } 8 public string DbDataParameterPrefix { get; set; } 9 public IDbDataParameter CreateDbDataParameter(string key, object value) 10 { 11 return new SQLiteParameter(key, value); 12 } 13 public string CreatePageSql(string sqlTag, int pageIndex, int pageSize) 14 { 15 string para = null; 16 para = @"select wang.* from ({0}) wang limit {1},{2}"; 17 para = string.Format(para, sqlTag, pageSize * (pageIndex - 1), pageSize); 18 return para; 19 } 20 }
目前支持Oracle,SqlServer,MySql,Access,SQLite数据库,如果要新增数据支持,只需实现ISqlConn和ISqlConn即可,具体实现同上。
2、具体测试&操作代码
1 var sqlExe = new WangSql.SqlExe("SQLITE", conn); 2 3 Write("初始化SqlExe完成"); 4 5 var site = new Site() 6 { 7 Id = Guid.NewGuid().ToString("N"), 8 Name = "site1", 9 Domain = "www.baidu.com" + Guid.NewGuid().ToString("N"), 10 Area = "web", 11 Remark = "测试" 12 }; 13 14 //insert 15 Write("insert开始"); 16 string sqlInsert = "insert into Site(Id,Name,Domain,Area,Remark) values(#Id#,#Name#,#Domain#,#Area#,#Remark#)"; 17 var resultInsert = sqlExe.NonQuery(sqlInsert, site); 18 Write("insert结束:结果:" + resultInsert); 19 20 //select 21 Write("select开始"); 22 string sqlSelect = "select * from Site"; 23 var resultSelect = sqlExe.QueryObject<Site>(sqlSelect); 24 var resultSelect1 = sqlExe.QueryList<Site>(sqlSelect); 25 int resultSelectIndex = new Random().Next(resultSelect1.Count); 26 Write("select结束:结果:" + resultSelect1[resultSelectIndex].Remark); 27 28 //update 29 Write("update开始"); 30 string sqlUpdate = "update Site set Remark=#Remark# where Id=#Id#"; 31 var site1 = new Site() 32 { 33 Remark = "测试1", 34 Id = resultSelect1[resultSelectIndex].Id 35 }; 36 var resultUpdate = sqlExe.NonQuery(sqlUpdate, site1); 37 Write("update结束:结果:" + resultUpdate); 38 39 //Transaction 40 Write("trans开始"); 41 using(var trans = sqlExe.BeginTransaction()) 42 { 43 string sqlTrans1 = "update Site set Remark=#Remark# where Id=#Id#"; 44 var site2 = new Site() 45 { 46 Remark = "测试2", 47 Id = resultSelect1[resultSelectIndex].Id 48 }; 49 var result1 = trans.NonQuery(sqlTrans1, site1); 50 51 string sqlTrans2 = "update Site set Name=#Name# where Id=#Id#"; 52 var site3 = new Site() 53 { 54 Name = "SASASA3", 55 Id = resultSelect1[resultSelectIndex].Id 56 }; 57 var result2 = trans.NonQuery(sqlTrans2, site1); 58 59 trans.Commit(); 60 } 61 Write("trans结束");
3、具体使用&接口代码
3.1 创建核心操作类实例SqlExe
var sqlExe = new WangSql.SqlExe("SQLITE", conn);
第一参数是数据库类型,第二个参数是数据库连接字符串,返回ISqlExe接口对象实例。
3.2 ISqlExe最核心的类,提供了所有数据操作方法,所有操作都是调用该接口里的方法。
1 public interface IMySqlExe 2 { 3 int ExecuteNonQuery(string sql); 4 int ExecuteNonQuery(string sql, global::System.Data.IDbDataParameter par); 5 int ExecuteNonQuery(string sql, global::System.Data.IDbDataParameter[] par); 6 object ExecuteProcedure(string sql, global::System.Collections.Generic.Dictionary<string, object> inpara, ref global::System.Collections.Generic.Dictionary<string, object> outpara, global::WangSql.ExcuteType excuteType = ExcuteType.Query); 7 object ExecuteProcedure(string sql, global::System.Collections.Generic.Dictionary<string, object> inpara, global::WangSql.ExcuteType excuteType = ExcuteType.Query); 8 object ExecuteProcedure(string sql, global::WangSql.ExcuteType excuteType = ExcuteType.Query); 9 global::System.Data.DataTable ExecuteReader(string sql); 10 global::System.Data.DataTable ExecuteReader(string sql, global::System.Data.IDataParameter par); 11 global::System.Data.DataTable ExecuteReader(string sql, global::System.Data.IDataParameter[] par); 12 int NonQuery(string sql); 13 int NonQuery(string sql, object para); 14 global::System.Collections.Generic.IList<T> QueryList<T>(string sql); 15 global::System.Collections.Generic.IList<T> QueryList<T>(string sql, object para); 16 T QueryObject<T>(string sql); 17 T QueryObject<T>(string sql, object para); 18 global::System.Data.DataTable QueryPage(string sql, int pageIndex, int pageSize, out int totalCount); 19 global::System.Data.DataTable QueryPage(string sql, object para, int pageIndex, int pageSize, out int totalCount); 20 global::System.Collections.Generic.IList<T> QueryPage<T>(string sql, int pageIndex, int pageSize, out int totalCount); 21 global::System.Collections.Generic.IList<T> QueryPage<T>(string sql, object para, int pageIndex, int pageSize, out int totalCount); 22 bool Transaction(global::System.Collections.Hashtable sqlList); 23 }
1 public interface ISqlExe : IMySqlExe 2 { 3 IMyTransaction BeginTransaction(); 4 }
3.3 IMyTransaction是事务操作接口,在ISqlExe包含该对象。
1 public interface IMyTransaction : IDisposable 2 { 3 void Commit(); 4 int NonQuery(string sql); 5 int NonQuery(string sql, object para); 6 System.Collections.Generic.IList<T> QueryList<T>(string sql); 7 System.Collections.Generic.IList<T> QueryList<T>(string sql, object para); 8 T QueryObject<T>(string sql); 9 T QueryObject<T>(string sql, object para); 10 void Rollback(); 11 }
4、SQL语句&事务使用说明
4.1 SQL语句
insert into Site(Id,Name,Domain,Area,Remark) values(#Id#,#Name#,#Domain#,#Area#,#Remark#)
上面就是一个完整的插入SQL语句,##这个就是最开始提到的支持参数统一化,所有参数都用##包裹,内部进行转换。
4.2 事务说明
//Transaction Write("trans开始"); using(var trans = sqlExe.BeginTransaction()) { try { string sqlTrans1 = "update Site set Remark=#Remark# where Id=#Id#"; var site2 = new Site() { Remark = "测试2", Id = resultSelect1[resultSelectIndex].Id }; var result1 = trans.NonQuery(sqlTrans1, site1); string sqlTrans2 = "update Site set Name=#Name# where Id=#Id#"; var site3 = new Site() { Name = "SASASA3", Id = resultSelect1[resultSelectIndex].Id }; var result2 = trans.NonQuery(sqlTrans2, site1); trans.Commit(); } catch { trans.Rollback(); } } Write("trans结束");
四,总结
6、缓存方案(未完成)
7、并发控制(未完成)
8、支持表达式组件(未完成)
上面三个还没有完成的,对了,代码简单粗鄙,请勿用于生成环境,仅用于学习和交流。
五,源码下载
地址:源码下载
..................
..................
标签:
版权申明:本站文章部分自网络,如有侵权,请联系:west999com@outlook.com
特别注意:本站所有转载文章言论不代表本站观点,本站所提供的摄影照片,插画,设计作品,如需使用,请与原作者联系,版权归原作者所有
下一篇:C#学习笔记-封装
- Java固定资产管理系统 源码 jsp ssh 2020-01-09
- Qt事件分发机制源码分析之QApplication对象构建过程 2019-12-08
- STL源码剖析——序列式容器#5 heap 2019-11-07
- stl源码学习(版本2.91)--list 2019-11-05
- webbench网站测压工具源码分析 2019-10-12
IDC资讯: 主机资讯 注册资讯 托管资讯 vps资讯 网站建设
网站运营: 建站经验 策划盈利 搜索优化 网站推广 免费资源
网络编程: Asp.Net编程 Asp编程 Php编程 Xml编程 Access Mssql Mysql 其它
服务器技术: Web服务器 Ftp服务器 Mail服务器 Dns服务器 安全防护
软件技巧: 其它软件 Word Excel Powerpoint Ghost Vista QQ空间 QQ FlashGet 迅雷
网页制作: FrontPages Dreamweaver Javascript css photoshop fireworks Flash