不同线程的连接无法读取在另一个线程中创建的表格?
创始人
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透视挂!wepow... WePoKe透视挂!wepower插件,WePoKer果然真的有挂,详细教程(有挂详情)1、很好的工...
aapoker猫腻!德扑软件决... aapoker猫腻!德扑软件决策,微扑克发牌机制(详细透视教程);wpk透视辅助官方版是专为公司和个...
wpk透视辅助!wpk积分后台... wpk透视辅助!wpk积分后台管理系统,Wpk原来真的有挂,详细教程,(有挂工具)1、金币登录送、破...
微扑克全自动机器人!微扑克发牌... 微扑克全自动机器人!微扑克发牌逻辑,WPK果然存在有挂,存在挂教程(有挂方法)1、用户打开应用后不用...
wepoke模拟器!wepok... wepoke模拟器!wepoke系统(透视)wEPoke(的确是有挂的)1、让任何用户在无需AI插件...
aapoker辅助!德州ai智... aapoker辅助!德州ai智能辅助,pokermastersteam外挂(详细透视挂教程)1、玩家...
wpk辅助挂(WPK)wpk发... wpk辅助挂(WPK)wpk发牌算法(辅助挂)其实真的有挂(wepoke教程);小薇(透视辅助)致您...
微扑克有辅助挂!微扑克辅助,微... 1、微扑克有辅助挂!微扑克辅助,微扑克辅助是真的(竟然真的是有挂)2、进入游戏-大厅左侧-新手福利-...
wepokeai代打的胜率!w... 【福星临门,好运相随】;wepokeai代打的胜率!wepoke透明挂辅助软件是真的,wepoke软...
WPK透视辅助(WPk)wpk... WPK透视辅助(WPk)wpk德州俱乐部机器人(辅助挂)果真真的有挂(科技教程);1、完成WPK的残...