登录
当前位置： 首页 > 知识库问答 >
问题：

已有关联的托管连接错误

杜元明
2023-03-14

根本原因是

org.hibernate.TransactionException: Already have an associated managed connection

    package com.next.domain;

import static javax.persistence.GenerationType.AUTO;
import static org.apache.commons.lang.builder.EqualsBuilder.reflectionEquals;
import static org.apache.commons.lang.builder.HashCodeBuilder.reflectionHashCode;
import static org.apache.commons.lang.builder.ToStringBuilder.reflectionToString;

import java.io.Serializable;
import java.util.Date;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.Id;
import javax.persistence.Table;
import javax.validation.constraints.Size;
import javax.xml.bind.annotation.XmlRootElement;

@Entity
@Table(name="answers")
@XmlRootElement
public class Answer implements Serializable {
    private static final long serialVersionUID = 1L;

    private Long mId;
    private Long mQuizId;

    @Size(max=1000, message="\'Description\' must be less than 1000 characters.")
    private String mContent;

    private Date mRegDate;

    @Id
    @GeneratedValue(strategy = AUTO)
    public Long getId() {
        return mId;
    }

    public void setId(Long id) {
        mId = id;
    }

    @Column(name="quiz_id")
    public Long getQuizId() {
        return mQuizId;
    }

    public void setQuizId(Long quizId) {
        mQuizId = quizId;
    }

    @Column(name="content")
    public String getContent() {
        return mContent;
    }

    public void setContent(String content) {
        mContent = content;
    }

    @Column(name="reg_date")
    public Date getRegDate() {
        return mRegDate;
    }

    public void setRegDate(Date regDate) {
        mRegDate = regDate;
    }

    @Override
    public boolean equals(Object obj) {
        return reflectionEquals(this, obj);
    }

    @Override
    public int hashCode() {
        return reflectionHashCode(this);
    }

    @Override
    public String toString() {
        return reflectionToString(this);
    }
}







package com.next.domain;

import static javax.persistence.GenerationType.AUTO;
import static org.apache.commons.lang.builder.EqualsBuilder.reflectionEquals;
import static org.apache.commons.lang.builder.HashCodeBuilder.reflectionHashCode;
import static org.apache.commons.lang.builder.ToStringBuilder.reflectionToString;

import java.io.Serializable;
import java.util.Date;
import java.util.List;

import javax.persistence.CascadeType;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.Id;
import javax.persistence.JoinColumn;
import javax.persistence.OneToMany;
import javax.persistence.Table;
import javax.validation.constraints.Size;
import javax.xml.bind.annotation.XmlRootElement;

import org.hibernate.validator.constraints.NotEmpty;

@Entity
@Table(name="quizzes")
@XmlRootElement
public class Quiz implements Serializable {
    private static final long serialVersionUID = 1L;

    private Long mId;

    private Integer mSection;

    private Long mAnswerId;

    @NotEmpty(message="\'Title\' must not be empty.")
    @Size(max=64, message="\'Title\' must be less than 64 characters.")
    private String mTitle;

    @Size(max=256, message="\'Question\' must be less than 256 characters.")
    private String mContent;

    @Size(max=256, message="\'Description\' must be less than 256 characters.")
    private String mDescription;

    private List<Answer> mAnswers;

    private Date mRegDate;

    @Id
    @GeneratedValue(strategy = AUTO)
    public Long getId() {
        return mId;
    }

    public void setId(Long id) {
        mId = id;
    }

    @Column(name="section")
    public Integer getSection() {
        return mSection;
    }

    public void setSection(Integer mSection) {
        this.mSection = mSection;
    }

    @Column(name="answer_id")
    public Long getAnswerId() {
        return mAnswerId;
    }

    public void setAnswerId(Long answer_id) {
        mAnswerId = answer_id;
    }

    @Column(name="title")
    public String getTitle() {
        return mTitle;
    }

    public void setTitle(String title) {
        mTitle = title;
    }

    @Column(name="content")
    public String getContent() {
        return mContent;
    }

    public void setContent(String content) {
        mContent = content;
    }

