轻量级ORM框架Dapper应用支持操作函数和事物

2022-04-17 10:37:54

dapper除了支持基础的CURD、存储过程以外,还支持操作函数和事物。

dapper操作函数的代码如下:

using Dapper;using System;using System.Collections.Generic;using System.Configuration;using System.Data;using System.Data.SqlClient;using System.Linq;using System.Text;using System.Threading.Tasks;namespace DapperDemo{    public static class OperFunction    {        /// <summary>        /// Dapper滴调用函数        /// </summary>        public static void ExecuteFunction()        {            // 连接字符串            string strCon = ConfigurationManager.ConnectionStrings["DbConnection"].ConnectionString;            // connection对象            IDbConnection dbConnection = new SqlConnection(strCon);            // 定义参数            DynamicParameters paras = new DynamicParameters();            paras.Add("@num1", 34);            paras.Add("@num2", 456);            // 返回值            paras.Add("@sum", 0, DbType.Int32, ParameterDirection.ReturnValue);            string functionName = "fun_test";            // 执行            int count = dbConnection.Execute(functionName, paras, null, null, CommandType.StoredProcedure);            // 获取输出参数的值            int sum = paras.Get<int>("@sum");            Console.WriteLine("sum:" + sum);//输出390        }    }}

dapper支持事物的代码如下:

using Dapper;using System;using System.Collections.Generic;using System.Configuration;using System.Data;using System.Data.SqlClient;using System.Linq;using System.Text;using System.Threading.Tasks;namespace DapperDemo{    public static class OperTransaction    {        /// <summary>        /// Dapper支持事物        /// </summary>        public static void ExecuteTransaction()        {            // 连接字符串            string strCon = ConfigurationManager.ConnectionStrings["DbConnection"].ConnectionString;            // connection对象            IDbConnection dbConnection = new SqlConnection(strCon);            string strSQL = "DELETE FROM Student WHERE StudentID=@StudentID";            DynamicParameters paras = new DynamicParameters();            paras.Add("@StudentID", 3);            // 在BeginTransaction之前要打开连接,否则报错:无效操作,连接已关闭            dbConnection.Open();            // 开启事物            IDbTransaction transaction = dbConnection.BeginTransaction();            try            {                dbConnection.Execute(strSQL, paras, transaction: transaction);                // 提交事务                transaction.Commit();            }            catch (Exception ex)            {                // 回滚事物                transaction.Rollback();            }        }    }}

Dapper除了支持Transaction以外,还支持Transactionscope:

public static void ExecuteTransactionScope(){      using (var transactionscope = new TransactionScope(TransactionScopeOption.Required))      {            // 连接字符串            string strCon = ConfigurationManager.ConnectionStrings["DbConnection"].ConnectionSwww.easck.comtring;            // connection对象            IDbConnection dbConnection = new SqlConnection(strCon);            string strSQL = "DELETE FROM Student WHERE StudentID=@StudentID";            DynamicParameters paras = new DynamicParameters();       vXYkW     paras.Add("@StudentID", 6);            dbConnection.Open();            try            {                dbConnection.Execute(strSQL, paras);                transactionscope.Complete();            }            catch (Exception ex)            {                // 不提交事务默认自动回滚                Console.WriteLine(ex.Message);            }      }}

到此这篇关于Dapper支持操作函数和事物的文章就介绍到这了。希望对大家的学习有所帮助,也希望大家多多支持我们。