帮看下我自己封装了个JDBC的通用查询，更新函数有没有什么问题

wgm993114

函数功能实现通用的增删改查，这个是第一版，还需要加的功能很多，希望把问题在萌芽阶段就找出来。

1. public class DBJdbcRunners {
   
2.         private static Log log = LogFactory.getLog(DBJdbcRunners.class);
   
3.         private boolean autoCommit;
   
4.     Connection connection = null;
   
5.        
   
6.     public DBJdbcRunners()throws SQLException{
   
7.             autoCommit = true;
   
8.             try {
   
9.                      connection = DBUtils.getConnection();
   
10.                 } catch (SQLException e) {
    
11.                          throw new SQLException();
    
12.                 }
    
13.     }
    
14.     public void begintx()throws SQLException{
    
15.             autoCommit = false;
    
16.             if (connection != null){
    
17.                     try {
    
18.                     connection.setAutoCommit(false);
    
19.                     } catch (SQLException e) {
    
20.                             throw new SQLException();
    
21.                    }
    
22.       }
    
23.     }
    
24.     public void committx()throws SQLException{
    
25.             autoCommit = false;
    
26.             if (connection != null){
    
27.                     try {
    
28.                     connection.commit();
    
29.                     connection.setAutoCommit(true);
    
30.                     autoCommit = true;
    
31.                     } catch (SQLException e) {
    
32.                      log.equals("committx exception is ->["+e+"]");
    
33.                             throw new SQLException();
    
34.                    }finally{
    
35.                             DBUtils.closeConnection(connection);
    
36.             }
    
37.       }
    
38.     }
    
39. 
    
40.           public int executeUpdate (String sql) throws SQLException,
    
41.                  InputIllegalException
    
42.           {
    
43.                Statement statement = null;               
    
44.               try
    
45.               {
    
46.        
    
47.                   statement = connection.createStatement();
    
48.                  int i = statement.executeUpdate(sql);
    
49.                                 return i;
    
50.            }catch( SQLException e){
    
51.                    log.error("error sql is-->["+sql+"]");
    
52.                    log.error(e);
    
53.                    if(!autoCommit){
    
54.                    try{
    
55.                    connection.rollback();
    
56.                    }catch(SQLException ex){
    
57.                            log.error(ex);
    
58.                    }
    
59.                 }
    
60.           throw new SQLException();
    
61.            }
    
62.            finally{
    
63.                       DBUtils.closeStatement(statement);
    
64.                    if(autoCommit){
    
65.               DBUtils.closeConnection(connection);
    
66.               }
    
67.            }
    
68.           }
    
69.           
    
70. 
    
71.   public  void executeQuery (
    
72.                   String sql,boolean isgetTotalNum)
    
73.           throws SQLException,InputIllegalException{
    
74.           
    
75.        Statement statement = null;
    
76.        PreparedStatement p_statement = null;
    
77.        ResultSet rs = null;
    
78.        if(sql == null){
    
79.                throw new InputIllegalException("in executeQuery function" +
    
80.                                "sql is null");
    
81.        }
    
82.        try{
    
83.                if(isgetTotalNum){
    
84.                        statement = connection.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,  
    
85.                            ResultSet.CONCUR_READ_ONLY);
    
86.                }else{
    
87.                statement = connection.createStatement();
    
88.                }
    
89.                rs = statement.executeQuery(sql);
    
90.                if(isgetTotalNum){
    
91.                        rs.last();
    
92.                        log.debug("total row num is-->["+rs.getRow()+"]");
    
93.                        rs.first();
    
94.                }
    
95.                ResultSetMetaData rsmd = rs.getMetaData();
    
96.                int numCols = rsmd.getColumnCount();
    
97.                log.debug("column num is-->["+rsmd.getColumnCount()+"]");
    
98.               
    
99.                while(rs.next()){
    
100.                        for(int i=1;i<=numCols;i++){
     
101.                                System.out.print("column "+i+" is-->["+rs.getString(i)+"]");
     
102.                        }
     
103.                        System.out.print("\n");
     
104.                }
     
105.            }catch( SQLException e){
     
106.                    log.error("error sql is-->["+sql+"]");
     
107.                    log.error("[ex in executeQuery function]-->["+e+"]");
     
108.                    if(!autoCommit){
     
109.                      try{
     
110.                             if(log.isDebugEnabled()){
     
111.                                log.debug("[in executeQuery function rollback]");
     
112.                          }
     
113.                        connection.rollback();
     
114.                      }catch(SQLException ex){
     
115.                            log.error(ex);
     
116.                      }
     
117.                    }
     
118.           throw new SQLException();
     
119.            }
     
120.            finally{
     
121.                           DBUtils.closeResultSet(rs);
     
122.                       DBUtils.closeStatement(statement);
     
123.                       if(autoCommit){
     
124.                    DBUtils.closeConnection(connection);
     
125.                   }
     
126.            }
     
127.           
     
128.   }

