黄龙300视频触发器
点击联系发帖人
时间：2016-07-04 16:23
1701人阅读
sql server（22）
定义：何为触发器？在SQL Server里面也就是对某一个表的一定的操作，触发某种条件，从而执行的一段程序。触发器是一个特殊的存储过程。
&&&&& 常见的触发器有三种：分别应用于Insert , Update , Delete
&&&&& 我为什么要使用触发器？比如，这么两个表：
&&&&& Create Table Student(&&&&&&&&&&&&& --学生表
&&&&&&& StudentID int primary key,&&&&&& --学号
&&&&&&& ....
&&&&& Create Table BorrowRecord(&&&&&&&&&&&&&& --学生借书记录表
&&&&&&& BorrowRecord&& int identity(1,1),&&&&&& --流水号&&
&&&&&&& StudentID&&&&& int ,&&&&&&&&&&&&&&&&&&& --学号
&&&&&&& BorrowDate&&&& datetime,&&&&&&&&&&&&&&& --借出时间
&&&&&&& ReturnDAte&&&& Datetime,&&&&&&&&&&&&&&& --归还时间
&&&&&&& ...
&&&& 用到的功能有:
&&&&&&& 1.如果我更改了学生的学号,我希望他的借书记录仍然与这个学生相关(也就是同时更改借书记录表的学号);
&&&&&&& 2.如果该学生已经毕业，我希望删除他的学号的同时，也删除它的借书记录。
&&&& 等等。
&&&& 这时候可以用到触发器。对于<span style="color:#，创建一个Update触发器：
&&&& Create Trigger truStudent
&&&&&& On Student&&&&&&&&&&&&&&&&&&&&&&&& --在Student表中创建触发器
&&&&&& for Update&&&&&&&&&&&&&&&&&&&&&&&&& --为什么事件触发
&&&& As&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&& --事件触发后所要做的事情
&&&&&& if Update(StudentID)&&&&&&&&&&&
&&&&&& begin
&&&&&&&& Update BorrowRecord
&&&&&&&&&& Set StudentID=i.StudentID
&&&&&&&&&& From BorrowRecord br , Deleted&& d ,Inserted i&&&&& --Deleted和Inserted临时表
&&&&&&&&&& Where br.StudentID=d.StudentID
&&&&&& end&&&&&&&
&&&&&&&&&&&&&&&&
&&&& 理解触发器里面的两个临时的表：Deleted , Inserted
。注意Deleted
与Inserted分别表示触发事件的表“旧的一条记录”和“新的一条记录”。
&&&& 一个数据库系统中有两个虚拟表用于存储在表中记录改动的信息，分别是：
&&&&&&&&&&&&&&&&&&&&&&&&&&&& 虚拟表Inserted&&&&&&&&&&&&&&&&&&&&
虚拟表Deleted
在表记录新增时&&&&
存放新增的记录&&&&&&&&&&&&&&&&&&&&&&&&
不存储记录
&&&&&&&& 修改时&&&&&&&&&&
存放用来更新的新记录&&&&&&&&&&&&&&&&&&
存放更新前的记录
&&&&&&&& 删除时&&&&&&&&&&
不存储记录&&&&&&&&&&&&&&&&&&&&&&&&&&&&
存放被删除的记录
&&&& 一个Update
的过程可以看作为：生成新的记录到Inserted表，复制旧的记录到Deleted表，然后删除Student记录并写入新纪录。
&&&& 对于<span style="color:#，创建一个Delete触发器
&&&& Create trigger trdStudent
&&&&&& On Student
&&&&&& for Delete
&&&&&& Delete BorrowRecord
&&&&&&&& From BorrowRecord br , Delted d
&&&&&&&& Where br.StudentID=d.StudentID
&&&& 从这两个例子我们可以看到了触发器的关键：A.2个临时的表；B.触发机制。
SQL触发器实例<span style="color:#
建立虚拟测试环境，包含：表[卷烟库存表]，表[卷烟销售表]。
请大家注意跟踪这两个表的数据，体会触发器到底执行了什么业务逻辑，对数据有什么影响。
为了能更清晰的表述触发器的作用，表结构存在数据冗余，且不符合第三范式，这里特此说明。
USE Master
IF EXISTS (SELECT NAME FROM SYSOBJECTS WHERE XTYPE = ’U’ AND NAME = ’卷烟库存表’)
DROP TABLE 卷烟库存表
IF EXISTS (SELECT NAME FROM SYSOBJECTS WHERE XTYPE = ’U’ AND NAME = ’卷烟销售表’)
DROP TABLE 卷烟销售表
--业务规则：销售金额 =
销售数量 *
销售单价业务规则。
CREATE TABLE 卷烟销售表
卷烟品牌 VARCHAR(40) PRIMARY KEY NOT NULL,
购货商 VARCHAR(40) NULL,
销售数量 INT NULL,
销售单价 MONEY NULL,
销售金额 MONEY NULL
--业务规则：库存金额 =
库存数量 *
库存单价业务规则。
CREATE TABLE 卷烟库存表
卷烟品牌 VARCHAR(40) PRIMARY KEY NOT NULL,
库存数量 INT NULL,
库存单价 MONEY NULL,
库存金额 MONEY NULL
--创建触发器，示例<span style="color:#
创建触发器[T_INSERT_卷烟库存表]，这个触发器较简单。
说明：每当[卷烟库存表]发生
INSERT 动作，则引发该触发器。
触发器功能：强制执行业务规则，保证插入的数据中，库存金额 =
库存数量 *
库存单价。
注意： [INSERTED]、[DELETED]为系统表，不可创建、修改、删除，但可以调用。
重要：这两个系统表的结构同插入数据的表的结构。
IF EXISTS (SELECT NAME FROM SYSOBJECTS WHERE XTYPE = ’TR’ AND NAME = ’T_INSERT_卷烟库存表’)
DROP TRIGGER T_INSERT_卷烟库存表
CREATE TRIGGER T_INSERT_卷烟库存表
ON 卷烟库存表
FOR INSERT
--提交事务处理
BEGIN TRANSACTION
--强制执行下列语句，保证业务规则
UPDATE 卷烟库存表
SET 库存金额 =
库存数量 * 库存单价
WHERE 卷烟品牌 IN (SELECT
卷烟品牌 from INSERTED)
COMMIT TRANSACTION
针对[卷烟库存表]，插入测试数据：
注意，第一条数据（红塔山新势力）中的数据符合业务规则，
第二条数据（红塔山人为峰）中，[库存金额]空，不符合业务规则，
第三条数据（云南映像）中，[库存金额]不等于[库存数量]乘以[库存单价]，不符合业务规则。
第四条数据库存数量为<span style="color:#。
请注意在插入数据后，检查[卷烟库存表]中的数据是否库存金额
= 库存数量 *
库存单价。
INSERT INTO 卷烟库存表(卷烟品牌,库存数量,库存单价,库存金额)
SELECT ’红塔山新势力’,100,12,1200 UNION ALL
SELECT ’红塔山人为峰’,100,22,NULL UNION ALL
SELECT ’云南映像’,100,60,500 UNION ALL
SELECT ’玉溪’,0,30,0
--查询数据
SELECT * FROM 卷烟库存表
RecordId 卷烟品牌库存数量库存单价库存金额
-------- ------------ -------- ------- ---------
1 红塔山新势力 100 12.00
2 红塔山人为峰 100 22.00
3 云南映像 100 60.00
4 玉溪 0 30.
（所影响的行数为 4
--触发器示例<span style="color:#
创建触发器[T_INSERT_卷烟销售表]，该触发器较复杂。
每当[卷烟库存表]发生 INSERT
动作，则引发该触发器。
触发器功能：实现业务规则。
如果销售的卷烟品牌不存在库存或者库存为零，则返回错误。
否则则自动减少[卷烟库存表]中对应品牌卷烟的库存数量和库存金额。
IF EXISTS (SELECT NAME FROM SYSOBJECTS WHERE XTYPE = ’TR’ AND NAME = ’T_INSERT_卷烟销售表’)
DROP TRIGGER T_INSERT_卷烟销售表
CREATE TRIGGER T_INSERT_卷烟销售表
ON 卷烟销售表
FOR INSERT
BEGIN TRANSACTION
--检查数据的合法性：销售的卷烟是否有库存，或者库存是否大于零
IF NOT EXISTS (
SELECT 库存数量
FROM 卷烟库存表
WHERE 卷烟品牌 IN (SELECT
卷烟品牌 FROM INSERTED)
--返回错误提示
RAISERROR(’错误！该卷烟不存在库存，不能销售。’,16,1)
--回滚事务
IF EXISTS (
SELECT 库存数量
FROM 卷烟库存表
WHERE 卷烟品牌 IN (SELECT
卷烟品牌 FROM INSERTED) AND
库存数量 &= 0
--返回错误提示
RAISERROR(’错误！该卷烟库存小于等于<span style="color:#，不能销售。’,16,1)
--回滚事务
--对合法的数据进行处理
--强制执行下列语句，保证业务规则
UPDATE 卷烟销售表
SET 销售金额 =
销售数量 * 销售单价
WHERE 卷烟品牌 IN (SELECT
卷烟品牌 FROM INSERTED)
DECLARE @卷烟品牌 VARCHAR(40)
SET @卷烟品牌 = (SELECT
卷烟品牌 FROM INSERTED)
DECLARE @销售数量 MONEY
SET @销售数量 = (SELECT
销售数量 FROM INSERTED)
UPDATE 卷烟库存表
SET 库存数量 =
库存数量 - @销售数量,
库存金额 = (库存数量 - @销售数量)*库存单价
WHERE 卷烟品牌 = @卷烟品牌
COMMIT TRANSACTION
--请大家自行跟踪[卷烟库存表]和[卷烟销售表]的数据变化。
--针对[卷烟销售表]，插入第一条测试数据，该数据是正常的。
INSERT INTO 卷烟销售表(卷烟品牌,购货商,销售数量,销售单价,销售金额)
SELECT ’红塔山新势力’,’某购货商’,10,12,1200
--针对[卷烟销售表]，插入第二条测试数据，该数据销售金额不等于销售单价
* 销售数量。
--触发器将自动更正数据，使销售金额等于销售单价 *
销售数量。
INSERT INTO 卷烟销售表(卷烟品牌,购货商,销售数量,销售单价,销售金额)
SELECT ’红塔山人为峰’,’某购货商’,10,22,2000
--针对[卷烟销售表]，插入第三条测试数据，该数据中的卷烟品牌在卷烟库存表中找不到对应。
--触发器将报错。
INSERT INTO 卷烟销售表(卷烟品牌,购货商,销售数量,销售单价,销售金额)
SELECT ’红河V8’,’某购货商’,10,60,600
消息 50000，级别 16，状态 1，过程
T_INSERT_卷烟销售表，行 15
错误！该卷烟不存在库存，不能销售。
--针对[卷烟销售表]，插入第三条测试数据，该数据中的卷烟品牌在卷烟库存表中库存为<span style="color:#。
--触发器将报错。
INSERT INTO 卷烟销售表(卷烟品牌,购货商,销售数量,销售单价,销售金额)
SELECT ’玉溪’,’某购货商’,10,30,300
消息 50000，级别 16，状态 1，过程
T_INSERT_卷烟销售表，行 29
错误！该卷烟库存小于等于<span style="color:#，不能销售。
--查询数据
SELECT * FROM 卷烟库存表
SELECT * FROM 卷烟销售表
1、本示例主要通过一个简单的业务规则实现来进行触发器使用的说明，具体的要根据需要灵活处理；
2、关于触发器要理解并运用好 INSERTED
两个系统表；
3、本示例创建的触发器都是 FOR INSERT ,具体的语法可参考：
/////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&& Trigger语法
//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
CREATE TRIGGER trigger_name
ON { table | view }
[ WITH ENCRYPTION ] --用于加密触发器
{ { FOR | AFTER | INSTEAD OF } { [ INSERT ] [ , ] [ UPDATE ] }
[ WITH APPEND ]
[ NOT FOR REPLICATION ]
[ { IF UPDATE ( column )
[ { AND | OR } UPDATE ( column ) ]
| IF ( COLUMNS_UPDATED ( ) { bitwise_operator } updated_bitmask )
{ comparison_operator } column_bitmask [ ...n ]
sql_statement [ ...n ]
4、关于触发器，还应该注意
(1)、DELETE
触发器不能捕获 TRUNCATE TABLE
(2)、触发器中不允许以下 Transact-SQL
ALTER DATABASE CREATE DATABASE DISK INIT
DISK RESIZE DROP DATABASE LOAD DATABASE
LOAD LOG RECONFIGURE RESTORE DATABASE
RESTORE LOG
(3)、触发器最多可以嵌套 32
--修改触发器
--实质上，是将 CREATE TRIGGER ...
修改为 ALTER TRIGGER ...即可。
--删除触发器
DROP TRIGGER xxx
--删除测试环境
DROP TABLE 卷烟库存表
DROP TABLE 卷烟销售表
DROP TRIGGER T_INSERT_卷烟库存表
DROP TRIGGER T_INSERT_卷烟销售表
##################################################################
触发器的基础知识和例子
：create trigger tr_name
on table/view
{for | after | instead of } [update][,][insert][,][delete]
[with encryption]
as {batch | if update (col_name) [{and|or} update (col_name)] }
1 tr_name ：触发器名称
2 on table/view ：触发器所作用的表。一个触发器只能作用于一个表
3 for 和after
4 after 与instead of :sql 2000新增项目afrer
与 instead of
在触发事件发生以后才被激活,只可以建立在表上
Instead of
代替了相应的触发事件而被执行,既可以建立在表上也可以建立在视图上
5 insert、update、delete：激活触发器的三种操作，可以同时执行，也可选其一
6 if update (col_name)：表明所作的操作对指定列是否有影响，有影响，则激活触发器。此外，因为delete
操作只对行有影响，
所以如果使用delete操作就不能用这条语句了(虽然使用也不出错，但是不能激活触发器，没意义)。
7 触发器执行时用到的两个特殊表：deleted ,inserted
deleted 和inserted
可以说是一种特殊的临时表，是在进行激活触发器时由系统自动生成的，其结构与触发器作用的表结构是一
样的，只是存放的数据有差异。
下面表格说明deleted
与inserted
数据的差异
deleted 与inserted
数据的差异
存放进行insert和update
操作后的数据
存放进行delete
和update操作前的数据
注意：update
操作相当于先进行delete
再进行insert ,所以在进行update操作时，修改前的数据拷贝一条到deleted
表中，修改后
的数据在存到触发器作用的表的同时，也同时生成一条拷贝到insered表中
CREATE TRIGGER [TRIGGER admixture_receive_log] ON dbo.chl_lydj
FOR UPDATE
&&&&&&& declare @djsfxg char(10)&&&&& declare @wtbh char(20)
&&&&&&& select @wtbh=wtbh from inserted
&&&&&& update ly_tzk set djsfxg='已修改' where
if (select data_sfjl from t_logsetup)='是'
declare @oldcjmc char (100)&&&&&&&&& declare @oldlyrq datetime
declare @oldbzbh char (60)&&&&&&&&&&&& declare @oldzl char (20)
declare @olddj char (10)
declare @newcjmc char (100)&&&&&&&&& declare @newlyrq datetime
declare @newbzbh char (60)&&&&&&&&&&&& declare @newzl char (20)
declare @newdj char (10)
&&&&&&&&&&&& declare @xgr char (20)
&&&&&&&&&&&& select @oldcjmc=cjmc,@oldlyrq=lyrq,@oldbzbh=bzbh,@oldzl=zl,@olddj=dj from deleted
&&&&&&&&&&&& select @newcjmc=cjmc,@newlyrq=lyrq,@newbzbh=bzbh,@newzl=zl,@newdj=dj from inserted
&&&&&&&&&&&& select @xgr=xgr from t_modifyuser where @wtbh=wtbh
&&&&&&&&&&&&
&&&&&&&& if @oldcjmc&&@newcjmc
&&&&&&&&&&&& begin
&&&&&&&&&&&&&&&&&&&&& insert into t_modifylog (wtbh, mod_time, mod_table, mod_field, ori_value, now_value, mod_people) values
&&&&&&&&&&&&&&&&&&&&& (@wtbh,getdate(), 'chl_lydj','cjmc', @oldcjmc, @newcjmc, @xgr)
&&&&&&&&&&&& end
//////////修改时，直接把‘create’改为‘alter’即可
/////////////////////////
CREATE TRIGGER [TRIGGER ly_tzk_syf] ON dbo.ly_tzk
FOR insert
&&&&&&&& declare @clmc char(100)&&&& declare @dwbh char(100) declare @syf char(100)&& declare @dwgcbh char(100) declare @wtbh char(50)
&&&&&&&& declare @dj_1 money&&&& declare @feiyong_z money&& declare @feiyong_xf money&& declare @feiyong_sy money
&&&&&&&& declare @dj char(20)
&&&&&&& select @wtbh=wtbh , @clmc=clmc , @dwbh=dwbh ,@syf=syf from inserted
&&&&&&& select&& @dj=dj from feihao_bz where
&&&&&&& select @feiyong_z=feiyong_z, @feiyong_xf=feiyong_xf, @feiyong_sy=feiyong_sy from gongchengxinxi where
&&&&&&& set @dj_1=convert(money ,@dj)
&&&&&& if @dj_1 &&0
&&&&&& begin
&&&&&&&&&&&& set @feiyong_xf=@feiyong_xf+@dj_1
&&&&&&&&&&&& set @feiyong_sy=@feiyong_sy-@dj_1
&&&&&&&&&&& update ly_tzk set
&&&&&&&&&&& update gongchengxinxi set ,
&&&&&& end
&&&&&& else&&& update ly_tzk set syf=convert(char , 0.0) where
//////////////////////
CREATE TRIGGER [TRIGGER ly_tzk_syf_shanchu] ON dbo.ly_tzk
FOR delete
&&&&&&&& declare @clmc char(100)&&&& declare @dwbh char(100)&&& declare @dwgcbh char(100) declare @wtbh char(50)
&&&&&&&& declare @feiyong_z money&&& declare @feiyong_xf money&& declare @feiyong_sy money
&&&&&&&& declare @syf char(100)&&&&& declare @syf_1 money
&&&&&&&& --declare @dj char(20)&& declare @dj_1 money
&&&&&&& select @wtbh=wtbh , @clmc=clmc , @dwbh=dwbh ,@syf=syf from inserted
&&&&&&& --select&& @dj=dj from feihao_bz where
&&&&&&& select @feiyong_z=feiyong_z, @feiyong_xf=feiyong_xf, @feiyong_sy=feiyong_sy from gongchengxinxi where
&&&&&&& set @syf_1=convert(money ,@syf)
&&&&&& if @syf_1 &&0
&&&&&& begin
&&&&&&&&&&&& set @feiyong_xf=@feiyong_xf-@syf_1
&&&&&&&&&&&& set @feiyong_sy=@feiyong_sy+@syf_1
&&&&&&&&&&& update gongchengxinxi set ,
&&&&&& end
//////////////////////
参考知识库
* 以上用户言论只代表其个人观点，不代表CSDN网站的观点或立场
访问：514732次
积分：6346
积分：6346
排名：第2455名
原创：97篇
转载：171篇
评论：100条
(1)(1)(1)(3)(1)(1)(1)(4)(1)(1)(2)(3)(1)(1)(2)(1)(7)(5)(1)(3)(1)(5)(9)(13)(17)(10)(1)(8)(9)(6)(13)(10)(18)(6)(8)(1)(6)(3)(10)(6)(1)(45)(24)14268人阅读
Quartz 学习笔记（4）
简单回顾一下上一节学习到的 &HelloWorld &
1 创建一个job类,实现Job接口,覆盖 public void execute(JobExecutionContext context) 方法,在方法中写入你要执行的操作(数据导入/备份,轮询检查文件等)代码
2 创建一个主线程类,&获得 Scheduler 对象
&&& SchedulerFactory sf = new StdSchedulerFactory();
& &&Scheduler sched = sf.getScheduler();&
&&& 获得要执行的对象& JobDetail job = newJob(HelloJob.class).withIdentity(&job1&, &group1&).build();
&&& 定义触发器 Trigger trigger = newTrigger().withIdentity(&trigger1&, &group1&).startAt(runTime).build();
&&&&将任务和Trigger放入scheduler&& :&
&&&&&&& sched.scheduleJob(job, trigger);
&&& 启动 和 停止
&&& sched.start();& sched.shutdown(true);
&&& 注意 给job 留有足够长的时间,如果主线程类停止工作,job线程也会停止工作
------------------------------------------------我是分割线--------------------------------------------------------
经过了 &HelloWorld& 之后,您老人家可能对 Quartz 有所了解,下面让我们继续深入,学习下Quartz 重复执行任务该怎么做
简单的说就是 触发器(Trigger)的参数设置. 什么? 触发器(Trigger)不知道是什么?
出门左转& && 不谢
还是老套路,一个job 类,一个主线程类
SimpleJob.java
public class SimpleJob implements Job {
public void execute(JobExecutionContext context)
throws JobExecutionException {
// job 的名字
String jobName = context.getJobDetail().getKey().getName();
// 任务执行的时间
SimpleDateFormat dateFormat = new SimpleDateFormat(&yyyy 年 MM 月 dd 日
HH 时 mm 分 ss 秒&);
String jobRunTime = dateFormat.format(Calendar.getInstance().getTime());
// 输出任务执行情况
System.out.println(&任务 : & + jobName + & 在
& +jobRunTime + & 执行了 &);
在这里 对输出 的日期进行了一小下 格式化,适应国人习惯.
其它没什么好说的 0.0
SimpleTriggerExample.java
import static org.quartz.DateBuilder.futureD
import static org.quartz.JobBuilder.newJ
import static org.quartz.JobKey.jobK
import static org.quartz.SimpleScheduleBuilder.simpleS
import static org.quartz.TriggerBuilder.newT
import java.text.SimpleDateF
import java.util.D
import org.quartz.DateB
import org.quartz.DateBuilder.IntervalU
import org.quartz.JobD
import org.quartz.S
import org.quartz.SchedulerF
import org.quartz.SchedulerMetaD
import org.quartz.SimpleT
import org.quartz.impl.StdSchedulerF
* Simple Triggers (简单触发器) 的使用.
public class SimpleTriggerExample {
public static void main(String[] args) throws Exception {
SimpleTriggerExample example = new SimpleTriggerExample();
example.run();
public void run() throws Exception {
// 日期格式化
SimpleDateFormat dateFormat = new SimpleDateFormat(&yyyy 年 MM 月 dd 日
HH 时 mm 分 ss 秒&);
SchedulerFactory sf = new StdSchedulerFactory();
Scheduler sched = sf.getScheduler();
System.out.println(&--------------- 初始化 -------------------&);
// 下一个第15秒 例:
当前 10秒,则 执行时间为15秒
当前 16秒,则 执行时间为30秒
当前 33秒,则 执行时间为45秒
当前 48秒,则 执行时间为00秒
Date startTime = DateBuilder.nextGivenSecondDate(null, 15);
// job1 将只会执行一次
JobDetail job = newJob(SimpleJob.class).withIdentity(&job1&, &group1&).build();
SimpleTrigger trigger = (SimpleTrigger) newTrigger()
.withIdentity(&trigger1&, &group1&)
.startAt(startTime).build();
// 把job1 和 trigger加入计划
ft:此任务要执行的时间
Date ft = sched.scheduleJob(job, trigger);
System.out.println(job.getKey().getName() + & 将在 : & + dateFormat.format(ft) + & 时运行.并且重复: &
+ trigger.getRepeatCount() + & 次, 每次间隔 &
+ trigger.getRepeatInterval() / 1000 + & 秒&);
// job2 将只会和执行一次(和job1一样一样的,吼~~)
job = newJob(SimpleJob.class).withIdentity(&job2&, &group1&).build();
trigger = (SimpleTrigger) newTrigger()
.withIdentity(&trigger2&, &group1&).startAt(startTime).build();
ft = sched.scheduleJob(job, trigger);
System.out.println(job.getKey().getName() + & 将在 : & + dateFormat.format(ft) + & 时运行.并且重复: &
+ trigger.getRepeatCount() + & 次, 每次间隔 &
+ trigger.getRepeatInterval() / 1000 + & 秒&);
// job3 将执行11次(执行1次,重复10次) ,每10秒重复一次
job = newJob(SimpleJob.class).withIdentity(&job3&, &group1&).build();
trigger = newTrigger()
.withIdentity(&trigger3&, &group1&)
.startAt(startTime)
.withSchedule(
simpleSchedule()
.withIntervalInSeconds(10)// 重复间隔
.withRepeatCount(10))
// 重复次数
ft = sched.scheduleJob(job, trigger);
System.out.println(job.getKey().getName()+ & 将在 : & + dateFormat.format(ft) + & 时运行.并且重复: &
+ trigger.getRepeatCount() + & 次, 每次间隔 &
+ trigger.getRepeatInterval() / 1000 + & 秒&);
// trigger3 改变了.
每隔10s重复.共重复2次
// 此处说明 , 上面job3已经 设定了 trigger3 重复10次,每次10s
在这里又改变了 trigger3的设置,不会对以前构成影响,而是当做一个新的来处理
trigger = newTrigger()
.withIdentity(&trigger3&, &group2&)
.startAt(startTime)
.withSchedule(
simpleSchedule()
.withIntervalInSeconds(10)
.withRepeatCount(2))
.forJob(job).build();
ft = sched.scheduleJob(trigger);
System.out.println(job.getKey().getName() + & 改变过trigger3属性的job3 : & + dateFormat.format(ft) + & 时运行.并且重复: &
+ trigger.getRepeatCount() + & 次, 每次间隔 &
+ trigger.getRepeatInterval() / 1000 + & 秒&);
// job5 将在5分钟后运行一次
job = newJob(SimpleJob.class).withIdentity(&job5&, &group1&).build();
trigger = (SimpleTrigger) newTrigger()
.withIdentity(&trigger5&, &group1&)
.startAt(futureDate(5, IntervalUnit.MINUTE)) // 设定5分钟后运行
ft = sched.scheduleJob(job, trigger);
System.out.println(job.getKey().getName()+ & 将在 : & + dateFormat.format(ft) + & 时运行.并且重复: &
+ trigger.getRepeatCount() + & 次, 每次间隔 &
+ trigger.getRepeatInterval() / 1000 + & 秒&);
每40s运行一次,没有指定重复次数,则无下限的重复
job = newJob(SimpleJob.class).withIdentity(&job6&, &group1&).build();
trigger = newTrigger()
.withIdentity(&trigger6&, &group1&)
.startAt(startTime)
.withSchedule(
simpleSchedule().withIntervalInSeconds(40)
.repeatForever()).build();
ft = sched.scheduleJob(job, trigger);
System.out.println(job.getKey().getName() + & 将在 : & + dateFormat.format(ft) + & 时运行.并且重复: &
+ trigger.getRepeatCount() + & 次, 每次间隔 &
+ trigger.getRepeatInterval() / 1000 + & 秒&);
// 所有的任务都被加入到了 scheduler中 ,但只有 schedulers.start(); 时才开始执行
sched.start();
System.out.println(&------- 开始调度 (调用.start()方法) ----------------&);
System.out.println(&-------系统 启动 的 时间 :& + dateFormat.format(new Date()));
// 在 scheduled.start(); 之后,还可以将 jobs 添加到执行计划中
// job7 将重复20次 ,每5分钟重复一次
job = newJob(SimpleJob.class).withIdentity(&job7&, &group1&).build();
trigger = newTrigger()
.withIdentity(&trigger7&, &group1&)
.startAt(startTime)
.withSchedule(
simpleSchedule()
.withIntervalInMinutes(5) // 5分钟
.withRepeatCount(20))
// 重复20次
ft = sched.scheduleJob(job, trigger);
System.out.println(job.getKey().getName() + & 将在 : & + dateFormat.format(ft) + & 时运行.并且重复: &
+ trigger.getRepeatCount() + & 次, 每次间隔 &
+ trigger.getRepeatInterval() / 1000 + & 秒&);
可以立即执行. 无trigger注册
job = newJob(SimpleJob.class).withIdentity(&job8&, &group1&)
.storeDurably().build();
sched.addJob(job, true);
System.out.println(&手动触发
job8...(立即执行)&);
sched.triggerJob(jobKey(&job8&, &group1&));
System.out.println(&------- 等待30 秒... --------------&);
Thread.sleep(30L * 1000L);
} catch (Exception e) { }
// job7 将马上执行,重复10次,每秒一次
System.out.println(&-------
重新安排 ... --------------------&);
trigger = newTrigger()
.withIdentity(&trigger7&, &group1&)
.startAt(startTime)
.withSchedule(
simpleSchedule().withIntervalInMinutes(5)
.withRepeatCount(20)).build();
ft = sched.rescheduleJob(trigger.getKey(), trigger);
System.out.println(&job7 被重新安排 在 : & + dateFormat.format(ft) +&
当前时间 :& + dateFormat.format(new Date())+&预定执行时间已过,任务立即执行&);
System.out.println(&------- 等待5分钟
... ------------&);
Thread.sleep(300L * 1000L);
} catch (Exception e) { }
sched.shutdown(true);
System.out.println(&------- 调度已关闭 ---------------------&);
// 显示一下
已经执行的任务信息
SchedulerMetaData metaData = sched.getMetaData();
System.out.println(&~~~~~~~~~~
执行了 & + metaData.getNumberOfJobsExecuted() + & 个 jobs.&);
1 DateBuilder.nextGivenSecondDate 的意思代码中已经说明了,就是下一个你想要的时间,不懂的可以自己测试一下
2 同一个任务可以多次注册.
3 重复执行 需要设置
&& trigger = newTrigger()
&&&&.withIdentity(&trigger3&, &group1&)
&&&&.startAt(startTime)
&&&&.withSchedule(
&&&&&&simpleSchedule()
&&&&&&.withIntervalInSeconds(10)// 重复间隔
&&&&&&.withRepeatCount(10))&&&& // 重复次数
&&&&&&.build();
&& 如果需要一直重复: &
&&& trigger = newTrigger()
&&&&.withIdentity(&trigger6&, &group1&)
&&&&.startAt(startTime)
&&&&.withSchedule(
&&&&&&simpleSchedule().withIntervalInSeconds(40)
&&&&&&&&.repeatForever()).build();
4 无trigger注册,表示任务立即执行 : sched.addJob(job, true);
5 // 在scheduler.start之后调用，可以在job开始后重新定义trigger，然后重新注册
&&& sched.rescheduleJob(trigger.getKey(), trigger);
这个Example 还是比较简单的,主要 就是Trigger的参数设置,多看看代码,里面有注释的 0.0
自己动手试试吧
参考知识库
* 以上用户言论只代表其个人观点，不代表CSDN网站的观点或立场
访问：77374次
排名：千里之外
原创：18篇
评论：20条
(1)(6)(2)(3)(2)(5)(3)(5)}
sql server（22）
定义：何为触发器？在SQL Server里面也就是对某一个表的一定的操作，触发某种条件，从而执行的一段程序。触发器是一个特殊的存储过程。
&&&&& 常见的触发器有三种：分别应用于Insert , Update , Delete
&&&&& 我为什么要使用触发器？比如，这么两个表：
&&&&& Create Table Student(&&&&&&&&&&&&& --学生表
&&&&&&& StudentID int primary key,&&&&&& --学号
&&&&&&& ....
&&&&& Create Table BorrowRecord(&&&&&&&&&&&&&& --学生借书记录表
&&&&&&& BorrowRecord&& int identity(1,1),&&&&&& --流水号&&
&&&&&&& StudentID&&&&& int ,&&&&&&&&&&&&&&&&&&& --学号
&&&&&&& BorrowDate&&&& datetime,&&&&&&&&&&&&&&& --借出时间
&&&&&&& ReturnDAte&&&& Datetime,&&&&&&&&&&&&&&& --归还时间
&&&&&&& ...
&&&& 用到的功能有:
&&&&&&& 1.如果我更改了学生的学号,我希望他的借书记录仍然与这个学生相关(也就是同时更改借书记录表的学号);
&&&&&&& 2.如果该学生已经毕业，我希望删除他的学号的同时，也删除它的借书记录。
&&&& 等等。
&&&& 这时候可以用到触发器。对于<span style="color:#，创建一个Update触发器：
&&&& Create Trigger truStudent
&&&&&& On Student&&&&&&&&&&&&&&&&&&&&&&&& --在Student表中创建触发器
&&&&&& for Update&&&&&&&&&&&&&&&&&&&&&&&&& --为什么事件触发
&&&& As&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&& --事件触发后所要做的事情
&&&&&& if Update(StudentID)&&&&&&&&&&&
&&&&&& begin
&&&&&&&& Update BorrowRecord
&&&&&&&&&& Set StudentID=i.StudentID
&&&&&&&&&& From BorrowRecord br , Deleted&& d ,Inserted i&&&&& --Deleted和Inserted临时表
&&&&&&&&&& Where br.StudentID=d.StudentID
&&&&&& end&&&&&&&
&&&&&&&&&&&&&&&&
&&&& 理解触发器里面的两个临时的表：Deleted , Inserted
。注意Deleted
与Inserted分别表示触发事件的表“旧的一条记录”和“新的一条记录”。
&&&& 一个数据库系统中有两个虚拟表用于存储在表中记录改动的信息，分别是：
&&&&&&&&&&&&&&&&&&&&&&&&&&&& 虚拟表Inserted&&&&&&&&&&&&&&&&&&&&
虚拟表Deleted
在表记录新增时&&&&
存放新增的记录&&&&&&&&&&&&&&&&&&&&&&&&
不存储记录
&&&&&&&& 修改时&&&&&&&&&&
存放用来更新的新记录&&&&&&&&&&&&&&&&&&
存放更新前的记录
&&&&&&&& 删除时&&&&&&&&&&
不存储记录&&&&&&&&&&&&&&&&&&&&&&&&&&&&
存放被删除的记录
&&&& 一个Update
的过程可以看作为：生成新的记录到Inserted表，复制旧的记录到Deleted表，然后删除Student记录并写入新纪录。
&&&& 对于<span style="color:#，创建一个Delete触发器
&&&& Create trigger trdStudent
&&&&&& On Student
&&&&&& for Delete
&&&&&& Delete BorrowRecord
&&&&&&&& From BorrowRecord br , Delted d
&&&&&&&& Where br.StudentID=d.StudentID
&&&& 从这两个例子我们可以看到了触发器的关键：A.2个临时的表；B.触发机制。
SQL触发器实例<span style="color:#
建立虚拟测试环境，包含：表[卷烟库存表]，表[卷烟销售表]。
请大家注意跟踪这两个表的数据，体会触发器到底执行了什么业务逻辑，对数据有什么影响。
为了能更清晰的表述触发器的作用，表结构存在数据冗余，且不符合第三范式，这里特此说明。
USE Master
IF EXISTS (SELECT NAME FROM SYSOBJECTS WHERE XTYPE = ’U’ AND NAME = ’卷烟库存表’)
DROP TABLE 卷烟库存表
IF EXISTS (SELECT NAME FROM SYSOBJECTS WHERE XTYPE = ’U’ AND NAME = ’卷烟销售表’)
DROP TABLE 卷烟销售表
--业务规则：销售金额 =
销售数量 *
销售单价业务规则。
CREATE TABLE 卷烟销售表
卷烟品牌 VARCHAR(40) PRIMARY KEY NOT NULL,
购货商 VARCHAR(40) NULL,
销售数量 INT NULL,
销售单价 MONEY NULL,
销售金额 MONEY NULL
--业务规则：库存金额 =
库存数量 *
库存单价业务规则。
CREATE TABLE 卷烟库存表
卷烟品牌 VARCHAR(40) PRIMARY KEY NOT NULL,
库存数量 INT NULL,
库存单价 MONEY NULL,
库存金额 MONEY NULL
--创建触发器，示例<span style="color:#
创建触发器[T_INSERT_卷烟库存表]，这个触发器较简单。
说明：每当[卷烟库存表]发生
INSERT 动作，则引发该触发器。
触发器功能：强制执行业务规则，保证插入的数据中，库存金额 =
库存数量 *
库存单价。
注意： [INSERTED]、[DELETED]为系统表，不可创建、修改、删除，但可以调用。
重要：这两个系统表的结构同插入数据的表的结构。
IF EXISTS (SELECT NAME FROM SYSOBJECTS WHERE XTYPE = ’TR’ AND NAME = ’T_INSERT_卷烟库存表’)
DROP TRIGGER T_INSERT_卷烟库存表
CREATE TRIGGER T_INSERT_卷烟库存表
ON 卷烟库存表
FOR INSERT
--提交事务处理
BEGIN TRANSACTION
--强制执行下列语句，保证业务规则
UPDATE 卷烟库存表
SET 库存金额 =
库存数量 * 库存单价
WHERE 卷烟品牌 IN (SELECT
卷烟品牌 from INSERTED)
COMMIT TRANSACTION
针对[卷烟库存表]，插入测试数据：
注意，第一条数据（红塔山新势力）中的数据符合业务规则，
第二条数据（红塔山人为峰）中，[库存金额]空，不符合业务规则，
第三条数据（云南映像）中，[库存金额]不等于[库存数量]乘以[库存单价]，不符合业务规则。
第四条数据库存数量为<span style="color:#。
请注意在插入数据后，检查[卷烟库存表]中的数据是否库存金额
= 库存数量 *
库存单价。
INSERT INTO 卷烟库存表(卷烟品牌,库存数量,库存单价,库存金额)
SELECT ’红塔山新势力’,100,12,1200 UNION ALL
SELECT ’红塔山人为峰’,100,22,NULL UNION ALL
SELECT ’云南映像’,100,60,500 UNION ALL
SELECT ’玉溪’,0,30,0
--查询数据
SELECT * FROM 卷烟库存表
RecordId 卷烟品牌库存数量库存单价库存金额
-------- ------------ -------- ------- ---------
1 红塔山新势力 100 12.00
2 红塔山人为峰 100 22.00
3 云南映像 100 60.00
4 玉溪 0 30.
（所影响的行数为 4
--触发器示例<span style="color:#
创建触发器[T_INSERT_卷烟销售表]，该触发器较复杂。
每当[卷烟库存表]发生 INSERT
动作，则引发该触发器。
触发器功能：实现业务规则。
如果销售的卷烟品牌不存在库存或者库存为零，则返回错误。
否则则自动减少[卷烟库存表]中对应品牌卷烟的库存数量和库存金额。
IF EXISTS (SELECT NAME FROM SYSOBJECTS WHERE XTYPE = ’TR’ AND NAME = ’T_INSERT_卷烟销售表’)
DROP TRIGGER T_INSERT_卷烟销售表
CREATE TRIGGER T_INSERT_卷烟销售表
ON 卷烟销售表
FOR INSERT
BEGIN TRANSACTION
--检查数据的合法性：销售的卷烟是否有库存，或者库存是否大于零
IF NOT EXISTS (
SELECT 库存数量
FROM 卷烟库存表
WHERE 卷烟品牌 IN (SELECT
卷烟品牌 FROM INSERTED)
--返回错误提示
RAISERROR(’错误！该卷烟不存在库存，不能销售。’,16,1)
--回滚事务
IF EXISTS (
SELECT 库存数量
FROM 卷烟库存表
WHERE 卷烟品牌 IN (SELECT
卷烟品牌 FROM INSERTED) AND
库存数量 &= 0
--返回错误提示
RAISERROR(’错误！该卷烟库存小于等于<span style="color:#，不能销售。’,16,1)
--回滚事务
--对合法的数据进行处理
--强制执行下列语句，保证业务规则
UPDATE 卷烟销售表
SET 销售金额 =
销售数量 * 销售单价
WHERE 卷烟品牌 IN (SELECT
卷烟品牌 FROM INSERTED)
DECLARE @卷烟品牌 VARCHAR(40)
SET @卷烟品牌 = (SELECT
卷烟品牌 FROM INSERTED)
DECLARE @销售数量 MONEY
SET @销售数量 = (SELECT
销售数量 FROM INSERTED)
UPDATE 卷烟库存表
SET 库存数量 =
库存数量 - @销售数量,
库存金额 = (库存数量 - @销售数量)*库存单价
WHERE 卷烟品牌 = @卷烟品牌
COMMIT TRANSACTION
--请大家自行跟踪[卷烟库存表]和[卷烟销售表]的数据变化。
--针对[卷烟销售表]，插入第一条测试数据，该数据是正常的。
INSERT INTO 卷烟销售表(卷烟品牌,购货商,销售数量,销售单价,销售金额)
SELECT ’红塔山新势力’,’某购货商’,10,12,1200
--针对[卷烟销售表]，插入第二条测试数据，该数据销售金额不等于销售单价
* 销售数量。
--触发器将自动更正数据，使销售金额等于销售单价 *
销售数量。
INSERT INTO 卷烟销售表(卷烟品牌,购货商,销售数量,销售单价,销售金额)
SELECT ’红塔山人为峰’,’某购货商’,10,22,2000
--针对[卷烟销售表]，插入第三条测试数据，该数据中的卷烟品牌在卷烟库存表中找不到对应。
--触发器将报错。
INSERT INTO 卷烟销售表(卷烟品牌,购货商,销售数量,销售单价,销售金额)
SELECT ’红河V8’,’某购货商’,10,60,600
消息 50000，级别 16，状态 1，过程
T_INSERT_卷烟销售表，行 15
错误！该卷烟不存在库存，不能销售。
--针对[卷烟销售表]，插入第三条测试数据，该数据中的卷烟品牌在卷烟库存表中库存为<span style="color:#。
--触发器将报错。
INSERT INTO 卷烟销售表(卷烟品牌,购货商,销售数量,销售单价,销售金额)
SELECT ’玉溪’,’某购货商’,10,30,300
消息 50000，级别 16，状态 1，过程
T_INSERT_卷烟销售表，行 29
错误！该卷烟库存小于等于<span style="color:#，不能销售。
--查询数据
SELECT * FROM 卷烟库存表
SELECT * FROM 卷烟销售表
1、本示例主要通过一个简单的业务规则实现来进行触发器使用的说明，具体的要根据需要灵活处理；
2、关于触发器要理解并运用好 INSERTED
两个系统表；
3、本示例创建的触发器都是 FOR INSERT ,具体的语法可参考：
/////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&& Trigger语法
//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
CREATE TRIGGER trigger_name
ON { table | view }
[ WITH ENCRYPTION ] --用于加密触发器
{ { FOR | AFTER | INSTEAD OF } { [ INSERT ] [ , ] [ UPDATE ] }
[ WITH APPEND ]
[ NOT FOR REPLICATION ]
[ { IF UPDATE ( column )
[ { AND | OR } UPDATE ( column ) ]
| IF ( COLUMNS_UPDATED ( ) { bitwise_operator } updated_bitmask )
{ comparison_operator } column_bitmask [ ...n ]
sql_statement [ ...n ]
4、关于触发器，还应该注意
(1)、DELETE
触发器不能捕获 TRUNCATE TABLE
(2)、触发器中不允许以下 Transact-SQL
ALTER DATABASE CREATE DATABASE DISK INIT
DISK RESIZE DROP DATABASE LOAD DATABASE
LOAD LOG RECONFIGURE RESTORE DATABASE
RESTORE LOG
(3)、触发器最多可以嵌套 32
--修改触发器
--实质上，是将 CREATE TRIGGER ...
修改为 ALTER TRIGGER ...即可。
--删除触发器
DROP TRIGGER xxx
--删除测试环境
DROP TABLE 卷烟库存表
DROP TABLE 卷烟销售表
DROP TRIGGER T_INSERT_卷烟库存表
DROP TRIGGER T_INSERT_卷烟销售表
##################################################################
触发器的基础知识和例子
：create trigger tr_name
on table/view
{for | after | instead of } [update][,][insert][,][delete]
[with encryption]
as {batch | if update (col_name) [{and|or} update (col_name)] }
1 tr_name ：触发器名称
2 on table/view ：触发器所作用的表。一个触发器只能作用于一个表
3 for 和after
4 after 与instead of :sql 2000新增项目afrer
与 instead of
在触发事件发生以后才被激活,只可以建立在表上
Instead of
代替了相应的触发事件而被执行,既可以建立在表上也可以建立在视图上
5 insert、update、delete：激活触发器的三种操作，可以同时执行，也可选其一
6 if update (col_name)：表明所作的操作对指定列是否有影响，有影响，则激活触发器。此外，因为delete
操作只对行有影响，
所以如果使用delete操作就不能用这条语句了(虽然使用也不出错，但是不能激活触发器，没意义)。
7 触发器执行时用到的两个特殊表：deleted ,inserted
deleted 和inserted
可以说是一种特殊的临时表，是在进行激活触发器时由系统自动生成的，其结构与触发器作用的表结构是一
样的，只是存放的数据有差异。
下面表格说明deleted
与inserted
数据的差异
deleted 与inserted
数据的差异
存放进行insert和update
操作后的数据
存放进行delete
和update操作前的数据
注意：update
操作相当于先进行delete
再进行insert ,所以在进行update操作时，修改前的数据拷贝一条到deleted
表中，修改后
的数据在存到触发器作用的表的同时，也同时生成一条拷贝到insered表中
CREATE TRIGGER [TRIGGER admixture_receive_log] ON dbo.chl_lydj
FOR UPDATE
&&&&&&& declare @djsfxg char(10)&&&&& declare @wtbh char(20)
&&&&&&& select @wtbh=wtbh from inserted
&&&&&& update ly_tzk set djsfxg='已修改' where
if (select data_sfjl from t_logsetup)='是'
declare @oldcjmc char (100)&&&&&&&&& declare @oldlyrq datetime
declare @oldbzbh char (60)&&&&&&&&&&&& declare @oldzl char (20)
declare @olddj char (10)
declare @newcjmc char (100)&&&&&&&&& declare @newlyrq datetime
declare @newbzbh char (60)&&&&&&&&&&&& declare @newzl char (20)
declare @newdj char (10)
&&&&&&&&&&&& declare @xgr char (20)
&&&&&&&&&&&& select @oldcjmc=cjmc,@oldlyrq=lyrq,@oldbzbh=bzbh,@oldzl=zl,@olddj=dj from deleted
&&&&&&&&&&&& select @newcjmc=cjmc,@newlyrq=lyrq,@newbzbh=bzbh,@newzl=zl,@newdj=dj from inserted
&&&&&&&&&&&& select @xgr=xgr from t_modifyuser where @wtbh=wtbh
&&&&&&&&&&&&
&&&&&&&& if @oldcjmc&&@newcjmc
&&&&&&&&&&&& begin
&&&&&&&&&&&&&&&&&&&&& insert into t_modifylog (wtbh, mod_time, mod_table, mod_field, ori_value, now_value, mod_people) values
&&&&&&&&&&&&&&&&&&&&& (@wtbh,getdate(), 'chl_lydj','cjmc', @oldcjmc, @newcjmc, @xgr)
&&&&&&&&&&&& end
//////////修改时，直接把‘create’改为‘alter’即可
/////////////////////////
CREATE TRIGGER [TRIGGER ly_tzk_syf] ON dbo.ly_tzk
FOR insert
&&&&&&&& declare @clmc char(100)&&&& declare @dwbh char(100) declare @syf char(100)&& declare @dwgcbh char(100) declare @wtbh char(50)
&&&&&&&& declare @dj_1 money&&&& declare @feiyong_z money&& declare @feiyong_xf money&& declare @feiyong_sy money
&&&&&&&& declare @dj char(20)
&&&&&&& select @wtbh=wtbh , @clmc=clmc , @dwbh=dwbh ,@syf=syf from inserted
&&&&&&& select&& @dj=dj from feihao_bz where
&&&&&&& select @feiyong_z=feiyong_z, @feiyong_xf=feiyong_xf, @feiyong_sy=feiyong_sy from gongchengxinxi where
&&&&&&& set @dj_1=convert(money ,@dj)
&&&&&& if @dj_1 &&0
&&&&&& begin
&&&&&&&&&&&& set @feiyong_xf=@feiyong_xf+@dj_1
&&&&&&&&&&&& set @feiyong_sy=@feiyong_sy-@dj_1
&&&&&&&&&&& update ly_tzk set
&&&&&&&&&&& update gongchengxinxi set ,
&&&&&& end
&&&&&& else&&& update ly_tzk set syf=convert(char , 0.0) where
//////////////////////
CREATE TRIGGER [TRIGGER ly_tzk_syf_shanchu] ON dbo.ly_tzk
FOR delete
&&&&&&&& declare @clmc char(100)&&&& declare @dwbh char(100)&&& declare @dwgcbh char(100) declare @wtbh char(50)
&&&&&&&& declare @feiyong_z money&&& declare @feiyong_xf money&& declare @feiyong_sy money
&&&&&&&& declare @syf char(100)&&&&& declare @syf_1 money
&&&&&&&& --declare @dj char(20)&& declare @dj_1 money
&&&&&&& select @wtbh=wtbh , @clmc=clmc , @dwbh=dwbh ,@syf=syf from inserted
&&&&&&& --select&& @dj=dj from feihao_bz where
&&&&&&& select @feiyong_z=feiyong_z, @feiyong_xf=feiyong_xf, @feiyong_sy=feiyong_sy from gongchengxinxi where
&&&&&&& set @syf_1=convert(money ,@syf)
&&&&&& if @syf_1 &&0
&&&&&& begin
&&&&&&&&&&&& set @feiyong_xf=@feiyong_xf-@syf_1
&&&&&&&&&&&& set @feiyong_sy=@feiyong_sy+@syf_1
&&&&&&&&&&& update gongchengxinxi set ,
&&&&&& end
//////////////////////
参考知识库
* 以上用户言论只代表其个人观点，不代表CSDN网站的观点或立场
访问：514732次
积分：6346
积分：6346
排名：第2455名
原创：97篇
转载：171篇
评论：100条
(1)(1)(1)(3)(1)(1)(1)(4)(1)(1)(2)(3)(1)(1)(2)(1)(7)(5)(1)(3)(1)(5)(9)(13)(17)(10)(1)(8)(9)(6)(13)(10)(18)(6)(8)(1)(6)(3)(10)(6)(1)(45)(24)14268人阅读
Quartz 学习笔记（4）
简单回顾一下上一节学习到的 &HelloWorld &
1 创建一个job类,实现Job接口,覆盖 public void execute(JobExecutionContext context) 方法,在方法中写入你要执行的操作(数据导入/备份,轮询检查文件等)代码
2 创建一个主线程类,&获得 Scheduler 对象
&&& SchedulerFactory sf = new StdSchedulerFactory();
& &&Scheduler sched = sf.getScheduler();&
&&& 获得要执行的对象& JobDetail job = newJob(HelloJob.class).withIdentity(&job1&, &group1&).build();
&&& 定义触发器 Trigger trigger = newTrigger().withIdentity(&trigger1&, &group1&).startAt(runTime).build();
&&&&将任务和Trigger放入scheduler&& :&
&&&&&&& sched.scheduleJob(job, trigger);
&&& 启动 和 停止
&&& sched.start();& sched.shutdown(true);
&&& 注意 给job 留有足够长的时间,如果主线程类停止工作,job线程也会停止工作
------------------------------------------------我是分割线--------------------------------------------------------
经过了 &HelloWorld& 之后,您老人家可能对 Quartz 有所了解,下面让我们继续深入,学习下Quartz 重复执行任务该怎么做
简单的说就是 触发器(Trigger)的参数设置. 什么? 触发器(Trigger)不知道是什么?
出门左转& && 不谢
还是老套路,一个job 类,一个主线程类
SimpleJob.java
public class SimpleJob implements Job {
public void execute(JobExecutionContext context)
throws JobExecutionException {
// job 的名字
String jobName = context.getJobDetail().getKey().getName();
// 任务执行的时间
SimpleDateFormat dateFormat = new SimpleDateFormat(&yyyy 年 MM 月 dd 日
HH 时 mm 分 ss 秒&);
String jobRunTime = dateFormat.format(Calendar.getInstance().getTime());
// 输出任务执行情况
System.out.println(&任务 : & + jobName + & 在
& +jobRunTime + & 执行了 &);
在这里 对输出 的日期进行了一小下 格式化,适应国人习惯.
其它没什么好说的 0.0
SimpleTriggerExample.java
import static org.quartz.DateBuilder.futureD
import static org.quartz.JobBuilder.newJ
import static org.quartz.JobKey.jobK
import static org.quartz.SimpleScheduleBuilder.simpleS
import static org.quartz.TriggerBuilder.newT
import java.text.SimpleDateF
import java.util.D
import org.quartz.DateB
import org.quartz.DateBuilder.IntervalU
import org.quartz.JobD
import org.quartz.S
import org.quartz.SchedulerF
import org.quartz.SchedulerMetaD
import org.quartz.SimpleT
import org.quartz.impl.StdSchedulerF
* Simple Triggers (简单触发器) 的使用.
public class SimpleTriggerExample {
public static void main(String[] args) throws Exception {
SimpleTriggerExample example = new SimpleTriggerExample();
example.run();
public void run() throws Exception {
// 日期格式化
SimpleDateFormat dateFormat = new SimpleDateFormat(&yyyy 年 MM 月 dd 日
HH 时 mm 分 ss 秒&);
SchedulerFactory sf = new StdSchedulerFactory();
Scheduler sched = sf.getScheduler();
System.out.println(&--------------- 初始化 -------------------&);
// 下一个第15秒 例:
当前 10秒,则 执行时间为15秒
当前 16秒,则 执行时间为30秒
当前 33秒,则 执行时间为45秒
当前 48秒,则 执行时间为00秒
Date startTime = DateBuilder.nextGivenSecondDate(null, 15);
// job1 将只会执行一次
JobDetail job = newJob(SimpleJob.class).withIdentity(&job1&, &group1&).build();
SimpleTrigger trigger = (SimpleTrigger) newTrigger()
.withIdentity(&trigger1&, &group1&)
.startAt(startTime).build();
// 把job1 和 trigger加入计划
ft:此任务要执行的时间
Date ft = sched.scheduleJob(job, trigger);
System.out.println(job.getKey().getName() + & 将在 : & + dateFormat.format(ft) + & 时运行.并且重复: &
+ trigger.getRepeatCount() + & 次, 每次间隔 &
+ trigger.getRepeatInterval() / 1000 + & 秒&);
// job2 将只会和执行一次(和job1一样一样的,吼~~)
job = newJob(SimpleJob.class).withIdentity(&job2&, &group1&).build();
trigger = (SimpleTrigger) newTrigger()
.withIdentity(&trigger2&, &group1&).startAt(startTime).build();
ft = sched.scheduleJob(job, trigger);
System.out.println(job.getKey().getName() + & 将在 : & + dateFormat.format(ft) + & 时运行.并且重复: &
+ trigger.getRepeatCount() + & 次, 每次间隔 &
+ trigger.getRepeatInterval() / 1000 + & 秒&);
// job3 将执行11次(执行1次,重复10次) ,每10秒重复一次
job = newJob(SimpleJob.class).withIdentity(&job3&, &group1&).build();
trigger = newTrigger()
.withIdentity(&trigger3&, &group1&)
.startAt(startTime)
.withSchedule(
simpleSchedule()
.withIntervalInSeconds(10)// 重复间隔
.withRepeatCount(10))
// 重复次数
ft = sched.scheduleJob(job, trigger);
System.out.println(job.getKey().getName()+ & 将在 : & + dateFormat.format(ft) + & 时运行.并且重复: &
+ trigger.getRepeatCount() + & 次, 每次间隔 &
+ trigger.getRepeatInterval() / 1000 + & 秒&);
// trigger3 改变了.
每隔10s重复.共重复2次
// 此处说明 , 上面job3已经 设定了 trigger3 重复10次,每次10s
在这里又改变了 trigger3的设置,不会对以前构成影响,而是当做一个新的来处理
trigger = newTrigger()
.withIdentity(&trigger3&, &group2&)
.startAt(startTime)
.withSchedule(
simpleSchedule()
.withIntervalInSeconds(10)
.withRepeatCount(2))
.forJob(job).build();
ft = sched.scheduleJob(trigger);
System.out.println(job.getKey().getName() + & 改变过trigger3属性的job3 : & + dateFormat.format(ft) + & 时运行.并且重复: &
+ trigger.getRepeatCount() + & 次, 每次间隔 &
+ trigger.getRepeatInterval() / 1000 + & 秒&);
// job5 将在5分钟后运行一次
job = newJob(SimpleJob.class).withIdentity(&job5&, &group1&).build();
trigger = (SimpleTrigger) newTrigger()
.withIdentity(&trigger5&, &group1&)
.startAt(futureDate(5, IntervalUnit.MINUTE)) // 设定5分钟后运行
ft = sched.scheduleJob(job, trigger);
System.out.println(job.getKey().getName()+ & 将在 : & + dateFormat.format(ft) + & 时运行.并且重复: &
+ trigger.getRepeatCount() + & 次, 每次间隔 &
+ trigger.getRepeatInterval() / 1000 + & 秒&);
每40s运行一次,没有指定重复次数,则无下限的重复
job = newJob(SimpleJob.class).withIdentity(&job6&, &group1&).build();
trigger = newTrigger()
.withIdentity(&trigger6&, &group1&)
.startAt(startTime)
.withSchedule(
simpleSchedule().withIntervalInSeconds(40)
.repeatForever()).build();
ft = sched.scheduleJob(job, trigger);
System.out.println(job.getKey().getName() + & 将在 : & + dateFormat.format(ft) + & 时运行.并且重复: &
+ trigger.getRepeatCount() + & 次, 每次间隔 &
+ trigger.getRepeatInterval() / 1000 + & 秒&);
// 所有的任务都被加入到了 scheduler中 ,但只有 schedulers.start(); 时才开始执行
sched.start();
System.out.println(&------- 开始调度 (调用.start()方法) ----------------&);
System.out.println(&-------系统 启动 的 时间 :& + dateFormat.format(new Date()));
// 在 scheduled.start(); 之后,还可以将 jobs 添加到执行计划中
// job7 将重复20次 ,每5分钟重复一次
job = newJob(SimpleJob.class).withIdentity(&job7&, &group1&).build();
trigger = newTrigger()
.withIdentity(&trigger7&, &group1&)
.startAt(startTime)
.withSchedule(
simpleSchedule()
.withIntervalInMinutes(5) // 5分钟
.withRepeatCount(20))
// 重复20次
ft = sched.scheduleJob(job, trigger);
System.out.println(job.getKey().getName() + & 将在 : & + dateFormat.format(ft) + & 时运行.并且重复: &
+ trigger.getRepeatCount() + & 次, 每次间隔 &
+ trigger.getRepeatInterval() / 1000 + & 秒&);
可以立即执行. 无trigger注册
job = newJob(SimpleJob.class).withIdentity(&job8&, &group1&)
.storeDurably().build();
sched.addJob(job, true);
System.out.println(&手动触发
job8...(立即执行)&);
sched.triggerJob(jobKey(&job8&, &group1&));
System.out.println(&------- 等待30 秒... --------------&);
Thread.sleep(30L * 1000L);
} catch (Exception e) { }
// job7 将马上执行,重复10次,每秒一次
System.out.println(&-------
重新安排 ... --------------------&);
trigger = newTrigger()
.withIdentity(&trigger7&, &group1&)
.startAt(startTime)
.withSchedule(
simpleSchedule().withIntervalInMinutes(5)
.withRepeatCount(20)).build();
ft = sched.rescheduleJob(trigger.getKey(), trigger);
System.out.println(&job7 被重新安排 在 : & + dateFormat.format(ft) +&
当前时间 :& + dateFormat.format(new Date())+&预定执行时间已过,任务立即执行&);
System.out.println(&------- 等待5分钟
... ------------&);
Thread.sleep(300L * 1000L);
} catch (Exception e) { }
sched.shutdown(true);
System.out.println(&------- 调度已关闭 ---------------------&);
// 显示一下
已经执行的任务信息
SchedulerMetaData metaData = sched.getMetaData();
System.out.println(&~~~~~~~~~~
执行了 & + metaData.getNumberOfJobsExecuted() + & 个 jobs.&);
1 DateBuilder.nextGivenSecondDate 的意思代码中已经说明了,就是下一个你想要的时间,不懂的可以自己测试一下
2 同一个任务可以多次注册.
3 重复执行 需要设置
&& trigger = newTrigger()
&&&&.withIdentity(&trigger3&, &group1&)
&&&&.startAt(startTime)
&&&&.withSchedule(
&&&&&&simpleSchedule()
&&&&&&.withIntervalInSeconds(10)// 重复间隔
&&&&&&.withRepeatCount(10))&&&& // 重复次数
&&&&&&.build();
&& 如果需要一直重复: &
&&& trigger = newTrigger()
&&&&.withIdentity(&trigger6&, &group1&)
&&&&.startAt(startTime)
&&&&.withSchedule(
&&&&&&simpleSchedule().withIntervalInSeconds(40)
&&&&&&&&.repeatForever()).build();
4 无trigger注册,表示任务立即执行 : sched.addJob(job, true);
5 // 在scheduler.start之后调用，可以在job开始后重新定义trigger，然后重新注册
&&& sched.rescheduleJob(trigger.getKey(), trigger);
这个Example 还是比较简单的,主要 就是Trigger的参数设置,多看看代码,里面有注释的 0.0
自己动手试试吧
参考知识库
* 以上用户言论只代表其个人观点，不代表CSDN网站的观点或立场
访问：77374次
排名：千里之外
原创：18篇
评论：20条
(1)(6)(2)(3)(2)(5)(3)(5)}
我要回帖
更多关于 黄龙300跑车版 的文章
更多推荐
- ·动漫吻戏片段，看看这是哪个动漫吻戏，各位大神？
- ·剑网3指尖江湖同袍情谊无骨惊弦断难续在哪领取_剑网3指尖江湖同袍情谊无骨惊弦断难续任务领取介绍
- ·醉江山3D（传世手游带元神组合的元神版）哪个平台优惠力度最大？
- ·醉江山3D（传世元神版官网）在哪个平台最好玩？
- ·醉江山3d哪个软件比较好平台玩家多？
- ·百色五中新校区2016年招收的新生发录取通知书了吗？
- ·河北安国中学成绩查询今年有考了名牌大学的吗
- ·bhcg不稀释就显示mysql 删除id大于50000怎么算
- ·诺基亚手机插卡器上的五金是卫浴五金什么材质好
- ·天津哪里有天津学习谷日语学校习的地方？有没有天津学习谷日语学校校？
- ·乌海苏州十中2016高考成绩绩排名
- ·一台14,7千瓦一台10千瓦100长三相6千瓦用多大的空开空开
- ·人在忙碌单调的大学生生活忙碌的原因里,应该怎样做
- ·下雨后，所有开关都关了，插头也拔了，漏电保护器插头开关总是推不上去，总开关
- ·上海静安区美食英语新概念培训班晚上
- ·重庆市和平药房2016新开药房需要哪些条件,面积等
- ·bio island乳钙/婴幼儿乳钙排行榜童补钙液体钙软胶囊真的有用吗？
- ·微信抢红包异常怎么办5秒抢完，正好常吗
- ·桑多纳专业维修哪家好长沙哪家治疗痘痘专业
- ·黄龙300视频触发器
- ·宝宝一岁半吐到黄水都吐出来黄水怎么办
- ·A strong appearance什么意思, a lonely heart, hidden in the bottom of my heart is not meant to hide, but
- ·4.5雅思4.5成绩可以到哪读大学
- ·肝门部胆胆总管内径正常值高限是什么病
- ·朋友野外交游2019元旦祝福朋友词语词语
- ·2016山东理科考生人数考生排名80526可以报什么大学
- ·安徽青阳中学三中王高鹏
- ·我想种植露地韭菜种植技术找技术人员
- ·12轴承7000阿布加尔的钓鱼线轮鱼线向上斜是什么原因
- ·电白一中春华实验学校均衡说的是哪几个学校
- ·昆仑学院的郑州大学冶金工程学院怎么样
- ·分工度,正式化,高组织集权程度高的表现度
- ·怎么算尺码 我只知道长乘宽 还有我不知道的事 宁远了
