JavaはopenCsvを利用してcsvファイルをmysqlデータベースにインポートする

4172 ワード

先日仕事をしていたとき、フロントでcsvファイルをインポートし、バックグラウンドで受信処理を行い、mysqlデータベースでは、プロジェクト用のspringboot+Vue+mybatisPlus実装を行い、実装プロセスを詳しく記録します.
 
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; }

 
ここでは、フロントエンドから送られてきたファイルを読み取り、直接入庫します.中間ファイルは生成されません.この文章が役に立つことを望んでいます.問題があれば、コメントエリアで交流してください.