使用C#写一个连接sql server数据库的工具类

以下是一个简单的 C# 工具类，用于连接 SQL Server 数据库：

using System;
using System.Data.SqlClient;

public class SqlHelper
{
    // 连接字符串
    private string connectionString;

    // 构造函数
    public SqlHelper(string connectionString)
    {
        this.connectionString = connectionString;
    }

    // 执行 SQL 命令，返回受影响的行数
    public int ExecuteNonQuery(string sql)
    {
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();

            using (SqlCommand command = new SqlCommand(sql, connection))
            {
                return command.ExecuteNonQuery();
            }
        }
    }

    // 执行 SQL 查询，返回 SqlDataReader 对象
    public SqlDataReader ExecuteReader(string sql)
    {
        SqlConnection connection = new SqlConnection(connectionString);
        connection.Open();

        SqlCommand command = new SqlCommand(sql, connection);

        SqlDataReader reader = command.ExecuteReader(System.Data.CommandBehavior.CloseConnection);

        return reader;
    }

    // 执行 SQL 查询，返回单个结果
    public object ExecuteScalar(string sql)
    {
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();

            using (SqlCommand command = new SqlCommand(sql, connection))
            {
                return command.ExecuteScalar();
            }
        }
    }
}

使用示例：

// 连接字符串
string connectionString = "Server=(local);Database=MyDatabase;User ID=MyUsername;Password=MyPassword;";

// 创建 SqlHelper 对象
SqlHelper sqlHelper = new SqlHelper(connectionString);

// 执行 SQL 命令
sqlHelper.ExecuteNonQuery("INSERT INTO MyTable (Column1, Column2) VALUES ('Value1', 'Value2')");

// 执行 SQL 查询
SqlDataReader reader = sqlHelper.ExecuteReader("SELECT * FROM MyTable");

while (reader.Read())
{
    // 读取数据
    string column1 = reader.GetString(0);
    string column2 = reader.GetString(1);
}

// 执行 SQL 查询，返回单个结果
object result = sqlHelper.ExecuteScalar("SELECT COUNT(*) FROM MyTable");