使用 Hibernate 和 Oracle 的 Spring Boot 应用程序中的对等方重置连接

问题描述 投票：0回答：1

我得到这个例外

  Caused by: java.sql.SQLException: An operation is being attempted on a closed connection.
   ------------------------ Cause of Close ---------------------------------
 java.io.IOException: Communication error with xxxxxxxxxx:9401[jdbc-1908517]
at cs.jdbc.driver.protocol.WireDecoder.processInput(WireDecoder.java:360)
at cs.jdbc.driver.protocol.ChannelConnection.processInput(ChannelConnection.java:371)
at cs.jdbc.driver.protocol.DataReader.run(DataReader.java:42)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:748)
      Caused by: java.io.IOException: Connection reset by peer
at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
at sun.nio.ch.IOUtil.read(IOUtil.java:197)
at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380)
at cs.jdbc.driver.protocol.ChannelConnection.read(ChannelConnection.java:376)
at cs.jdbc.driver.protocol.WireDecoder.processInput(WireDecoder.java:260)

... 还有 5 个

                  at 


cs.jdbc.driver.CompositeConnection.getChannel(CompositeConnection.java:165)
at cs.jdbc.driver.CompositeConnection.prepareStatement(CompositeConnection.java:390)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.apache.tomcat.jdbc.pool.ProxyConnection.invoke(ProxyConnection.java:126)
at org.apache.tomcat.jdbc.pool.JdbcInterceptor.invoke(JdbcInterceptor.java:108)
at org.apache.tomcat.jdbc.pool.DisposableConnectionFacade.invoke(DisposableConnectionFacade.java:81)
at com.sun.proxy.$Proxy120.prepareStatement(Unknown Source)
at org.hibernate.engine.jdbc.internal.StatementPreparerImpl$5.doPrepare(StatementPreparerImpl.java:146)
at org.hibernate.engine.jdbc.internal.StatementPreparerImpl$StatementPreparationTemplate.prepareStatement(StatementPreparerImpl.java:172)
... 104 common frames omitted

我正在使用 Spring Boot + Spring DATA + Hibernate/JPA。一段时间后，我得到这个异常。但是当重新启动服务器时，应用程序仍然可以运行一段时间（当再次抛出此类异常时）。

这里是application.properties

    spring.datasource.url = jdbc:compositesw:dbapi@xxxxxxxxxxxxx:9401?domain=twccorp&dataSource=SFDC&autoReconnect=true
      spring.datasource.username = xxxx
   spring.datasource.password = xxxx
   spring.datasource.driverClassName = cs.jdbc.driver.CompositeDriver
   spring.jpa.properties.hibernate.dialect = org.hibernate.dialect.OracleDialect
   spring.jpa.properties.hibernate.show_sql=true
   spring.jpa.properties.hibernate.use_sql_comments=true
   spring.jpa.properties.hibernate.format_sql=true


    spring.jpa.properties.hibernate.type=trace 

      spring.datasource.dbcp.test-while-idle=true
          spring.datasource.dbcp.validation-query=SELECT 1 from dual
      spring.datasource.dbcp.time-between-eviction-runs-millis=5000
    spring.datasource.dbcp.min-evictable-idle-time-millis=60000

     spring.datasource.test-while-idle=true
      spring.datasource.validation-query=SELECT 1 from dual
     spring.datasource.time-between-eviction-runs-millis=5000
         spring.datasource.min-evictable-idle-time-millis=60000

数据库是Oracle。

