JDBCDataSource.java

package org.objectweb.jonas.dbm;

// JOnAS imports
import org.objectweb.jonas.management.ReconfiguredProp;
import org.objectweb.jonas.management.j2eemanagement.J2EEManagedObject;

public class JDBCDataSource extends J2EEManagedObject {

    private String jdbcDriver = null;

    private ConnectionManager cm = null;

    private Pool pool = null;

    private String datasourceName = null;

    private long sequenceNumber = 0;

    public JDBCDataSource(String objectName, ConnectionManager cm) {
        super(objectName);
        this.cm = cm;
        this.pool = cm.getPool();
        this.datasourceName = cm.getDatasourceName();
    }

    // JDBC DataSource Configuration

    public String getJdbcDriver() {
        return jdbcDriver;
    }

    public void setJdbcDriver(String jdbcDriverObjectName) {
        jdbcDriver = jdbcDriverObjectName;
    }

    public String getName() {
        return datasourceName;
    }

    public String getJndiName() {
        return cm.getDSName();
    }

    public String getDescription() {
        return cm.getDataSourceDescription();
    }

    public String getUrl() {
        return cm.getUrl();
    }

    public String getUserName() {
        return cm.getUserName();
    }

    public String getUserPassword() {
        return cm.getPassword();
    }

    public String getMapperName() {
        return cm.getMapperName();
    }

    // JDBC Connection Pool Configuration

    public Integer getJdbcConnCheckLevel() {
        return new Integer(pool.getCheckLevel());
    }
    public void setJdbcConnCheckLevel(Integer level) {
        pool.setCheckLevel(level.intValue());
        String propName = DataBaseServiceImpl.CONNCHECKLEVEL;
        ReconfiguredProp prop = new ReconfiguredProp(propName, level.toString());
        // Send a reconfiguration notification to the listener MBean
        sendReconfigNotification(getSequenceNumber(), datasourceName, prop);
    }

    public Integer getJdbcConnMaxAge() {
        return new Integer(pool.getMaxAge());
    }
    public void setJdbcConnMaxAge(Integer mn) {
        pool.setMaxAge(mn.intValue());
        String propName = DataBaseServiceImpl.CONNMAXAGE;
        ReconfiguredProp prop = new ReconfiguredProp(propName, mn.toString());
        // Send a reconfiguration notification to the listener MBean
        sendReconfigNotification(getSequenceNumber(), datasourceName, prop);
    }

    public Integer getJdbcMaxConnPool() {
        return new Integer(pool.getPoolMax());
    }
    public void setJdbcMaxConnPool(Integer max) {
        pool.setPoolMax(max.intValue());
        // Update the configuration file
        String propName = DataBaseServiceImpl.MAXCONPOOL;
        ReconfiguredProp prop = new ReconfiguredProp(propName, max.toString());
        // Send a reconfiguration notification to the listener MBean
        sendReconfigNotification(getSequenceNumber(), datasourceName, prop);
    }

    public Integer getJdbcMaxOpenTime() {
        return new Integer(pool.getMaxOpenTime());
    }
    public void setJdbcMaxOpenTime(Integer mn) {
        pool.setMaxOpenTime(mn.intValue());
        String propName = DataBaseServiceImpl.MAXOPENTIME;
        ReconfiguredProp prop = new ReconfiguredProp(propName, mn.toString());
        // Send a reconfiguration notification to the listener MBean
        sendReconfigNotification(getSequenceNumber(), datasourceName, prop);
    }

    public Integer getJdbcMaxWaiters() {
        return new Integer(pool.getMaxWaiters());
    }
    public void setJdbcMaxWaiters(Integer max) {
        pool.setMaxWaiters(max.intValue());
        // Update the configuration file
        String propName = DataBaseServiceImpl.MAXWAITERS;
        ReconfiguredProp prop = new ReconfiguredProp(propName, max.toString());
        // Send a reconfiguration notification to the listener MBean
        sendReconfigNotification(getSequenceNumber(), datasourceName, prop);
    }

    public Integer getJdbcMaxWaitTime() {
        return new Integer(pool.getMaxWaitTime());
    }

