java mysql的jdbc批量导入

缺乏、安全感 2022-06-07 00:17 26阅读 0赞

/\*\*  
     \* 批量导入的方法  
     \* @param receiverList  
     \* @throws Exception   
     \*/

private void inserBatch(List<GgEntity> GgList) throws Exception\{

Connection con = null;  
        PreparedStatement pst = null;  
        
        try\{  
            Class.forName("com.mysql.jdbc.Driver");  
            con = (Connection) DriverManager.getConnection(url,username,this.getPassword());              
            String sql = "insert into Gg(COLUMN\_NAME , COLUMN\_CODE ,TYPE,PARENT\_COLUMN\_CODE,status,CREATE\_BY,CREATE\_TIME) values "  
            \+ "(?,?,?,?,?,?,?)";  
            // 关闭事务自动提交  
            con.setAutoCommit(false);  
                        
            pst = (PreparedStatement) con.prepareStatement(sql);  
            int i=0;  
            Long start = System.currentTimeMillis();  
            if (GgList.size() > 0) \{  
            for (GgEntity bre : GgList)  
            \{  
            pst.setString(1,bre.getColumnName());  
            pst.setString(2, bre.getColumnCode());  
            pst.setInt(3, bre.getType());  
            pst.setString(4, bre.getParentColumnCode());  
            pst.setInt(5, bre.getStatus());  
            pst.setLong(6, bre.getCreateBy());  
            pst.setTimestamp(7, new Timestamp(System.currentTimeMillis()));  
  
  
            // 把一个SQL命令加入命令列表  
            pst.addBatch();  
              
            if (i % 500 == 0)\{//500条执行一次  
            pst.executeBatch();  
            con.commit();  
            System.out.println("批量插入数据库=======" + i);  
            \}  
            i++;  
              
            \}  
            // 执行批量更新  
            pst.executeBatch();  
            // 语句执行完毕，提交本事务              
            con.commit();  
            Long end  = System.currentTimeMillis();  
            System.out.println("=============================插入"+receiverList.size()+"条数据用了"+(end - start)/1000 + "秒");  
\}  
       \} catch (ClassNotFoundException e) \{  
           e.printStackTrace();  
       \} catch (SQLException e) \{  
           e.printStackTrace();  
       \}finally \{  
           try  
          \{  
              con.setAutoCommit(true);  
              con.close();  
              pst.close();  
          \}  
          catch (SQLException e)  
          \{  
                
              e.printStackTrace();  
          \}  
            
      \}  
  
  
    \}