mysql建立分割槽、儲存統計、定時事件

阿新 • • 發佈：2018-12-10

DROP TABLE IF EXISTS  monitor_printer;
CREATE TABLE monitor_printer
(
  id int NOT NULL AUTO_INCREMENT COMMENT '自增長id（主鍵）',
  monitorId int NOT NULL COMMENT '監控項ID',
  tonerLow int(11) DEFAULT '0' COMMENT '墨粉不足',
  tonerUtilization decimal(18,2) DEFAULT '0' COMMENT '墨粉使用率',
  lineState int(11) DEFAULT '0' 
 COMMENT '工作狀態',
  paperOut int(11) DEFAULT '0' COMMENT '缺紙狀態',
  paperJam int(11) DEFAULT '0' COMMENT '卡紙狀態',
  busyStatus int(11) DEFAULT '0' COMMENT '繁忙狀態',
  waitStatus int(11) DEFAULT '0' COMMENT '等待狀態',
  initializeStatus int(11) DEFAULT '0' COMMENT '初始化狀態',
  doorOpenStatus int(11) DEFAULT '0' COMMENT '機蓋開啟狀態' 
,
  createTime datetime COMMENT '建立時間',
  PRIMARY KEY (id,createTime),
  index monitorId_time(monitorId,createTime)
)DEFAULT CHARSET=utf8;

DROP TABLE IF EXISTS  monitor_printer_latest;
CREATE TABLE monitor_printer_latest
(
  id int NOT NULL AUTO_INCREMENT COMMENT '自增長id（主鍵）',
  monitorId int NOT NULL 
 COMMENT '監控項ID',
  tonerLow int(11) DEFAULT '0' COMMENT '墨粉不足',
  tonerUtilization decimal(18,2) DEFAULT '0' COMMENT '墨粉使用率',
  lineState int(11) DEFAULT '0' COMMENT '工作狀態',
  paperOut int(11) DEFAULT '0' COMMENT '缺紙狀態',
  paperJam int(11) DEFAULT '0' COMMENT '卡紙狀態',
  busyStatus int(11) DEFAULT '0' COMMENT '繁忙狀態',
  waitStatus int(11) DEFAULT '0' COMMENT '等待狀態',
  initializeStatus int(11) DEFAULT '0' COMMENT '初始化狀態',
  doorOpenStatus int(11) DEFAULT '0' COMMENT '機蓋開啟狀態',
  createTime datetime COMMENT '建立時間',
  PRIMARY KEY (id,createTime),
  index monitorId_time(monitorId,createTime)
)DEFAULT CHARSET=utf8;

DROP TABLE IF EXISTS  monitor_printer_stat_hour;
CREATE TABLE monitor_printer_stat_hour
(
    id int NOT NULL AUTO_INCREMENT COMMENT '自增長id（主鍵）',
    monitorId int NOT NULL COMMENT '監控項ID',
    tonerLow_max int(11) DEFAULT '0' COMMENT '最大墨粉不足',
    tonerLow_min int(11) DEFAULT '0' COMMENT '最小墨粉不足',
    tonerLow_ave decimal(18,2) DEFAULT '0' COMMENT '平均墨粉不足',
    tonerUtilization_max decimal(18,2) DEFAULT '0' COMMENT '最大墨粉使用率',
    tonerUtilization_min decimal(18,2) DEFAULT '0' COMMENT '最小墨粉使用率',
    tonerUtilization_ave decimal(18,2) DEFAULT '0' COMMENT '平均墨粉使用率',
    lineState_max int(11) DEFAULT '0' COMMENT '最大工作狀態',
    lineState_min int(11) DEFAULT '0' COMMENT '最小工作狀態',
    lineState_ave decimal(18,2) DEFAULT '0' COMMENT '平均工作狀態',
    doorOpenStatus_max int(11) DEFAULT '0' COMMENT '最大機蓋開啟狀態',
    doorOpenStatus_min int(11) DEFAULT '0' COMMENT '最小機蓋開啟狀態',
    doorOpenStatus_ave decimal(18,2) DEFAULT '0' COMMENT '平均機蓋開啟狀態',
    createTime datetime COMMENT '建立時間',
    PRIMARY KEY (id,createTime),
    index monitorId_time(monitorId,createTime)
)DEFAULT CHARSET=utf8;

