You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@james.apache.org by bt...@apache.org on 2023/01/21 06:02:01 UTC

[james-project] 01/02: JAMES-3875 JDBCMailRepository, cut off to long error messages

This is an automated email from the ASF dual-hosted git repository.

btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git

commit c93ba533a3e9819b4c0fd01199f4d94dd2485886
Author: Adrian Bucher <e3...@e3ag.ch>
AuthorDate: Tue Aug 16 14:55:03 2022 +0200

    JAMES-3875 JDBCMailRepository, cut off to long error messages
---
 .../apache/james/mailrepository/jdbc/JDBCMailRepository.java | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/server/data/data-jdbc/src/main/java/org/apache/james/mailrepository/jdbc/JDBCMailRepository.java b/server/data/data-jdbc/src/main/java/org/apache/james/mailrepository/jdbc/JDBCMailRepository.java
index 260c716d22..d475cc0d9e 100644
--- a/server/data/data-jdbc/src/main/java/org/apache/james/mailrepository/jdbc/JDBCMailRepository.java
+++ b/server/data/data-jdbc/src/main/java/org/apache/james/mailrepository/jdbc/JDBCMailRepository.java
@@ -376,7 +376,11 @@ public class JDBCMailRepository implements MailRepository, Configurable, Initial
             insertMessage.setString(1, mc.getName());
             insertMessage.setString(2, repositoryName);
             insertMessage.setString(3, mc.getState());
-            insertMessage.setString(4, mc.getErrorMessage());
+            if (mc.getErrorMessage() != null && mc.getErrorMessage().length() > 200) {
+                insertMessage.setString(4, mc.getErrorMessage().substring(0, 199));
+            } else {
+                insertMessage.setString(4, mc.getErrorMessage());
+            }
             if (mc.getMaybeSender().isNullSender()) {
                 insertMessage.setNull(5, Types.VARCHAR);
             } else {
@@ -460,7 +464,11 @@ public class JDBCMailRepository implements MailRepository, Configurable, Initial
         // Update the existing record
         try (PreparedStatement updateMessage = conn.prepareStatement(sqlQueries.getSqlString("updateMessageSQL", true))) {
             updateMessage.setString(1, mc.getState());
-            updateMessage.setString(2, mc.getErrorMessage());
+            if (mc.getErrorMessage() != null && mc.getErrorMessage().length() > 200) {
+                updateMessage.setString(2, mc.getErrorMessage().substring(0, 199));
+            } else {
+                updateMessage.setString(2, mc.getErrorMessage());
+            }
             if (mc.getMaybeSender().isNullSender()) {
                 updateMessage.setNull(3, Types.VARCHAR);
             } else {


---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org