帮我看看代码！

Question

由于本模块要手动拼装SQL，所以我通过hibernate的dateSouce去得到 JDBC的Connection.而且每一次用同一个Connection去操作CRUD,本机测试没有问题，到客户那里在连接池与集群服务器下抛异常。老大说应该每一次都去获取一个Connection,由hibernate去管理Connection，而不是每次都用同一个Connection。
---------------------------修改后的代码-------------------------
1.每次通过hibernate 的dataSource得到不同的Connection实例,执行完SQL 语句后再关闭ResultSet,Statement，Connection这样在连接池和集群服务器下能行不package com.landray.kmss.km.coustomtable.dao.jdbc;import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;import javax.sql.DataSource;import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;import com.landray.kmss.common.dao.HQLInfo;
import com.landray.kmss.common.model.IBaseModel;
import com.landray.kmss.km.coustomtable.dao.IKmCustbDataOperaDao;
import com.landray.kmss.km.coustomtable.model.KmCustbData;
import com.landray.kmss.km.coustomtable.model.KmCustbTb;
import com.landray.kmss.km.coustomtable.util.Constants;
import com.landray.kmss.util.DateUtil;
import com.sunbor.web.tag.Page;/**
 * 创建日期 2009-五月-11
 * 
 * @author 罗小军 自定义表维护
 */