这里是存储库实现：

   @Repository
 public class AccountRepositoryCustomImpl implements AccountRepositoryCustom {

@PersistenceContext
private EntityManager em;

@Value("${recordLimit}")
private String recordLimit;

@Override
public List<AccountDatabase> searchForAccounts(Map<String, Object> map) {

    List<String> whereClause = new ArrayList<>();

    StringBuilder queryBuilder = new StringBuilder();
    queryBuilder.append("select ad from AccountDatabase ad ");

    for (String key : map.keySet()) {
        if (!key.equals("city") && !key.equalsIgnoreCase("address")) {
            whereClause.add(" ad." + key + " LIKE :" + key);
        }
    }

    queryBuilder.append(" where " + StringUtils.join(whereClause, " and "));

    if (map.containsKey("city")) {
        queryBuilder.append("(( ad.accountType = :accountType AND ad.billingCity LIKE :billingCity ) OR "
                + "( ad.accountType = :accountType2 AND ad.shippingCity LIKE :shippingCity ))");

    }

    if (map.containsKey("address")) {
        queryBuilder.append("(( ad.accountType = :accountType AND ad.billingStreet LIKE :billingStreet ) OR "
                + "( ad.accountType = :accountType2 AND ad.shippingStreet LIKE :shippingStreet ))");

    }

    Query jpaQuery = em.createQuery(queryBuilder.toString(), AccountDatabase.class);

    for (String key : map.keySet()) {
        if (!key.equals("city") && !key.equalsIgnoreCase("address")) {
            jpaQuery.setParameter(key, "%" + map.get(key) + "%");
        }
    }

    if (map.containsKey("address")) {
        jpaQuery.setParameter("accountType", "Billing Account");
        jpaQuery.setParameter("billingStreet", "%" + map.get("address") + "%");
        jpaQuery.setParameter("accountType2", "Service Location");
        jpaQuery.setParameter("shippingStreet", "%" + map.get("address") + "%");

    }

    if (map.containsKey("city")) {
        jpaQuery.setParameter("accountType", "Billing Account");
        jpaQuery.setParameter("billingCity", "%" + map.get("city") + "%");
        jpaQuery.setParameter("accountType2", "Service Location");
        jpaQuery.setParameter("shippingCity", "%" + map.get("city") + "%");

    }

    int limit = Integer.valueOf(recordLimit);
    List<AccountDatabase> list = jpaQuery.getResultList();
    if (list.size() > limit) {
        list = list.subList(0, limit);
    }

    em.close();
    return list;

}

}

这是 pom.xml

http://maven.apache.org/xsd/maven-4.0.0.xsd"> 4.0.0

<artifactId>xxxxxxxx</artifactId>
<version>0.0.1</version>
<packaging>jar</packaging>

<parent>
    <groupId>xxxxxxxx</groupId>
    <artifactId>xxxxxxxx</artifactId>
    <version>0.0.2</version>
</parent>

<name>egateway-api-service</name>
<url>http://maven.apache.org</url>

<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <java-version>1.8</java-version>
</properties>


<dependencies>

    <dependency>
        <groupId>some.group</groupId>
        <artifactId>non-maven-proj</artifactId>
        <version>1</version>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-cache</artifactId>
    </dependency>






    <dependency>
        <groupId>org.ehcache</groupId>
        <artifactId>ehcache</artifactId>
    </dependency>

    <dependency>
        <groupId>javax.cache</groupId>
        <artifactId>cache-api</artifactId>
    </dependency>

    <dependency>
        <groupId>io.springfox</groupId>
        <artifactId>springfox-swagger2</artifactId>
        <version>2.4.0</version>
    </dependency>

    <dependency>
        <groupId>io.springfox</groupId>
        <artifactId>springfox-swagger-ui</artifactId>
        <version>2.4.0</version>
    </dependency>

    <dependency>
        <groupId>commons-collections</groupId>
        <artifactId>commons-collections</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-integration</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>

    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-test</artifactId>
    </dependency>


    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
    </dependency>


    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-jpa</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-orm</artifactId>

    </dependency>
    <!-- Hibernate 5.2.9 Final -->
    <dependency>
        <groupId>org.hibernate</groupId>
        <artifactId>hibernate-core</artifactId>
    </dependency>
    <!-- Apache Commons DBCP -->
    <dependency>
        <groupId>org.apache.commons</groupId>
        <artifactId>commons-dbcp2</artifactId>
        <version>2.1.1</version>
    </dependency>
</dependencies>
<build>
    <plugins>
        <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
            <executions>
                <execution>
                    <goals>
                        <goal>repackage</goal>
                    </goals>
                </execution>
            </executions>
        </plugin>
    </plugins>
</build>

我做错了什么？问候

spring spring-boot spring-data-jpa jpa-2.0 apache-commons-dbcp
1个回答
0
投票

它是远程服务器（或它们之间的防火墙）的响应。 它表示不会继续完成此请求。 很可能是防火墙或 SSL 握手失败、代理问题甚至 HTTP 请求失败。 如果您没有向请求添加正确的标头，则有可能。

最新问题
© www.soinside.com 2019 - 2024. All rights reserved.