主頁 > 資料庫 > Mysql創建定時任務

Mysql創建定時任務

2020-12-09 08:58:45 資料庫

一、事件概述

在MySQL 5.1中新增了一個特色功能事件調度器(Event Scheduler),簡稱事件,它可以作為定時任務調度器,取代部分原來只能用作業系統的計劃任務才能執行的作業,另外,更值得一提的是,MySQL的事件可以實作每秒鐘執行一個任務,這在一些對實時性要求較高的環境下是非常實用的,

事件調度器是定時觸發執行的,從這個角度上看也可以稱作是“臨時觸發器”,但是它與觸發器又有所區別,觸發器只針對某個表產生的事件執行一些陳述句,而事件調度器則是在某一段(間隔)時間執行一些陳述句,

1.查看事件調度器是否開啟

事件由一個特定的執行緒來管理,啟用事件調度器后,擁有SUPER權限的賬戶執行SHOW PROCESSLIST就可以看到這個執行緒了,

示例:查看事件是否開啟,

SHOW VARIABLES LIKE 'event_scheduler';

SELECT @@event_scheduler;

SHOW PROCESSLIST;

2.開啟或關閉事件調度器

通過設定全域變數event_scheduler的值即可動態的控制事件調度器是否啟用,開啟MySQL的事件調度器,可以通過下面兩種方式實作,

①通過設定全域引數

使用SET GLOBAL命令可以開啟或關閉事件,將event_scheduler引數的值設定為ON,則開啟事件;如果設定為OFF,則關閉事件,

示例:使用SET GLOBAL命令可以開啟或關閉事件,

# 開啟事件調度器
SET GLOBAL event_scheduler = ON;

# 關閉事件調度器
SET GLOBAL event_scheduler = OFF;

# 查看事件調度器狀態
SHOW VARIABLES LIKE 'event_scheduler';

注意:如果想要始終開啟事件,那么在使用SET GLOBAL開啟事件后,還需要在my.ini(Windows系統)/my.cnf(Linux系統)中添加event_scheduler=on,因為如果沒有添加,MySQL重啟事件后又會回到原來的狀態,

②通過更改組態檔

在MySQL的組態檔my.ini(Windows系統)/my.cnf(Linux系統)中,找對[mysqld],然后在下面添加以下代碼開啟事件,

# 事件調度器啟動狀態
event_scheduler = on

在組態檔中添加代碼并保存檔案后,還需要重新啟動MySQL服務器才能生效,通過該方法開啟事件,重啟MySQL服務器后,不恢復為系統默認的狀態,

二、創建事件

在MySQL 5.1以上版本中,可以通過CREATE EVENT陳述句來創建事件,

CREATE
	[DEFINER={user | CURRENT_USER}]
	EVENT [IF NOT EXISTS] event_name
	ON SCHEDULE schedule
	[ON COMPLETION [NOT] PRESERVE]
	[ENABLE | DISABLE | DISABLE ON SLAVE]
	[COMMENT 'comment']
	DO event_body;

CREATE EVENT陳述句的子句:

子句 說明
DEFINER 可選,用于定義事件執行時檢查權限的用戶
IF NOT EXISTS 可選項,用于判斷要創建的事件是否存在
EVENT event_name 必選,用于指定事件名,event_name的最大長度為64個字符,如果為指定event_name,則默認為當前的MySQL用戶名(不區分大小寫)
ON SCHEDULE schedule 必選,用于定義執行的時間和時間間隔
ON COMPLETION [NOT] PRESERVE 可選,用于定義事件是否回圈執行,即是一次執行還是永久執行,默認為一次執行,即 NOT PRESERVE
ENABLE | DISABLE | DISABLE ON SLAVE 可選項,用于指定事件的一種屬性,其中,關鍵字ENABLE表示該事件是活動的,也就是調度器檢查事件是否必選呼叫;關鍵字DISABLE表示該事件是關閉的,也就是事件的宣告存盤到目錄中,但是調度器不會檢查它是否應該呼叫;關鍵字DISABLE ON SLAVE表示事件在從機中是關閉的,如果不指定這三個選擇中的任意一個,則在一個事件創建之后,它立即變為活動的,
COMMENT 'comment' 可選,用于定義事件的注釋
DO event_body 必選,用于指定事件啟動時所要執行的代碼,可以是任何有效的SQL陳述句、存盤程序或者一個計劃執行的事件,如果包含多條陳述句,可以使用BEGIN...END復合結構

