c# sqlhelper

using System;
using System.Data;
using System.Data.SqlClient;

public class SqlHelper
{
    // 执行查询并返回DataSet
    public static DataSet ExecuteDataset(string connectionString, CommandType commandType, string commandText, params SqlParameter[] commandParameters)
    {
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            using (SqlCommand command = new SqlCommand(commandText, connection))
            {
                command.CommandType = commandType;
                if (commandParameters != null)
                {
                    foreach (SqlParameter parameter in commandParameters)
                    {
                        if (parameter != null)
                        {
                            command.Parameters.Add(parameter);
                        }
                    }
                }

                using (SqlDataAdapter adapter = new SqlDataAdapter(command))
                {
                    DataSet dataSet = new DataSet();
                    adapter.Fill(dataSet);
                    return dataSet;
                }
            }
        }
    }

    // 执行非查询命令（如INSERT、UPDATE、DELETE）
    public static int ExecuteNonQuery(string connectionString, CommandType commandType, string commandText, params SqlParameter[] commandParameters)
    {
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            using (SqlCommand command = new SqlCommand(commandText, connection))
            {
                command.CommandType = commandType;
                if (commandParameters != null)
                {
                    foreach (SqlParameter parameter in commandParameters)
                    {
                        if (parameter != null)
                        {
                            command.Parameters.Add(parameter);
                        }
                    }
                }

                connection.Open();
                int rowsAffected = command.ExecuteNonQuery();
                return rowsAffected;
            }
        }
    }

    // 执行查询并返回单个值
    public static object ExecuteScalar(string connectionString, CommandType commandType, string commandText, params SqlParameter[] commandParameters)
    {
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            using (SqlCommand command = new SqlCommand(commandText, connection))
            {
                command.CommandType = commandType;
                if (commandParameters != null)
                {
                    foreach (SqlParameter parameter in commandParameters)
                    {
                        if (parameter != null)
                        {
                            command.Parameters.Add(parameter);
                        }
                    }
                }

                connection.Open();
                object result = command.ExecuteScalar();
                return result;
            }
        }
    }
}

解释说明

1. ExecuteDataset:

   • 用于执行查询并返回一个 DataSet 对象。
   • 参数包括连接字符串、命令类型、SQL 命令文本和可选的参数列表。
   • 使用 SqlDataAdapter 将查询结果填充到 DataSet 中。

2. ExecuteNonQuery:

   • 用于执行非查询命令（如 INSERT、UPDATE、DELETE）。
   • 返回受影响的行数。
   • 参数包括连接字符串、命令类型、SQL 命令文本和可选的参数列表。

3. ExecuteScalar:

   • 用于执行查询并返回单个值。
   • 适用于只需要获取一个结果的情况，例如 SELECT COUNT(*)。
   • 参数包括连接字符串、命令类型、SQL 命令文本和可选的参数列表。

这些方法可以帮助你更方便地与 SQL Server 数据库进行交互。