1

有人可以告诉我如何修复下面的代码，以免引发错误吗？

以下代码行给了我一个空指针异常： 

return dataSource.getConnection();

请注意，dataSource 是 web.xml 中指定的 javax.sql.DataSource 的一个实例，并且在被其他代码调用时可以正常工作。

这是 DataAccessObject.java 中发生空指针的实际方法： 

protected static Connection getConnection(){  
  try {
     return dataSource.getConnection();  //
  } catch (SQLException e) {
     throw new RuntimeException(e);
  }
}

这行代码正在调用前面的方法： 

connection = getConnection();

它位于名为 CourseSummaryDAO 的类中的以下方法中，如下所示： 

public List<CourseSummary> findAll(Long sid) {
    LinkedList<CourseSummary> coursesummaries = new LinkedList<CourseSummary>();
    ResultSet rs = null;
    PreparedStatement statement = null;
    Connection connection = null;
    try {
        connection = getConnection(); //
        String sql = "select * from coursetotals where spid=?";
        statement = connection.prepareStatement(sql);
        statement.setLong(1, sid);
        rs = statement.executeQuery();
        //for every row, call read method to extract column 
        //values and place them in a coursesummary instance
        while (rs.next()) {
            CourseSummary coursesummary = read("findAll", rs);
            coursesummaries.add(coursesummary);
        }
        return coursesummaries;
     }catch (SQLException e) {
        throw new RuntimeException(e);
     } 
     finally {
        close(rs, statement, connection);
    }
 }

为了简单地重新创建它，我创建了以下 TestCourseSummaries 类： 

public class TestCourseSummaries {
    public static void main(String[] args) {
    Long id = new Long(1002);
    CourseSummaryDAO myCSDAO = new CourseSummaryDAO();
    List<CourseSummary> coursesummaries = myCSDAO.findAll(id);
    for(int i = 0;i<coursesummaries.size();i++){
    System.out.println("type, numunits are: "+coursesummaries.get(i).getCourseType()+","+coursesummaries.get(i).getNumUnits());
    }
}
}

编辑：

为了解决 JustDanyul 的问题，我附上了在我的应用程序中调用的代码，以及由调用代码中的两个 DAO 对象扩展的底层 DataAccessObject 代码：

这是我的应用程序中触发错误的代码。看到有两个类，每个扩展DataAccessObject。也许他们相互冲突，导致第二个没有获得数据库连接？ 

protected void doGet(HttpServletRequest req, HttpServletResponse resp) 
throws ServletException, IOException {  
   String idString = req.getParameter("id");
   Long id = new Long(idString);
   ThisObj thisobj = new ThisDAO().find(id);
   req.setAttribute("thisobj", thisobj);
   ThoseObjDAO myThoseDAO = new ThoseObjDAO();
   List<ThoseObj> thoseobjects = myThoseObjDAO.findAll(id);
   req.setAttribute("thoseobjects", thoseobjects);
   jsp.forward(req, resp);

}

下面是调用代码中的两个 DAO 类扩展的 DataAccessObject 类的代码： 

public class DataAccessObject {
private static DataSource dataSource;
private static Object idLock = new Object();

public static void setDataSource(DataSource dataSource) {
   DataAccessObject.dataSource = dataSource;
}

protected static Connection getConnection() {
   try {return dataSource.getConnection();}
   catch (SQLException e) {throw new RuntimeException(e);}
}

protected static void close(Statement statement, Connection connection) {
   close(null, statement, connection);
}

protected static void close(ResultSet rs, Statement statement, Connection connection) {
   try {
      if (rs != null) rs.close();
      if (statement != null) statement.close();
      if (connection != null) connection.close();
   } catch (SQLException e) {throw new RuntimeException(e);}
}

protected static Long getUniqueId() {
   ResultSet rs = null;
   PreparedStatement statement = null;
   Connection connection = null;
   try {
      connection = getConnection();
      synchronized (idLock) {
         statement = connection.prepareStatement("select next_value from sequence");
         rs = statement.executeQuery();
         rs.first();
         long id = rs.getLong(1);
         statement.close();
         statement = connection.prepareStatement("update sequence set next_value = ?");
         statement.setLong(1, id + 1);
         statement.executeUpdate();
         statement.close();
         return new Long(id);
      }
   }
   catch (SQLException e) {throw new RuntimeException(e);}
   finally{close(rs, statement, connection);}
}
}

数据源在web.xml中创建，如下： 

<resource-ref>
    <description>dataSource</description>
    <res-ref-name>datasource</res-ref-name>
    <res-type>javax.sql.DataSource</res-type>
    <res-auth>Container</res-auth>
</resource-ref>
4

3 回答 3

1

我怀疑它“运行良好”的代码实际上是在应用程序服务器中运行的代码。您发布的示例仅运行一个static void main()方法，不会获得 web.xml 中定义的任何资源。

我猜您使用 JDNI 来设置初始数据源。然后使用类似的东西

@Resource(name="jdbc/mydb")
private DataSource dataSource;

设置您的连接。对？

编辑：

看到您的代码后，您的数据源似乎完全初始化了。仅将一个元素放入您的 web.xml 不会单独完成。您还需要实际配置数据源，您知道，指定驱动程序、用户名、密码、uri 等等等等。

我猜 DAO 的 find() 方法有效，实际上并没有使用数据源。到目前为止，您所展示的内容并没有暗示您有一个初始化的数据源。

只是为了给你一个想法，我喜欢一个关于如何使用 Tomcat 和 JDNI 做到这一点的教程。（或者更好的是，使用 spring-jdbc）。

http://www.mkyong.com/tomcat/how-to-configure-mysql-datasource-in-tomcat-6/

于 2013-08-10T00:36:43.963 回答
1

使用 dataSource 作为<javax.sql.DataSource>实例，而不是<javax.activation.DataSource>.

简而言之，您应该用<import javax.activation.DataSource;>this other替换该语句<import javax.sql.DataSource;>。

于 2013-11-08T00:13:32.793 回答
1

使用 dataSource 作为 javax.sql.DataSource 实例，而不是 javax.activation.DataSource 的实例。简而言之，您应该替换以下语句：

import javax.activation.DataSource;

通过这个：

import javax.sql.DataSource;
于 2013-11-08T00:18:39.793 回答