-- 以天為單位 建立 分割槽
alter table  monitor_printer
PARTITION BY RANGE (TO_DAYS(createTime))
(PARTITION pmax VALUES LESS THAN MAXVALUE);

DELIMITER $$
DROP EVENT IF EXISTS event_create_partition_printer$$
CREATE EVENT event_create_partition_printer ON SCHEDULE EVERY 1 DAY STARTS TIMESTAMP(CURDATE(), '00:00:00') ON COMPLETION PRESERVE ENABLE DO BEGIN
    DECLARE partition_name VARCHAR(32);
    DECLARE partition_desc INT UNSIGNED;
    SET partition_name = CONCAT('pd', DATE_FORMAT(DATE_SUB(CURRENT_DATE(), INTERVAL 1 DAY),'%Y%m%d'));
    SET partition_desc = TO_DAYS(CURRENT_DATE());
    SET @partition_alter = CONCAT('ALTER TABLE  monitor_printer REORGANIZE PARTITION pmax INTO (
        PARTITION ', partition_name, ' VALUES LESS THAN (', partition_desc, '),
        PARTITION pmax VALUES LESS THAN MAXVALUE)');
    PREPARE stmt FROM @partition_alter;
    EXECUTE stmt;
    DEALLOCATE PREPARE stmt;
END $$
DELIMITER ;

-- 小時統計表儲存過程
DELIMITER $$
DROP PROCEDURE IF EXISTS proce_printer_stat_hour$$
CREATE PROCEDURE proce_printer_stat_hour(IN startTime TIMESTAMP,IN endTime TIMESTAMP)
BEGIN
    INSERT INTO  monitor_printer_stat_hour(
        monitorId,
        tonerLow_max,  tonerUtilization_max,  lineState_max, doorOpenStatus_max,
        tonerLow_min,  tonerUtilization_min,  lineState_min, doorOpenStatus_min,
        tonerLow_ave,  tonerUtilization_ave,  lineState_ave, doorOpenStatus_ave,
        createTime
    )SELECT
        monitorId,
        MAX(tonerLow) AS tonerLow_max,  MAX(tonerUtilization) AS tonerUtilization_max,  MAX(lineState) AS lineState_max,  MIN(doorOpenStatus) AS doorOpenStatus_min,
        MIN(tonerLow) AS tonerLow_min,  MIN(tonerUtilization) AS tonerUtilization_min,  MIN(lineState) AS lineState_min,  MIN(doorOpenStatus) AS doorOpenStatus_min,
        AVG(tonerLow) AS tonerLow_ave,  AVG(tonerUtilization) AS tonerUtilization_ave,  AVG(lineState) AS lineState_ave, (select FLOOR(AVG(doorOpenStatus))) AS doorOpenStatus_ave,
        endTime AS createTime
FROM   monitor_printer_latest WHERE createTime >= startTime AND  createTime <= endTime GROUP BY monitorId;
END $$

-- 建立事件 呼叫 儲存過程
DELIMITER $$
DROP EVENT IF EXISTS event_hongshan_stat_hour$$
CREATE EVENT event_hongshan_stat_hour ON SCHEDULE EVERY 1 HOUR STARTS NOW()+INTERVAL 3600-(TIME_TO_SEC(NOW()))%3600 SECOND ON COMPLETION PRESERVE ENABLE DO
BEGIN
    DECLARE endTime TIMESTAMP;
    DECLARE startTime TIMESTAMP;
    SET endTime=now()-INTERVAL (TIME_TO_SEC(NOW()))%3600 SECOND;
    SET startTime = endTime - INTERVAL 1 hour;

    call proce_printer_stat_hour(startTime,endTime);
END $$

