1. 程式人生 > 資料庫 >MySQL實戰之Insert語句的使用心得

MySQL實戰之Insert語句的使用心得

一、Insert的幾種語法

1-1.普通插入語句

INSERT INTO table (`a`,`b`,`c`,……) VALUES ('a','b','c',……);

這裡不再贅述,注意順序即可,不建議小夥伴們去掉前面括號的內容,別問為什麼,容易被同事罵。

1-2.插入或更新

如果我們希望插入一條新記錄(INSERT),但如果記錄已經存在,就更新該記錄,此時,可以使用"INSERT INTO … ON DUPLICATE KEY UPDATE …"語句:

情景示例:這張表存了使用者歷史充值金額,如果第一次充值就新增一條資料,如果該使用者充值過就累加歷史充值金額,需要保證單個使用者資料不重複錄入。

這時可以使用"INSERT INTO … ON DUPLICATE KEY UPDATE …"語句。

注意事項:"INSERT INTO … ON DUPLICATE KEY UPDATE …"語句是基於唯一索引或主鍵來判斷唯一(是否存在)的。如下SQL所示,需要在username欄位上建立唯一索引(Unique),transId設定自增即可。

-- 使用者陳哈哈充值了30元買會員
INSERT INTO total_transaction (t_transId,username,total_amount,last_transTime,last_remark) 
 VALUES (null,'chenhaha',30,'2020-06-11 20:00:20','充會員') 
 ON DUPLICATE KEY UPDATE total_amount=total_amount + 30,last_transTime='2020-06-11 20:00:20',last_remark ='充會員';
 
-- 使用者陳哈哈充值了100元買瞎子至高之拳面板
INSERT INTO total_transaction (t_transId,100,'購買盲僧至高之拳面板') 
 ON DUPLICATE KEY UPDATE total_amount=total_amount + 100,last_transTime='2020-06-11 21:00:00',last_remark ='購買盲僧至高之拳面板';

若username='chenhaha'的記錄不存在,INSERT語句將插入新記錄,否則,當前username='chenhaha'的記錄將被更新,更新的欄位由UPDATE指定。

對了,ON DUPLICATE KEY UPDATE為MySQL特有語法,比如在MySQL遷移Oracle或其他DB時,類似的語句要改為MERGE INTO語法,相容性讓人想罵街。但沒辦法,就像用WPS寫的xlsx用Office無法開啟一樣。

1-3.插入或替換

如果我們想插入一條新記錄(INSERT),但如果記錄已經存在,就先刪除原記錄,再插入新記錄。

情景示例:這張表存的每個客戶最近一次交易訂單資訊,要求保證單個使用者資料不重複錄入,且執行效率最高,與資料庫互動最少,支撐資料庫的高可用。

此時,可以使用"REPLACE INTO"語句,這樣就不必先查詢,再決定是否先刪除再插入。

"REPLACE INTO"語句是基於唯一索引或主鍵來判斷唯一(是否存在)的。
"REPLACE INTO"語句是基於唯一索引或主鍵來判斷唯一(是否存在)的。
"REPLACE INTO"語句是基於唯一索引或主鍵來判斷唯一(是否存在)的。

注意事項:如下SQL所示,需要在username欄位上建立唯一索引(Unique),transId設定自增即可。

-- 20點充值
REPLACE INTO last_transaction (transId,amount,trans_time,remark) 
 VALUES (null,'會員充值');
 
-- 21點買面板
REPLACE INTO last_transaction (transId,'2020-06-11 21:00:00','購買盲僧至高之拳面板');

若username='chenhaha'的記錄不存在,REPLACE語句將插入新記錄(首次充值),否則,當前username='chenhaha'的記錄將被刪除,然後再插入新記錄。

id不要給具體值,不然會影響SQL執行,業務有特殊需求除外。

小tips:
ON DUPLICATE KEY UPDATE:如果插入行出現唯一索引或者主鍵重複時,則執行舊的update;如果不會導致唯一索引或者主鍵重複時,就直接新增新行。
REPLACE INTO:如果插入行出現唯一索引或者主鍵重複時,則delete老記錄,而錄入新的記錄;如果不會導致唯一索引或者主鍵重複時,就直接新增新行。

