Mycat2 Loaddate 注解導(dǎo)入CSV數(shù)據(jù)

/*+ mycat:loaddata{
    "fileName":"xxx/mycat_loaddata_example",
    "delimiter":",",
    "schemaName":"db1",
    "tableName":"travelrecord"
} */;

• fileName是mycat所在服務(wù)器的csv文件路徑
• delimiter是row分隔符,默認(rèn)為空格
• schemaName是邏輯庫(kù)名
• tableName是邏輯表名

CSV解析使用org.apache.commons.csv實(shí)現(xiàn),上述的delimiter就是org.apache.commons.csv.CSVFormat的參數(shù)

可以自行添加更多參數(shù)控制解析格式

Mycat2 會(huì)把 csv 的row記錄轉(zhuǎn)換成insert語(yǔ)句并以1000行一批次依次執(zhí)行,整體執(zhí)行與多語(yǔ)句執(zhí)行沒(méi)有區(qū)別

如果導(dǎo)入的是全局表數(shù)據(jù),可能返回的影響行數(shù)是物理表的影響行數(shù),而不是邏輯表的

如果要求數(shù)據(jù)一致性,可以開(kāi)啟事務(wù)后再使用該注解,但是事務(wù)會(huì)影響并行插入的連接數(shù),性能不如不開(kāi)事務(wù)

2021-7-22號(hào)后 1.20版本會(huì)自動(dòng)開(kāi)啟事務(wù)并自動(dòng)提交

?/*+ mycat:loaddata{
? ?"fileName":"xxxxx",
? ?"schemaName":"db1",
? ?"tableName":"travelrecord"
} */;

對(duì)應(yīng)csv格式
1 ?\N \N \N \N \N
2 ?\N \N \N \N \N
3 ?\N \N \N \N \N

?/*+ mycat:loaddata{
? ?"fileName":"xxxx",
? ?"delimiter":",",
? ?"schemaName":"db1",
? ?"tableName":"travelrecord"
} */;

對(duì)應(yīng)csv格式
1,\N,\N,\N,\N,\N
2,\N,\N,\N,\N,\N
3,\N,\N,\N,\N,\N