import_table(importTable) 的延申功能:可定制化行輸入。

創(chuàng)新互聯(lián)企業(yè)建站,十多年網(wǎng)站建設(shè)經(jīng)驗(yàn),專注于網(wǎng)站建設(shè)技術(shù),精于網(wǎng)頁(yè)設(shè)計(jì),有多年建站和網(wǎng)站代運(yùn)營(yíng)經(jīng)驗(yàn),設(shè)計(jì)師為客戶打造網(wǎng)絡(luò)企業(yè)風(fēng)格,提供周到的建站售前咨詢和貼心的售后服務(wù)。對(duì)于成都做網(wǎng)站、網(wǎng)站設(shè)計(jì)中不同領(lǐng)域進(jìn)行深入了解和探索,創(chuàng)新互聯(lián)在網(wǎng)站建設(shè)中充分了解客戶行業(yè)的需求,以靈動(dòng)的思維在網(wǎng)頁(yè)中充分展現(xiàn),通過(guò)對(duì)客戶行業(yè)精準(zhǔn)市場(chǎng)調(diào)研,為客戶提供的解決方案。
import_table(importTable) 我們之前有介紹過(guò),是一款并行導(dǎo)入各種格式文本的工具,封裝了 MySQL 語(yǔ)句?load data local infile。
比如說(shuō)要導(dǎo)入一個(gè)以 TAB 為分隔符的文本數(shù)據(jù)文件:/tmp/sample_ytt.txt?到表:ytt_new.t1,可以執(zhí)行下面語(yǔ)句:
上面結(jié)果是?load data infile?語(yǔ)句的導(dǎo)入結(jié)果。如果改用 import_table 方法來(lái)做同樣的事情,基于 Python 語(yǔ)法,使用方法如下:
那接下來(lái)看另外一個(gè)需求:在導(dǎo)入文本文件時(shí)對(duì)每行做預(yù)處理(例如在導(dǎo)入數(shù)據(jù)之前更改列 r2 的值為 mod(r1,10),列 r5 的值為 abs(r4-46) ),這樣可以減少導(dǎo)入后再次處理的時(shí)間開(kāi)銷。
這個(gè)需求用?load data infile?語(yǔ)句非常容易實(shí)現(xiàn):(導(dǎo)入時(shí)更改列 r2 和 r5 的數(shù)據(jù),類似 UPDATE 語(yǔ)法)
那如果要用 util.import_table(importTable) 來(lái)實(shí)現(xiàn)上面的需求,在 MySQL 8.0.22 之前是沒(méi)辦法的。
隨著 MySQL 8.0.22 的發(fā)布,MySQL 對(duì) import_table 方法做了些擴(kuò)充功能,其中增加了一個(gè)選項(xiàng) “decodeColumns” 可以實(shí)現(xiàn)字段的預(yù)先輸入定制化功能,并且還可以更加豐富。
接下來(lái)用 import_table 來(lái)實(shí)現(xiàn)上面的需求,定制化字段 r2 和 r5:
以上 Options 選項(xiàng),見(jiàn)下圖:
我來(lái)具體解釋下上圖的含義:藍(lán)色字體 columns 對(duì)應(yīng)的數(shù)組分別指定數(shù)據(jù)文件中的每行字段,也就是默認(rèn)的 TAB 分隔符所分割的每列值,1 和 2 代表占位符,1 代表數(shù)據(jù)文件中每行的第一個(gè)列,2 代表數(shù)據(jù)文件中每行的第四列,decodeColumns 字典分別對(duì)需要預(yù)先輸入的字段做處理。比如 r1 字段保留為變量 @1,r2 字段對(duì)應(yīng) mod(r1,10) 等。
如果還是不太理解變換規(guī)則,可以臨時(shí)打開(kāi) general log, 上面 import_table(importTable)對(duì)應(yīng)的 MySQL 日志為:
以上日志寫的很清楚,內(nèi)部轉(zhuǎn)換為最基本的load data infile語(yǔ)法。
那這里我簡(jiǎn)單解讀了下 MySQL 8.0.22 對(duì) MySQL Shell 的一項(xiàng)定制化輸入文本文件的新特性,更多的新特性可以繼續(xù)關(guān)注。
去裝一個(gè) pymsql包
然后
import pymysql #導(dǎo)入pymsql模塊 #鏈接數(shù)據(jù)庫(kù),注意port是int型,不是str,所以不要用引號(hào)conn = pymysql.connect( user='root', password='root', host='127.0.0.1', port=3306, database='test_demo', use_unicode=True, charset="utf8" )#獲取游標(biāo)cursor = conn.cursor()#插入數(shù)據(jù),注意看有變量的時(shí)候格式cursor.execute("INSERT INTO tieba_user(`uuid`,`user_name`,`user_rank`,`user_level`,`level_status`,`tieba_name`) VALUES (%s,%s,%s,%s,%s,%s)", (user_id, user_name, user_rank, user_level, level_statu, tieba_name))#提交conn.commit()#關(guān)閉連接cursor.close()
類似這樣
你導(dǎo)出 information_schema 數(shù)據(jù)庫(kù)里的所有表就OK了
新特性啊,以前只有ORACLE才有的
網(wǎng)站名稱:mysql怎么插入字典 mysql字典表怎么創(chuàng)建
瀏覽路徑:http://chinadenli.net/article14/hepgde.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供定制開(kāi)發(fā)、網(wǎng)站策劃、App設(shè)計(jì)、營(yíng)銷型網(wǎng)站建設(shè)、自適應(yīng)網(wǎng)站、小程序開(kāi)發(fā)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來(lái)源: 創(chuàng)新互聯(lián)