replace into 與 insert on deplicate udpate 比較:

1、在沒有主鍵或者唯一索引重複時,replace into 與 insert on deplicate udpate 相同。

2、在主鍵或者唯一索引重複時,replace是delete老記錄,而錄入新的記錄,所以原有的所有記錄會被清除,這個時候,如果replace語句的欄位不全的話,有些原有的比如c欄位的值會被自動填充為預設值(如Null)。

3、細心地朋友們會發現,insert on deplicate udpate只是影響一行,而REPLACE INTO可能影響多行,為什麼呢?寫在文章最後一節咯~

1-4.插入或忽略

如果我們希望插入一條新記錄(INSERT),但如果記錄已經存在,就啥事也不幹直接忽略,此時,可以使用INSERT IGNORE INTO …語句:情景很多,不再舉例贅述。

注意事項:同上,"INSERT IGNORE INTO …"語句是基於唯一索引或主鍵來判斷唯一(是否存在)的,需要在username欄位上建立唯一索引(Unique),transId設定自增即可。

-- 使用者首次新增
INSERT IGNORE INTO users_info (id,sex,age,balance,create_time) 
 VALUES (null,'男',26,'2020-06-11 20:00:20');
 
-- 二次新增,直接忽略
INSERT IGNORE INTO users_info (id,'2020-06-11 21:00:20');

二、大量資料插入

2-1、三種處理方式

2-1-1、單條迴圈插入

我們取10w條資料進行了一些測試,如果插入方式為程式遍歷迴圈逐條插入。在mysql上檢測插入一條的速度在0.01s到0.03s之間。

逐條插入的平均速度是0.02*100000,也就是33分鐘左右。

下面程式碼是測試例子:

1普通迴圈插入100000條資料的時間測試

 @Test
 public void insertUsers1() {
  
  User user = new User();
  
  user.setUserName("提莫隊長");
  user.setPassword("正在送命");
  user.setPrice(3150);
  user.setHobby("種蘑菇");
  
  for (int i = 0; i < 100000; i++) {
   user.setUserName("提莫隊長" + i);
   // 呼叫插入方法
   userMapper.insertUser(user);
  }
 }

執行速度是30分鐘也就是0.018*100000的速度。可以說是很慢了

發現逐條插入優化成本太高。然後去查詢優化方式。發現用批量插入的方法可以顯著提高速度。

將100000條資料的插入速度提升到1-2分鐘左右↓

2-1-2、修改SQL語句批量插入

insert into user_info (user_id,password,price,hobby)
 values (null,'提莫隊長1','123456',3150,'種蘑菇'),(null,'蓋倫',450,'踩蘑菇');

用批量插入插入100000條資料,測試程式碼如下:

 @Test
 public void insertUsers2() {
   
  List<User> list= new ArrayList<User>();
		
  User user = new User();
  user.setPassword("正在送命");
  user.setPrice(3150);
  user.setHobby("種蘑菇");
		
  for (int i = 0; i < 100000; i++) {
   user.setUserName("提莫隊長" + i);
   // 將單個物件放入引數list中
   list.add(user);
   
  }
  userMapper.insertListUser(list);
 }

批量插入使用了0.046s 這相當於插入一兩條資料的速度,所以用批量插入會大大提升資料插入速度,當有較大資料插入操作是用批量插入優化

批量插入的寫法:

dao定義層方法:

Integer insertListUser(List<User> user);

mybatis Mapper中的sql寫法:

