PSI.DBUitlity/SqlHelper.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

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 PSI.DbUtility
{
        public class SqlHelper
        {
                /// <summary>
                /// 连接字符串
                /// </summary>
                private static string connStr = ConfigurationManager.ConnectionStrings["connStr"].ConnectionString;
                /// <summary>
                /// 增、删、改的通用方法
                /// 执行Sql语句或存储过程，返回受影响的行数
                /// SQL注入 
                /// </summary>
                /// <param name="sql">sql语句或存储过程名</param>
                /// <param name="cmdType">执行的脚本类型 1:sql语句  2:存储过程</param>
                /// <param name="parameters">参数列表</param>
                /// <returns></returns>
                public static int ExecuteNonQuery(string sql, int cmdType, params SqlParameter[] parameters)
                {
                        //select @@Identity 返回上一次插入记录时自动产生的ID
                        int result = 0;//返回结果
                        using (SqlConnection conn = new SqlConnection(connStr))
                        {
                                //执行脚本的对象cmd
                                SqlCommand cmd = BuilderCommand(conn, sql, cmdType, null, parameters);
                                result = cmd.ExecuteNonQuery();//执行T-SQL并返回受影响行数
                                cmd.Parameters.Clear();
                        }
                        //using原理：类似于try finally
                        return result;
                }

                /// <summary>
                /// 执行sql查询，返回第一行第一列的值
                /// </summary>
                /// <param name="sql">sql语句或存储过程</param>
                /// <param name="cmdType">执行的脚本类型 1:sql语句  2:存储过程</param>
                /// <param name="parameters">参数列表</param>
                /// <returns></returns>
                public static object ExecuteScalar(string sql, int cmdType, params SqlParameter[] parameters)
                {
                        object result = null;//返回结果
                        using (SqlConnection conn = new SqlConnection(connStr))
                        {
                                //执行脚本的对象cmd
                                SqlCommand cmd = BuilderCommand(conn, sql, cmdType, null, parameters);
                                result = cmd.ExecuteScalar();//执行T-SQL并返回第一行第一列的值
                                cmd.Parameters.Clear();
                                if (result == null || result == DBNull.Value)
                                {
                                        return null;