【Sql Server】存储过程通过定时执行添加记录作业

简介: 通过上篇了解了什么是存储过程,创建存储过程的方法,以及调用存储过程的方法 本次将通过数据库中的作业功能,进行定时执行存储过程,这样就可以完成我们刚开始假设的场景
作者:小5聊基础
简介:一只喜欢全栈方向的程序员,欢迎咨询,尽绵薄之力答疑解惑
编程原则:Write Less Do More
  • 定时任务效果

image.png

主要知识点列表

编号 语言或插件 知识点 说明
1 sql 作业 包含步骤、计划、警告等
2 sql 步骤 执行sql语句或存储过程的主要命令操作
3 sql 计划 定时任务的主要设置,可灵活设置按日、周、月等执行
4 sql 间隔10秒 这里的定时最低间隔10秒执行一次,这里涉及到数据库执行成本问题,如果发布订阅是实时的,会非常耗资源,所以会有一定的最小间隔时间

【什么是数据库中的作业功能】

1)定时或者每隔一段时间执行某个存储过程<br/>
2)执行的sql语句在3200字符以内<br/>

【作业类别】

编号 类别 备注
1 未分类(本地)
2 数据收集器
3 数据库引擎优化顾问
4 数据库维护
5 日志传送

...

【新建作业步骤】

1)打开Sql server可视化工具,Management Studio<br/>
2)选择管理>SQL Server代理<br/>
image.png

3)从上图可知,被禁用了<br/>
4)打开配置管理器<br/>
找不到配置管理器解决方法
2008:SQLServerManager10.msc<br/>
2012:SQLServerManager11.msc<br/>
2014:SQLServerManager12.msc<br/>
5)启动代理<br/>
image.png
6)再打开查看
image.png
7)鼠标右键SQL Server代理<br/>
新建 > 作业<br/>
8)填写基本信息<br/>

  • 常规

名称:auto_add_domain_record<br/>
勾选启用<br/>
9)新建步骤<br/>
填写步骤名称,关键是命令区域的命令语句,填写如下执行存储过程代码,增加两个输入参数,起始值和结束值

exec createDomainValue 1,100

1654488633672.png
10)选择计划选项,设置定时执行时间<br/>
最低只能每隔10秒执行一次,没法假设100毫秒执行一次
image.png
从10的整数倍开始执行
image.png

【提高添加记录】

通过上面的操作和分析,我们可以知道,最低间隔10秒执行一次添加,这个和我们假设的场景有点差距。<br/>
10秒添加一条记录,1分钟60秒,只会生成6条记录,1小时=60分钟=60 6=360条,1=24小时=24 60 * 6=8640,一天才8千多条记录<br/>

  • 解决方案<br/>

1)创建多个作业(不可行)<br/>
2)在一个作业和一个计划的基础上,创建多个步骤来实现10秒内添加多条记录(不可行)
3)在存储过程里,每次快速循环生成1000条记录
一天86400秒,乘以100倍,就是860万条记录一天

USE [test]
GO
/****** Object:  StoredProcedure [dbo].[createDomainValue]    Script Date: 06/06/2022 13:05:35 ******/
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFIER ON
GO

ALTER procedure [dbo].[createDomainValue]
@count int,
@count_max int
as
begin 
    
    while @count<=@count_max
    begin
        set @count+=1
        declare @rows int
        declare @index int
        declare @length int
        declare @str varchar(50)
        declare @domain_value varchar(50)
        declare @random int
        declare @temp varchar(50)

        set @domain_value=N'' --拼接字符串,必须先初始化
        set @index=1
        set @str='abcdefghijklmnopqrstuvwxyz0123456789'
        set @length=3+round(rand()*5,0)

        while @index<=@length
        begin
            set @random=round(rand()*34,0) --0~35随机下标
            set @temp=substring(@str,@random,1) --截取1位长度值\
            set @domain_value+=@temp 
            set @index+=1
        end

        --随机产生域名,此处域名组合使用顶级的国际域名
        declare @full_domain varchar(50)
        set @full_domain='www.'+@domain_value+'.com'

        --查询记录是否存在,不存在则添加,存在则不做任何操作
        select @rows=count(1) from domain_table where domain_value=@full_domain
        if @rows<=0
        begin
            insert into domain_table(domain_value,domain_length,create_time)
            values(@full_domain,@length,getdate())
        end
    end
end
相关文章
|
存储 SQL 缓存
4.2.1 SQL语句、索引、视图、存储过程
4.2.1 SQL语句、索引、视图、存储过程
183 0
|
存储 SQL 数据库
sql serve存储过程
sql serve存储过程
|
存储 SQL 数据库
数据库sql语句-----游标和存储过程
数据库sql语句-----游标和存储过程
298 1
|
SQL 存储 运维
Flink⼤状态作业调优实践指南:Flink SQL 作业篇
本文整理自俞航翔、陈婧敏、黄鹏程老师所撰写的大状态作业调优实践指南。由于内容丰富,本文中篇内容分享 Flink SQL 作业大状态导致反压的调优原理与方法。
70968 8
Flink⼤状态作业调优实践指南:Flink SQL 作业篇
|
存储 SQL 数据库
SQL 语言:存储过程和触发器
SQL 语言:存储过程和触发器
568 6
|
SQL 数据库连接 网络安全
SQLServer非默认端口下事务复制代理作业服务无法启动的处理
【8月更文挑战第14天】若SQL Server非默认端口下的事务复制代理作业无法启动,可按以下步骤解决:1) 确认服务器连接字符串正确无误,包括非默认端口号;2) 检查防火墙设置,确保允许非默认端口的连接;3) 核实SQL Server配置已启用非默认端口;4) 查阅代理作业日志寻找错误详情;5) 重启SQL Server与Agent服务;6) 使用工具测试非默认端口的连接性。如问题持续,请寻求专业支持。
442 0
|
SQL 消息中间件 资源调度
Flink报错问题之flink 1.11 sql作业提交JM报错如何解决
Apache Flink是由Apache软件基金会开发的开源流处理框架,其核心是用Java和Scala编写的分布式流数据流引擎。本合集提供有关Apache Flink相关技术、使用技巧和最佳实践的资源。
|
存储 SQL Oracle
oracle 存储过程导出sql语句 导出为文件
oracle 存储过程导出sql语句 导出为文件
526 0
|
存储 SQL Oracle
PL/SQL存储过程的使用
PL/SQL存储过程的使用
487 1
|
存储 SQL
SQL Server 存储过程 触发器 事务处理
SQL Server 存储过程 触发器 事务处理
426 0