<insert id="insertListUser" parameterType="java.util.List">
  INSERT INTO `db`.`user_info`
   ( `id`,`username`,`password`,`price`,`hobby`) 
   values
  <foreach collection="list" item="item" separator="," index="index">
   (null,#{item.userName},#{item.password},#{item.price},#{item.hobby})
  </foreach>
 
 </insert>

這樣就能進行批量插入操作:

注:但是當批量操作資料量很大的時候。例如我插入10w條資料的SQL語句要操作的資料包超過了1M,MySQL會報如下錯:

報錯資訊:

Mysql You can change this value on the server by setting the max_allowed_packet' variable. Packet for query is too large (6832997 > 1048576). You can change this value on the server by setting the max_allowed_packet' variable.

解釋:

用於查詢的資料包太大(6832997> 1048576)。 您可以通過設定max_allowed_packet的變數來更改伺服器上的這個值。

通過解釋可以看到用於操作的包太大。這裡要插入的SQL內容資料大小為6M 所以報錯。

解決方法:

資料庫是MySQL57,查了一下資料是MySQL的一個系統引數問題:

max_allowed_packet,其預設值為1048576(1M),

查詢:

show VARIABLES like '%max_allowed_packet%';

MySQL實戰之Insert語句的使用心得

修改此變數的值:MySQL安裝目錄下的my.ini(windows)或/etc/mysql.cnf(linux) 檔案中的[mysqld]段中的

max_allowed_packet = 1M,如更改為20M(或更大,如果沒有這行內容,增加這一行),如下圖

MySQL實戰之Insert語句的使用心得

儲存,重啟MySQL服務。現在可以執行size大於1M小於20M的SQL語句了。

MySQL實戰之Insert語句的使用心得

但是如果20M也不夠呢?

2-1-3、分批量多次迴圈插入

如果不方便修改資料庫配置或需要插入的內容太多時,也可以通過後端程式碼控制,比如插入10w條資料,分100批次每次插入1000條即可,也就是幾秒鐘而已;當然,如果每條的內容很多的話,另說。。

2-2、插入速度慢的其他幾種優化途徑

A、通過show processlist;命令,查詢是否有其他長程序或大量短程序搶佔執行緒池資源 ?看能否通過把部分程序分配到備庫從而減輕主庫壓力;或者,先把沒用的程序kill掉一些?(手動撓頭o_O)

B、大批量導資料,也可以先關閉索引,資料匯入完後再開啟索引

關閉:ALTER TABLE user_info DISABLE KEYS;
開啟:ALTER TABLE user_info ENABLE KEYS;

三、REPLACE INTO語法的“坑”

上面曾提到REPLACE可能影響3條以上的記錄,這是因為在表中有超過一個的唯一索引。在這種情況下,REPLACE將考慮每一個唯一索引,並對每一個索引對應的重複記錄都刪除,然後插入這條新記錄。假設有一個table1表,有3個欄位a,b,c。它們都有一個唯一索引,會怎麼樣呢?我們早一些資料測試一下。

-- 測試表建立,a,c三個欄位均有唯一索引
CREATE TABLE table1(a INT NOT NULL UNIQUE,b INT NOT NULL UNIQUE,c INT NOT NULL UNIQUE);
-- 插入三條測試資料
INSERT into table1 VALUES(1,1,1);
INSERT into table1 VALUES(2,2,2);
INSERT into table1 VALUES(3,3,3);

此時table1中已經有了3條記錄,a,c三個欄位都是唯一(UNIQUE)索引

mysql> select * from table1;
+---+---+---+
| a | b | c |
+---+---+---+
| 1 | 1 | 1 |
| 2 | 2 | 2 |
| 3 | 3 | 3 |
+---+---+---+
3 rows in set (0.00 sec)

下面我們使用REPLACE語句向table1中插入一條記錄。

REPLACE INTO table1(a,c) VALUES(1,3);

mysql> REPLACE INTO table1(a,3);
Query OK,4 rows affected (0.04 sec)

此時查詢table1中的記錄如下,只剩一條資料了~

mysql> select * from table1;
+---+---+---+
| a | b | c |
+---+---+---+
| 1 | 2 | 3 |
+---+---+---+
1 row in set (0.00 sec)

(老闆:插入前10w資料,插入5w資料後還剩8w資料??,咱們家資料讓你喂狗了嗎!!)

REPLACE INTO語法回顧:如果插入行出現唯一索引或者主鍵重複時,則delete老記錄,而錄入新的記錄;如果不會導致唯一索引或者主鍵重複時,就直接新增新行。

我們可以看到,在用REPLACE INTO時每個唯一索引都會有影響的,可能會造成誤刪資料的情況,因此建議不要在多唯一索引的表中使用REPLACE INTO;

總結

到此這篇關於MySQL實戰之Insert語句的使用心得的文章就介紹到這了,更多相關MySQL Insert語句使用心得內容請搜尋我們以前的文章或繼續瀏覽下面的相關文章希望大家以後多多支援我們!