У меня есть следующий код:
public boolean updateDatabase(long houseValue, List<Users> userList)
{
boolean result = false;
Connection conn = null;
PreparedStatement stmtUpdateUsers = null;
PreparedStatement stmtQueryHouse = null;
PreparedStatement stmtUpdateHouse = null;
ResultSet rs = null;
String updateUsers = "UPDATE users SET money = ? WHERE username = ?";
String queryHouse = "SELECT * FROM house WHERE house_id = ?";
String updateHouse = "UPDATE house SET house_money = ? WHERE house_id = ?";
try
{
conn = getConnectionPool().getConnection();
conn.setAutoCommit(false);
stmtUpdateUsers = conn.prepareStatement(updateUsers);
...
// Here is some code that updates Users table in a short loop
...
stmtQueryHouse = conn.prepareStatement(queryHouse);
stmtQueryHouse.setInt(1, 1);
rs = stmtQueryHouse.executeQuery();
if(rs.next())
{
long houseMoney = rs.getLong("house_money");
houseMoney += houseValue;
stmtUpdateHouse = conn.prepareStatement(updateHouse);
stmtUpdateHouse.setLong(1, houseMoney);
stmtUpdateHouse.setInt(2, 1);
stmtUpdateHouse.executeUpdate();
}
else
{
throw new SQLException("Failed to update house: unable to query house table");
}
conn.commit();
result = true;
}
catch(SQLException e)
{
logger.warn(getStackTrace(e));
try{conn.rollback();}catch(SQLException excep)
{
logger.warn(getStackTrace(excep));
}
}
finally
{
DbUtils.closeQuietly(rs);
DbUtils.closeQuietly(stmtQueryHouse);
DbUtils.closeQuietly(stmtUpdateUsers);
DbUtils.closeQuietly(stmtUpdateHouse);
try { conn.setAutoCommit(true); } catch (SQLException e) { /* quiet */ }
DbUtils.closeQuietly(conn);
}
return result
}
Этот метод может быть вызван из нескольких потоков, домашняя таблица — это всего лишь таблица с одной строкой, которая содержит общие заработанные деньги. Он обновляется разными потоками.
Проблема в том, что stmtQueryHouse.executeQuery() возвращает пустой набор, и этого не должно происходить, потому что таблица house всегда (с момента создания базы данных) имеет одну строку, которая обновляется (обновляется только столбец house_money).
Когда я запускаю этот код в Windows (драйвер JDBC + mysql 5.5.13), он работает нормально, но когда я запускаю его в CentOS (тот же драйвер JDBC + mysql 5.1.57), он очень часто (если не всегда) возвращает пустой набор результатов. Любая идея, что происходит не так или как я могу проверить, где проблема? Может быть, мне следует использовать select для обновления, но тогда почему он работает в Windows, а не в Linux? Я ценю любую помощь. Заранее спасибо.
