小编Mik*_*kov的帖子

list.stream().forEach(e -> { dbCall.delete(e.Id());});

列表中的每一项都会从数据库中删除。

假设列表中有3项，如何进行单元测试：

1. 删除被调用了 3 次。
2. 删除被称为“按顺序/顺序”，即列表中元素的顺序？

我制作了一个简单的应用程序以连接到MySQL数据库，但出现此错误：

org.springframework.jdbc.core.JdbcTemplate

在我的配置中(com.kubamadry.dao.MySqlStudentDao)：

*****************************
APPLICATION FAILED TO START
*****************************

Description:

Field jdbcTemplate in com.kubamadry.dao.MySqlStudentDao required a bean of type 'org.springframework.jdbc.core.JdbcTemplate' that could not be found.


Action:

Consider defining a bean of type 'org.springframework.jdbc.core.JdbcTemplate' in your configuration.

Disconnected from the target VM, address: '127.0.0.1:49838', transport: 'socket'

Process finished with exit code 1

项目结构：

图片

班级

主要

package com.kubamadry;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class Main {
    public static void main(String args[]) {
        SpringApplication.run(Main.class, args);
    }
}

学生

package …

最近升级到 Java 11 并开始执行回归检查。当前在尝试调用 时收到非法反射访问错误com.itextpdf.text.pdf.PdfReader.close。目前在 Itext 5.5.13 版上，但也在 itext 7.0.0 上尝试过并且遇到了同样的问题。

有没有人对如何解决 Java-11 和 Itext 之间的兼容性问题有任何建议？

警告：发生非法反射访问操作警告：com.itextpdf.io.source.ByteBufferRandomAccessSource$1 非法反射访问（文件：...repository/com/itextpdf/io/7.0.0/io-7.0.0.jar ) 方法 java.nio.DirectByteBuffer.cleaner() 警告：请考虑将此报告给 com.itextpdf.io.source.ByteBufferRandomAccessSource$1 的维护者 警告：使用 --illegal-access=warn 启用进一步非法反射访问的警告操作警告：在未来的版本中将拒绝所有非法访问操作

我正在尝试选择最好的方法来并行进行大量的http请求。以下是我到目前为止拥有的两种方法：

1. 使用Apache HttpAsyncClient和CompletableFutures：

   try (CloseableHttpAsyncClient httpclient = HttpAsyncClients.custom()
   .setMaxConnPerRoute(2000).setMaxConnTotal(2000)
   .setUserAgent("Mozilla/4.0")
   .build()) {
   httpclient.start();
   HttpGet request = new HttpGet("http://bing.com/");
   long start = System.currentTimeMillis();
   CompletableFuture.allOf(
           Stream.generate(()->request).limit(1000).map(req -> {
               CompletableFuture<Void> future = new CompletableFuture<>();
               httpclient.execute(req, new FutureCallback<HttpResponse>() {
                   @Override
                   public void completed(final HttpResponse response) {
                       System.out.println("Completed with: " + response.getStatusLine().getStatusCode())
                       future.complete(null);
                   }
                   ...
               });
               System.out.println("Started request");
               return future;
   }).toArray(CompletableFuture[]::new)).get();
   

   Run Code Online (Sandbox Code Playgroud)

2. 常规的每请求线程数方法：

   long start1 = System.currentTimeMillis();
   URL url = new URL("http://bing.com/");
   ExecutorService executor = Executors.newCachedThreadPool();
   
   Stream.generate(()->url).limit(1000).forEach(requestUrl ->{
       executor.submit(()->{
           try {
               URLConnection conn = requestUrl.openConnection();
               System.out.println("Completed …

   Run Code Online (Sandbox Code Playgroud)

我有一个对象列表.该对象如下所示:

public class Slots {
  String slotType;
  Visits visit;
}


public class Visits {
  private long visitCode;
  private String agendaCode;
  private String scheduledTime;
  private String resourceType;
  private String resourceDescription;
  private String visitTypeCode;
  ...
}

我需要找到具有相同元素的元素agendaCode,visitTypeCode并且scheduledTime在我的生活中我无法完成它.

我试过这个:

Set<String> agendas = slotsResponse.getContent().stream()
    .map(Slots::getVisit)
    .map(Visits::getAgendaCode)
    .collect(Collectors.toUnmodifiableSet());

Set<String> visitTypeCode = slotsResponse.getContent().stream()
    .map(Slots::getVisit)
    .map(Visits::getVisitTypeCode)
    .collect(Collectors.toUnmodifiableSet());

Set<String> scheduledTime = slotsResponse.getContent().stream()
    .map(Slots::getVisit)
    .map(Visits::getScheduledTime)
    .collect(Collectors.toUnmodifiableSet());

List<Slots> collect = slotsResponse.getContent().stream()
    .filter(c -> agendas.contains(c.getVisit().getAgendaCode()))
    .filter(c -> visitTypeCode.contains(c.getVisit().getVisitTypeCode()))
    .filter(c -> scheduledTime.contains(c.getVisit().getScheduledTime()))
    .collect(Collectors.toList());

但它没有做我想的那样.理想情况下,我会有一个列表列表,其中每个子列表是共享相同的Slots对象的列表agendaCode, …

JLS 11 “ 7.7.2。导出和打开的包”说：

允许opens指定一个与当前模块关联的编译单元未声明的包。

这将是什么情况？为什么需要这个？

我有两个int数组,a = {10,20,30}和{1,2,3}.

我想获得这两个阵列的笛卡尔积.

当我使用List的IntegerS中的逻辑正常工作:

    List<Integer> intList = Arrays.asList(10,20,30);
    List<Integer> intList1 = Arrays.asList(1,2,3);
    intList.stream().flatMap(i -> intList1.stream().map(j -> new int[]{i,j})).collect(Collectors.toList());

但是,当我使用时int[],我收到编译错误.

错误:(16,79)java:不兼容类型:lambda表达式中的错误返回类型没有变量类型的实例U存在以便java.util.stream.Stream符合java.util.stream.IntStream

    int[] intArray = {10,20,30};
    int[] intArray1 = {1,2,3};
    Arrays.stream(intArray).flatMap(i -> Arrays.stream(intArray1).mapToObj(j -> new int[]{j,i})).collect(Collectors.toList());

请帮我理解这里有什么问题.

PS

Arrays.stream(intArray).mapToObj(i -> new int[]{i,i+1}).collect(Collectors.toList());

产生出局, {(10,11),(20,21),(30,31)}.

我正在使用Selenium webdriver在Java.

该工具将通过Jenkins调用在无头服务器上运行。我的问题是处理多个文件上传。Selenium无法打开浏览器，所以当我点击网站上的上传按钮时，也没有出现选择文件弹出窗口。