    public void setJdbcMaxWaitTime(Integer max) {
        pool.setMaxWaitTime(max.intValue());
        // Update the configuration file
        String propName = DataBaseServiceImpl.MAXWAITTIME;
        ReconfiguredProp prop = new ReconfiguredProp(propName, max.toString());
        // Send a reconfiguration notification to the listener MBean
        sendReconfigNotification(getSequenceNumber(), datasourceName, prop);
    }

    public Integer getJdbcMinConnPool() {
        return new Integer(pool.getPoolMin());
    }
    public void setJdbcMinConnPool(Integer min) {
        pool.setPoolMin(min.intValue());
        // Update the configuration file
        String propName = DataBaseServiceImpl.MINCONPOOL;
        ReconfiguredProp prop = new ReconfiguredProp(propName, min.toString());
        // Send a reconfiguration notification to the listener MBean
        sendReconfigNotification(getSequenceNumber(), datasourceName, prop);
    }

    public Integer getJdbcSamplingPeriod() {
        return new Integer(pool.getSamplingPeriod());
    }

    public void setJdbcSamplingPeriod(Integer i) {
        pool.setSamplingPeriod(i.intValue());
        // Update the configuration file
        String propName = DataBaseServiceImpl.SAMPLINGPERIOD;
        ReconfiguredProp prop = new ReconfiguredProp(propName, i.toString());
        // Send a reconfiguration notification to the listener MBean
        sendReconfigNotification(getSequenceNumber(), datasourceName, prop);
    }

    public String getJdbcTestStatement() {
        return pool.getTestStatement();
    }
    public void setJdbcTestStatement(String test) {
        pool.setTestStatement(test);
        String propName = DataBaseServiceImpl.CONNTESTSTMT;
        ReconfiguredProp prop = new ReconfiguredProp(propName, test);
        // Send a reconfiguration notification to the listener MBean
        sendReconfigNotification(getSequenceNumber(), datasourceName, prop);
    }

    // JDBC Connection Pool Statistics

    public Integer getConnectionFailures() {
        return new Integer(pool.getConnectionFailures());
    }
    public Integer getConnectionLeaks() {
        return new Integer(pool.getConnectionLeaks());
    }
    public Integer getCurrentBusy() {
        return new Integer(pool.getCurrentBusy());
    }
    public Integer getBusyMax() {
        return new Integer(pool.getBusyMaxRecent());
    }
    public Integer getBusyMin() {
        return new Integer(pool.getBusyMinRecent());
    }
    public Integer getCurrentInTx() {
        return new Integer(pool.getCurrentInTx());
    }
    public Integer getCurrentOpened() {
        return new Integer(pool.getCurrentOpened());
    }
    public Integer getCurrentWaiters() {
        return new Integer(pool.getCurrentWaiters());
    }
    public Integer getOpenedCount() {
        return new Integer(pool.getOpenedCount());
    }
    public Integer getRejectedFull() {
        return new Integer(pool.getRejectedFull());
    }
    public Integer getRejectedOpen() {
        return new Integer(pool.getRejectedOpen());
    }
    public Integer getRejectedOther() {
        return new Integer(pool.getRejectedOther());
    }
    public Integer getRejectedTimeout() {
        return new Integer(pool.getRejectedTimeout());
    }
    public Integer getServedOpen() {
        return new Integer(pool.getServedOpen());
    }
    public Integer getWaiterCount() {
        return new Integer(pool.getWaiterCount());
    }
    public Integer getWaitersHigh() {
        return new Integer(pool.getWaitersHigh());
    }
    public Integer getWaitersHighRecent() {
        return new Integer(pool.getWaitersHighRecent());
    }
    public Long getWaitingHigh() {
        return new Long(pool.getWaitingHigh());
    }
    public Long getWaitingHighRecent() {
        return new Long(pool.getWaitingHighRecent());
    }
    public Long getWaitingTime() {
        return new Long(pool.getWaitingTime());
    }
    protected long getSequenceNumber() {
        return ++sequenceNumber;
    }

    public void saveConfig() {
        sendSaveNotification(getSequenceNumber(), datasourceName);
    }
}

---