在ON SCHEDULE子句中,引數schedule的值為一個AS子句,用于指定事件在某個時刻發生,其語法格式如下:

AT timestamp [+ INTERVAL interval] ...
  | EVERY interval
    [STARTS timestamp [+ INTERVAL interval] ...]
    [ENDS timestamp [+ INTERVAL interval] ...]

引數說明:

(1)timestamp:表示一個具體的時間點,后面加上一個時間間隔,表示在這個時間間隔后事件發生,

(2)EVERY子句:用于表示事件在指定時間區間內每隔多長時間發生一次,其中 SELECT子句用于指定開始時間;ENDS子句用于指定結束時間,

(3)interval:表示一個從現在開始的時間,其值由一個數值和單位構成,例如,使用“4 WEEK”表示4周;使用“‘1:10’ HOUR_MINUTE”表示1小時10分鐘,間隔的距離用DATE_ADD()函式來支配,

interval引數值的語法格式如下:

quantity {YEAR | QUARTER | MONTH | DAY | HOUR | MINUTE |
              WEEK | SECOND | YEAR_MONTH | DAY_HOUR | DAY_MINUTE |
              DAY_SECOND | HOUR_MINUTE | HOUR_SECOND | MINUTE_SECOND}

一些常用的時間間隔設定:

(1)每隔5秒鐘執行

ON SCHEDULE EVERY 5 SECOND

(2)每隔1分鐘執行

ON SCHEDULE EVERY 1 MINUTE

(3)每天凌晨1點執行

ON SCHEDULE EVERY 1 DAY STARTS DATE_ADD(DATE_ADD(CURDATE(), INTERVAL 1 DAY), INTERVAL 1 HOUR)

(4)每個月的第一天凌晨1點執行

ON SCHEDULE EVERY 1 MONTH STARTS DATE_ADD(DATE_ADD(DATE_SUB(CURDATE(),INTERVAL DAY(CURDATE())-1 DAY),INTERVAL 1 MONTH),INTERVAL 1 HOUR)

(5)每 3 個月,從現在起一周后開始

ON SCHEDULE EVERY 3 MONTH STARTS CURRENT_TIMESTAMP + 1 WEEK

(6)每十二個小時,從現在起三十分鐘后開始,并于現在起四個星期后結束

ON SCHEDULE EVERY 12 HOUR STARTS CURRENT_TIMESTAMP + INTERVAL 30 MINUTE ENDS CURRENT_TIMESTAMP + INTERVAL 4 WEEK

示例1:創建名稱為updateCardRecord的事件,用于每隔1秒鐘更新一次bbs_uhome_card_order_record表中charge_amount為null的資料

# 創建事件
CREATE  EVENT `updateCardRecord`
on schedule every 1 second
ON COMPLETION PRESERVE ENABLE 
DO UPDATE bbs_uhome_card_order_record set charge_amount=0,charge_gift_amount=0,update_time=now() WHERE charge_amount is null;

同樣可以借助存盤程序將執行的陳述句進行封裝

# 創建需要操作的sql陳述句的存盤程序
create procedure card_record()
begin
UPDATE bbs_uhome_card_order_record set charge_amount=0,charge_gift_amount=0,update_time=now() WHERE charge_amount is null;
end;

# 創建定時事件
CREATE  EVENT `updateCardRecord`
on schedule every 1 second
ON COMPLETION PRESERVE ENABLE 
DO
call card_record();

洗掉存盤程序(存盤程序名字card_record)

DROP PROCEDURE card_record;

查看存盤程序的創建代碼

show create procedure card_record;

查詢資料庫中的存盤程序

select name from mysql.proc

三、查詢事件

在MySQL中可以通過查詢information_schema.events表,查看已創建的事件,其陳述句如下:

SELECT * FROM information_schema.events; 

四、修改事件