    @Column(name="description")
    public String getDescription() {
        return mDescription;
    }

    public void setDescription(String description) {
        mDescription = description;
    }

    @OneToMany(cascade={CascadeType.MERGE, CascadeType.REMOVE})
    @JoinColumn(name="quiz_id", referencedColumnName="id")
    public List<Answer> getAnswers() {
        return mAnswers;
    }

    public void setAnswers(List<Answer> answers) {
        mAnswers = answers;
    }

    @Column(name="reg_date")
    public Date getRegDate() {
        return mRegDate;
    }

    public void setRegDate(Date regDate) {
        mRegDate = regDate;
    }

    @Override
    public boolean equals(Object obj) {
        return reflectionEquals(this, obj);
    }

    @Override
    public int hashCode() {
        return reflectionHashCode(this);
    }

    @Override
    public String toString() {
        return reflectionToString(this);
    }
}







       package com.next.persistence;

    import java.text.ParseException;
    import java.text.SimpleDateFormat;
    import java.util.Date;
    import java.util.List;
    import java.util.Map;

    import javax.persistence.EntityManager;
    import javax.persistence.NoResultException;
    import javax.persistence.PersistenceContext;
    import javax.persistence.PersistenceContextType;

    import org.springframework.stereotype.Repository;
    import org.springframework.transaction.annotation.Propagation;
    import org.springframework.transaction.annotation.Transactional;

    import com.next.domain.Answer;
    import com.next.domain.Quiz;
    import com.next.domain.QuizSubmission;

    @Repository("quizDao")
    @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Throwable.class)
    public class QuizDaoImpl implements QuizDao {
        private static final String QUIZ_SELECT_CLAUSE = "select new map(q.id as id, q.title as title, q.regDate as regDate)";
        private static final String ANSWER_SELECT_CLAUSE = "select new map(a.id as id, a.content as content)";

        @PersistenceContext(type=PersistenceContextType.EXTENDED)
        private EntityManager em;

        @Override
        public void addQuiz(Quiz quiz) {
            em.persist(quiz);
        }

        @Override
        public void saveQuiz(Quiz quiz) {
            em.merge(quiz);
        }

        @Override
        public void deleteQuiz(long id) {
            try {
                em.remove(getQuiz(id));
            } catch (IllegalArgumentException ie) {
                return;
            }
        }

        @Override
        public Quiz getQuiz(long id) {
            Quiz quiz = null;

            try {
                quiz = em.find(Quiz.class, id);
            } catch (NoResultException e) {}        

            return quiz;
        }

        @Override
        public void addAnswer(Answer answer) {
            em.persist(answer);
        }

        @Override
        public void saveAnswer(Answer answer) {
            em.merge(answer);
        }

        @Override
        public void deleteAnswer(long id) {
            try {
                em.remove(getAnswer(id));
            } catch (IllegalArgumentException ie) {
                return;
            }
        }

        @Override
        public Answer getAnswer(long id) {
            Answer answer = null;

            try {
                answer = em.find(Answer.class, id);
            } catch (NoResultException e) {}        

            return answer;
        }

        @SuppressWarnings("unchecked")
        @Override
        public List<Map<String, Object>> getAnswers(long quizId) {
            return (List<Map<String, Object>>) em.createQuery(ANSWER_SELECT_CLAUSE + " from Answer a where a.quizId = :quizId")
                    .setParameter("quizId", quizId)
                    .getResultList();
        }

        @SuppressWarnings("unchecked")
        @Override
        public List<Map<String, Object>> getQuizzes(int section) {
            return (List<Map<String, Object>>) em.createQuery(QUIZ_SELECT_CLAUSE + " from Quiz q where q.section = :section order by q.regDate desc")
                    .setParameter("section", section)
                    .getResultList();
        }

        @SuppressWarnings("unchecked")
        @Override
        public List<Map<String, Object>> getQuizzesDetails(int section) {
            return (List<Map<String, Object>>) em.createQuery("select q from Quiz q where q.section = :section order by q.regDate desc")
                    .setParameter("section", section)
                    .getResultList();
        }

        @Override
        public Answer getAnswerByQuizId(long quizId) {
            Answer answer = null;

            try {
                answer = em.find(Answer.class, quizId);
            } catch (NoResultException e) {

            }
            return answer;
        }

        @Override
        public void addQuizSubmission(QuizSubmission quizSubmission) {
            em.persist(quizSubmission);
        }

        @Override
        public void saveQuizSubmission(QuizSubmission quizSubmission) {
            em.merge(quizSubmission);
        }

        @Override
        public void deleteQuizSubmission(long id) {
            try {
                em.remove(getQuiz(id));
            } catch (IllegalArgumentException ie) {
                return;
            }
        }

        @Override
        public QuizSubmission getQuizSubmission(long id) {
            QuizSubmission quizSubmission = null;

            try {
                quizSubmission = em.find(QuizSubmission.class, id);
            } catch (NoResultException e) {}        

            return quizSubmission;
        }

        @SuppressWarnings("unchecked")
        @Override
        public List<Map<String, Object>> getQuizSubmissions(long quizId) {
            return (List<Map<String, Object>>) em.createQuery("select qs from QuizSubmission qs where qs.quizId = :quizId order by qs.date desc")
                    .setParameter("quizId", quizId)
                    .getResultList();
        }

        @SuppressWarnings("unchecked")
        @Override
        public List<QuizSubmission> getQuizSubmissions(String date) {
            /*return em.createNativeQuery("SELECT `id`, `quiz_id`, `answer_id`, `date` FROM `quizzes_submissions` WHERE DATE(`date`) = :date")
                    .setParameter("date", date )
                    .getResultList();*/

            SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            Date startDate = null;
            Date endDate = null;
            try {
                startDate = format.parse(date.trim()+" 00:00:00");
                endDate = format.parse(date.trim()+" 23:59:59");
            } catch (ParseException e) {
                e.printStackTrace();
            }

            return em.createQuery("select qs from QuizSubmission qs WHERE qs.date BETWEEN :startDate AND :endDate")
                    .setParameter("startDate", startDate)
                    .setParameter("endDate", endDate)
                    .getResultList();
        }
    }

