c#实现用SQL池,多线程定时批量执行SQL语句的方法

实现用SQL池、多线程定时批量执行SQL语句的方法，可以避免单线程执行SQL语句时的性能瓶颈。以下是具体的实现步骤：

步骤一：创建连接池

1. 安装 System.Data.SqlClient NuGet 包，用于创建 SQL Server 数据库连接 。
2. 使用 SqlConnection 类创建一个数据库连接对象，并使用 SqlConnectionStringBuilder 类组装连接字符串。
3. 使用 SqlConnection.Open() 方法打开数据库连接，然后将连接对象添加到连接池中。
4. 声明一个静态（或单例）列表，用于保存连接池中的连接对象。

步骤二：编写批量执行 SQL 语句的方法

1. 定义一个方法，该方法接受一个参数类型为 List<string> 的 SQL 语句列表，同时使用连接池中的某个连接对象，批量执行 SQL 语句。
2. 使用 SqlCommand 类创建一个 SQL 命令对象，然后循环遍历传入的 SQL 语句列表，为每个 SQL 语句创建一个命令参数，并将其添加到 SQL 命令对象中。
3. 使用 SqlCommand.ExecuteNonQuery() 方法执行 SQL 命令，该方法将返回受影响的行数。
4. 在执行完所有 SQL 语句后，关闭数据库连接。

步骤三：使用多线程执行 SQL 语句

1. 定义一个方法，该方法接受两个参数：一个是 SQL 语句列表，一个是整数类型的线程数（即要开启的线程数量）。
2. 在该方法中，按照指定的线程数，将 SQL 语句列表拆分成若干个分组，并为每个分组启动一个新的线程执行 SQL 语句。
3. 每个线程执行步骤二中编写的批量执行 SQL 语句的方法。
4. 在所有线程执行完毕后，整合各个线程的执行结果。

步骤四：定时执行 SQL 语句

1. 使用 System.Threading.Timer 类或 System.Timers.Timer 类，设置定时器的触发时间间隔和执行计时器任务的方法。
2. 在计时器任务中，调用步骤三中编写的使用多线程执行 SQL 语句的方法。

下面是两个示例，演示如何使用以上步骤来实现用 SQL 池、多线程定时批量执行 SQL 语句的功能。

示例一：使用 Timer 定时执行 SQL 语句

static void Main(string[] args)
{
    // 创建连接池，初始化可用连接
    SqlConnectionStringBuilder builder = new SqlConnectionStringBuilder();
    builder.DataSource = "localhost";
    builder.InitialCatalog = "TestDB";
    builder.IntegratedSecurity = true; // 使用 Windows 身份验证

    for (int i = 0; i < 10; i++)
    {
        SqlConnection sqlConn = new SqlConnection(builder.ConnectionString);
        sqlConn.Open();
        connectionPool.Add(sqlConn);
    }

    // 定时执行 SQL 语句
    Timer timer = new Timer(1000 * 60); // 每隔一分钟执行一次
    timer.Elapsed += new ElapsedEventHandler(OnTimerElapsed);
    timer.Enabled = true;

    // 阻止控制台应用程序退出
    Console.ReadKey();
}

static void OnTimerElapsed(object sender, ElapsedEventArgs e)
{
    List<string> sqlList = new List<string>();
    sqlList.Add("INSERT INTO Person (Name, Sex) VALUES ('张三', '男')");
    sqlList.Add("INSERT INTO Person (Name, Sex) VALUES ('李四', '女')");
    sqlList.Add("INSERT INTO Person (Name, Sex) VALUES ('王五', '男')");

    ExecuteSqlWithMultithreading(sqlList, 3);
}

示例二：使用 Quartz 定时执行 SQL 语句

static void Main(string[] args)
{
    // 创建连接池，初始化可用连接
    SqlConnectionStringBuilder builder = new SqlConnectionStringBuilder();
    builder.DataSource = "localhost";
    builder.InitialCatalog = "TestDB";
    builder.IntegratedSecurity = true; // 使用 Windows 身份验证

    for (int i = 0; i < 10; i++)
    {
        SqlConnection sqlConn = new SqlConnection(builder.ConnectionString);
        sqlConn.Open();
        connectionPool.Add(sqlConn);
    }

    // 定时执行 SQL 语句
    ISchedulerFactory schedulerFactory = new StdSchedulerFactory();
    IScheduler scheduler = schedulerFactory.GetScheduler().Result;
    scheduler.Start().Wait();

    IJobDetail job = JobBuilder.Create<SqlJob>()
        .WithIdentity("sqlJob", "group1")
        .Build();

    ITrigger trigger = TriggerBuilder.Create()
        .WithIdentity("sqlTrigger", "group1")
        .StartNow()
        .WithSimpleSchedule(x => x
            .WithIntervalInMinutes(1)
            .RepeatForever())
        .Build();

    scheduler.ScheduleJob(job, trigger).Wait(); // 将任务和触发器关联起来

    // 阻止控制台应用程序退出
    Console.ReadKey();
}

public class SqlJob : IJob
{
    public void Execute(IJobExecutionContext context)
    {
        List<string> sqlList = new List<string>();
        sqlList.Add("INSERT INTO Person (Name, Sex) VALUES ('张三', '男')");
        sqlList.Add("INSERT INTO Person (Name, Sex) VALUES ('李四', '女')");
        sqlList.Add("INSERT INTO Person (Name, Sex) VALUES ('王五', '男')");

        ExecuteSqlWithMultithreading(sqlList, 3);
    }
}