线程池和连接池，需要帮助来理解它们是如何工作的 Java

Question

所以基本上我是一家大公司的实习生。我必须做一个小的java程序（javaFX），它需要一个csv列表并更新我们的数据库（3个服务器6个数据库）。该文件有超过 700.000 个条目，我们的服务器可以支持 50 个连接。所以我对连接池的限制是 50，我应该使用不超过 200 个线程。那是我从首席程序员那里得到的信息。

我开始了我的项目，制作了我的对象并从 csv 文件中制作了一个可观察的列表（可以说它只有 Id 和 price，其他字段无论如何都无关紧要）。我所在的堆栈是线程池和连接池。我如何与两者一起工作？在我的新手头脑中，我在想我将创建一个循环，使 200 个线程执行语句，但是我必须使用 50 个连接，所以我应该创建 50 个线程，从池中打开 50 个连接并执行更新？如果有人有一个例子让我了解 mysql 连接的线程是如何工作的，我会非常高兴，因为我的脑袋要爆炸了。

Answer 1

我不明白是否需要使用多线程来读取 CSV 文件 (IO) 并将数据加载到数据库。没有它你也可以做到。 在 Spring 中（假设 JavaFX 支持 Spring）您可以将 Chunks 中的数据作为字节流读取，并将数据分批加载到数据库中（例如每 5000 行）。下面是一个示例 sn-p。

import org.springframework.data.repository.CrudRepository;

//import org.springframework.data.jpa.repository.JpaRepository;
//import org.springframework.data.repository.CrudRepository;

import com.billing.portal.notification.entities.Notification;

public interface NotifyRepo extends CrudRepository<Notification, Integer> {

}

下面的实现代码

@Autowired
NotifyRepo notify;

int total=notifyRecords.size();
System.out.println("Total records are  "+total);
int limit=5000;
int start=0;
int rem=0;
boolean check=true;
if(total>5000) {
    rem = total-limit;
    while(check) {
            System.out.println("Start ::: "+start
                    +" limit ::: "+limit
                    +" rem ::: "+rem
                     );
            notifyRecords1 = notifyRecords.subList(start,limit);
            System.out.println("********************* Batch Insert Started from "+start+" to "+limit +"************************");
            notify.saveAll(notifyRecords1);
            System.out.println("Batch Insert Completed");
            if(limit==total) {
                break;
            }
            start=limit;
            rem=rem-5000;
            limit+=5000;    
            if(rem<=0) {
                limit=total;
            }

        }

    Batchload load = new Batchload();
    loadRepo.save(load);                    

    }else {

        System.out.println("Batch insert started, total less than "+limit);
        notify.saveAll(notifyRecords);
}