1. Connection connection = null;
  2. boolean deadlock = false;
  3. ISFSObject outData = null;
  4. int retries = 0;
  5. int userId = sender.getVariable("userId").getIntValue();
  7. PreparedStatement psSelectUsersSettings = null;
  9. ResultSet rsSelectUsersSettings = null;
  11. do
  12. {
  13. deadlock = false;
  14. outData = new SFSObject();
  16. try
  17. {
  18. connection = this.getParentExtension().getParentZone().getDBManager().getConnection();
  20. connection.setAutoCommit(true);
  22. psSelectUsersSettings = connection.prepareStatement("SELECT * FROM users_settings WHERE user_id = ?");
  23. psSelectUsersSettings.setInt(1, userId);
  25. rsSelectUsersSettings = psSelectUsersSettings.executeQuery();
  27. if(rsSelectUsersSettings.first())
  28. {
  29. outData.putUtfString("icon_bar_order", rsSelectUsersSettings.getString("icon_bar_order"));
  30. }
  31. else
  32. {
  33. this.trace(ExtensionLogLevel.ERROR, "User settings do not exist for user id: " + userId);
  35. return;
  36. }
  38. this.send(ClientRequestHandlerID.USER_SETTINGS, outData, sender);
  39. }
  40. catch(SQLException e)
  41. {
  42. this.trace(ExtensionLogLevel.ERROR, e.getMessage());
  44. if(e.getErrorCode() == MySQLExceptionErrorCode.ER_LOCK_DEADLOCK.getErrorCode())
  45. {
  46. deadlock = true;
  47. }
  48. }
  49. finally
  50. {
  51. if(rsSelectUsersSettings != null)
  52. {
  53. try
  54. {
  55. rsSelectUsersSettings.close();
  56. }
  57. catch (SQLException e)
  58. {
  59. this.trace(ExtensionLogLevel.ERROR, e.getMessage());
  60. }
  61. }
  63. if(psSelectUsersSettings != null)
  64. {
  65. try
  66. {
  67. psSelectUsersSettings.close();
  68. }
  69. catch (SQLException e)
  70. {
  71. this.trace(ExtensionLogLevel.ERROR, e.getMessage());
  72. }
  73. }
  75. if(connection != null)
  76. {
  77. try
  78. {
  79. connection.close();
  80. }
  81. catch (SQLException e)
  82. {
  83. this.trace(ExtensionLogLevel.ERROR, e.getMessage());
  84. }
  85. }
  86. }
  87. }
  88. while(deadlock && retries++ < 3);
  90. if(retries == 3)
  91. {
  92. this.trace(ExtensionLogLevel.ERROR, "Maximum MySQL transaction retries reached");
  93. }