Java应用中SQL操作性能基准测试指南

import java.time.Instant;
import java.time.Duration;

public class PerformanceMeasurer {

    public void measureOperation() {
        // 记录操作开始时间
        Instant start = Instant.now();

        // 这里执行您的SQL数据库操作，例如：
        // sql.checkFileImport(); // 假设这是一个耗时的数据库操作

        // 模拟一个耗时的数据库操作
        try {
            Thread.sleep(1500); // 模拟1.5秒的数据库操作
            System.out.println("模拟数据库操作完成。");
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            System.err.println("模拟操作被中断: " + e.getMessage());
        }

        // 记录操作结束时间
        Instant end = Instant.now();

        // 计算并打印持续时间
        Duration timeElapsed = Duration.between(start, end);
        System.out.println("操作耗时: " + timeElapsed);
        System.out.println("操作耗时（毫秒）: " + timeElapsed.toMillis() + "ms");
    }

    public static void main(String[] args) {
        new PerformanceMeasurer().measureOperation();
    }
}

import java.io.IOException;
import java.nio.file.*;
import java.time.Instant;
import java.time.Duration;
import java.util.HashMap;
import java.util.List;

// 假设 SqlUtils 类包含 checkFileImport 方法
class SqlUtils {
    public HashMap<String, List> checkFileImport() {
        // 模拟实际的数据库操作，例如导入XML文件到SQL表
        System.out.println("开始执行数据库文件导入检查...");
        try {
            Thread.sleep((long)(Math.random() * 2000) + 500); // 模拟0.5到2.5秒的数据库操作
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            System.err.println("数据库操作被中断: " + e.getMessage());
        }
        System.out.println("数据库文件导入检查完成。");
        return new HashMap<>(); // 实际应返回数据库操作结果
    }
}

public class FileImportBenchmark extends SqlUtils {

    private static String folderPath = "D:\EntityImportEversana"; // 请替换为实际的监控路径

    public static void main(final String[] args) throws IOException, InterruptedException {

        System.out.println("正在运行文件验证器...");
        System.out.println("正在监控文件夹: " + folderPath);
        SqlUtils sql = new SqlUtils();

        WatchService watchService = FileSystems.getDefault().newWatchService();
        Path path = Paths.get(folderPath);
        // 确保文件夹存在，否则注册会失败
        if (!Files.exists(path)) {
            Files.createDirectories(path); // 如果不存在则创建
            System.out.println("创建了监控文件夹: " + folderPath);
        }
        path.register(watchService, StandardWatchEventKinds.ENTRY_CREATE, StandardWatchEventKinds.ENTRY_DELETE, StandardWatchEventKinds.ENTRY_MODIFY);

        WatchKey key;
        while ((key = watchService.take()) != null) {
            for (WatchEvent<?> event : key.pollEvents()) {
                System.out.println("事件类型: " + event.kind() + ". 受影响文件: " + event.context() + ".");

                // 仅在文件删除事件发生时进行基准测试
                if(event.kind().equals(StandardWatchEventKinds.ENTRY_DELETE)){
                    System.out.println("检测到文件删除，开始数据库操作基准测试...");
                    // 记录基准测试开始时间
                    Instant start = Instant.now();

                    // 执行目标数据库操作
                    HashMap<String, List> map = sql.checkFileImport();

                    // 记录基准测试结束时间
                    Instant end = Instant.now();

                    // 计算并打印耗时
                    Duration timeElapsed = Duration.between(start, end);
                    System.out.println("数据库操作 'checkFileImport' 耗时: " + timeElapsed);
                    System.out.println("具体耗时（毫秒）: " + timeElapsed.toMillis() + "ms");
                    System.out.println("----------------------------------------");
                }
            }
            key.reset(); // 重置key以接收更多事件
        }

        watchService.close();
    }
}