.NET数据库编程求索之路--4.使用ADO.NET实现(三层架构篇-使用Table传递数据)(1)

简介: 4.使用ADO.NET实现(三层架构篇-使用Table传递数据)(1)   4.1 解决方案框架 解决方案(.sln)包含以下几个项目: (1)类库项目HomeShop.DbUtility,数据访问实用工具; (2)类库项目HomeShop.Model,实体层; (3)类库项目HomeShop.DAL,数据访问层; (4)类库项目HomeShop.BLL,业务逻辑层; (5)WinForm项目HomeShop.WinForm,界面层。

4.使用ADO.NET实现(三层架构篇-使用Table传递数据)(1)

 

4.1 解决方案框架

解决方案(.sln)包含以下几个项目:

(1)类库项目HomeShop.DbUtility,数据访问实用工具;

(2)类库项目HomeShop.Model,实体层;

(3)类库项目HomeShop.DAL,数据访问层;

(4)类库项目HomeShop.BLL,业务逻辑层;

(5)WinForm项目HomeShop.WinForm,界面层。

 

4.2 数据访问实用工具HomeShop.DbUtility

 

SqlDbHelper.cs

  1  using System;
  2  using System.Collections.Generic;
  3  using System.Linq;
  4  using System.Text;
  5  using System.Data; // 新添命名空间
  6  using System.Configuration; // 新添命名空间
  7  using System.Data.SqlClient; // 新添命名空间
  8 
  9  namespace HomeShop.DbUtility
 10 {
 11      // 功能:SQL Server数据访问基础类;
 12       // 作者:夏春涛;
 13       // 日期:2011-11-30;
 14       public  class SqlDbHelper
 15     {
 16          // 数据库连接字符串
 17           private  string connectionString =  "";
 18          public  string ConnectionString
 19         {
 20              get { return connectionString; }
 21         }
 22 
 23          // 数据库连接对象
 24           private SqlConnection connection;
 25         
 26          // 默认构造函数,从应用程序配置文件中读取第1个数据库连接字符串
 27           public SqlDbHelper()
 28         {
 29              this.connectionString = ConfigurationManager.ConnectionStrings[ 1].ConnectionString;
 30              this.connection =  new SqlConnection( this.connectionString);            
 31         }
 32 
 33          // 重载构造函数,根据入参初始化数据库连接字符串
 34           public SqlDbHelper( string connectionString)
 35         {
 36              this.connectionString = connectionString;
 37              this.connection =  new SqlConnection( this.connectionString);
 38         }
 39 
 40          // 执行SQL命令(Select),获取返回数据-重载函数
 41           public DataTable ExecuteQuery( string selectCommandText)
 42         {
 43              return ExecuteQuery(selectCommandText,  null);
 44         }
 45 
 46          // 执行SQL命令(Select),获取返回数据
 47           public DataTable ExecuteQuery( string selectCommandText,  params SqlParameter[] cmdParameters)
 48         {            
 49             connection.Open();
 50             SqlCommand command =  new SqlCommand(selectCommandText, connection);
 51              if ( null != cmdParameters)
 52             {
 53                  for ( int i =  0; i < cmdParameters.Length; i++)
 54                 {
 55                     command.Parameters.Add(cmdParameters[i]);
 56                 }
 57             }
 58             SqlDataAdapter adapter =  new SqlDataAdapter(command);
 59             DataTable dataTable =  new DataTable();
 60             adapter.Fill(dataTable);
 61             connection.Close();
 62 
 63              return dataTable;
 64         }
 65 
 66          // 执行SQL命令(Insert/Delete/Update),以数据库事务方式
 67           public  int ExecuteNonQueryTrans( string cmdText,  params SqlParameter[] cmdParameters)
 68         {
 69              int rowsCountAffected =  0;            
 70             connection.Open();
 71             SqlCommand command =  new SqlCommand(cmdText, connection);
 72              if ( null != cmdParameters)
 73             {
 74                  for ( int i =  0; i < cmdParameters.Length; i++)
 75                 {
 76                     command.Parameters.Add(cmdParameters[i]);
 77                 }
 78             }
 79              // 开始数据库事务
 80              SqlTransaction trans = connection.BeginTransaction();
 81             command.Transaction = trans;
 82              try
 83             {
 84                 rowsCountAffected += command.ExecuteNonQuery();
 85                 trans.Commit(); // 提交数据库事务
 86              }
 87              catch
 88             {
 89                 trans.Rollback(); // 回滚数据库事务
 90                   throw;
 91             }
 92             connection.Close();
 93 
 94              return rowsCountAffected;
 95         }
 96 
 97          // 执行多条SQL(Insert/Delete/Update),以数据库事务方式-重载函数
 98           public  int ExecuteNonQueryTrans( params SqlCmdTextAndParams[] cmdTextAndParams)
 99         {
100             List<SqlCmdTextAndParams> list =  new List<SqlCmdTextAndParams>();
101              for( int i= 0;i<cmdTextAndParams.Length;i++)
102             {
103                 list.Add(cmdTextAndParams[i]);
104             }
105 
106              return ExecuteNonQueryTrans(list);
107         }
108 
109          // 执行多条SQL(Insert/Delete/Update),以数据库事务方式
110           public  int ExecuteNonQueryTrans(List<SqlCmdTextAndParams> listCmdTextAndParams)
111         {
112              int rowsCountAffected =  0;            
113             connection.Open();
114              // 开始数据库事务
115              SqlTransaction trans = connection.BeginTransaction();
116             SqlCommand command =  new SqlCommand();
117             command.Connection = connection;
118             command.Transaction = trans;
119              try
120             {
121                  // 循环执行每一个CommandTextAndParameters对象
122                   foreach (SqlCmdTextAndParams cmdTextAndParams  in listCmdTextAndParams)
123                 {
124                     command.CommandText = cmdTextAndParams.CommandText;
125                      foreach (SqlParameter param  in cmdTextAndParams.CommandParameters)
126                     {
127                         command.Parameters.Add(param);
128                     }
129                     rowsCountAffected += command.ExecuteNonQuery();
130                      // 清空参数列表,避免参数重名问题
131                      command.Parameters.Clear();
132                 }
133                 trans.Commit(); // 提交数据库事务
134              }
135              catch
136             {
137                 trans.Rollback(); // 回滚数据库事务
138                   throw;
139             }
140             connection.Close();
141 
142              return rowsCountAffected;
143         }
144 
145          // 开始(生成)一个数据库事务
146           public SqlTransaction BeginTransaction()
147         { 
148             connection.Open();
149             SqlTransaction trans = connection.BeginTransaction();
150 
151              return trans;
152         }
153 
154          // 在指定的数据库事务中执行SQL命令,最后要手工提交事务
155           public  int ExecuteNonQueryTrans(SqlTransaction inTransaction,  string cmdText,  params SqlParameter[] cmdParameters)
156         {
157              int rowsCountAffected =  0;            
158             SqlCommand command =  new SqlCommand(cmdText, inTransaction.Connection);
159              if ( null != cmdParameters)
160             {
161                  for ( int i =  0; i < cmdParameters.Length; i++)
162                 {
163                     command.Parameters.Add(cmdParameters[i]);
164                 }
165             }
166             command.Transaction = inTransaction;
167             rowsCountAffected += command.ExecuteNonQuery();
168             command.Parameters.Clear(); // 清空参数列表,避免参数重名问题
169 
170              return rowsCountAffected;
171         }
172 
173          // 关闭数据库连接
174           public  void Close()
175         {
176              if (ConnectionState.Open ==  this.connection.State )
177                  this.connection.Close();
178         }
179 
180          /* ************************************************************************************** */
181     }
182 }

  

