dbconnector.java

intra_mart是日本NDD公司开发的著名企业应用解决方案中间件。集成了J2ee服务器

/*
 * DBConnector.java
 *
 * Created on 2001/11/12, 18:02
 */

package jp.co.intra_mart.framework.base.data;

import java.sql.Connection;
import java.util.HashMap;
import java.util.Map;

/**
 * 僨乕僞儀乕僗偵懳偡傞僐僱僋僞偱偡丅
 *
 * @author INTRAMART
 * @version 1.0
 */
public abstract class DBConnector extends DataConnector {

    /**
     * 儕僜乕僗堦棗
     */
    protected Map resources;

    /**
     * DBConnector傪怴婯偵惗惉偟傑偡丅
     */
    public DBConnector() {
        super();
        this.resources = new HashMap();
    }

    /**
     * 愙懕愭偺儕僜乕僗傪捛壛偟傑偡丅
     *
     * @return 僐僱僋僔儑儞
     * @param resource 儕僜乕僗
     * @param params 儕僜乕僗偺僷儔儊乕僞
     * @throws DataConnectException 愙懕偵幐攕
     */
    protected abstract Connection putResource(
        String resource,
        ResourceParam[] params)
        throws DataConnectException;

    /**
     * 儕僜乕僗傪庢摼偟傑偡丅
     *
     * @param key 僉乕
     * @param connect 愙懕忣曬
     * @param resource 儕僜乕僗柤
     * @return 儕僜乕僗
     * @throws DataPropertyException 儕僜乕僗偺庢摼偵幐攕
     * @throws DataConnectException 愙懕偵幐攕
     */
    protected Object getResource(String key, String connect, String resource)
        throws DataPropertyException, DataConnectException {
        Object obj = this.resources.get(resource);
        if (obj == null) {
            ResourceParam[] resourceInfo =
                getDataPropertyHandler().getResourceParams(resource);
            obj = putResource(resource, resourceInfo);
        }

        return obj;
    }

    /**
     * 僨乕僞儀乕僗傊偺僐僱僋僔儑儞傪庢摼偟傑偡丅
     *
     * @param resource 儕僜乕僗柤
     * @return 僨乕僞儀乕僗傊偺僐僱僋僔儑儞
     * @throws DataPropertyException 僨乕僞儀乕僗傊偺僐僱僋僔儑儞偺庢摼偵幐攕
     * @throws DataConnectException 僨乕僞儀乕僗傊偺愙懕偵幐攕
     */
    public Connection getConnection(String resource)
        throws DataPropertyException, DataConnectException {
        return (Connection)getResource("", "", resource);
    }

    /**
     * 僐儈僢僩偟傑偡丅
     * 幚嵺偵偼偙偺僋儔僗偱偼偙偺儊僜僢僪偼壗傕偟傑偣傫丅
     *
     * @throws DataConnectException 僐儈僢僩偵幐攕
     */
    public void commit() throws DataConnectException {
    }

    /**
     * 儘乕儖僶僢僋偟傑偡丅
     * 幚嵺偵偼偙偺僋儔僗偱偼偙偺儊僜僢僪偼壗傕偟傑偣傫丅
     *
     * @throws DataConnectException 儘乕儖僶僢僋偵幐攕
     */
    public void rollback() throws DataConnectException {
    }

    /**
     * 僨乕僞僗僩傾偺帒尮傪夝曻偟傑偡丅
     *
     * @throws DataConnectException 帒尮奐曻偵幐攕
     * 幚嵺偵偼偙偺僋儔僗偱偼偙偺儊僜僢僪偼壗傕偟傑偣傫丅
     */
    public void release() throws DataConnectException {
    }
}