[[352779]]

作者個人研發的在高并發場景下，提供的簡單、穩定、可擴展的延遲消息隊列框架，具有精準的定時任務和延遲隊列處理功能。自開源半年多以來，已成功為十幾家中小型企業提供了精準定時調度方案，經受住了生產環境的考驗。為使更多童鞋受益，現給出開源框架地址：https://github.com/sunshinelyz/mykit-delay

數據案例

原本的數據庫有3張表。

• t_user ：用戶表，存放用戶的基本信息。
• t_role ：角色表，存放角色信息。
• t_role_user：存放角色與用戶的對應關系。

因為業務邏輯的改變，現在要把它們合并為一張表，把t_role中的角色信息插入到t_user中。

首先獲取到所有用戶對應的角色，以用戶ID分組，合并角色地到一行，以逗號分隔。

SELECT t_user.id,GROUP_CONCAT(t_role.content) FROM t_user LEFT JOIN t_role_user on t_user.id = t_role_user.t_user_id LEFT JOIN t_role ON t_role_user.t_role_id = t_role.id GROUP BY t_user.id 

先把查到的數據存放到了一個新建的表mid里

INSERT into mid (t_user_id,t_role_info) SELECT t_user.id,GROUP_CONCAT(t_role.info) FROM t_user LEFT JOIN t_role_user on t_user.id = t_role_user.t_user_id LEFT JOIN t_role ON t_role_user.t_role_id = t_role.id GROUP BY t_user.id 

然后將mid表的數據更新到t_user里，因為是更新，所以不能用insert into select from 語句了

update t_user,mid set t_user.t_role_info = mid.t_role_info where t_user.id = mid.t_user_id 

成功將目的地以逗號分隔的字符串形式導入t_user表中

說一下用到的幾個方法，group_concat

group_concat( [DISTINCT] 要連接的字段 [Order BY 排序字段 ASC/DESC] [Separator '分隔符'] ),該函數能夠將相同的行組合起來

select * from goods; 
+------+------+ 
| id| price| 
+------+------+ 
|1 | 10| 
|1 | 20| 
|1 | 20| 
|2 | 20| 
|3 | 200 | 
|3 | 500 | 
+------+------+ 
6 rows in set (0.00 sec) 

以id分組，把price字段的值在同一行打印出來，逗號分隔(默認)

select id, group_concat(price) from goods group by id; 
+------+--------------------+ 
| id| group_concat(price) | 
+------+--------------------+ 
|1 | 10,20,20| 
|2 | 20 | 
|3 | 200,500| 
+------+--------------------+ 
3 rows in set (0.00 sec) 

以id分組，把price字段去重打印在一行，逗號分隔

select id,group_concat(distinct price) from goods group by id; 
+------+-----------------------------+ 
| id| group_concat(distinct price) | 
+------+-----------------------------+ 
|1 | 10,20| 
|2 | 20 | 
|3 | 200,500 | 
+------+-----------------------------+ 
3 rows in set (0.00 sec) 

以id分組，把price字段的值打印在一行，逗號分隔，按照price倒序排列

select id,group_concat(price order by price desc) from goods group by id; 
+------+---------------------------------------+ 
| id| group_concat(price order by price desc) | 
+------+---------------------------------------+ 
|1 | 20,20,10 | 
|2 | 20| 
|3 | 500,200| 
+------+---------------------------------------+ 
3 rows in set (0.00 sec) 

insert into select from 將查詢到的記錄插入到某個表中

INSERT INTO db1_name(field1,field2) SELECT field1,field2 FROM db2_name 

要求目標db2必須存在，下面測試一下，有兩個表，結構如下

select * from insert_one; 
+----+--------+-----+-----+ 
| id | name  | age | sex | 
+----+--------+-----+-----+ 
| 1 | 冰河001 | 25 |   | 
| 2 | 冰河002 | 26 |   | 
| 3 | 冰河003 | 28 |   | 
| 4 | 冰河004 | 30 |   | 
+----+--------+-----+-----+ 
4 rows in set 
 
  
select * from insert_sex; 
+----+-----+ 
| id | sex | 
+----+-----+ 
| 1 | 1  | 
| 2 | 2  | 
| 3 | 1  | 
| 4 | 2  | 
+----+-----+ 
4 rows in set 

從表2中查找性別數據，插入到表1中

into insert_one(sex) select sex from insert_sex; 
Query OK, 4 rows affected 
select * from insert_one; 
+----+--------+-----+-----+ 
| id | name  | age | sex | 
+----+--------+-----+-----+ 
| 1 | 田小斯 | 25 |   | 
| 2 | 劉大牛 | 26 |   | 
| 3 | 鄭大錘 | 28 |   | 
| 4 | 胡二狗 | 30 |   | 
| 5 |    |   | 1  | 
| 6 |    |   | 2  | 
| 7 |    |   | 1  | 
| 8 |    |   | 2  | 
+----+--------+-----+-----+ 
8 rows in set 

結果很尷尬，我是想要更新這張表的sex字段，而不是插入新的數據，那么這個命令只適用于要把數據導入空表中，所以在上面的實際需要中，我建立了新表mid，利用update來中轉并更新數據

UPDATE tb1,tb2 SET tb1.address=tb2.address WHERE tb1.name=tb2.name 

根據條件匹配，把表1的數據替換為(更新為)表2的數據，表1和表2必須有關聯才可以

update insert_one,insert_sex set insert_one.sex = insert_sex.sex where insert_one.id = insert_sex.id; 
Query OK, 4 rows affected 
select * from insert_one; 
+----+--------+-----+-----+ 
| id | name  | age | sex | 
+----+--------+-----+-----+ 
| 1 | 冰河001 | 25 | 1  | 
| 2 | 冰河002 | 26 | 2  | 
| 3 | 冰河003 | 28 | 1  | 
| 4 | 冰河004 | 30 | 2  | 
| 5 |    |   | 1  | 
| 6 |    |   | 2  | 
| 7 |    |   | 1  | 
| 8 |    |   | 2  | 
+----+--------+-----+-----+ 
8 rows in set 

成功將數據更新到insert_one表的sex字段中。

本文轉載自微信公眾號「冰河技術」，可以通過以下二維碼關注。轉載本文請聯系冰河技術公眾號。