【批量往数据库导入数据遇到的问题】

批量往数据库导入数据遇到的问题

我也踩过这个坑( 1 )

已统计您的踩坑,无需重复点击

回答(0)

详细描述

错误截图

源码

 public static void insertTable(Properties p, String tableName) throws Exception{
        Connection connection = getConnection(p);
        InputStream inputStream = TransferData.class.getResourceAsStream("/"+tableName+".txt");
        BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));
        PreparedStatement preparedStatement = connection.prepareStatement(table_quote.get(tableName));
        String line;

        int linecount = 1;
        String[] params = null;
        try {
            while ((line = reader.readLine()) != null){
                params = line.replaceAll("'","").split(",");
                for(int i=0;i<params.length;i++) {
                    preparedStatement.setObject(i+1,params[i].trim());
                }
                preparedStatement.addBatch();
                if (linecount % 1000 == 0) {
                    preparedStatement.executeBatch();
                    connection.commit();
                }
                linecount++;

            }
            preparedStatement.executeBatch();
            connection.commit();
            preparedStatement.close();
            connection.close();
            inputStream.close();
        } catch (Exception e) {
            e.printStackTrace();
            throw e;
        }
    }

编辑于2024-11-16