我的观察是：在新的部署下，整个系统工作得很好。一旦数据库长时间处于理想状态，问题就会在6-8小时后出现

root cause

org.hibernate.TransactionException: Already have an associated managed connection
    org.hibernate.engine.transaction.internal.jdbc.JdbcTransaction.doBegin(JdbcTransaction.java:65)
    org.hibernate.engine.transaction.spi.AbstractTransactionImpl.begin(AbstractTransactionImpl.java:160)
org.hibernate.internal.SessionImpl.beginTransaction(SessionImpl.java:1309)
org.hibernate.ejb.TransactionImpl.begin(TransactionImpl.java:57)
org.springframework.orm.jpa.ExtendedEntityManagerCreator$ExtendedEntityManagerInvocationHandler.enlistInCurrentTransaction(ExtendedEntityManagerCreator.java:421)
org.springframework.orm.jpa.ExtendedEntityManagerCreator$ExtendedEntityManagerInvocationHandler.doJoinTransaction(ExtendedEntityManagerCreator.java:398)
org.springframework.orm.jpa.ExtendedEntityManagerCreator$ExtendedEntityManagerInvocationHandler.invoke(ExtendedEntityManagerCreator.java:356)
sun.proxy.$Proxy150.createQuery(Unknown Source)
com.next.persistence.QuizDaoImpl.getQuizzes(QuizDaoImpl.java:102)
sun.reflect.GeneratedMethodAccessor358.invoke(Unknown Source)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:601)
org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:318)
org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:183)
org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:150)
org.springframework.dao.support.PersistenceExceptionTranslationInterceptor.invoke(PersistenceExceptionTranslationInterceptor.java:155)
org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:172)
org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:110)
org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:172)
org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:202)
sun.proxy.$Proxy163.getQuizzes(Unknown Source)
com.next.service.QuizServiceImpl.getQuizzes(QuizServiceImpl.java:92)
sun.reflect.GeneratedMethodAccessor357.invoke(Unknown Source)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:601)
org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:318)
org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:183)
org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:150)
org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:110)
org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:172)
org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:202)
sun.proxy.$Proxy164.getQuizzes(Unknown Source)
com.next.mvc.HomeController.showListPage(HomeController.java:308)
sun.reflect.GeneratedMethodAccessor356.invoke(Unknown Source)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:601)
org.springframework.web.method.support.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:213)
org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:126)
org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:96)
org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:617)
org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:578)
org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:80)
org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:923)
org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:852)
org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:882)
org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:778)
javax.servlet.http.HttpServlet.service(HttpServlet.java:617)
javax.servlet.http.HttpServlet.service(HttpServlet.java:717)
org.springframework.web.filter.HiddenHttpMethodFilter.doFilterInternal(HiddenHttpMethodFilter.java:77)
org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:76)
org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:311)
org.springframework.security.web.access.intercept.FilterSecurityInterceptor.invoke(FilterSecurityInterceptor.java:116)
org.springframework.security.web.access.intercept.FilterSecurityInterceptor.doFilter(FilterSecurityInterceptor.java:83)
org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:323)
org.springframework.security.web.access.ExceptionTranslationFilter.doFilter(ExceptionTranslationFilter.java:113)
org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:323)
org.springframework.security.web.session.SessionManagementFilter.doFilter(SessionManagementFilter.java:101)
org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:323)
org.springframework.security.web.authentication.AnonymousAuthenticationFilter.doFilter(AnonymousAuthenticationFilter.java:113)
org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:323)
org.springframework.security.web.authentication.rememberme.RememberMeAuthenticationFilter.doFilter(RememberMeAuthenticationFilter.java:146)
org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:323)
org.springframework.security.web.servletapi.SecurityContextHolderAwareRequestFilter.doFilter(SecurityContextHolderAwareRequestFilter.java:54)
org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:323)
org.springframework.security.web.savedrequest.RequestCacheAwareFilter.doFilter(RequestCacheAwareFilter.java:45)
org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:323)
org.springframework.security.web.authentication.www.BasicAuthenticationFilter.doFilter(BasicAuthenticationFilter.java:150)
org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:323)
org.springframework.security.web.authentication.AbstractAuthenticationProcessingFilter.doFilter(AbstractAuthenticationProcessingFilter.java:182)
org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:323)
org.springframework.security.web.authentication.logout.LogoutFilter.doFilter(LogoutFilter.java:105)
org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:323)
org.springframework.security.web.context.SecurityContextPersistenceFilter.doFilter(SecurityContextPersistenceFilter.java:87)
org.springframework.security.web.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:323)
org.springframework.security.web.FilterChainProxy.doFilter(FilterChainProxy.java:173)
org.springframework.web.filter.DelegatingFilterProxy.invokeDelegate(DelegatingFilterProxy.java:346)
org.springframework.web.filter.DelegatingFilterProxy.doFilter(DelegatingFilterProxy.java:259)