SqlCmdTextAndParams.cs

 

 1  using System;
 2  using System.Collections.Generic;
 3  using System.Linq;
 4  using System.Text;
 5  using System.Data.SqlClient; // 新添命名空间
 6 
 7  namespace HomeShop.DbUtility
 8 {
 9      // 用于保存一条SQL命令及对应参数的类
10       public  class SqlCmdTextAndParams
11     {
12          public SqlCmdTextAndParams( string commandText,  params SqlParameter[] commandParamters)
13         {
14              this.CommandText = commandText;
15              this.CommandParameters = commandParamters;
16         }
17 
18          public  string CommandText {  setget; }
19 
20          public SqlParameter[] CommandParameters {  setget; }
21     }
22 }

 

 

 

数据库文件:/Files/SummerRain/NetDbDevRoad/HomeShopDB.rar

完整源代码:/Files/SummerRain/NetDbDevRoad/4使用ADONET实现三层架构Table.rar

 

 

 

目录
相关文章
|
16天前
|
SQL 数据库 微服务
微服务03,最简单的Demo,我们每个服务不能重复开发相同业务,微服务数据独立,不要访问其他微服务的数据库,微服务的特点之一是提供不能功能的数据库互相分割,微服务需要根据业务模块拆分,做到单一职责,
微服务03,最简单的Demo,我们每个服务不能重复开发相同业务,微服务数据独立,不要访问其他微服务的数据库,微服务的特点之一是提供不能功能的数据库互相分割,微服务需要根据业务模块拆分,做到单一职责,
|
3天前
|
SQL DataWorks 关系型数据库
DataWorks产品使用合集之数据集成时源头提供数据库自定义函数调用返回数据,数据源端是否可以写自定义SQL实现
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
|
1天前
|
存储 负载均衡 定位技术
现代数据库系统中的数据分片策略与优化
数据分片在现代数据库系统中扮演着关键角色,特别是在面对海量数据和高并发访问的情况下。本文探讨了数据分片的基本概念、常见的分片策略(如水平分片与垂直分片)、以及如何通过优化和选择合适的分片策略来提升数据库系统的性能和可扩展性。
|
3天前
|
数据采集 分布式计算 大数据
MaxCompute产品使用合集之数据集成中进行数据抽取时,是否可以定义使用和源数据库一样的字符集进行抽取
MaxCompute作为一款全面的大数据处理平台,广泛应用于各类大数据分析、数据挖掘、BI及机器学习场景。掌握其核心功能、熟练操作流程、遵循最佳实践,可以帮助用户高效、安全地管理和利用海量数据。以下是一个关于MaxCompute产品使用的合集,涵盖了其核心功能、应用场景、操作流程以及最佳实践等内容。
|
5天前
|
Java 关系型数据库 数据库
实时计算 Flink版产品使用问题之如何将增量数据直接写入下游数据库
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
12天前
编程之路:从代码到架构的心路历程
【7月更文挑战第9天】在数字世界的迷宫中,每一行代码都承载着创造者的梦想与挑战。本文将通过个人技术感悟的镜头,探索编程实践的深层次价值,从最初的代码编写到复杂的系统架构设计,揭示技术成长的内在逻辑和情感变迁。我们将一同穿梭在技术的森林里,寻找那些让代码生动起来的秘密。
15 2
|
18天前
|
存储 关系型数据库 分布式数据库
PolarDB,阿里云的云原生分布式数据库,以其存储计算分离架构为核心,解决传统数据库的扩展性问题
【7月更文挑战第3天】PolarDB,阿里云的云原生分布式数据库,以其存储计算分离架构为核心,解决传统数据库的扩展性问题。此架构让存储层专注数据可靠性,计算层专注处理SQL,提升性能并降低运维复杂度。通过RDMA加速通信,多副本确保高可用性。资源可独立扩展,便于成本控制。动态添加计算节点以应对流量高峰,展示了其灵活性。PolarDB的开源促进了数据库技术的持续创新和发展。
234 2
|
18天前
|
关系型数据库 MySQL 数据库
关系型数据库mysql数据增量恢复
【7月更文挑战第3天】
133 2
|
18天前
|
关系型数据库 MySQL Shell
关系型数据库mysql数据完全恢复
【7月更文挑战第3天】
84 2
|
18天前
|
数据处理 数据库 索引
数据库索引策略如何影响数据的读取效率?
【7月更文挑战第3天】数据库索引策略如何影响数据的读取效率?
11 2