使用tomcat datasource-如何通过spring jndi访问datasource以获取当前数据库池状态

Question

现状

我在web和rest api服务器上使用Jmeter进行压力负载测试，但是有些转换的响应时间延迟很多，所以我使用Spring方面来获取方法处理时间。我无法设置的是，一些过程调用花费了太多的时间，因此尝试通过编写特定事务的日志来检查DB进程时间（get con,release con,pure DB进程时间）。JMX不是一个选项，因为我无法跟踪使用它的事务。我只想保留DB池状态，并将ThreadContext标记为on，这样我就可以同时检查慢速事务和DB池状态。

Spring项目的事务管理器使用带有Oracle数据源的Tomcat DBCP池（带有javax.sql.datasource的Oracle.jdbc.oracleDriver）

ApplicationContext.xml-数据库设置

<bean id="dataSource" class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiName" value="java:/comp/env/jdbc/svc"/>
    <property name="resourceRef" value="true"/>
</bean> 

<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
    <property name="mapperLocations" value="classpath*:../sql/**.xml"/>
    <property name="dataSource"><ref bean="dataSource"/></property>
</bean>

<bean id="sqlSession" class="org.mybatis.spring.SqlSessionTemplate">
    <constructor-arg ref="sqlSessionFactory"/>
</bean>

<bean id="oracleTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager" p:dataSource-ref="dataSource" />
<bean id="transactionManager" class="com.xxx.xxx.api.transaction.TransactionManager">
    <property name="transactionManagers">
        <list>
            <ref bean="oracleTransactionManager"/>
        </list>
    </property>
</bean>

试图做...记录数据库池状态

null

null

Answer 1

您可以简单地创建TomcatJDBCPoolDataSource的代理，并将其用作spring bean。我已经为C3P0池数据源创建了一个代理。随后，我使用所需的配置创建了类的spring bean并将其用作数据源。我相信你也能做些类似的事。

public class C3PODataSourceProxy extends AbstractComboPooledDataSource {

    public C3PODataSourceProxy() {
        super();
    }

    public C3PODataSourceProxy(boolean autoregister) {
        super(autoregister);
    }

    public C3PODataSourceProxy(String configName) {
        super(configName);
    }

    @Override
    public Connection getConnection() throws SQLException {
        try {
            Connection connection = super.getConnection();
            //You can call the below methods and log it, send it to some other class etc
            getNumIdleConnections();
            getNumBusyConnections();
            return connection;
        } catch (Exception exception) {
            //log the exception
            throw exception;
        }
    }

    public Connection getConnection(String username, String password) throws SQLException {

        try {
            Connection connection = super.getConnection(username, password);
               //You can call the below methods and log it, send it to some other class etc
            getNumIdleConnections(username, password);
            getNumBusyConnections(username, password);
            return connection;
        } catch (Exception exception) {
            //log the exception
            throw exception;
        }
    }

}