MySQL避免重複插入記錄方法(ignore,Replace,ON DUPLICATE KEY UPDATE)

本文章來給你們提供三種在mysql中避免重複插入記錄方法,主要是講到了ignore,Replace,ON DUPLICATE KEY UPDATE三種方法,各位同窗可嘗試參考。php

案一:使用ignore關鍵字html

若是是用主鍵primary或者惟一索引unique區分了記錄的惟一性,避免重複插入記錄可使用:mysql

 代碼以下 複製代碼
1 INSERT IGNORE INTO `table_name` (`email`, `phone`, `user_id`) VALUES ('test9@163.com', '99999', '9999');

這樣當有重複記錄就會忽略,執行後返回數字0算法

還有個應用就是複製表,避免重複記錄:sql

 代碼以下 複製代碼
1 INSERT IGNORE INTO `table_1` (`name`) SELECT `name` FROM `table_2`;

方案二:使用Replace數據庫

語法格式:併發

 代碼以下 複製代碼
REPLACE INTO `table_name`(`col_name`, ...) VALUES (...);
REPLACE INTO `table_name` (`col_name`, ...) SELECT ...;
REPLACE INTO `table_name` SET `col_name`='value',

...算法說明:
REPLACE的運行與INSERT很相像,可是若是舊記錄與新記錄有相同的值,則在新記錄被插入以前,舊記錄被刪除,即:函數

嘗試把新行插入到表中 
當由於對於主鍵或惟一關鍵字出現重複關鍵字錯誤而形成插入失敗時: 
從表中刪除含有重複關鍵字值的衝突行 
再次嘗試把新行插入到表中 
舊記錄與新記錄有相同的值的判斷標準就是:
表有一個PRIMARY KEY或UNIQUE索引,不然,使用一個REPLACE語句沒有意義。該語句會與INSERT相同,由於沒有索引被用於肯定是否新行復制了其它的行。高併發

返回值:
REPLACE語句會返回一個數,來指示受影響的行的數目。該數是被刪除和被插入的行數的和
受影響的行數能夠容易地肯定是否REPLACE只添加了一行,或者是否REPLACE也替換了其它行:檢查該數是否爲1(添加)或更大(替換)。oop

示例:
# eg:(phone字段爲惟一索引)

 代碼以下 複製代碼

REPLACE INTO `table_name` (`email`, `phone`, `user_id`) VALUES ('test569', '99999', '123');

另外,在 SQL Server 中能夠這樣處理:

 代碼以下 複製代碼

if not exists (select phone from t where phone= '1')   insert into t(phone, update_time) values('1', getdate()) else    update t set update_time = getdate() where phone= '1'

更多信息請看:http://dev.mysql.com/doc/refman/5.1/zh/sql-syntax.html#replace

方案三:ON DUPLICATE KEY UPDATE

如‍上所寫,你也能夠在INSERT INTO…..後面加上 ON DUPLICATE KEY UPDATE方法來實現。若是您指定了ON DUPLICATE KEY UPDATE,而且插入行後會致使在一個UNIQUE索引或PRIMARY KEY中出現重複值,則執行舊行UPDATE。

例如,若是列a被定義爲UNIQUE,而且包含值1,則如下兩個語句具備相同的效果:

 代碼以下 複製代碼

INSERT INTO `table` (`a`, `b`, `c`) VALUES (1, 2, 3) ON DUPLICATE KEY UPDATE `c`=`c`+1; 
UPDATE `table` SET `c`=`c`+1 WHERE `a`=1;

若是行做爲新記錄被插入,則受影響行的值爲1;若是原有的記錄被更新,則受影響行的值爲2。

註釋:若是列b也是惟一列,則INSERT與此UPDATE語句至關:

 代碼以下 複製代碼

UPDATE `table` SET `c`=`c`+1 WHERE `a`=1 OR `b`=2 LIMIT 1;

若是a=1 OR b=2與多個行向匹配,則只有一個行被更新。一般,您應該儘可能避免對帶有多個惟一關鍵字的表使用ON DUPLICATE KEY子句。

您能夠在UPDATE子句中使用VALUES(col_name)函數從INSERT…UPDATE語句的INSERT部分引用列值。換句話說,若是沒有發生重複關鍵字衝突,則UPDATE子句中的VALUES(col_name)能夠引用被插入的col_name的值。本函數特別適用於多行插入。VALUES()函數只在INSERT…UPDATE語句中有意義,其它時候會返回NULL。

 代碼以下 複製代碼

INSERT INTO `table` (`a`, `b`, `c`) VALUES (1, 2, 3), (4, 5, 6) ON DUPLICATE KEY UPDATE `c`=VALUES(`a`)+VALUES(`b`);

