0

如您所见,此代码是我的数据访问对象层的一部分。我以前从未使用过 ConnectionPool 对象,因为我还在学习 Java。无论如何,我收到一条错误消息,说明:

对于 ConnectionPool 类型,方法 getInstance() 未定义。(第 5 行)

如果你们中的任何人以前经历过这种情况,我们将不胜感激。

import java.sql.*;
import java.util.*;

import org.apache.tomcat.jdbc.pool.ConnectionPool;

import music.business.*;

public class ProductDB
{
    //This method returns null if a product isn't found.
    public static Product selectProduct(String productCode)
    {
        ConnectionPool pool = ConnectionPool.getInstance(); //<===<====<====<=================
        Connection connection = pool.getConnection();
        PreparedStatement ps = null;
        ResultSet rs = null;

        String query = "SELECT * FROM Product " +
                "WHERE ProductCode = ?";
        try
        {
            ps = connection.prepareStatement(query);
            ps.setString(1, productCode);
            rs = ps.executeQuery();
            if (rs.next())
            {
                Product p = new Product();
                p.setCode(rs.getString("ProductCode"));
                p.setDescription(rs.getString("ProductDescription"));
                p.setPrice(rs.getDouble("ProductPrice"));
                return p;
            }
            else
            {
                return null;
            }
        }
        catch(SQLException e)
        {
            e.printStackTrace();
            return null;
        }
        finally
        {
            DBUtil.closeResultSet(rs);
            DBUtil.closePreparedStatement(ps);
            pool.freeConnection(connection);
        }
    }

我刚刚发现我犯了一个错误: - 我上面提到的类中的 ConnectionPool 不应该是 Tomcat 导入的。它是一个 JNDI 类。见下文。getInstance 实际上是我的 JNDI 类中的一个方法。抱歉耽误你们的时间了伙计们。谢谢

import java.sql.*;
import javax.sql.DataSource;
import javax.naming.InitialContext;

public class ConnectionPool
{
    private static ConnectionPool pool = null;
    private static DataSource dataSource = null;

    public synchronized static ConnectionPool getInstance()
    {
        if (pool == null)
        {
            pool = new ConnectionPool();
        }
        return pool;
    }

    private ConnectionPool()
    {
        try
        {
            InitialContext ic = new InitialContext();
            dataSource = (DataSource) ic.lookup("java:/comp/env/jdbc/musicDB");
        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
    }

    public Connection getConnection()
    {
        try
        {
            return dataSource.getConnection();
        }
        catch (SQLException sqle)
        {
            sqle.printStackTrace();
            return null;
        }
    }

    public void freeConnection(Connection c)
    {
        try
        {
            c.close();
        }
        catch (SQLException sqle)
        {
            sqle.printStackTrace();
        }
    }
}
4

3 回答 3

2

AConnectionPool可以使用它的构造函数来创建,它接受一些池属性。即使这个构造函数暴露在你的应用程序中创建一个池,尤其是在每个 DAO 中可能并不可取。

池化的目的是拥有一个连接池,应用程序可以在需要对数据库执行某些工作时从中检索连接。使用这种设计,代码将有多个连接池,这破坏了池的意义。

通常在 Tomcat 内部建立一个数据源,它在内部处理连接池的构建。有关 Tomcat 中的连接池的更多信息,请参阅这些资源

于 2013-05-16T09:18:17.783 回答
1

如果您真的不想在 Tomcat 中定义它,请在“DBService”类中创建它并共享它。正如 Duffy 所说,在 Tomcat 中定义它可能是最好的方法。

在 Tomcat 中定义它:http: //tomcat.apache.org/tomcat-6.0-doc/jndi-datasource-examples-howto.html#Database_Connection_Pool_ (DBCP)_Configurations

getInstance() 语法似乎全错了。要直接创建和配置它,请参阅: http: //people.apache.org/~fhanik/jdbc-pool/jdbc-pool.html

于 2013-05-16T09:22:20.517 回答
0

我会让 Tomcat 为你管理那个池。它包含有关如何创建 JNDI 数据源的说明。你应该这样做并从你的代码中得到它。

它将您的应用程序中的连接参数外部化具有额外的好处。它们将存在于应用服务器上的配置中。

于 2013-05-16T09:32:12.447 回答