我正在尝试模拟一个场景,其中我的服务失去与数据库的连接并且无法执行INSERT
通过阻止与 iptables 的连接,但我无法使executeQuery()
方法超时。
我所做的是为PreparedStatement设置一个超时,如下所示statement.setQueryTimeout(5)
。这是代码。
HikariConfig config = new HikariConfig();
config.setJdbcUrl("jdbc:mysql://db-url/db");
config.setUsername("user");
config.setPassword("passwd");
config.setMaximumPoolSize(10);
config.setAutoCommit(false);
config.setConnectionTimeout(5000);
config.setDriverClassName("com.mysql.jdbc.Driver");
config.addDataSourceProperty("cachePrepStmts", "true");
config.addDataSourceProperty("prepStmtCacheSize", "250");
config.addDataSourceProperty("prepStmtCacheSqlLimit", "2048");
config.addDataSourceProperty("autoReconnect", "true");
final HikariDataSource pool = new HikariDataSource(config);
final String query = "INSERT INTO xtable VALUES (?, ?, ?, ?, ?)";
try ( Connection connection = pool.getConnection() )
{
try ( PreparedStatement statement = connection.prepareStatement(query) )
{
// this is what I expect to work
statement.setQueryTimeout(5);
for ( Info info : infos )
{
statement.setString(1, info.getValue1());
statement.setString(2, info.getValue2());
statement.setString(3, info.getValue3());
statement.setString(4, info.getValue4());
statement.setString(5, info.getValue5());
try
{
System.out.println("Waiting");
Thread.sleep(5000);
// I use this sleep to ban the database url with iptables
// to simulate a disconnection
System.out.println("Waited");
}
catch ( InterruptedException e )
{
e.printStackTrace();
}
System.out.println("Before executeQuery");
statement.executeQuery();
// I assumed that this would timeout after 5 seconds
// But it never reaches the next System.out.print
System.out.println("After executeQuery");
}
}
System.out.println("Before commit");
connection.commit();
System.out.println("After commit");
}
catch ( SQLException e )
{
log.error("Couldn't execute query", e);
}
输出将是:
Waiting
Waited
Before executeQuery
然后它永远挂起......我该怎么做才能让它抛出异常?