共有1个答案

曹均
2023-03-14

问题出现在@PersistenceContext批注中。我有：

@PersistenceContext(type = PersistenceContextType.EXTENDED)
private EntityManager entityManager;

我把它换成了：

@PersistenceContext
private EntityManager entityManager;
 类似资料：
  • 连接与托管连接无关.org.jboss.resource.adapter.jdbc.jdk6.WrappedConnectionJDK6

    问题内容： 我在JBoss服务器上使用Hibernate。我得到下面的错误。 当我尝试在同一会话中第二次连接到数据库时，发生错误。 另外，我还会收到错误消息“为您关闭连接。请关闭您的连接”。 可能是什么原因，如何解决这种情况？ 问题答案： 自从您一年前提出这个问题以来，这个答案实际上可能为时已晚。但它将帮助将来会遇到此错误的人。 您的错误可能来自不同的来源，但在我的情况下，它的所有原因均与事务超时

  • 关联连接

    一、本功能说明 可以自动批量的将内容里面的关键词语加上超链接 二、子功能导航 1.添加连接 2.管理连接 三、功能详解 1.添加规则 1).如何进入本功能 导航栏 选择扩展 -> 菜单栏 选择关联连接 -> 添加关联连接 2).界面解释 点击后弹出如下界面 界面详述 1). 关联连接名称： 您可以需要添加连接的关键字 2). 关联连接网址： 该关键字对应的网址 2.管理连接 1).如何进入本功能

  • Spring Boot中的Postgres连接已关闭错误

    我正在运行一个Spring Boot应用程序来创建REST API。我经常会收到一个错误，说数据库连接关闭了，然后我就不能对应用程序进行任何调用。我在用Postgres数据库。这是完整的堆栈跟踪： 当我重新启动应用程序时，它就会消失。我认为当我重新启动我的postgres数据库时会出现这个问题。为什么会出现这种情况？

  • 连接到docker托管的MSSQL失败

    我在[本教程]后面有个问题(https://hub.docker.com/r/microsoft/mssql-server-linux/）我试图通过sqlcmd连接到docker托管的MSSQL。 我从windows在PowerShell中执行了以下操作： 注意：添加了“-it”和“/bin/bash”，因为如果没有检测到任何活动，docker将自动停止。 我运行了docker container

  • "java.sql.SQLException：连接已关闭"关闭连接后

    我使用weblogic应用服务器和oracle数据库。我使用jdbc与oracle数据库通信。我从weblogic数据源获得连接，并向表中插入一条记录。问题是，当我想关闭连接（插入数据库后）时，我会遇到一个异常（连接已经关闭）。这是我的代码： 但是联系。close语句引发异常： 我试图避免连接。close语句（因为我教过连接是自动关闭的！！但过了一段时间，所有的连接都打开了，因此引发了一个异常）

  • Azure Databricks -无法创建托管表，关联的位置已经存在

    我在Azure Databricks中遇到了以下问题。有时，当我试图将数据帧保存为托管表时: 我收到以下错误： 无法创建托管表(“< code>SomeData”)。关联的位置(' dbfs:/user/hive/warehouse/some data ')已经存在。;" 我过去通过运行%fs rm命令来删除该位置来解决此问题，但现在我使用的是由其他用户管理的群集，我无法再在该位置上运行rm。 目

相关问答

使用JDBC连接到云中托管的MongoDB时出错“MongoServerSelectionError:xxx.xx.xx.xxx:27017的连接已关闭Dropwizard JDBI-连接已关闭异常SQL状态[null]；错误代码[31]；连接已关闭：连接已关闭；嵌套异常是java.sql.sqlexception错误：“SQL Server未返回响应。连接已关闭。”

相关文章

Hibernate条件：没有映射关联的联接表Node.js中的Elasticsearch连接时没有活动连接错误MYSQLi错误：用户已经具有多个'max_user_connections'活动连接nodejs mysql错误：连接丢失服务器关闭了连接左外部联接是关联的吗？

相关阅读

联想测开（已凉）MyBatis关联查询Hibernate关联映射Access关联数据湖南联通一面（已测评已OC）

相关工具

携程酒店联盟接口SDK局域网或蓝牙连接基于cocos2d的连连看游戏OpenNTF 联盟php 实现数据库连接池、直播平台

相关文档

Windows 连接管理器 帮助文档Windows 连接管理器管理工具包 帮助文档滴滴企业管理接口文档NEI 接口文档管理平台配套自动化工具文档关于 Python 的面试题
快捷导航： 新手教程 算法原理 架构设计 Java进阶 数据库进阶 大厂专栏 面试经验 编程笔记 编程问答 所有专题 文档资料 工具软件 电子书籍 小牛导航
在线工具： 房贷计算器 个税计算器 Linux命令查询 Json格式化 正则表达式 颜色转换 AES加解密 SHA1加密 MD5加密 毒鸡汤 字数统计 随机密码生成 进制转换 Base64编解码 励志句子
Copyright © 2019-2024 小牛知识库@xnip.cn. All Rights Reserved.