JavaはopenCsvを利用してcsvファイルをmysqlデータベースにインポートする
4172 ワード
先日仕事をしていたとき、フロントでcsvファイルをインポートし、バックグラウンドで受信処理を行い、mysqlデータベースでは、プロジェクト用のspringboot+Vue+mybatisPlus実装を行い、実装プロセスを詳しく記録します.
1.controller層部分:
ここでは,フロントエンドから渡されたfileをgetCsvFileContentメソッドに渡して処理し,一括挿入するリストを生成してmybatisPlusで一括挿入する.
2.実装クラス:
ここでは、フロントエンドから送られてきたファイルを読み取り、直接入庫します.中間ファイルは生成されません.この文章が役に立つことを望んでいます.問題があれば、コメントエリアで交流してください.
1.controller層部分:
/**
* csv ,
*/
@RequestMapping("/importcsv")
@RequiresPermissions("xxx:xxxxx:xxx")
public R importCsv(@RequestParam("file") MultipartFile file) throws IOException, CsvException {
if (null == file) {
return R.error(" ");
}
List csvFileContentList = xxxService.getCsvFileContent(file);
boolean b = xxxService.saveBatch(csvFileContentList);
if (b) {
return R.ok(" ");
} else {
return R.ok(" ");
}
}
ここでは,フロントエンドから渡されたfileをgetCsvFileContentメソッドに渡して処理し,一括挿入するリストを生成してmybatisPlusで一括挿入する.
2.実装クラス:
@Override
public List getCsvFileContent(MultipartFile file) throws IOException, CsvException {
// csv
String charset = "GBK";
Reader reader = new InputStreamReader(file.getInputStream(), charset);
CSVReader csvReader = new CSVReader(reader);
csvReader.readNext();
List csvList = csvReader.readAll();
List xxxList = new ArrayList<>();
xxxEntity xxx = null;
for(String[] csv : csvList){
xxx = new xxxEntity();
if(null != csv && csv.length != 0){
//
xxxEntity xxxx = findOneByxxxAndxxx(csv[0], csv[1]);
if (xxxx == null) {
xxx.setXxx(csv[0]);
xxx.setXxx(csv[1]);
xxx.setXxx(csv[2]);
}else {
continue;
}
}
xxxList.add(xxx);
}
return xxxList;
}
ここでは、フロントエンドから送られてきたファイルを読み取り、直接入庫します.中間ファイルは生成されません.この文章が役に立つことを望んでいます.問題があれば、コメントエリアで交流してください.