/* 定時清理最新小時過度表*/
DELIMITER $$
DROP EVENT IF EXISTS event_clear_table_latest$$
CREATE EVENT event_clear_table_latest ON SCHEDULE EVERY 1 HOUR STARTS NOW() ON COMPLETION PRESERVE ENABLE DO
BEGIN
     DECLARE clearTime TIMESTAMP;
     SET clearTime=now()- INTERVAL 1 hour;
    
     delete from imp_monitordb.monitor_printer_latest where createTime <= clearTime ;
END $$ TABLE IF EXISTS  monitor_printer;
CREATE TABLE monitor_printer
(
  id int NOT NULL AUTO_INCREMENT COMMENT '自增長id（主鍵）',
  monitorId int NOT NULL COMMENT '監控項ID',
  tonerLow int(11) DEFAULT '0' COMMENT '墨粉不足',
  tonerUtilization decimal(18,2) DEFAULT '0' COMMENT '墨粉使用率',
  lineState int(11) DEFAULT '0' COMMENT '工作狀態',
  paperOut int(11) DEFAULT '0' COMMENT '缺紙狀態',
  paperJam int(11) DEFAULT '0' COMMENT '卡紙狀態',
  busyStatus int(11) DEFAULT '0' COMMENT '繁忙狀態',
  waitStatus int(11) DEFAULT '0' COMMENT '等待狀態',
  initializeStatus int(11) DEFAULT '0' COMMENT '初始化狀態',
  doorOpenStatus int(11) DEFAULT '0' COMMENT '機蓋開啟狀態',
  createTime datetime COMMENT '建立時間',
  PRIMARY KEY (id,createTime),
  index monitorId_time(monitorId,createTime)
)DEFAULT CHARSET=utf8;

DROP TABLE IF EXISTS  monitor_printer_latest;
CREATE TABLE monitor_printer_latest
(
  id int NOT NULL AUTO_INCREMENT COMMENT '自增長id（主鍵）',
  monitorId int NOT NULL COMMENT '監控項ID',
  tonerLow int(11) DEFAULT '0' COMMENT '墨粉不足',
  tonerUtilization decimal(18,2) DEFAULT '0' COMMENT '墨粉使用率',
  lineState int(11) DEFAULT '0' COMMENT '工作狀態',
  paperOut int(11) DEFAULT '0' COMMENT '缺紙狀態',
  paperJam int(11) DEFAULT '0' COMMENT '卡紙狀態',
  busyStatus int(11) DEFAULT '0' COMMENT '繁忙狀態',
  waitStatus int(11) DEFAULT '0' COMMENT '等待狀態',
  initializeStatus int(11) DEFAULT '0' COMMENT '初始化狀態',
  doorOpenStatus int(11) DEFAULT '0' COMMENT '機蓋開啟狀態',
  createTime datetime COMMENT '建立時間',
  PRIMARY KEY (id,createTime),
  index monitorId_time(monitorId,createTime)
)DEFAULT CHARSET=utf8;

DROP TABLE IF EXISTS  monitor_printer_stat_hour;
CREATE TABLE monitor_printer_stat_hour
(
    id int NOT NULL AUTO_INCREMENT COMMENT '自增長id（主鍵）',
    monitorId int NOT NULL COMMENT '監控項ID',
    tonerLow_max int(11) DEFAULT '0' COMMENT '最大墨粉不足',
    tonerLow_min int(11) DEFAULT '0' COMMENT '最小墨粉不足',
    tonerLow_ave decimal(18,2) DEFAULT '0' COMMENT '平均墨粉不足',
    tonerUtilization_max decimal(18,2) DEFAULT '0' COMMENT '最大墨粉使用率',
    tonerUtilization_min decimal(18,2) DEFAULT '0' COMMENT '最小墨粉使用率',
    tonerUtilization_ave decimal(18,2) DEFAULT '0' COMMENT '平均墨粉使用率',
    lineState_max int(11) DEFAULT '0' COMMENT '最大工作狀態',
    lineState_min int(11) DEFAULT '0' COMMENT '最小工作狀態',
    lineState_ave decimal(18,2) DEFAULT '0' COMMENT '平均工作狀態',
    doorOpenStatus_max int(11) DEFAULT '0' COMMENT '最大機蓋開啟狀態',
    doorOpenStatus_min int(11) DEFAULT '0' COMMENT '最小機蓋開啟狀態',
    doorOpenStatus_ave decimal(18,2) DEFAULT '0' COMMENT '平均機蓋開啟狀態',
    createTime datetime COMMENT '建立時間',
    PRIMARY KEY (id,createTime),
    index monitorId_time(monitorId,createTime)
)DEFAULT CHARSET=utf8;