复制代码

wgm993114

1. 
   
2. public class testDBQuery {
   
3. private static Log log = LogFactory.getLog(testDBQuery.class);
   
4. public static void main(String[] args) {       
   
5. DBJdbcRunners query = null;       
   
6. try {        query.begintx();       
   
7. query.executeUpdate("insert into user (id,name) values(9001,'wgm')");       
   
8. query.executeQuery("select id, name from user order by id",true);       
   
9. query.committx();
   
10. } catch (Exception e) {               
    
11. //System.out.print(rowSet.print());               
    
12. e.printStackTrace();        }
    
13. }
    
14. }
    

复制代码

以上在MYSQL数据库，INFORMIX数据库上都已经测试过，支持事物。
查询结果正确。
说明在DBJdbcRunners中DBUtils.getConnection();
DBUtils.closeResultSet(rs); DBUtils.closeStatement(statement); DBUtils.closeConnection(connection);
是写的一个通用方法DBUtils，管理连接，结果集和statement。
但我不知道这种调用方式会不会有其他的问题，所以请大家帮我参考下。

wgm993114

0。我最关心的这个代码会不会出现连接无限增长，无法关闭的问题。
rs.last()在数据量很大的时候会不会出现性能问题。
这样的事务调用方式，累似hibernate的调用方式，虽然生效，但不知道会不会有其他问题和弊病。

1.为什么不用现成的开源产品如hibernate,ibats?
回答：并不是每个项目都适合用hibernate，不是说hibernate的能力适用不适用，而是开发人员的学习能力。毕竟hibernate中还是有很多东西需要学习，如果有些问题注意不好会出现性能问题，比如我前段时间碰见过延迟加载没有设置，导致列表页面超级慢。比如关联删除没有设置好，也会出问题。还有出了问题，人的第一个放应是框架的问题，不是自己问题。

而我写的JDBC只是简单的封装，学习门槛低，对付一些小的项目是很合适的。hibernate虽然开源，但真正能大体看懂源码得人很少。

2。这个代码不适合预处理查询和大字段（BLOB）的查询
是，这个需要在之后加入。
预处理查询 可以参考 Jdon彭老师 的jdbcUtil.setQueryParams(queryParams, ps);
blob 我只想写一个插入函数，和查询findbykey()的方法，不会在一般列表查询中也把blob,查询出来。

3.rs.getString都用这个函数似乎有偷工减料的嫌疑。
rs.getString 对一般的类型都可以取出，可能效率不是最好，但是问题应该不大。取出后在进行类型的转换。
Jdon的彭老师用的 rs.getObject
这个也是我有疑问的地方。
4。这个代码不支持分页查询
是，这个也需要在之后加入。
5。查询的结果没有返回，只是打印。
是，我回将结果放入的一个rowSet 种，rowSet中放入row.
6.不够优化，没有对各种数据库进行优化。
是，我看了hibernate的Dialect，可以搬过来。

最后我觉得这个东西还是有用的，适合比较简单，业务不复杂但要求进度的项目。

fantix

轻量级SqlBean，嘿嘿～～我原来也写过，有创意！考虑做成框架式的？PoEAA里的那几个模式。

angus1923

是否应该加入同步的方法~~

perryhg

我以前也写过类似的东西，不过后来发现绝大多数功能用spring的jdbc template就已经实现了，代码又简单，不用担心关闭连接的问题，通过配置文件就可以自动集成连接池，建议楼主有空看看。

jakieyoung

楼主有这样的积极性，是值得表扬的。
但是正如版主所说的，Spring的JdbcTemplate确实是好东西

楼主有创造轮子的嫌疑

另外，对于Hibernate，iBatis这些东西，没有必要敬而远之
你知道它帮你做了什么东西之后，就会从中获益匪浅

jelver

jakieyoung   
圣骑士说的有道理!