public class KmCustbDataOperaDaoImp implements IKmCustbDataOperaDao {
private DataSource dataSource;
private String dbType; public DataSource getDataSource() {
return dataSource;
} public void setDataSource(DataSource dataSource) {
this.dataSource = dataSource;
} public String getDbType() {
return dbType;
} public void setDbType(String dbType) {
this.dbType = dbType;
} public Connection getConnection() throws SQLException {
return dataSource.getConnection();
} public Long add(IBaseModel modelObj) throws Exception {
Connection connection = getConnection();
KmCustbTb kmCustbTb = null;
if (modelObj instanceof KmCustbTb) {
kmCustbTb = (KmCustbTb) modelObj;
StringBuffer addStr = new StringBuffer();
StringBuffer addValueStr = new StringBuffer();
addStr.append("insert into ");
addStr.append(kmCustbTb.getFdTableName());
addStr.append(" ( ");
addValueStr.append(" ) values ( ");
// 判断数据库
if (Constants.ORACLE.equalsIgnoreCase(dbType)) {
// 暂未对主键生成方式(getPkType)做判断，默认为自动增长
addStr.append(kmCustbTb.getFdPkName());
addStr.append(",");
addValueStr.append("hibernate_sequence.nextval,");
}
List dataList = kmCustbTb.getCustbDatas();
for (int i = 0; i < dataList.size(); i++) {
KmCustbData tempData = (KmCustbData) dataList.get(i);
addStr.append(tempData.getFdCloumnName());
if (Constants.DATE.equalsIgnoreCase(tempData.getFdDataType())
&& Constants.ORACLE.equalsIgnoreCase(dbType)) { addValueStr.append("to_date('");
addValueStr.append(tempData.getFdValue());
addValueStr.append("','yyyy-mm-dd hh24:mi:ss')");
continue; } else {
addValueStr.append("'");
addValueStr.append(tempData.getFdValue());
addValueStr.append("'");
}
if (i + 1 < dataList.size()) {
addStr.append(",");
addValueStr.append(",");
}
}
addValueStr.append(")");
addStr.append(addValueStr);
logger.debug("insert statement : " + addStr);
Statement statement = connection.createStatement();
statement.execute(addStr.toString());
close(connection, statement, null);
}
return kmCustbTb.getFdId();
} public Page findPage(HQLInfo hqlInfo, IBaseModel model) throws Exception {
Connection connection = getConnection();
Statement statement = connection.createStatement();
ResultSet resultSet = null;
StringBuffer selectStr = new StringBuffer();
KmCustbTb kmCustbTb = null;
if (model instanceof KmCustbTb) {
kmCustbTb = (KmCustbTb) model;
if (Constants.ORACLE.equalsIgnoreCase(dbType)) {
selectStr
.append("select * from (select a.*,rownum rn from (select * from ");
selectStr.append(kmCustbTb.getFdTableName());
selectStr.append(" order by ");
selectStr.append(kmCustbTb.getFdPkName());
selectStr.append(" ) a where rownum<=");
selectStr.append(hqlInfo.getPageNo() * hqlInfo.getRowSize());
selectStr.append(") where rn>");
selectStr.append((hqlInfo.getPageNo() - 1)
* hqlInfo.getRowSize());
selectStr.append(" order by "); } else { selectStr.append("select top ");
selectStr.append(hqlInfo.getRowSize());
selectStr.append(" * from ");
selectStr.append(kmCustbTb.getFdTableName());
selectStr.append(" where ( ");
selectStr.append(kmCustbTb.getFdPkName());
selectStr.append(" not in ( select top ");
selectStr.append((hqlInfo.getPageNo() - 1)
* hqlInfo.getRowSize());
selectStr.append(" ");
selectStr.append(kmCustbTb.getFdPkName());
selectStr.append(" from ");
selectStr.append(kmCustbTb.getFdTableName());
selectStr.append(" order by ");
selectStr.append(kmCustbTb.getFdPkName());
selectStr.append(" )) order by ");
}
if (hqlInfo != null && hqlInfo.getOrderBy() != null) {
selectStr.append(hqlInfo.getOrderBy());
} else {
selectStr.append(kmCustbTb.getFdPkName());
} if (hqlInfo != null
&& Constants.DOWN.equalsIgnoreCase(hqlInfo.getOrderBy())) {
selectStr.append(" desc ");
}
logger.debug("select statement = " + selectStr);
}
// 查询得到ResultSet对象
resultSet = statement.executeQuery(selectStr.toString());
KmCustbTb kmCustbTbValue = new KmCustbTb();
List valueList = new ArrayList();
while (resultSet.next()) {
// clone kmCustbTb对象
KmCustbTb tempKmCustbTb = (KmCustbTb) kmCustbTb.clone();
List dataList = tempKmCustbTb.getCustbDatas();
// 给主键赋值
tempKmCustbTb.setFdPkValue(resultSet.getLong(tempKmCustbTb
.getFdPkName()));
// 通过循环把值set到custbData中
for (int j = 0; j < dataList.size(); j++) {
KmCustbData custbData = (KmCustbData) dataList.get(j);
if (Constants.DATE.equals(custbData.getFdDataType())) {
custbData.setFdValue(DateUtil.convertDateToString(DateUtil
.convertStringToDate(resultSet.getString(custbData
.getFdCloumnName()), "yyyy-MM-dd"),
"yyyy-MM-dd"));
} else {
custbData.setFdValue(resultSet.getString(custbData
.getFdCloumnName()));
}
}
valueList.add(tempKmCustbTb);
}
// 测试数据
Page page = new Page();
page.setList(valueList);
close(connection, statement, resultSet);
return page;
} // select count(id) from tableName
// 获取某个表中的数据数量
public Long getCount(String tableName, String id) throws Exception {
Connection connection = getConnection();
Statement statement = connection.createStatement();
StringBuffer selectCount = new StringBuffer("select count(");
selectCount.append(id);
selectCount.append(") from ");
selectCount.append(tableName);
ResultSet resultSet = statement.executeQuery(selectCount.toString());
if (resultSet != null) {
resultSet.next();
return resultSet.getLong(1);
}
close(connection, statement, resultSet);
return null;
} public void close(Connection connection, Statement statement,
ResultSet resultSet) throws SQLException {
if (resultSet != null) {
resultSet.close();
resultSet = null;
}
if (statement != null) {
statement.close();
statement = null;
}
if (connection != null) {
connection.close();
connection = null;
}
}
}

Answer 1

语句后再关闭ResultSet,Statement，Connection这样在连接池连接池里,连接是不要关的,否则肯定会有异常, 应该有个管理连接池的类吧
...........
和集群服务器下能行不 这个我不清楚

Answer 2

必须将close操作放在try{}catch(){}finally{close(con,st,rs);}中，否则会在出现异常的时候造成资源泄漏。

Answer 3

   你不是用的hibernate嘛    看一下数据库连接上没有。
   自己可以得到连接啥 你不是继承了一个HibernateDaosupport  
  session = super.getSession();  这个不是得到连接了嘛。
Query query = session.createQuery(hql);   这样你就可以写sql语句了
该返回什么就返回什么   。  

Answer 4

老大说了，不要关闭连接，让hibernate去管理它

Answer 5

如果配置的是hibernate连接池的话 关闭连接还是要做的(不是关闭连接 而是通知Hibernate回收这个连接 有人称他为释放)
看LZ是想打算做个分页 实际上这其中的一部分代码还是可以放到hibernate中执行的 
个人建议 再另启个JDBC 用时开 不用时关 不一定非得用hibernate的方法获得Connection