不同线程的连接无法读取在另一个线程中创建的表格?
创始人
2025-01-09 21:00:54
0

问题的解决方法是使用线程安全的数据库连接池来创建不同线程之间的连接。下面是一个使用HikariCP连接池的代码示例:

// 创建HikariCP连接池
HikariConfig config = new HikariConfig();
config.setJdbcUrl("jdbc:mysql://localhost:3306/test");
config.setUsername("username");
config.setPassword("password");
HikariDataSource ds = new HikariDataSource(config);

// 在不同的线程中使用连接
ExecutorService executor = Executors.newFixedThreadPool(2);
executor.submit(() -> {
    try (Connection conn = ds.getConnection()) {
        // 在第一个线程中创建表格
        Statement stmt = conn.createStatement();
        stmt.executeUpdate("CREATE TABLE IF NOT EXISTS users (id INT PRIMARY KEY, name VARCHAR(255))");
    } catch (SQLException e) {
        e.printStackTrace();
    }
});

executor.submit(() -> {
    try (Connection conn = ds.getConnection()) {
        // 在第二个线程中读取表格
        Statement stmt = conn.createStatement();
        ResultSet rs = stmt.executeQuery("SELECT * FROM users");
        while (rs.next()) {
            System.out.println(rs.getInt("id") + " " + rs.getString("name"));
        }
    } catch (SQLException e) {
        e.printStackTrace();
    }
});

executor.shutdown();

在这个示例中,我们使用HikariCP连接池创建了两个不同的线程,并在第一个线程中创建了一个表格,同时在第二个线程中从数据库中读取该表格。注意每个线程都通过连接池获取了数据库连接,并在处理完成后关闭了它们的连接。这样,就可以安全地在不同的线程中使用连接来读取/写入数据库了。

相关内容

热门资讯

黑科技科技(wepoke智能a... 黑科技科技(wepoke智能ai)wepower使用说明书(wepOkE)素来是真的有挂(确实有挂)...
黑科技模拟器(wepoke智能... WePoker透视辅助工具核心要点解析‌,黑科技模拟器(wepoke智能ai)wepoke是机器发牌...
黑科技脚本(wepokeai代... 您好,这款游戏可以开挂的,确实是有挂的,需要了解加微【136704302】很多玩家在这款游戏中打牌都...
黑科技辅助挂(wepoke真的... 黑科技辅助挂(wepoke真的有挂)wepoke 软件(wEPOKE)固有真的有挂(有挂猫腻)-哔哩...
黑科技辅助挂(wepoke黑科... 黑科技辅助挂(wepoke黑科技)wepoke软件透明挂演示(wEpOke)一直真的有挂(真的有挂)...
黑科技app(wepoke真的... 此外,数据分析德州()辅助神器app还具备辅助透视行为开挂功能,通过对客户透明挂的深入研究,你可以了...
黑科技智能ai(wepoke辅... 黑科技智能ai(wepoke辅助插件)wepoke软件透明(WEPOke)先前是有挂(果真有挂)-哔...
黑科技模拟器(wepoke透明... 黑科技模拟器(wepoke透明黑科技)wepoke德州扑克用ai代打(WEPOKE)最初存在有挂(有...
黑科技插件(wepoke辅助插... 黑科技插件(wepoke辅助插件)wepoke软件透明(WEPOke)从来是真的有挂(有挂解惑)-哔...
黑科技美元局(wepoke智能... 黑科技美元局(wepoke智能ai)wepoke辅助真的假的(wepoKE)原先真的有挂(竟然有挂)...