DAO 设计3、数据库连接的管理

DAO 类是线程安全的，它的所有操作都通过调用 DbExecutor 对象来执行。每次操作，DAO 都会从 DbExecutorFactory 中获得一个 DbExecutor 对象。DAO 要做的就是保证做完操作之后都要执行 DbExecutor 对象的 close 方法。

DbExecutor 是一个接口，它的大部分方法和 DAO 差不多。它包含一个数据库连接，当连接关闭时，DbExecutor 对象的生命周期也就结束了。OraDbExecutor 是 DbExecutor 的一个实现。

OraDbExecutor.java - 构造函数

/**
 * 构造函数
 *
 * @param dsName 数据源名称
 * @param conn   数据库连接
 */
public OraDbExecutor(String dsName, Connection conn) {
    this.dsName = dsName;
    this.connection = conn;
}

当创建 DbExecutor 实例时，DbExecutorFactory 先从 ConnectionFactoryBuilder 获得一个 ConnectionFactory 对象，然后从ConnectionFactory 获取一个数据库连接，用来创建 DbExecutor。当然，连接每个数据库的 ConnectionFactory 对象只有一个。

ConnectionFactoryBuilder.java - build()

/**
 * 创建一个数据库连接工厂
 *
 * @param dsName 配置文件中的 datasource 名称
 *
 * @return 数据库连接工厂
 *
 * @throws ConfigErrorException 如果配置文件不正确
 */
public synchronized ConnectionFactory build(String dsName) throws ConfigErrorException {
    // 先从缓存中查找
    if (factoryCache.get(dsName) == null) {
        DataSourceCollection sources = Configurator.getDataSources();
        DataSource ds = sources.getDataSource(dsName);

        if (ds == null) {
            throw new ConfigErrorException("没有找到数据源 " + dsName);
        }
        factoryCache.put(dsName, buildFactory(ds));
    }

    return (ConnectionFactory) factoryCache.get(dsName);
}

评论

2 楼 pdw2009 2007-08-23  

用到了缓存吧，

1 楼 bluepopopo 2007-06-15  

javastudy 写道

public synchronized ConnectionFactory build(String dsName) throws ConfigErrorException {

为什么设成线程安全的

有factoryCache的get和set嘛 要用同步