潜渊者 2023-03-17 15:36 采纳率: 68.3%
浏览 57
已结题

java怎么控制for循环内的程序等待IO读完数据?

我现在用jdbc程序往mysql插入十万条假数据,其中一种假数据的生成依赖io读取excel文件,再生成随机数拼接而成。
现在报空指针错误,我怀疑是因为假数据还没有生成,io时间长,for循环的赋值程序就进行了。
现在运行个3秒或4秒,就报空指针错误,一次只能插入200条数据,离目标很远。
我添加if语句判断假数据不为空才继续赋值,也不管用。
请问我该怎么控制啊?

public class AddXXXData {
    public static int  generateNum(int range){
        SecureRandom random = new SecureRandom();
        return  random.nextInt(range+1);
    }

    public static double  generateFloatNum(){
        double min = 1.0;
        double max = 200.0;
        double boundedDouble = min + new Random().nextDouble() * (max - min);
        return  boundedDouble;
    }

    public static String generateXXXname(){
        StringBuilder xxName = new StringBuilder();
        try {
            //创建工作簿对象
            XSSFWorkbook xssfWorkbook = new XSSFWorkbook(new FileInputStream("C:\\xx\\Desktop\\xx.xlsx"));
            XSSFSheet sheet = xssfWorkbook.getSheetAt(0);
            int maxRow = sheet.getLastRowNum();
            SecureRandom random = new SecureRandom();
            int i=random.nextInt(maxRow);

            XSSFWorkbook xssfWorkbook2 = new XSSFWorkbook(new FileInputStream("C:\\xx\\Desktop\\yy.xlsx"));
            XSSFSheet sheet2 = xssfWorkbook2.getSheetAt(0);
            int maxRow2 = sheet2.getLastRowNum();
            SecureRandom random2 = new SecureRandom();
            int j=random2.nextInt(maxRow2);

            xxName.append(sheet2.getRow(j-1).getCell(0)).append(sheet.getRow(i-1).getCell(0));
        } catch (IOException e) {
            e.printStackTrace();
        }
        return  xxName.toString();
    }

    @Test
    public void add(){
        long stime = System.currentTimeMillis();
        try {
            Class.forName("com.mysql.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            String url = "jdbc:mysql://xx.xx.xxx.xxx:3306/ss?characterEncoding=utf-8";
            String user = "xx";
            String password = "xx";
            conn = DriverManager.getConnection(url, user, password);
            for(int i=0;i<100000;i++){
                int id = generateNum(100);
                double num = generateFloatNum();
                String name = generateXXXname();

                if(name!=null){
                    Timestamp timestamp = new Timestamp(System.currentTimeMillis());
                    String sql = "INSERT INTO tb_xx (info,xx_name,aa_id,xx_picture," +
                            "price,num,status,bargin,zz_id,payment_count,insurance,free_delivery," +
                            "yy_id,created_time,updated_time) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
                    PreparedStatement ps = conn.prepareStatement(sql);
                    ps.setString(1," ");
                    ps.setString(2,name);
                    ps.setInt(3,id);
                    ps.setString(4," ");
                    ps.setDouble(5, num);
                    ps.setInt(6,100);
                    ps.setInt(7,1);
                    ps.setDouble(8,10.0);
                    ps.setInt(9,id);
                    ps.setInt(10,0);
                    ps.setString(11,"  ");
                    ps.setInt(12,1);
                    ps.setInt(13,id);
                    ps.setTimestamp(14,timestamp);
                    ps.setTimestamp(15,timestamp);
                    ps.executeUpdate();
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        long etime = System.currentTimeMillis();
        System.out.printf("执行时长:%d 秒.", (etime - stime)/1000);
    }
}


  • 写回答

7条回答 默认 最新

  • Ycj_3355 2023-03-19 00:09
    关注

    可以尝试使用多线程来控制数据的生成和插入。将数据生成和插入分别放在不同的线程中,通过线程间的通信来控制数据的生成和插入速度。可以使用线程池来管理线程,避免线程过多导致系统资源的浪费。另外,也可以尝试优化数据生成和插入的代码,例如使用缓存来减少IO操作的次数,或者是使用批量插入来提高插入效率。最后,可以根据具体情况来调整数据生成和插入的速度,避免出现空指针错误。

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(6条)

报告相同问题?

问题事件

  • 系统已结题 3月28日
  • 已采纳回答 3月20日
  • 创建了问题 3月17日

悬赏问题

  • ¥18 深度学习tensorflow1,ssdv1,coco数据集训练一个模型
  • ¥100 关于注册表摄像头和麦克风的问题
  • ¥30 代码本地运行正常,但是TOMCAT部署时闪退
  • ¥15 关于#python#的问题
  • ¥15 主机可以ping通路由器但是连不上网怎么办
  • ¥15 数据库一张以时间排好序的表中,找出多次相邻的那些行
  • ¥50 关于DynamoRIO处理多线程程序时候的问题
  • ¥15 kubeadm部署k8s出错
  • ¥15 Abaqus打不开cae文件怎么办?
  • ¥15 小程序准备上线,软件开发公司需要提供哪些资料给甲方