SQL Server 作业同步 (结合备份作业)


  本文标签:SQL,Server,作业,同步

核心导出作业的 代码 和 作业备份是相似的
复制代码 代码如下:

alter PROC DumpJob (@job VARCHAR(100))
AS
DECLARE @retrun NVARCHAR(max)
DECLARE @jobname VARCHAR(30),@category_calss_i INT ,@category_calss VARCHAR(50),@category_name VARCHAR(50)
,@category_type VARCHAR(30),@category_id int
,@category_type_i int
SELECT @jobname = powershell,@category_calss = ,@category_name=,@category_type =
SELECT @jobname = @job
SELECT @category_calss = CASE WHEN tshc.category_class = 1 THEN JOB
WHEN tshc.category_class = 2 THEN ALERT
else OPERATOR
END
, @category_type = CASE WHEN tshc.category_type = 1 THEN LOCAL
WHEN tshc.category_type = 2 THEN MULTI-SERVER
else NONE
END
,@category_name = tshc.name
,@category_type_i = category_type
,@category_calss_i = tshc.category_class
,@category_id = tshc.category_id
FROM
msdb.dbo.sysjobs_view AS sv
INNER JOIN msdb.dbo.syscategories AS tshc ON sv.category_id = tshc.category_id
WHERE
(sv.name=@jobname AND tshc.category_class = 1)

SET @retrun = BEGIN TRANSACTION
SET @retrun = @retrun+CHAR(13)+CHAR(10) + DECLARE @ReturnCode INT
SET @retrun = @retrun+CHAR(13)+CHAR(10) + IF NOT EXISTS (SELECT name FROM msdb.dbo.syscategories WHERE name=N + @category_name +AND category_class= +rtrim(@category_calss_i)+)
SET @retrun = @retrun+CHAR(13)+CHAR(10) + BEGIN
SET @retrun = @retrun+CHAR(13)+CHAR(10) + EXEC @ReturnCode = msdb.dbo.sp_add_category @class=N+ @category_calss+, @type=N+@category_type+, @name=N+@category_name+
SET @retrun = @retrun+CHAR(13)+CHAR(10) + IF (@@ERROR <> 0 OR @ReturnCode <> 0) GOTO QuitWithRollback
SET @retrun = @retrun+CHAR(13)+CHAR(10) + end

DECLARE @EventLogLevel INT,@EmailLevel INT,@NetSendLevel INT,@PageLevel INT
DECLARE @EmailLeveloprid NVARCHAR(256),@NetSendLeveloprid NVARCHAR(256),@PageLeveloprid NVARCHAR(256)
DECLARE @isenable INT , @description NVARCHAR(1024),@owner_log_name Nvarchar(512),@delete_level INT
DECLARE @jobId UNIQUEIDENTIFIER,@start_step_id INT,@server NVARCHAR(512)
SELECT
@EventLogLevel=sv.notify_level_eventlog
,@EmailLevel=sv.notify_level_email
,@NetSendLevel=sv.notify_level_netsend
,@PageLevel=sv.notify_level_page
,@EmailLeveloprid = ISNULL((SELECT TOP 1 name FROM msdb..sysoperators WHERE id = sv.notify_email_operator_id),)
,@NetSendLeveloprid = ISNULL((SELECT TOP 1 name FROM msdb..sysoperators WHERE id = sv.notify_netsend_operator_id),)
,@PageLeveloprid = ISNULL((SELECT TOP 1 name FROM msdb..sysoperators WHERE id = sv.notify_page_operator_id),)
,@isenable = sv.enabled
,@description = sv.description
,@owner_log_name = ISNULL(suser_sname(sv.owner_sid), N)
,@delete_level = sv.delete_level
,@jobId = sv.job_id
,@start_step_id = start_step_id
,@server = originating_server
FROM msdb.dbo.sysjobs_view AS sv
WHERE (sv.name=@jobname and sv.category_id=0)


