文章詳情頁

MySQL Shell import_table數(shù)據(jù)導(dǎo)入的實(shí)現(xiàn)

瀏覽：148日期：2023-10-18 07:19:22

目錄1. import_table介紹2. Load Data 與 import table功能示例2.1 用Load Data方式導(dǎo)入數(shù)據(jù)2.2 用import_table方式導(dǎo)入數(shù)據(jù)3. import_table特定功能3.1 多文件導(dǎo)入(模糊匹配)3.2 并發(fā)導(dǎo)入3.3 導(dǎo)入速率控制3.4 自定義chunk大小4. Load Data vs import_table性能對(duì)比5. 技術(shù)總結(jié)1. import_table介紹

上期技術(shù)分享我們介紹了MySQL Load Data的4種常用的方法將文本數(shù)據(jù)導(dǎo)入到MySQL,這一期我們繼續(xù)介紹另一款更加高效的數(shù)據(jù)導(dǎo)入工具,MySQL Shell 工具集中的import_table,該工具的全稱是Parallel Table Import Utility,顧名思義,支持并發(fā)數(shù)據(jù)導(dǎo)入,該工具在MySQL Shell 8.0.23版本后,功能更加完善, 以下列舉該工具的核心功能

基本覆蓋了MySQL Data Load的所有功能,可以作為替代品使用默認(rèn)支持并發(fā)導(dǎo)入(支持自定義chunk大小) 支持通配符匹配多個(gè)文件同時(shí)導(dǎo)入到一張表(非常適用于相同結(jié)構(gòu)數(shù)據(jù)匯總到一張表) 支持限速(對(duì)帶寬使用有要求的場景,非常合適) 支持對(duì)壓縮文件處理支持導(dǎo)入到5.7及以上MySQL2. Load Data 與 import table功能示例

該部分針對(duì)import table和Load Data相同的功能做命令示例演示,我們依舊以導(dǎo)入employees表的示例數(shù)據(jù)為例,演示MySQL Load Data的綜合場景

數(shù)據(jù)自定義順序?qū)? 數(shù)據(jù)函數(shù)處理自定義數(shù)據(jù)取值

## 示例數(shù)據(jù)如下[root@10-186-61-162 tmp]# cat employees_01.csv'10001','1953-09-02','Georgi','Facello','M','1986-06-26''10003','1959-12-03','Parto','Bamford','M','1986-08-28''10002','1964-06-02','Bezalel','Simmel','F','1985-11-21''10004','1954-05-01','Chirstian','Koblick','M','1986-12-01''10005','1955-01-21','Kyoichi','Maliniak','M','1989-09-12''10006','1953-04-20','Anneke','Preusig','F','1989-06-02''10007','1957-05-23','Tzvetan','Zielinski','F','1989-02-10''10008','1958-02-19','Saniya','Kalloufi','M','1994-09-15''10009','1952-04-19','Sumant','Peac','F','1985-02-18''10010','1963-06-01','Duangkaew','Piveteau','F','1989-08-24'## 示例表結(jié)構(gòu) 10.186.61.162:3306 employees SQL > desc emp;+-------------+---------------+------+-----+---------+-------+| Field | Type | Null | Key | Default | Extra |+-------------+---------------+------+-----+---------+-------+| emp_no | int | NO | PRI | NULL | || birth_date | date | NO | | NULL | || first_name | varchar(14) | NO | | NULL | || last_name | varchar(16) | NO | | NULL | || full_name | varchar(64) | YES | | NULL | | -- 表新增字段,導(dǎo)出數(shù)據(jù)文件中不存在| gender | enum(’M’,’F’) | NO | | NULL | || hire_date | date | NO | | NULL | || modify_date | datetime | YES | | NULL | | -- 表新增字段,導(dǎo)出數(shù)據(jù)文件中不存在| delete_flag | varchar(1) | YES | | NULL | | -- 表新增字段,導(dǎo)出數(shù)據(jù)文件中不存在+-------------+---------------+------+-----+---------+-------+2.1 用Load Data方式導(dǎo)入數(shù)據(jù)

具體參數(shù)含義不做說明,需要了解語法規(guī)則及含義可查看系列上一篇文章<MySQL Load Data的多種用法>

load data infile ’/data/mysql/3306/tmp/employees_01.csv’into table employees.empcharacter set utf8mb4fields terminated by ’,’enclosed by ’'’lines terminated by ’n’(@C1,@C2,@C3,@C4,@C5,@C6)set emp_no=@C1, birth_date=@C2, first_name=upper(@C3), last_name=lower(@C4), full_name=concat(first_name,’ ’,last_name), gender=@C5, hire_date=@C6 , modify_date=now(), delete_flag=if(hire_date<’1988-01-01’,’Y’,’N’);