在MySQL 5.1及以后版本中,事件被創建之后,還可以使用ALTER EVENT陳述句修改其定義和相關屬性,其語法如下:

ALTER
	[DEFINER={user | CURRENT_USER}]
	EVENT [IF NOT EXISTS] event_name
	ON SCHEDULE schedule
	[ON COMPLETION [NOT] PRESERVE]
	[ENABLE | DISABLE | DISABLE ON SLAVE]
	[COMMENT 'comment']
	DO event_body;

ALTER EVENT陳述句與CREATE EVENT陳述句基本相同,另外ALTER EVENT陳述句還有一個用法就是讓一個事件關倍訓再次活動,

五、啟動與關閉事件

另外ALTER EVENT陳述句還有一個用法就是讓一個事件關倍訓再次活動,

示例:啟動名稱為event_user的事件,

ALTER EVENT event_user ENABLE;

示例:關閉名稱為event_user的事件,

ALTER EVENT event_user DISABLE;

六、洗掉事件

在MySQL 5.1及以后版本中,洗掉已經創建的事件可以使用DROP EVENT陳述句來實作,

示例:洗掉名稱為event_user的事件,

DROP EVENT IF EXISTS event_user;

站在巨人肩膀上摘蘋果

https://blog.csdn.net/pan_junbiao/article/details/86489237

https://www.cnblogs.com/furenjian/p/11411103.html

轉載請註明出處,本文鏈接:https://www.uj5u.com/shujuku/231897.html

標籤:其他

上一篇:[20201208]為什么回傳2行記錄補充.txt

下一篇:MySQL資料庫基礎學習筆記(二)

標籤雲
其他(157675) Python(38076) JavaScript(25376) Java(17977) C(15215) 區塊鏈(8255) C#(7972) AI(7469) 爪哇(7425) MySQL(7132) html(6777) 基礎類(6313) sql(6102) 熊猫(6058) PHP(5869) 数组(5741) R(5409) Linux(5327) 反应(5209) 腳本語言(PerlPython)(5129) 非技術區(4971) Android(4554) 数据框(4311) css(4259) 节点.js(4032) C語言(3288) json(3245) 列表(3129) 扑(3119) C++語言(3117) 安卓(2998) 打字稿(2995) VBA(2789) Java相關(2746) 疑難問題(2699) 细绳(2522) 單片機工控(2479) iOS(2429) ASP.NET(2402) MongoDB(2323) 麻木的(2285) 正则表达式(2254) 字典(2211) 循环(2198) 迅速(2185) 擅长(2169) 镖(2155) 功能(1967) .NET技术(1958) Web開發(1951) python-3.x(1918) HtmlCss(1915) 弹簧靴(1913) C++(1909) xml(1889) PostgreSQL(1872) .NETCore(1853) 谷歌表格(1846) Unity3D(1843) for循环(1842)

