wisplite/distant-horizons-core-sharded
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

handle additional DB closed message on DTO get

Browse Source
This commit is contained in:
James Seibel
2025-01-20 07:38:40 -06:00
parent f609dcb468
commit 582541d240
2 changed files with 13 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core/src/main/java/com/seibel/distanthorizons/core/sql/DbConnectionClosedException.java
+4 -1
View File
@@ -20,7 +20,10 @@ public class DbConnectionClosedException extends SQLException
{
// TODO long term we should prevent using repos that are closed, but for now this is the easier solution
String message = e.getMessage().toLowerCase();
return message.contains("connection closed") || message.contains("pointer is closed") || message.contains("database has been closed");
return message.contains("connection closed")
|| message.contains("pointer is closed")
|| message.contains("stmt pointer is closed")
|| message.contains("database has been closed");
}
}
core/src/main/java/com/seibel/distanthorizons/core/sql/repo/AbstractDhRepo.java
+9 -1
View File
@@ -189,7 +189,15 @@ public abstract class AbstractDhRepo<TKey, TDTO extends IBaseDTO<TKey>> implemen
}
catch (SQLException | IOException e)
{
LOGGER.warn("Unexpected issue deserializing DTO ["+this.dtoClass.getSimpleName()+"] with primary key ["+primaryKey+"]. Error: ["+e.getMessage()+"].", e);
if (e instanceof SQLException
&& DbConnectionClosedException.IsClosedException((SQLException)e))
{
//LOGGER.warn("Attempted to get ["+this.dtoClass.getSimpleName()+"] with primary key ["+primaryKey+"] on closed repo ["+this.connectionString+"].");
}
else
{
LOGGER.warn("Unexpected issue deserializing DTO ["+this.dtoClass.getSimpleName()+"] with primary key ["+primaryKey+"]. Error: ["+e.getMessage()+"].", e);
}
return null;
}
}