alter table  monitor_printer
PARTITION BY RANGE (TO_DAYS(createTime))
(PARTITION pmax VALUES LESS THAN MAXVALUE);

-- 以天為單位 建立 分割槽
DELIMITER $$
DROP EVENT IF EXISTS event_create_partition_printer$$
CREATE EVENT event_create_partition_printer ON SCHEDULE EVERY 1 DAY STARTS TIMESTAMP(CURDATE(), '00:00:00') ON COMPLETION PRESERVE ENABLE DO BEGIN
    DECLARE partition_name VARCHAR(32);
    DECLARE partition_desc INT UNSIGNED;
    SET partition_name = CONCAT('pd', DATE_FORMAT(DATE_SUB(CURRENT_DATE(), INTERVAL 1 DAY),'%Y%m%d'));
    SET partition_desc = TO_DAYS(CURRENT_DATE());
    SET @partition_alter = CONCAT('ALTER TABLE  monitor_printer REORGANIZE PARTITION pmax INTO (
        PARTITION ', partition_name, ' VALUES LESS THAN (', partition_desc, '),
        PARTITION pmax VALUES LESS THAN MAXVALUE)');
    PREPARE stmt FROM @partition_alter;
    EXECUTE stmt;
    DEALLOCATE PREPARE stmt;
END $$
DELIMITER ;

-- 小時統計表儲存過程
DELIMITER $$
DROP PROCEDURE IF EXISTS proce_printer_stat_hour$$
CREATE PROCEDURE proce_printer_stat_hour(IN startTime TIMESTAMP,IN endTime TIMESTAMP)
BEGIN
    INSERT INTO  monitor_printer_stat_hour(
        monitorId,
        tonerLow_max,  tonerUtilization_max,  lineState_max, doorOpenStatus_max,
        tonerLow_min,  tonerUtilization_min,  lineState_min, doorOpenStatus_min,
        tonerLow_ave,  tonerUtilization_ave,  lineState_ave, doorOpenStatus_ave,
        createTime
    )SELECT
        monitorId,
        MAX(tonerLow) AS tonerLow_max,  MAX(tonerUtilization) AS tonerUtilization_max,  MAX(lineState) AS lineState_max,  MIN(doorOpenStatus) AS doorOpenStatus_min,
        MIN(tonerLow) AS tonerLow_min,  MIN(tonerUtilization) AS tonerUtilization_min,  MIN(lineState) AS lineState_min,  MIN(doorOpenStatus) AS doorOpenStatus_min,
        AVG(tonerLow) AS tonerLow_ave,  AVG(tonerUtilization) AS tonerUtilization_ave,  AVG(lineState) AS lineState_ave, (select FLOOR(AVG(doorOpenStatus))) AS doorOpenStatus_ave,
        endTime AS createTime
FROM   monitor_printer_latest WHERE createTime >= startTime AND  createTime <= endTime GROUP BY monitorId;
END $$

-- 建立事件 呼叫 儲存過程
DELIMITER $$
DROP EVENT IF EXISTS event_hongshan_stat_hour$$
CREATE EVENT event_hongshan_stat_hour ON SCHEDULE EVERY 1 HOUR STARTS NOW()+INTERVAL 3600-(TIME_TO_SEC(NOW()))%3600 SECOND ON COMPLETION PRESERVE ENABLE DO
BEGIN
    DECLARE endTime TIMESTAMP;
    DECLARE startTime TIMESTAMP;
    SET endTime=now()-INTERVAL (TIME_TO_SEC(NOW()))%3600 SECOND;
    SET startTime = endTime - INTERVAL 1 hour;

    call proce_printer_stat_hour(startTime,endTime);
