資料庫異步寫入功能概要設計

在新項目中，我們要求每一個寫入資料庫的操作不允許直接寫入到MYSQL資料庫中，防止在大并發情況下資料庫的瓶頸出現，解決的思路是凡是有需要更新、插入資料庫的需求，必須按規定封裝成JSON資料，然後存放到REDIS的隊列中，由資料庫寫入隊列監控程式進行監視，發現後串行寫入到資料庫中。如果JAVA項目有在寫入資料庫的同時修改緩存的需要，那麼自行修改緩存，資料庫寫入程式不負責修改緩存資料。

下面以一個有代表性的寫入動作為例，進行說明：

學生表

CREATE TABLE `t_base_student` (
  `ID` int(11) NOT NULL AUTO_INCREMENT COMMENT '學生表主鍵，自增長',
  `STUDENT_GUID` char(36) DEFAULT NULL COMMENT '學生的GUID編号',
  `STUDENT_NAME` varchar(20) DEFAULT NULL COMMENT '學生姓名',
  `XB` char(2) DEFAULT NULL COMMENT '性别',
  `BYXX` varchar(50) DEFAULT NULL COMMENT '畢業學校',
  PRIMARY KEY (`ID`)
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;      

插入一條測試資料

INSERT INTO `t_base_student` VALUES ('1', 'bd81eb89-b933-11e3-8d96-7427eab28b71', '黃海', '男', '東北師範大學');      

家長表

CREATE TABLE `t_base_parent` (
  `PARENT_ID` int(11) NOT NULL AUTO_INCREMENT COMMENT '家長的編号',
  `PARENT_GUID` char(36) DEFAULT NULL COMMENT '家長的GUID号',
  `PARENT_NAME` varchar(255) DEFAULT NULL COMMENT '家長的姓名',
  `STUDENT_ID` int(11) DEFAULT NULL COMMENT '學生号',
  `STUDENT_GUID` char(36) DEFAULT NULL COMMENT '學生GUID号',
  `PARENT_TYPE` int(11) DEFAULT NULL COMMENT '家長的類型',
  PRIMARY KEY (`PARENT_ID`)
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;      

 插入兩條測試資料

INSERT INTO `t_base_parent` VALUES ('1', 'f1af5347-b933-11e3-8d96-7427eab28b71', '黃章', '1', 'bd81eb89-b933-11e3-8d96-7427eab28b71', '1');
INSERT INTO `t_base_parent` VALUES ('2', '0f517382-b934-11e3-8d96-7427eab28b71', '王雲', '1', 'bd81eb89-b933-11e3-8d96-7427eab28b71', '2');      

 最終确定使用存儲過程來解決這個問題：

-- 删除存儲過程

drop PROCEDURE sp_addstudent;

-- 清空測試資料表

TRUNCATE TABLE a;

TRUNCATE TABLE t_base_parent;

TRUNCATE TABLE t_base_student;

-- 'bd81eb89-b933-11e3-8d96-7427eab28b71','黃海','男','東北師範大學'

CREATE PROCEDURE sp_addstudent (IN V_STUDENT_GUID CHAR (36),IN V_STUDENT_NAME VARCHAR (20),V_XB CHAR (2),V_BYXX VARCHAR (50))

BEGIN

DECLARE v_student_id INT;

START TRANSACTION;

INSERT INTO t_base_student (STUDENT_GUID,STUDENT_NAME,XB,BYXX)VALUES(V_STUDENT_GUID,V_STUDENT_NAME,V_XB,V_BYXX);

SELECT LAST_INSERT_ID() INTO v_student_id;

INSERT INTO a VALUES(v_student_id);

COMMIT;

END;