执行多条SQL语句,执行数据库事务(可传入Sql参数)
上篇博客,实例介绍了一个事务执行多条SQL语句函数(int ExecuteSqlTran(List<String> SQLStringList))点击打开链接,方便之余又发现了它的缺陷——不能传入Sql语句的参数,只能靠拼接字符串完成Sql语句,很是麻烦哈!人类是‘贪婪’滴(*^__^*) 嘻嘻……,同时也是勇于探索滴,有不可传参的,那我想 必定就有可传参的,这篇博客就分享一下——执行多条SQL语句,实现数据库事务函数(可传Sql参数)
(注:本篇博客涉及到哈希表的些许知识,就不做介绍了,用一次也就大概了解了。哪天姐姐高兴,再来对哈希表来个分析 O(∩_∩)O哈哈~)
D层SqlTaskAssignInfo类:
- /// <summary>
- /// 组长分配任务(更新任务信息表T_TaskInfo和任务分配表T_TaskAssignInfo)
- /// </summary>
- /// <param name="modelTaskAssignInfo">任务分配信息实体类(任务ID、小组ID、成员ID、成员姓名、组长分配日期、组长分配时间)</param>
- /// <returns>bool(true:分配成功;false:分配失败)</returns>
- public bool AssignTask2(Entity.TaskAssignInfoEntity enTaskAssignInfo)
- {
- //1,sql1语句:根据任务ID和分配等级,更新任务分配信息表T_TaskAssignInfo中任务分配状态字段taskDistributeState的值为‘已分配’
- string sql1 = "update T_TaskAssignInfo set taskDistributeState='已分配' where taskID=@taskID and distributeLevel='1'";
- //2,sql2语句:向任务分配信息表中插入一条组长分配的任务信息,包括(任务ID,小组ID,成员ID,成员姓名、分配日期、分配时间、分配等级、提交状态)
- string sql2 = "insert into T_TaskAssignInfo(taskID,groupID,memberID,memberName,distributeDate,distributeTime,distributeLevel,submitState)
- values (@taskID,@groupID,@memberID,@memberName,@distributeDate,@distributeTime, '2','未提交')";
- //3,设置参数(任务ID、小组ID、成员ID、成员姓名、分配日期、分配时间)
- SqlParameter[] parameters ={new SqlParameter ("@taskID",enTaskAssignInfo.taskID ),
- new SqlParameter("@groupID",enTaskAssignInfo.groupID),
- new SqlParameter("@memberID",enTaskAssignInfo.memberID),
- new SqlParameter("@memberName",enTaskAssignInfo.memberName ),
- new SqlParameter("@distributeDate",enTaskAssignInfo.distributeDate),
- new SqlParameter("@distributeTime",enTaskAssignInfo.distributeTime)};
- //4,创建哈希表
- Hashtable SQLStringList=new Hashtable ();
- SQLStringList.Add(sql1,parameters);//4.1将sql1语句,和参数添加到哈希表
- SQLStringList.Add(sql2,parameters);//4.2将sql2语句和参数添加到哈希表
- try
- {//5,调用DbHelperSQL类的事务函数(执行多条sql语句,完成数据库事务)
- DbHelperSQL.ExecuteSqlTran(SQLStringList);
- return true;
- }
- catch(SystemException)
- {
- return false;
- }
- }
(注:DbHelperSQL类代码中的ConnectionString是写在配置文件里的数据库连接字符串)
DbHelperSQL类:
- using System.Configuration '这里添加后,还必须在管理器中添加引用
- public static string connectionString = ConfigurationManager.AppSettings["ConnectionString"];
- /// <summary>
- /// 执行多条SQL语句,实现数据库事务。
- /// </summary>
- /// <param name="SQLStringList">SQL语句的哈希表(key为sql语句,value是该语句的SqlParameter[])</param>
- public static void ExecuteSqlTran(Hashtable SQLStringList)
- {
- using (SqlConnection conn = new SqlConnection(connectionString))
- {
- conn.Open();//打开数据库连接
- using (SqlTransaction trans = conn.BeginTransaction())//开始数据库事务
- {
- SqlCommand cmd = new SqlCommand();//创建SqlCommand命令
- try
- {
- //循环
- foreach (DictionaryEntry myDE in SQLStringList)//循环哈希表(本例中 即,循环执行添加在哈希表中的sql语句
- {
- string cmdText = myDE.Key.ToString();//获取键值(本例中 即,sql语句)
- SqlParameter[] cmdParms = (SqlParameter[])myDE.Value;//获取键值(本例中 即,sql语句对应的参数)
- PrepareCommand(cmd, conn, trans, cmdText, cmdParms); //调用PrepareCommand()函数,添加参数
- int val = cmd.ExecuteNonQuery();//调用增删改函数ExcuteNoQuery(),执行哈希表中添加的sql语句
- cmd.Parameters.Clear(); //清除参数
- }
- trans.Commit();//提交事务
- }
- catch //捕获异常
- {
- trans.Rollback(); //事务回滚
- throw; //抛出异常
- }
- }
- }
- }
- //添加参数
- private static void PrepareCommand(SqlCommand cmd, SqlConnection conn, SqlTransaction trans, string cmdText, SqlParameter[] cmdParms)
- {
- if (conn.State != ConnectionState.Open)//如果数据库连接为关闭状态
- conn.Open();//打开数据库连接
- cmd.Connection = conn;//设置命令连接
- cmd.CommandText = cmdText;//设置执行命令的sql语句
- if (trans != null)//如果事务不为空
- cmd.Transaction = trans;//设置执行命令的事务
- cmd.CommandType = CommandType.Text;//设置解释sql语句的类型为“文本”类型(也是就说该函数不适用于存储过程)
- if (cmdParms != null)//如果参数数组不为空
- {
- foreach (SqlParameter parameter in cmdParms) //循环传入的参数数组
- {
- if ((parameter.Direction == ParameterDirection.InputOutput || parameter.Direction == ParameterDirection.Input) &&
- (parameter.Value == null))
- {
- parameter.Value = DBNull.Value; //获取参数的值
- }
- cmd.Parameters.Add(parameter);//添加参数
- }
- }
- }
配置文件:
- <appSettings> <add key="ConnectionString" value="server=hanxuemin;database=Library;uid=sa;pwd=123456"/>
- </appSettings>
对比上篇博客中介绍的“执行多条sql语句,实现数据库事务(不可传入sql参数)函数”点击打开链接,体会两个函数的优缺点,了解两个函数在D层函数中是如何调用的,学会使用!
执行多条SQL语句,执行数据库事务(可传入Sql参数)相关推荐
- oracle 查看用户日志,Oracle查看用户操作sql语句以及数据库日志
--查看日志文件 select member from v$logfile; --查看表空间使用情况 SELECT SUM(bytes) / (1024 * 1024) AS free_space, ...
- 一条SQL语句执行得很慢的原因有哪些?
一.开始装逼:分类讨论 一条 SQL 语句执行的很慢,那是每次执行都很慢呢?还是大多数情况下是正常的,偶尔出现很慢呢?所以我觉得,我们还得分以下两种情况来讨论. 1.大多数情况是正常的,只是偶尔会出现 ...
- 数据库索引--SQL语句执行效率、分析及优化
数据库表中字段上创建的索引,在写SQL语句进行查询时,索引可能会被使用到,也肯能因为SQL语句导致索引在此条SQL语句执行时索引无效. 聚簇索引的顺序就是数据的物理存储顺序,而对非聚簇索引的解释是:索 ...
- 判断resultset是否遍历到最后一条记录_干货:一条SQL语句执行得很慢的原因
说实话,这个问题可以涉及到 MySQL 的很多核心知识,可以扯出一大堆,就像要考你计算机网络的知识时,问你"输入URL回车之后,究竟发生了什么"一样,看看你能说出多少了. 之前腾讯 ...
- 腾讯面试题:一条SQL语句执行得很慢的原因有哪些?
最近的招聘季,腾讯有一道面试题:一条SQL语句执行得很慢的原因有哪些? 其实,这个问题可以涉及到 MySQL 的很多核心知识,可以扯出一大堆,就像要考你计算机网络的知识时,问你"输入URL回 ...
- 腾讯面试:一条SQL语句执行得很慢的原因有哪些?
戳蓝字"CSDN云计算"关注我们哦! 技术头条:干货.简洁.多维全面.更多云计算精华知识尽在眼前,get要点.solve难题,统统不在话下! 作者:帅地 转自:苦逼的码农 说实话, ...
- 一条SQL语句执行得很慢的原因有哪些
一.一条 SQL 语句执行的很慢,那是每次执行都很慢呢?还是大多数情况下是正常的,偶尔出现很慢呢?所以我觉得,我们还得分以下两种情况来讨论. 1.大多数情况是正常的,只是偶尔会出现很慢的情况. 2.在 ...
- 【转】SQL 语句执行顺序
From:http://www.jellythink.com/archives/924 Oracle-SQL语句执行原理和完整过程详解:https://wenku.baidu.com/view/398 ...
- SQL 语句执行顺序
From:http://www.jellythink.com/archives/924 Oracle-SQL语句执行原理和完整过程详解:https://wenku.baidu.com/view/398 ...
- MySQL实战 | 01 当执行一条 select 语句时,MySQL 到底做了啥?
原文链接:当执行一条 select 语句时,MySQL 到底做了啥? 也许,你也跟我一样,在遇到数据库问题时,总时茫然失措,想重启解决问题,又怕导致数据丢失,更怕重启失败,影响业务. 就算重启成功了, ...
最新文章
- 安卓自动化测试(1)安卓自动化测试原理概念
- 马斯克的“大脑改造计划”,还需要点亮哪些技能树?
- java中 2017 1等于_java 2017秋招1
- virtual machine(vmware)知识
- javascript . 05 json的组成、for...in 遍历对象、简单数据类型与复杂数据类型的传值与传址、内置对象...
- mysql 双从性能_MySQL双主一致性架构优化
- PowerShell 7.0 RC 发布
- 对Unity3d C#手动处理异常产生
- spring boot: java @interface注解
- 如何开启刷题,蓝桥杯练习系统
- 现在的python版本_为什么有这么多 Python版本
- 如何制作Android语音机器人
- java页面展示_JAVA页面展示问题
- 「BTC之城」的奇幻漂流
- 华视身份证阅读器SDK使用手册
- 现在为什么很多企业都在使用终端安全管理系统?有什么好处...
- 7月20日到12月3日
- 这个世界是一个矛盾的综合体,高手有在各种各样的矛盾中保持平衡的能力
- Day23(CopyFile,InputStreamReader,OutputStreamWruiter,Buffered,BufferedInputStream,BufferedOutputStr)
- Big Sur航拍动态壁纸4K高清
热门文章
- 【EventBus】Subscribe 注解分析 ( Subscribe 注解属性 | threadMode 线程模型 | POSTING | MAIN | MAIN_ORDERED | ASYNC)
- 【Java 虚拟机原理】栈帧 | 动态链接 | 方法区 | 字节码文件二进制分析
- 【Android TV 开发】焦点处理 ( 父容器与子组件焦点获取关系处理 | 不同电视设备上的兼容问题 | 触摸获取焦点 | 按键获取焦点 )
- 【Cubase】Cubase 量化设置 ( 量化预置 | 长度量化 | 快捷键设置 | 量化开头 | 量化 MIDI 事件结尾 | 量化 MIDI 事件长度 )
- 【Android RTMP】安卓直播推流总结 ( 直播服务器搭建 | NV21 图像采集 | H.264 视频编码 | PCM 音频采集 | AAC 音频编码 | RTMP 包封装推流 )
- 设计模式-Builder模式
- 医疗影像网络PACS系统方案
- intelliJ idea 下载安装
- 【leetcode】500. Keyboard Row
- salt常用命令(一)