本語句與如下兩個語句做用相同:

 代碼以下 複製代碼

INSERT INTO `table` (`a`, `b`, `c`) VALUES (1, 2, 3) ON DUPLICATE KEY UPDATE `c`=3; 
INSERT INTO `table` (`a`, `b`, `c`) VALUES (4, 5, 6) ON DUPLICATE KEY UPDATE c=9;

註釋:當您使用ON DUPLICATE KEY UPDATE時,DELAYED選項被忽略。

示例:
這個例子是我在實際項目中用到的:是將一個表的數據導入到另一個表中,數據的重複性就得考慮(以下),惟一索引爲:email:

 代碼以下 複製代碼

INSERT INTO `table_name1` (`title`, `first_name`, `last_name`, `email`, `phone`, `user_id`, `role_id`, `status`, `campaign_id`) 
    SELECT '', '', '', `table_name2`.`email`, `table_name2`.`phone`, NULL, NULL, 'pending', 29 FROM `table_name2` 
    WHERE `table_name2`.`status` = 1 
ON DUPLICATE KEY UPDATE `table_name1`.`status`='pending'

再貼一個例子:

 代碼以下 複製代碼

1 INSERT INTO `class` SELECT * FROM `class1` ON DUPLICATE KEY UPDATE `class`.`course`=`class1`.`course`

其它關鍵:DELAYED  作爲快速插入,並非很關心失效性,提升插入性能。 
IGNORE  只關注主鍵對應記錄是不存在,無則添加,有則忽略。

更多信息請看:  http://dev.mysql.com/doc/refman/5.1/zh/sql-syntax.html#insert

特別說明:在MYSQL中UNIQUE索引將會對null字段失效,也就是說(a字段上創建惟一索引):

 代碼以下 複製代碼

1 INSERT INTO `test` (`a`) VALUES (NULL);

是能夠重複插入的(聯合惟一索引也同樣)。

因工做須要,須要實現以下業務功能:

給定日期範圍(開始日期~結束日期),批量將該範圍內的日期,按照天把價格存儲(insert or update)到數據庫(MySQL)中;簡化考慮,採用觸發器實現;

因爲日期設置了惟一索引,所以,insert語句有可能出現惟一索引衝突,所以須要使用 on duplicate key update 語法來實現;該語法的做用:某條件的記錄不存在時新增,不然更新。

如下是表結構語句:

CREATE TABLE `price_date` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `travel_date` date NOT NULL COMMENT '日期',
  `price` int(9) NOT NULL COMMENT '價格',
  `price_desc` varchar(100) DEFAULT NULL COMMENT '價格描述',
  PRIMARY KEY (`id`),
  UNIQUE KEY `IDXU_date` (`travel_date`) USING BTREE
) COMMENT='價格表';


爲了使用觸發器,單獨建個無心義的表price_date_batch,目的是爲了在此表上創建觸發器

如下是trigger的內容:

CREATE TRIGGER `tbi_date_batch` BEFORE INSERT ON `price_date_batch` FOR EACH ROW BEGIN
  declare v_from date default new.`date_from`;
  declare v_to date default new.`date_to`;
  
  loop_label: loop
    if v_from > v_to then
      leave loop_label;
    end if;
    
    insert into price_date(travel_date, price, price_desc)
    values(v_from, new.price, new.price_desc)
    ON DUPLICATE KEY UPDATE price=new.price, price_desc=new.price_desc;
    set v_from = date_add(v_from, interval 1 day);
  end loop;
END;


使用循環語句,則實現了批量新增/更新.

===================================================================================

平時咱們在設計數據庫表的時候總會設計 unique  或者 給表加上 primary key 的限制條件.

此時 插入數據的時候 ,常常會有這樣的狀況:

咱們想向數據庫插入一條記錄:

  若數據表中存在以相同主鍵的記錄,咱們就更新該條記錄。

  不然就插入一條新的記錄。

邏輯上咱們須要怎麼寫:

可是這樣寫有兩個問題

一、效率太差,每次執行都要執行2個sql
二、高併發的狀況下數據會出問題,不能保證原子性 

$result = mysql_query('select * from xxx where id = 1');
$row = mysql_fetch_assoc($result);
if($row){
mysql_query('update ...');
}else{
mysql_query('insert ...');
}

還好MySQL 爲咱們解決了這個問題:咱們能夠經過 ON DUPLICATE KEY UPDATE  達到以上目的, 且能保證操做的原子性和數據的完整性。

ON DUPLICATE KEY UPDATE 能夠達到如下目的:

向數據庫中插入一條記錄:

若該數據的主鍵值/ UNIQUE KEY 已經在表中存在,則執行更新操做, 即UPDATE 後面的操做。

