Java读取csv文件并将内容插入到数据库

一时失言乱红尘 2022-07-14 07:19 272阅读 0赞

Java读取csv文件， 并使用jdbc将内容插入到数据库， 插入数据库的类可以在另一篇文章中查看， 有一个公共的csv操作jar包，本文未使用

<groupId>net.sourceforge.javacsv</groupId>

<artifactId>javacsv</artifactId>

</dependency>

package com.thinkive.common.util;
    
    import java.io.BufferedReader;
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.InputStreamReader;
    import java.util.ArrayList;
    import java.util.List;
    
    import com.thinkive.common.function.gastatisics.bean.Bean;
    
    /**
     * @desc: 读取csv文件， 并将内容插入到数据库
     * @author: changez@thinkive.com
     * @time: 2016年11月28日 下午3:37:35
     */
    public class ReadCsv {
    
    	public static void readCsvAndInstallDB(String path, int ignoreRows) throws Exception {
    		File file = new File(path);
    		BufferedReader bReader = new BufferedReader(new InputStreamReader(new FileInputStream(file), Constants.CHAR_CODING_GBK));
    		String line = "";
    		List<Bean> beanList = new ArrayList<Bean>();
    		int count = 0;
    		// 忽略前几行标题
    		if(ignoreRows > 0) {
    			for (int i = 0; i < ignoreRows; i++) {
    				line = bReader.readLine();
    			}
    		}
    		try {
    			while((line = bReader.readLine()) != null) {
    	//			System.out.println(++count+"  "+line);
    				if(line.trim() != "") {
    					String[] pills = line.split(",");
    					Bean bean = new Bean(pills[0].trim(), pills[1].trim(), pills[2].trim(), pills[3].trim(), Constants.CHANNEL_TYPE_GUI_TAI);
    					beanList.add(bean);
    					if(++count%Constants.BATCH_NUM == 0) {
    						// 数据库操作， 见“jdbc批量插入一文”
    						DBHelp.executeUpate(DBHelp.SQL_INSTALL_IDNO_THIRD, beanList, Constants.DATE_FORMATE_DEFAULT);
    						beanList.clear();
    					}
    				}
    			}
    			// 操作集合中最后一批数据  数据库操作， 见“jdbc批量插入一文”
    			DBHelp.executeUpate(DBHelp.SQL_INSTALL_IDNO_THIRD, beanList, Constants.DATE_FORMATE_DEFAULT);
    			beanList.clear();
    			DBHelp.closeSources(DBHelp.getConn(), DBHelp.getPs());
    			beanList = null;
    		}finally {
    			if(bReader != null) {
    				bReader.close();
    			}
    		}
    	}
    }