SET @retrun = @retrun+CHAR(13)+CHAR(10) + DECLARE @jobId BINARY(16)
SET @retrun = @retrun+CHAR(13)+CHAR(10) + EXEC @ReturnCode = msdb.dbo.sp_add_job @job_name=N+@jobname+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @enabled=+RTRIM(@isenable)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @notify_level_eventlog=+RTRIM(@EventLogLevel)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @notify_level_email=+RTRIM(@EmailLevel)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @notify_level_netsend=+RTRIM(@NetSendLevel)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @notify_level_page=+RTRIM(@PageLevel)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @notify_email_operator_name =+RTRIM(@EmailLeveloprid)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @notify_netsend_operator_name=+RTRIM(@NetSendLeveloprid)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @notify_page_operator_name=+RTRIM(@PageLeveloprid)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @delete_level=+RTRIM(@delete_level)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @description=N+@description+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @category_name=N+@category_name+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @owner_login_name=N+@owner_log_name+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @job_id = @jobId OUTPUT
SET @retrun = @retrun+CHAR(13)+CHAR(10) + IF (@@ERROR <> 0 OR @ReturnCode <> 0) GOTO QuitWithRollback
--SELECT * FROM msdb.dbo.syscategories

DECLARE @step_id INT
declare @step_name nvarchar(512) ,@cmdexec_success_code INT,@on_success_action INT,@on_success_step_id INT
,@on_fail_action INT,@on_fail_step_id INT,@retry_attempts INT,@retry_interval INT,@os_run_priority INT
,@subsystem NVARCHAR(512),@database_name NVARCHAR(512),@flags INT,@command NVARCHAR(max)

DECLARE jbcur CURSOR FOR SELECT step_id FROM msdb..sysjobsteps WHERE job_id = @jobid ORDER BY step_id ;
OPEN jbcur;
FETCH NEXT FROM jbcur INTO @step_id
WHILE @@FETCH_STATUS = 0
BEGIN

SELECT @step_name = step_name
,@cmdexec_success_code= cmdexec_success_code
,@on_success_action = on_success_action
,@on_success_step_id = on_success_step_id
,@on_fail_action = on_fail_action
,@on_fail_step_id = on_fail_step_id
,@retry_attempts = retry_attempts
,@retry_interval = retry_interval
,@os_run_priority = os_run_priority
,@subsystem = subsystem
,@database_name = database_name
,@command = command
,@flags = flags
FROM msdb..sysjobsteps a WHERE job_id = @jobid and step_id = @step_id

SET @retrun = @retrun+CHAR(13)+CHAR(10) + EXEC @ReturnCode = msdb.dbo.sp_add_jobstep @job_id=@jobId,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @step_name=N+@step_name+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @step_id=+RTRIM(@step_id)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @cmdexec_success_code=+RTRIM(@cmdexec_success_code)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @on_success_action=+RTRIM(@on_success_action)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @on_success_step_id=+RTRIM(@on_success_step_id)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @on_fail_action=+RTRIM(@on_fail_action)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @on_fail_step_id=+RTRIM(@on_fail_step_id)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @retry_attempts=+RTRIM(@retry_attempts)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @retry_interval=+RTRIM(@retry_interval)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @os_run_priority=+RTRIM(@os_run_priority)+, @subsystem=N+@subsystem+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @database_name=N+@database_name+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @flags=+RTRIM(@flags)+ ,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @command=N+REPLACE(@command,,)+
SET @retrun = @retrun+CHAR(13)+CHAR(10) + IF (@@ERROR <> 0 OR @ReturnCode <> 0) GOTO QuitWithRollback

FETCH NEXT FROM jbcur INTO @step_id

END

CLOSE jbcur
DEALLOCATE jbcur

SET @retrun = @retrun+CHAR(13)+CHAR(10) + EXEC @ReturnCode = msdb.dbo.sp_update_job @job_id = @jobId, @start_step_id = +rtrim(@start_step_id)
SET @retrun = @retrun+CHAR(13)+CHAR(10) + IF (@@ERROR <> 0 OR @ReturnCode <> 0) GOTO QuitWithRollback

DECLARE @enabled INT,@freq_type INT,@freq_interval INT,@freq_subday_type INT,@freq_subday_interval INT
,@freq_relative_interval INT,@freq_recurrence_factor INT,@active_start_date INT,@active_end_date INT
,@active_start_time INT,@active_end_time INT,@name VARCHAR(512)

SELECT
@name = a.name
,@enabled = enabled
,@freq_interval = freq_interval
,@freq_type = freq_type
,@freq_subday_type=freq_subday_type
,@freq_subday_interval=freq_subday_interval
,@freq_relative_interval=freq_relative_interval
,@freq_recurrence_factor=freq_recurrence_factor
,@active_start_date=active_start_date
,@active_end_date=active_end_date
,@active_start_time=active_start_time
,@active_end_time=active_end_time
FROM msdb..sysschedules a
INNER JOIN msdb.dbo.sysjobschedules b ON a.schedule_id = b.schedule_id
WHERE job_id = @jobId

