Class ExceptionFactory

    • Field Detail

      • LOCK_DEADLOCK_ERROR_CODES

        private static final java.util.Set<java.lang.Integer> LOCK_DEADLOCK_ERROR_CODES
      • threadId

        private long threadId
      • statement

        private java.sql.Statement statement
    • Method Detail

      • buildMsgText

        private static java.lang.String buildMsgText​(java.lang.String initialMessage,
                                                     long threadId,
                                                     Configuration conf,
                                                     java.lang.String sql,
                                                     int errorCode,
                                                     Connection connection)
      • setConnection

        public void setConnection​(ExceptionFactory oldExceptionFactory)
      • setThreadId

        public void setThreadId​(long threadId)
      • createBatchUpdate

        public java.sql.BatchUpdateException createBatchUpdate​(java.util.List<Completion> res,
                                                               int length,
                                                               java.sql.SQLException sqle)
      • createBatchUpdate

        public java.sql.BatchUpdateException createBatchUpdate​(java.util.List<Completion> res,
                                                               int length,
                                                               int[] responseMsg,
                                                               java.sql.SQLException sqle)
      • createException

        private java.sql.SQLException createException​(java.lang.String initialMessage,
                                                      java.lang.String sqlState,
                                                      int errorCode,
                                                      java.lang.Exception cause)
      • notSupported

        public java.sql.SQLException notSupported​(java.lang.String message)
      • create

        public java.sql.SQLException create​(java.lang.String message)
      • create

        public java.sql.SQLException create​(java.lang.String message,
                                            java.lang.String sqlState)
      • create

        public java.sql.SQLException create​(java.lang.String message,
                                            java.lang.String sqlState,
                                            java.lang.Exception cause)
      • create

        public java.sql.SQLException create​(java.lang.String message,
                                            java.lang.String sqlState,
                                            int errorCode)
      • getSql

        public java.lang.String getSql()