END $$

/* 定時清理最新小時過度表*/
DELIMITER $$
DROP EVENT IF EXISTS event_clear_table_latest$$
CREATE EVENT event_clear_table_latest ON SCHEDULE EVERY 1 HOUR STARTS NOW() ON COMPLETION PRESERVE ENABLE DO
BEGIN
     DECLARE clearTime TIMESTAMP;
     SET clearTime=now()- INTERVAL 1 hour;
    
     delete from imp_monitordb.monitor_printer_latest where createTime <= clearTime ;
END $$

mysql建立分割槽、儲存統計、定時事件

DROP TABLE IF EXISTS monitor_printer; CREATE TABLE monitor_printer ( id int NOT NULL AUTO_INCREMENT COMMENT '自增長id（主鍵）', monitorId int NOT NULL C

mysql 利用儲存過程和定時事件實現分割槽的自動建立與自動刪除

公司在做郵件伺服器的時候，要把收到的郵件的主要的資訊儲存到資料庫中。因此在資料庫中建立了 2 張資料表：arc 表：郵件的主體資訊；arc_att 表：郵件的附件資訊；但是，由於每天收到的郵件數量有1萬封左右，所以過幾個月後郵件的主體資訊表就達到了百萬行記錄。這麼大的資料量非常的不利於資料

MySQL------索引、叢集、儲存原理、優化查詢

1. MySQL資料庫儲存的原理: 儲存過程是一個可程式設計的函式，它在資料庫中建立並儲存。它可以有SQL語句和一些特殊的控制結構組成。當希望在不同的應用程式或平臺上執行相同的函式，或者封裝特定功能時，儲存過程是非常有用的。資料庫中的儲存過程可以看做是對程式設計中面向物件方法的模擬。它允

Mysql的檢視、儲存過程、函式、索引全解析

檢視是查詢命令結果構成的一個虛擬表（非真實存在），其本質是【根據SQL語句獲取動態的資料集，併為其命名】，使用者使用時只需使用【名稱】即可獲取結果集合，並可以當作表來查詢使用。 1建立檢視 --格式：CREATE VIEW 檢視名稱 AS SQL語句 CREATE VIEW v1 AS S

mysql-檢視、觸發器、事務、儲存過程、函式

目錄檢視觸發器事務儲存過程流程控制一、檢視檢視是由查詢結果構成的一張虛擬表，和真實的表一樣，帶有名稱的列和行資料強調：檢視是永久儲存的，但是檢視儲存的不是資料，只是一條sql語句檢視的特點：檢視的列可以來自不同的表，是表的抽象和邏輯意義上建立的新關係。

mysql資料庫學習11-儲存過程、函式、觸發器

儲存的程式 ======================================== * 資料庫中儲存的程式，對資料進行運算處理 * 儲存過程 * 函式 * 觸發器會話變數

MySQL：檢視、觸發器、儲存過程、事務

檢視：檢視，虛擬表建立虛擬表： # 語法： # create view 虛擬表名稱 as 虛擬表; create view course_and_teacher as select * from course inner join teacher on course.teacher_id =

mysql 初級篇(三) 觸發器、儲存過程、遊標

mysql 初級篇(三) 觸發器、儲存過程、遊標觸發器triggerCreat trigger buggoodAfterInsertOn ordFor each rowBeginUpdate goods set num=num-new.much where id=new.gidEnd

【轉】MySQL資料庫外來鍵、檢視、儲存過程、觸發器的優缺點

https://www.yiibai.com/mysql/introduction-sql-views.html 檢視使用資料庫檢視的優點資料庫檢視允許簡化複雜查詢：資料庫檢視由與許多基礎表相關聯的SQL語句定義。您可以使用資料庫檢視來隱藏終端使用者和外部應用

MySQL筆記(二)：儲存結構、函式、流程控制

MySQL筆記(二)：變數、儲存結構、函式、流程控制變數 MySQL中的變數分為系統變數和自定義變數，系統變數分為全域性變數和會話變數，自定義變數分為區域性變數和使用者變數一、系統變數作用域： ①全域性變數作用域：伺服器每次啟動將為所有的全域性變數賦初始值，針對於

初學mysql(十)-資料庫之儲存過程、函式與遊標-自定義函式和流程控制（下）

上一篇部落格講了儲存過程、函式、以及遊標，這一篇部落格接著上一篇部落格來說。首先說說mysql資料庫中的流程控制及自定義函式的使用。自定義函式：根據所需要的功能，使用流程控制來完成所需要的功能，完成功能的程式碼就稱為自定義函式。要想完成自定義函式就必須學會流程控制的使

MySQL 第八篇：自定義函式、儲存過程、遊標

本篇內容由猿道教育的課程內容整理而來。我把MySQL的內容整理成9篇部落格，學完這9篇部落格雖不能說能成為大神，但是應付一般中小企業的開發已經足夠了，有疑問或建議的歡迎留言討論。自定義函式一、函式的概念與定義 1、理解函式函式可以看作是

mysql複合語句、儲存過程、遊標

一、概念： 1、mysql複合語句：必須放在儲存過程或者函式或者其他資料庫物件中 2、儲存過程：一組SQL語句組成，可以帶引數，用於實現特定功能 BEGIN #Routine body goes here... END;放在BEGIN……END中的語句就是複合語句二、

MySql—檢視、函式、儲存過程、觸發器

MySql高階—檢視、函式、儲存過程、觸發器目錄一、檢視 1 一、檢視 1、檢視的定義檢視的定義：檢視是由查詢結果形成的一張虛擬表，是表通過某種運算得到的一個投影。同一張表可以建立多個檢視建立檢視的語法： create view view_name as select 語句說明：

mysql筆記三-----sql儲存過程、事務的隔離級別和sql各查詢的區別、防黑

儲存過程 ※※儲存過程※※※ 定義： create procedure 過程名(引數) begin 多條sql語句 end 呼叫： call 過程名(實參) 例項1--無參的儲存過程： △小細節：要把預設的語句結束“;”號改成其它如“$$”，

我的Python成長之路--Day48--mysql高階(檢視、觸發器、事物、儲存過程、函式、流程控制、資料備份與恢復)

目錄 1、檢視 2、觸發器 3、事物自定義函式 1、檢視 1.1、什麼是檢視檢視是一張表或者多張表的查詢結果構成的一張虛擬表

MySQL觸發器、儲存過程、自定義函式、檢視常用SQL

1.建立一個userinfo表新增記錄時的觸發器將新增日誌加入到userinfolog 2.建立一個向userinfo表新增記錄的儲存過程 3.根據userinfo表的出生日期欄位我們將建立一個簡單算得年齡的自定義函式 4.建立一個userinfo的檢視呼叫年齡函式

Apache Ignite學習筆記:建立快取、儲存資料、讀取快取

使用Apache Ignite2.4 建立快取、儲存資料、讀取快取 1 Ignite初始化 (1)初始化程式碼 //使用配置檔案 example-default.xml 初始化Ignite Ignite ignite=I

【JAVA】使用 jedis操作redis——連線、儲存資料、切庫等

本篇運用Java呼叫jedis包（jedis線上文件API ），做簡單操作例項。安裝jedis 1. 2.9.0 jar 版本下載： jedis-2.9.0.jar 2. 新建專案，新增該驅動包連線到 redis 服務

C語言（一資料型別、儲存類、分配空間）

C語言是一種移植性強，面向過程的語言，最初由丹尼斯創立，用於編寫UNIX作業系統，移植性強指的是它的程式碼通用性強。特點：操作簡易，結構化語言，適合處理底層事件。我的第一個C語言程式 #include <stdio.h> /*前處理器指令，在實際編譯之前執行的*

mysql建立分割槽、儲存統計、定時事件

相關推薦