运行 Sql 来自 C# 的服务器代理作业
Running Sql Server Agent Jobs from C#
在网上搜索上述主题时,我发现了两种方法,两种方法都可以正常工作,但我需要知道两者之间的区别,哪种适合什么场合等...我们的工作需要一些时间时间,我需要一种方法来等待作业完成,然后再执行下一个 C# 行。
方法一
var dbConn = new SqlConnection(myConString);
var execJob = new SqlCommand
{
CommandType = CommandType.StoredProcedure,
CommandText = "msdb.dbo.sp_start_job"
};
execJob.Parameters.AddWithValue("@job_name", p0);
execJob.Connection = dbConn;
using (dbConn)
{
dbConn.Open();
using (execJob)
{
execJob.ExecuteNonQuery();
Thread.Sleep(5000);
}
}
方法二
using System.Threading;
using Microsoft.SqlServer.Management.Smo;
using Microsoft.SqlServer.Management.Smo.Agent;
var server = new Server(@"localhost\myinstance");
var isStopped = false;
try
{
server.ConnectionContext.LoginSecure = true;
server.ConnectionContext.Connect();
var job = server.JobServer.Jobs[jobName];
job.Start();
Thread.Sleep(1000);
job.Refresh();
while (job.CurrentRunStatus == JobExecutionStatus.Executing)
{
Thread.Sleep(1000);
job.Refresh();
}
isStopped = true;
}
finally
{
if (server.ConnectionContext.IsOpen)
{
server.ConnectionContext.Disconnect();
}
}
sp_start_job - 示例 1
您的第一个示例通过 sp_start_job 系统存储过程调用您的作业。
请注意,它以异步方式启动作业,无论作业成功或失败,线程都会在继续之前休眠一段任意时间(5 秒)。
SQL 服务器管理对象 (SMO) - 示例 2
您的第二个示例使用(因此依赖于)SQL Server Management Objects 来实现相同的目标。
在第二种情况下,作业也开始 运行 异步,但后续循环会监视作业状态,直到它不再处于正在执行状态。请注意,"isStopped" 标志似乎没有任何作用,循环可以重构为:
job.Start();
do
{
Thread.Sleep(1000);
job.Refresh();
} while (job.CurrentRunStatus == JobExecutionStatus.Executing);
您可能希望在特定时间段后添加该循环的中断。
其他注意事项
您的每个示例似乎都需要相同的权限;本质上,使用 SMO 的解决方案是 sp_start_job 的包装器,但为您提供了(可以说)更强大的代码,其目的更明确。
使用最适合你的那个,或者做一些分析,如果性能是一个问题,选择最有效的。
在网上搜索上述主题时,我发现了两种方法,两种方法都可以正常工作,但我需要知道两者之间的区别,哪种适合什么场合等...我们的工作需要一些时间时间,我需要一种方法来等待作业完成,然后再执行下一个 C# 行。
方法一
var dbConn = new SqlConnection(myConString);
var execJob = new SqlCommand
{
CommandType = CommandType.StoredProcedure,
CommandText = "msdb.dbo.sp_start_job"
};
execJob.Parameters.AddWithValue("@job_name", p0);
execJob.Connection = dbConn;
using (dbConn)
{
dbConn.Open();
using (execJob)
{
execJob.ExecuteNonQuery();
Thread.Sleep(5000);
}
}
方法二
using System.Threading;
using Microsoft.SqlServer.Management.Smo;
using Microsoft.SqlServer.Management.Smo.Agent;
var server = new Server(@"localhost\myinstance");
var isStopped = false;
try
{
server.ConnectionContext.LoginSecure = true;
server.ConnectionContext.Connect();
var job = server.JobServer.Jobs[jobName];
job.Start();
Thread.Sleep(1000);
job.Refresh();
while (job.CurrentRunStatus == JobExecutionStatus.Executing)
{
Thread.Sleep(1000);
job.Refresh();
}
isStopped = true;
}
finally
{
if (server.ConnectionContext.IsOpen)
{
server.ConnectionContext.Disconnect();
}
}
sp_start_job - 示例 1
您的第一个示例通过 sp_start_job 系统存储过程调用您的作业。 请注意,它以异步方式启动作业,无论作业成功或失败,线程都会在继续之前休眠一段任意时间(5 秒)。
SQL 服务器管理对象 (SMO) - 示例 2
您的第二个示例使用(因此依赖于)SQL Server Management Objects 来实现相同的目标。
在第二种情况下,作业也开始 运行 异步,但后续循环会监视作业状态,直到它不再处于正在执行状态。请注意,"isStopped" 标志似乎没有任何作用,循环可以重构为:
job.Start();
do
{
Thread.Sleep(1000);
job.Refresh();
} while (job.CurrentRunStatus == JobExecutionStatus.Executing);
您可能希望在特定时间段后添加该循环的中断。
其他注意事项
您的每个示例似乎都需要相同的权限;本质上,使用 SMO 的解决方案是 sp_start_job 的包装器,但为您提供了(可以说)更强大的代码,其目的更明确。
使用最适合你的那个,或者做一些分析,如果性能是一个问题,选择最有效的。