熱門瀏覽
  • GPU虛擬機創建時間深度優化

    **?桔妹導讀:**GPU虛擬機實體創建速度慢是公有云面臨的普遍問題,由于通常情況下創建虛擬機屬于低頻操作而未引起業界的重視,實際生產中還是存在對GPU實體創建時間有苛刻要求的業務場景。本文將介紹滴滴云在解決該問題時的思路、方法、并展示最終的優化成果。 從公有云服務商那里購買過虛擬主機的資深用戶,一 ......

    uj5u.com 2020-09-10 06:09:13 more
  • 可編程網卡芯片在滴滴云網路的應用實踐

    **?桔妹導讀:**隨著云規模不斷擴大以及業務層面對延遲、帶寬的要求越來越高,采用DPDK 加速網路報文處理的方式在橫向縱向擴展都出現了局限性。可編程芯片成為業界熱點。本文主要講述了可編程網卡芯片在滴滴云網路中的應用實踐,遇到的問題、帶來的收益以及開源社區貢獻。 #1. 資料中心面臨的問題 隨著滴滴 ......

    uj5u.com 2020-09-10 06:10:21 more
  • 滴滴資料通道服務演進之路

    **?桔妹導讀:**滴滴資料通道引擎承載著全公司的資料同步,為下游實時和離線場景提供了必不可少的源資料。隨著任務量的不斷增加,資料通道的整體架構也隨之發生改變。本文介紹了滴滴資料通道的發展歷程,遇到的問題以及今后的規劃。 #1. 背景 資料,對于任何一家互聯網公司來說都是非常重要的資產,公司的大資料 ......

    uj5u.com 2020-09-10 06:11:05 more
  • 滴滴AI Labs斬獲國際機器翻譯大賽中譯英方向世界第三

    **桔妹導讀:**深耕人工智能領域,致力于探索AI讓出行更美好的滴滴AI Labs再次斬獲國際大獎,這次獲獎的專案是什么呢?一起來看看詳細報道吧! 近日,由國際計算語言學協會ACL(The Association for Computational Linguistics)舉辦的世界最具影響力的機器 ......

    uj5u.com 2020-09-10 06:11:29 more
  • MPP (Massively Parallel Processing)大規模并行處理

    1、什么是mpp? MPP (Massively Parallel Processing),即大規模并行處理,在資料庫非共享集群中,每個節點都有獨立的磁盤存盤系統和記憶體系統,業務資料根據資料庫模型和應用特點劃分到各個節點上,每臺資料節點通過專用網路或者商業通用網路互相連接,彼此協同計算,作為整體提供 ......

    uj5u.com 2020-09-10 06:11:41 more
  • 滴滴資料倉庫指標體系建設實踐

    **桔妹導讀:**指標體系是什么?如何使用OSM模型和AARRR模型搭建指標體系?如何統一流程、規范化、工具化管理指標體系?本文會對建設的方法論結合滴滴資料指標體系建設實踐進行解答分析。 #1. 什么是指標體系 ##1.1 指標體系定義 指標體系是將零散單點的具有相互聯系的指標,系統化的組織起來,通 ......

    uj5u.com 2020-09-10 06:12:52 more
  • 單表千萬行資料庫 LIKE 搜索優化手記

    我們經常在資料庫中使用 LIKE 運算子來完成對資料的模糊搜索,LIKE 運算子用于在 WHERE 子句中搜索列中的指定模式。 如果需要查找客戶表中所有姓氏是“張”的資料,可以使用下面的 SQL 陳述句: SELECT * FROM Customer WHERE Name LIKE '張%' 如果需要 ......

    uj5u.com 2020-09-10 06:13:25 more
  • 滴滴Ceph分布式存盤系統優化之鎖優化

    **桔妹導讀:**Ceph是國際知名的開源分布式存盤系統,在工業界和學術界都有著重要的影響。Ceph的架構和演算法設計發表在國際系統領域頂級會議OSDI、SOSP、SC等上。Ceph社區得到Red Hat、SUSE、Intel等大公司的大力支持。Ceph是國際云計算領域應用最廣泛的開源分布式存盤系統, ......

    uj5u.com 2020-09-10 06:14:51 more
  • es~通過ElasticsearchTemplate進行聚合~嵌套聚合

    之前寫過《es~通過ElasticsearchTemplate進行聚合操作》的文章,這一次主要寫一個嵌套的聚合,例如先對sex集合,再對desc聚合,最后再對age求和,共三層嵌套。 Aggregations的部分特性類似于SQL語言中的group by,avg,sum等函式,Aggregation ......

    uj5u.com 2020-09-10 06:14:59 more
  • 爬蟲日志監控 -- Elastc Stack(ELK)部署

    傻瓜式部署,只需替換IP與用戶 導讀: 現ELK四大組件分別為:Elasticsearch(核心)、logstash(處理)、filebeat(采集)、kibana(可視化) 下載均在https://www.elastic.co/cn/downloads/下tar包,各組件版本最好一致,配合fdm會 ......

    uj5u.com 2020-09-10 06:15:05 more
