读取txt文件然后录入数据库（批处理）

﹏ヽ暗。殇╰゛Y 2022-06-05 07:40 88阅读 0赞

public static void main(String\[\] args) \{  
    File file = new File("1.txt");  
    txt2String(file);  
\}  
      
    public static String txt2String(File file)\{  
        StringBuilder result = new StringBuilder();  
        int i=0;  
        try\{  
    JT\_po\[\] sql3 = new JT\_po\[20000\];  
            BufferedReader br = new BufferedReader(new FileReader(file));//构造一个BufferedReader类来读取文件  
            String s = null;  
            while((s = br.readLine())!=null)\{//使用readLine方法，一次读一行  
            JT\_po jt\_po=new JT\_po();  
            int nu=s.lastIndexOf("\#");  
            String\[\] dd= s.split("\#");  
            jt\_po.setAllcount( s.substring((nu+1),s.length()));  
            jt\_po.setId(dd\[0\].toString());  
            jt\_po.setNewstext("0");  
            jt\_po.setNewstime(dd\[4\].toString());  
            jt\_po.setTitle(dd\[3\].toString());  
            jt\_po.setType1(dd\[1\].toString());  
            jt\_po.setType2(dd\[2\].toString());  
                result.append(System.lineSeparator()+s);  
                sql3\[i\]=jt\_po;  
                i++;  
            \}  
            DBService.insert(sql3);  
            br.close();      
        \}catch(Exception e)\{  
            e.printStackTrace();  
        \}

return result.toString();

**DBService     采用的spring的数据库操作**

**//测试专有  
 public static int insert(final JT\_po\[\] sqlArray) throws Exception \{    
 String  sql="insert into D\_SRC\_FLOW(MC,TYPE1,TYPE2,TYPE3,Ldbh,Lnglat,Type) values(?,?,?,?,?,?,?)";  
       try\{      
        JdbcTemplate  jdbcTemplate = jdbcTemplateMap.get(YJZHDEVICE);  
           int\[\] ii =jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter()\{    
                public void setValues(PreparedStatement ps, int i)      
                   throws SQLException \{      
                 JT\_po jt= sqlArray\[i\];  
               ps.setString(1,jt.getId());    
               ps.setString(2,jt.getType1());    
               ps.setString(3,jt.getType2());    
               ps.setString(4,jt.getTitle());    
               ps.setString(5,jt.getNewstime());    
               ps.setString(6,jt.getAllcount());    
               ps.setString(7,jt.getNewstext());    
           \}    
               @Override    
               public int getBatchSize() \{    
                   return sqlArray.length;  
               \}      
           \});      
           System.out.println("sql执行完成，长度为："+ii.length);  
           return ii.length;    
       \}catch (org.springframework.dao.DataAccessException e) \{      
           e.printStackTrace();      
       \}    
       return 0;     
   \}  **