关于Tomcat的MySQL连接池的问题，求救！

zjkdc

你这个bean是被什么调用的？如果是jsp的话，那在jsp中等你处理完rs后，调用这个bean的close方法不就可以了么

elgs

你对数据库操作不是要catch 诸如 NamingException SQLException等等的Exceptions吗？ 如果我说得没错， 那就在你的catch候加上一个finally块， 在finnally块里关闭连接， 这是你的业务逻辑肯定已经结束了， 如果这个bean里的另外一个方法还需要连接， 那让它再去获取连接， 这是标准操作， 获取的连接池里的空闲连接。

elgs

不是再jsp里关闭， 再bean里就要关闭。

zjkdc

楼上的，他的bean里那个方法是返回rs的，如果来个finally,那rs就没用了。

elgs

返回rs的做法不对， 那样又把很多java代码弄到页面里来了，最好放回一个数组， 或者另外一个bean

我是好人

to elgs：请具体讲讲好吗？

elgs

1. 
   
2. package something;
   
3. 
   
4. import java.sql.*;
   
5. import javax.naming.NamingException;
   
6. 
   
7. 
   
8. public class RsBean
   
9. {
   
10.         private ConnMaker connMaker;
    
11.         private Connection connection;
    
12.         private Statement statement;
    
13.         private ResultSet rs;
    
14. 
    
15.         private int rows;
    
16.         private int cols;
    
17.         private String[][] data;
    
18. 
    
19.         public int getRows()
    
20.         {
    
21.                 return this.rows;
    
22.         }
    
23.         public void setRows(int rows)
    
24.         {
    
25.                 this.rows = rows;
    
26.         }
    
27. 
    
28.         public int getCols()
    
29.         {
    
30.                 return this.cols;
    
31.         }
    
32.         public void setCols(int cols)
    
33.         {
    
34.                 this.cols = cols;
    
35.         }
    
36. 
    
37.         public RsBean()
    
38.         {
    
39.                 connMaker = new ConnMaker();
    
40.         }
    
41. 
    
42.         public double getSum(int col) throws NumberFormatException
    
43.         {
    
44.                 if(data != null)
    
45.                 {
    
46.                         double sum = 0D;
    
47.                         for(int i = 0; i < getRows(); ++i)
    
48.                                 sum += Double.parseDouble(data[col][i]);
    
49.                         return sum;
    
50.                 }
    
51.                 else
    
52.                         return 0D;
    
53.         }
    
54.       public void setData(String sql) throws NamingException, SQLException
    
55.       {
    
56.             try
    
57.             {
    
58.                   connection = connMaker.getConnection();
    
59.                   statement = connection.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
    
60.                   rs = statement.executeQuery(sql);
    
61.                   rs.last();
    
62.                   setRows(rs.getRow());
    
63.                   rs.beforeFirst();
    
64.                   ResultSetMetaData rsMetaData = rs.getMetaData();
    
65.                   setCols(rsMetaData.getColumnCount());
    
66.                   data = new String[cols][rows];
    
67.                   while(rs.next())
    
68.                   {
    
69.                         int row = rs.getRow() - 1;
    
70.                         for(int col = 0; col < cols; ++col)
    
71.                               data[col][row] = rs.getString(col + 1);
    
72.                   }
    
73.             }
    
74.             finally
    
75.             {
    
76.                   if(rs != null)
    
77.                   {
    
78.                         rs.close();
    
79.                   }
    
80.                   if(statement != null)
    
81.                   {
    
82.                         statement.close();
    
83.                   }
    
84.                   if(connection != null)
    
85.                   {
    
86.                         connection.close();
    
87.                   }
    
88.             }
    
89. 
    
90.       }
    
91.       public String[][] getData()
    
92.       {
    
93.             return data;
    
94.       }
    
95. }
    
96. 
    

复制代码

elgs

1. 
   
2. package something;
   
3. 
   
4. import java.sql.*;
   
5. import javax.sql.*;
   
6. import javax.naming.*;
   
7. 
   
8. public class ConnMaker
   
9. {
   
10.         Context context = null;
    
11.         public ConnMaker()
    
12.         {
    
13.         }
    
14.         public Connection getConnection() throws NamingException,SQLException
    
15.         {       
    
16.                 try
    
17.                 {
    
18.                         context = new InitialContext();
    
19.                         DataSource dataSource = (DataSource)context.lookup("java:comp/env/jdbc/hd31DB");
    
20.                         return dataSource.getConnection();
    
21.                 }
    
22.                 finally
    
23.                 {
    
24.                         if(context == null)
    
25.                                 context.close();
    
26.                 }
    
27.         }
    
28. }
    

复制代码