最新发布
  • day02-2-商鋪查詢快取

    功能02-商鋪查詢快取 3.商鋪詳情快取查詢 3.1什么是快取? 快取就是資料交換的緩沖區(稱作Cache),是存盤資料的臨時地方,一般讀寫性能較高。 快取的作用: 降低后端負載 提高讀寫效率,降低回應時間 快取的成本: 資料一致性成本 代碼維護成本 運維成本 3.2需求說明 如下,當我們點擊商店詳 ......

    uj5u.com 2023-04-20 08:33:24 more
  • MySQL中binlog備份腳本分享

    關于MySQL的二進制日志(binlog),我們都知道二進制日志(binlog)非常重要,尤其當你需要point to point災難恢復的時侯,所以我們要對其進行備份。關于二進制日志(binlog)的備份,可以基于flush logs方式先切換binlog,然后拷貝&壓縮到到遠程服務器或本地服務器 ......

    uj5u.com 2023-04-20 08:28:06 more
  • day02-短信登錄

    功能實作02 2.功能01-短信登錄 2.1基于Session實作登錄 2.1.1思路分析 2.1.2代碼實作 2.1.2.1發送短信驗證碼 發送短信驗證碼: 發送驗證碼的介面為:http://127.0.0.1:8080/api/user/code?phone=xxxxx<手機號> 請求方式:PO ......

    uj5u.com 2023-04-20 08:27:27 more
  • 快取與資料庫雙寫一致性幾種策略分析

    本文將對幾種快取與資料庫保證資料一致性的使用方式進行分析。為保證高并發性能,以下分析場景不考慮執行的原子性及加鎖等強一致性要求的場景,僅追求最終一致性。 ......

    uj5u.com 2023-04-20 08:26:48 more
  • sql陳述句優化

    問題查找及措施 問題查找 需要找到具體的代碼,對其進行一對一優化,而非一直把關注點放在服務器和sql平臺 降低簡化每個事務中處理的問題,盡量不要讓一個事務拖太長的時間 例如檔案上傳時,應將檔案上傳這一步放在事務外面 微軟建議 4.啟動sql定時執行計劃 怎么啟動sqlserver代理服務-百度經驗 ......

    uj5u.com 2023-04-20 08:26:35 more
  • 云時代,MySQL到ClickHouse資料同步產品對比推薦

    ClickHouse 在執行分析查詢時的速度優勢很好的彌補了MySQL的不足,但是對于很多開發者和DBA來說,如何將MySQL穩定、高效、簡單的同步到 ClickHouse 卻很困難。本文對比了 NineData、MaterializeMySQL(ClickHouse自帶)、Bifrost 三款產品... ......

    uj5u.com 2023-04-20 08:26:29 more
  • sql陳述句優化

    問題查找及措施 問題查找 需要找到具體的代碼,對其進行一對一優化,而非一直把關注點放在服務器和sql平臺 降低簡化每個事務中處理的問題,盡量不要讓一個事務拖太長的時間 例如檔案上傳時,應將檔案上傳這一步放在事務外面 微軟建議 4.啟動sql定時執行計劃 怎么啟動sqlserver代理服務-百度經驗 ......

    uj5u.com 2023-04-20 08:25:13 more
  • Redis 報”OutOfDirectMemoryError“(堆外記憶體溢位)

    Redis 報錯“OutOfDirectMemoryError(堆外記憶體溢位) ”問題如下: 一、報錯資訊: 使用 Redis 的業務介面 ,產生 OutOfDirectMemoryError(堆外記憶體溢位),如圖: 格式化后的報錯資訊: { "timestamp": "2023-04-17 22: ......

    uj5u.com 2023-04-20 08:24:54 more
  • day02-2-商鋪查詢快取

    功能02-商鋪查詢快取 3.商鋪詳情快取查詢 3.1什么是快取? 快取就是資料交換的緩沖區(稱作Cache),是存盤資料的臨時地方,一般讀寫性能較高。 快取的作用: 降低后端負載 提高讀寫效率,降低回應時間 快取的成本: 資料一致性成本 代碼維護成本 運維成本 3.2需求說明 如下,當我們點擊商店詳 ......

    uj5u.com 2023-04-20 08:24:03 more
  • day02-短信登錄

    功能實作02 2.功能01-短信登錄 2.1基于Session實作登錄 2.1.1思路分析 2.1.2代碼實作 2.1.2.1發送短信驗證碼 發送短信驗證碼: 發送驗證碼的介面為:http://127.0.0.1:8080/api/user/code?phone=xxxxx<手機號> 請求方式:PO ......

    uj5u.com 2023-04-20 08:23:11 more