IF(@name IS not null)
begin
SET @retrun = @retrun+CHAR(13)+CHAR(10) + EXEC @ReturnCode = msdb.dbo.sp_add_jobschedule @job_id=@jobId, @name=N+@name+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @enabled=+RTRIM(@enabled)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @freq_type=+RTRIM(@freq_type)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @freq_interval=+RTRIM(@freq_interval)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @freq_subday_type=+RTRIM(@freq_subday_type)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @freq_subday_interval=+RTRIM(@freq_subday_interval)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @freq_relative_interval=+RTRIM(@freq_relative_interval)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @freq_recurrence_factor=+RTRIM(@freq_recurrence_factor)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @active_start_date=+RTRIM(@active_start_date)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @active_end_date=+RTRIM(@active_end_date)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @active_start_time=+RTRIM(@active_start_time)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @active_end_time=+RTRIM(@active_end_time)+,
SET @retrun = @retrun+CHAR(13)+CHAR(10) + @schedule_uid=N+RTRIM(NEWID())+
SET @retrun = @retrun+CHAR(13)+CHAR(10) + IF (@@ERROR <> 0 OR @ReturnCode <> 0) GOTO QuitWithRollback
END


SET @retrun = @retrun+CHAR(13)+CHAR(10) + EXEC @ReturnCode = msdb.dbo.sp_add_jobserver @job_id = @jobId, @server_name = N(local)
SET @retrun = @retrun+CHAR(13)+CHAR(10) + IF (@@ERROR <> 0 OR @ReturnCode <> 0) GOTO QuitWithRollback
SET @retrun = @retrun+CHAR(13)+CHAR(10) + COMMIT TRANSACTION
SET @retrun = @retrun+CHAR(13)+CHAR(10) + GOTO EndSave
SET @retrun = @retrun+CHAR(13)+CHAR(10) + QuitWithRollback:
SET @retrun = @retrun+CHAR(13)+CHAR(10) + IF(@@TRANCOUNT>0)ROLLBACK TRANSACTION
SET @retrun = @retrun+CHAR(13)+CHAR(10) + EndSave:
SET @retrun = @retrun+CHAR(13)+CHAR(10) +

select @retrun

我创建了一个存储过程,用来导出 作业,只有用powershell 脚本来实现同步,你可以powershell 脚本放入 sqlagent 中 定时运行起到同步的效果

一下是powershell 代码:
复制代码 代码如下:

$server = "(local)"
$uid = "sa"
$db="master"
$pwd="fanzhouqi"
$mailprfname = "sina"
$recipients = "32116057@qq.com"
$subject = System Log
function execproc($message)
{
$SqlConnection = New-Object System.Data.SqlClient.SqlConnection
$CnnString ="Server = $server; Database = $db;User Id = $uid; Password = $pwd"
$SqlConnection.ConnectionString = $CnnString
$CC = $SqlConnection.CreateCommand();

$CC.CommandText=$message
$adapter = New-Object System.Data.SqlClient.SqlDataAdapter $CC
$dataset = New-Object System.Data.DataSet
#$SqlConnection.SelectCommand = $CC
if (-not ($SqlConnection.State -like "Open")) { $SqlConnection.Open() }

$adapter.Fill($dataset) |out-null
$dataset.Tables[0].Rows[0][0]
$SqlConnection.Close();
}
function execsql($message)
{
$SqlConnection = New-Object System.Data.SqlClient.SqlConnection
$CnnString ="Server = fanr-pc\sql2012; Database = $db;User Id = $uid; Password = $pwd"
$SqlConnection.ConnectionString = $CnnString
$CC = $SqlConnection.CreateCommand();
if (-not ($SqlConnection.State -like "Open")) { $SqlConnection.Open() }

$cc.CommandText=$message
$cc.ExecuteNonQuery()|out-null
$SqlConnection.Close();
}
$jobscript = execproc " EXEC master..DumpJob @job = backup"
#$jobscript
execsql $jobscript

有什么问题可以联系我:如果blog 的代码没办法使用也可以 加我qq 联系我,问我要 。qq:32116057 fanr