简单的JDBC助手类

gongfuxuan

1. 
   
2. import java.sql.*;
   
3. 
   
4. public class Helper {
   
5.   private Helper() {
   
6.   }
   
7. 
   
8.   public static Connection getConnection() {
   
9.     try {
   
10.       Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver").newInstance();
    
11.       String url = "";
    
12.       Connection con = DriverManager.getConnection(url, "gongfuxuan",
    
13.           "password");
    
14.       return con;
    
15.     }
    
16.     catch (Exception e) {
    
17.       e.printStackTrace();
    
18.       throw new RuntimeException("Error while get database Connection");
    
19.     }
    
20.   }
    
21. 
    
22.   public static ResultSet query(String sql) {
    
23.     Connection con = getConnection();
    
24.     ResultSet rs = null;
    
25.     try {
    
26.       Statement st = con.createStatement();
    
27.       rs = st.executeQuery(sql);
    
28.       if (st != null) {
    
29.         st.close();
    
30.       }
    
31.       if (con != null) {
    
32.         con.close();
    
33.       }
    
34.     }
    
35.     catch (SQLException e) {
    
36.       System.out.println("SQL Error,code: " + e.getErrorCode() + ", state:" +
    
37.                          e.getSQLState() + "when execute sql:" + sql);
    
38.     }
    
39. 
    
40.     return rs;
    
41.   }
    
42. 
    
43.   public static boolean execute(String sql) {
    
44.     Connection con = getConnection();
    
45.     boolean result = false;
    
46.     try {
    
47.       Statement st = con.createStatement();
    
48.       result = st.execute(sql);
    
49.       if (st != null) {
    
50.         st.close();
    
51.       }
    
52.       if (con != null) {
    
53.         con.close();
    
54. 
    
55.       }
    
56.     }
    
57.     catch (SQLException e) {
    
58.       System.out.println("SQL Error,code: " + e.getErrorCode() + ", state:" +
    
59.                          e.getSQLState() + "when execute sql:" + sql);
    
60.     }
    
61.     return result;
    
62.   }
    
63. 
    
64.   public static long Update(String sql) {
    
65.     Connection con = getConnection();
    
66.     long result = -1L;
    
67.     try {
    
68.       Statement st = con.createStatement();
    
69.       result = st.executeUpdate(sql);
    
70.       if (st != null) {
    
71.         st.close();
    
72.       }
    
73.       if (con != null) {
    
74.         con.close();
    
75.       }
    
76.     }
    
77.     catch (SQLException e) {
    
78.       System.out.println("SQL Error,code: " + e.getErrorCode() + ", state:" +
    
79.                          e.getSQLState() + "when execute sql:" + sql);
    
80.     }
    
81.     return result;
    
82.   }
    
83. 
    
84. }

复制代码

逸远

呵呵~~,其实可以使用工厂模式,以后就什么数据库都可以通用了

elgs

有两个问题， 1， 不用连接池， 没什么实用价值， 2， 是又第一个问题导致的， 返回ResultSet必须保持住连接， 直到ResultSet用完才能关闭， 封装得不好。
不过这样设计的想法是很不错的。
如果把ResultSet里的数据导到一个其它的数据结构里，就像CachedRowSet一样， 如何

jhsea3do

我记得好像说JIVE在这方面处理得比较好！

gongfuxuan

谢谢elgs 指点，对，实际用是肯定要用连接池才行，把
getConnection()函数重写。你指出的第二点，让我很佩服，谢谢，我将修改一下。

moonight

这种写法我们原来也试过，但是在查询大结果集的时候和有事务处理的时候问题比较多。所以只能不封装了。

要是能有通用的解决方法就好了。