list中的insert语句

        private BufferedReader getInputStreamReader(String filePath,
                String unfileName) throws UnsupportedEncodingException,
                FileNotFoundException {
            /**读取文件内容,生成流*/
            InputStreamReader read;
                read = new InputStreamReader(
                        new FileInputStream(filePath+unfileName),CoreConstant.ENCODE_GBK);
                 BufferedReader bufferedReader = new BufferedReader(read);
            return bufferedReader;
        }

 

private int importData_Aip(String date, String areaType,
Connection con, Statement statement, Map<String, String> map,
String sql, File file, List<List<String>> list)
throws InterruptedException {
int i=0;
try{
log.info("正在导入数据,请耐心等候...");
for(List<String> k:list){
sql=SqlConstant.AIPTTRANSALL_SQL+
FuncUtil.isEmpty(k.get(0))+FuncUtil.isEmpty(k.get(1))+FuncUtil.isEmpty(k.get(2))+
FuncUtil.isEmpty(k.get(3))+FuncUtil.isEmpty(k.get(4))+FuncUtil.isEmpty(k.get(5))+
FuncUtil.isEmpty(k.get(6))+FuncUtil.isEmpty(k.get(7))+FuncUtil.isEmpty(k.get(8))+
FuncUtil.isEmpty(k.get(9))+FuncUtil.isEmpty(k.get(10))+FuncUtil.isEmpty(k.get(11))+
FuncUtil.isEmpty(k.get(12))+FuncUtil.isEmpty(alterStatus(k.get(13)))+FuncUtil.isEmpty(k.get(14))+
FuncUtil.isEmpty(k.get(15))+FuncUtil.isEmpty(k.get(16))+FuncUtil.isEmpty(k.get(17))+
FuncUtil.isEmpty(k.get(18))+FuncUtil.isEmpty(k.get(19))+FuncUtil.isEmpty(k.get(20))+
FuncUtil.isEmpty(k.get(21))+FuncUtil.isEmpty(k.get(22))+FuncUtil.isEmpty(k.get(23))+
FuncUtil.isEmpty(k.get(24))+FuncUtil.isEmpty(k.get(25))+FuncUtil.isEmpty(k.get(26))+
FuncUtil.isEmpty(k.get(27))+FuncUtil.isEmpty(k.get(28))+FuncUtil.isEmpty(k.get(29))+
FuncUtil.isEmpty(k.get(30))+FuncUtil.isEmpty(k.get(31))+FuncUtil.isEmpty(k.get(32))+
FuncUtil.isEmpty(k.get(33))+FuncUtil.isEmpty(k.get(34))+FuncUtil.isEmpty(k.get(35))+
FuncUtil.isEmpty(k.get(36))+FuncUtil.isEmpty(k.get(37))+FuncUtil.isEmpty(k.get(38))+
FuncUtil.isEmpty(k.get(39))+FuncUtil.isEmpty(k.get(40))+FuncUtil.isEmpty(k.get(41))+
FuncUtil.isEmpty(k.get(42))+FuncUtil.isEmpty(k.get(43))+FuncUtil.isEmpty(k.get(44))+
FuncUtil.isEmpty(k.get(45))+FuncUtil.isEmpty(k.get(46))+FuncUtil.isEmpty(k.get(47))+
FuncUtil.isEmpty(k.get(48))+FuncUtil.isEmpty(k.get(49))+FuncUtil.isEmpty(k.get(50))+
FuncUtil.isEmpty(k.get(51))+"'"+date+"','"+areaType+"')";
statement.execute(sql);
i++;
}
FuncUtil.getMap(map,CoreConstant.RESULT_SUCCESS, "");
}
catch (Exception e) {
try {
con.rollback();
} catch (SQLException e1) {
log.error(e1);
}
log.error("导入数据出错了!!出错的数据行数为:"+(i+2));
log.error("出错语句:"+sql);
log.error(e);
FuncUtil.getMap(map,CoreConstant.RESULT_FAIL, "导入数据出错了!!出错的数据行数为:"+(i+2)+";error:"+String.valueOf(e));
}finally{
FuncUtil.removeFile(file); // 删除解析后的.csv文件
}
return i;
}

 

posted @ 2019-02-27 09:47  jourage  阅读(1501)  评论(0编辑  收藏  举报