不然插入一條新的記錄。

示例:

Step1 . 建立表,插入測試數據

SET FOREIGN_KEY_CHECKS=0;


-- ----------------------------
-- Table structure for mRowUpdate
-- ----------------------------
DROP TABLE IF EXISTS `mRowUpdate`;
CREATE TABLE `mRowUpdate` (
  `id` int(11) NOT NULL,
  `value` varchar(255) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB;


-- ----------------------------
-- Records of mRowUpdate
-- ----------------------------
INSERT INTO `mRowUpdate` VALUES ('1', 'sss');
INSERT INTO `mRowUpdate` VALUES ('2', 'szh');
INSERT INTO `mRowUpdate` VALUES ('3', '9999');
SET FOREIGN_KEY_CHECKS=1;

Step2 .測試 ON DUPLICATE KEY UPDATE 的使用方法:

INSERT INTO mRowUpdate(id,`value`) VALUES(3, 'SuperMan') ON DUPLICATE KEY UPDATE `value`='SuperMan';

Step3. 查詢數據的變化狀況

 

==========================     話外篇   ===============================

技巧:

技巧 1 :

ON DUPLICATE KEY UPDATE 特別適用於多行插入。如:
 

INSERT INTO `table` (`a`, `b`, `c`) VALUES (1, 2, 3), (4, 5, 6) ON DUPLICATE KEY UPDATE `c`=VALUES(`a`)+VALUES(`b`);

 Tips: VALUES()函數只在INSERT…UPDATE語句中有意義,其它時候會返回NULL。

注意事項:

注意 1:

若多個索引都衝突,則只有一條記錄被修改。

create table test(
id int not null primary key,
num int not null UNIQUE key,
tid int not null
)


爲了測試兩個惟一索引都衝突的狀況,而後插入下面的數據

insert into test values(1,1,1), (2,2,2);


而後執行:

insert into test values(1,2,3) on duplicate key update tid = tid + 1;


由於a和b都是惟一索引,插入的數據在兩條記錄上產生了衝突,然而執行後只有第一條記錄被修改

PS:關於日期的計算,能夠參考

ADDTIME (date2 ,time_interval ) //將time_interval加到date2;

CONVERT_TZ (datetime2 ,fromTZ ,toTZ ) //轉換時區;CURRENT_DATE ( ) //當前日期;CURRENT_TIME ( ) //當前時間...

ADDTIME (date2 ,time_interval ) //將time_interval加到date2
CONVERT_TZ (datetime2 ,fromTZ ,toTZ ) //轉換時區
CURRENT_DATE ( ) //當前日期
CURRENT_TIME ( ) //當前時間
CURRENT_TIMESTAMP ( ) //當前時間戳

DATE (datetime ) //返回datetime的日期部分
DATE_ADD (date2 , INTERVAL d_value d_type ) //在date2中加上日期或時間
DATE_FORMAT (datetime ,FormatCodes ) //使用formatcodes格式顯示datetime
DATE_SUB (date2 , INTERVAL d_value d_type ) //在date2上減去一個時間
DATEDIFF (date1 ,date2 ) //兩個日期差

DAY (date ) //返回日期的天
DAYNAME (date ) //英文星期
DAYOFWEEK (date ) //星期(1-7) ,1爲星期天
DAYOFYEAR (date ) //一年中的第幾天
EXTRACT (interval_name FROM date ) //從date中提取日期的指定部分

MAKEDATE (year ,day ) //給出年及年中的第幾天,生成日期串
MAKETIME (hour ,minute ,second ) //生成時間串
MONTHNAME (date ) //英文月份名
NOW ( ) //當前時間
SEC_TO_TIME (seconds ) //秒數轉成時間

STR_TO_DATE (string ,format ) //字串轉成時間,以format格式顯示
TIMEDIFF (datetime1 ,datetime2 ) //兩個時間差
TIME_TO_SEC (time ) //時間轉秒數]
WEEK (date_time [,start_of_week ]) //第幾周
YEAR (datetime ) //年份

DAYOFMONTH(datetime) //月的第幾天
HOUR(datetime) //小時
LAST_DAY(date) //date的月的最後日期
MICROSECOND(datetime) //微秒
MONTH(datetime) //月
MINUTE(datetime) //分


date_sub()函數的例子:今天是2013年5月20日。
date_sub('2012-05-25', interval 1 day) 表示 2012-05-24
date_sub(curdate(), interval 1 day) 表示 2013-05-19
date_sub(curdate(), interval 1 month) 表示 2013-04-20
date_sub(curdate(), interval 1 year) 表示 2012-05-20

 

原文地址:http://www.111cn.net/database/mysql/50135.htm

相關文章
相關標籤/搜索