如题，使用DBUtil实现简单的增删改查的封装！！！

1. package org.home.util;
   
2. 
   
3. import java.sql.Connection;
   
4. import java.sql.SQLException;
   
5. import java.util.List;
   
6. import org.apache.commons.dbutils.QueryRunner;
   
7. import org.apache.commons.dbutils.ResultSetHandler;
   
8. import org.apache.commons.dbutils.handlers.BeanListHandler;
   
9. import org.apache.tomcat.jdbc.pool.DataSource;
   
10. import org.apache.tomcat.jdbc.pool.PoolProperties;
    
11. 
    
12. public class DBUtil {
    
13.         private static DataSource ds;
    
14.         private static QueryRunner runner;
    
15.         static {
    
16.                 PoolProperties p = new PoolProperties();
    
17.                 p.setUrl("jdbc:mysql://localhost:3306/home");
    
18.                 p.setDriverClassName("com.mysql.jdbc.Driver");
    
19.                 p.setUsername("root");
    
20.                 p.setPassword("sa");
    
21.                 p.setJmxEnabled(true);
    
22.                 p.setTestWhileIdle(false);
    
23.                 p.setTestOnBorrow(true);
    
24.                 p.setValidationQuery("SELECT 1");
    
25.                 p.setTestOnReturn(false);
    
26.                 p.setValidationInterval(30000);
    
27.                 p.setTimeBetweenEvictionRunsMillis(30000);
    
28.                 p.setMaxActive(100);
    
29.                 p.setInitialSize(10);
    
30.                 p.setMaxWait(10000);
    
31.                 p.setRemoveAbandonedTimeout(60);
    
32.                 p.setMinEvictableIdleTimeMillis(30000);
    
33.                 p.setMinIdle(10);
    
34.                 p.setLogAbandoned(true);
    
35.                 p.setRemoveAbandoned(true);
    
36.                 p.setJdbcInterceptors("org.apache.tomcat.jdbc.pool.interceptor.ConnectionState;"
    
37.                                 + "org.apache.tomcat.jdbc.pool.interceptor.StatementFinalizer");
    
38.                 ds = new DataSource();
    
39.                 ds.setPoolProperties(p);
    
40.                 runner = new QueryRunner();
    
41.         }
    
42. 
    
43.         private static Connection getConnection() throws SQLException {
    
44.                 return ds.getConnection();
    
45.         }
    
46. 
    
47.         /**
    
48.          * 删除
    
49.          * @param tableName
    
50.          * @param id
    
51.          * @return
    
52.          */
    
53.         public static boolean delete(String tableName, long id) {
    
54.                 String sql = "delete from " + tableName + " where id=?";
    
55.                 int i = 0;
    
56.                 boolean flag = false;
    
57.                 Connection con = null;
    
58.                 try {
    
59.                         con = getConnection();
    
60.                         i = runner.update(con, sql, id);
    
61.                         if (i >= 0) {
    
62.                                 flag = true;
    
63.                         }
    
64.                 } catch (SQLException e) {
    
65.                         System.out.println(e.getMessage());
    
66.                 } finally {
    
67.                         if (con != null) {
    
68.                                 try {
    
69.                                         con.close();
    
70.                                 } catch (SQLException e) {
    
71.                                         System.out.println(e.getMessage());
    
72.                                 }
    
73.                         }
    
74.                 }
    
75.                 return flag;
    
76.         }
    
77. 
    
78.         /**
    
79.          * 修改/添加
    
80.          * @param sql
    
81.          * @param pring
    
82.          * @return
    
83.          */
    
84.         public static boolean update(String sql, Object pring[]) {
    
85.                 int i = 0;
    
86.                 boolean flag = false;
    
87.                 Connection con = null;
    
88.                 try {
    
89.                         con = getConnection();
    
90.                         i = runner.update(con, sql, pring);
    
91.                         if (i >= 0) {
    
92.                                 flag = true;
    
93.                         }
    
94.                 } catch (SQLException e) {
    
95.                         e.printStackTrace();
    
96.                 } finally {
    
97.                         if (con != null) {
    
98.                                 try {
    
99.                                         con.close();
    
100.                                 } catch (SQLException e) {
     
101.                                         e.printStackTrace();
     
102.                                 }
     
103.                         }
     
104.                 }
     
105.                 return flag;
     
106.         }
     
107. 
     
108.         /**
     
109.          * 查询
     
110.          * @param sql
     
111.          * @param rsh
     
112.          * @return
     
113.          */
     
114.         public static List<?> query(String sql, ResultSetHandler<?> rsh) {  
     
115.         List<?> result = null;  
     
116.         Connection con = null;
     
117.         try {  
     
118.                 con = getConnection();
     
119.                 result = (List<?>) runner.query(con, sql, rsh);
     
120.         } catch (SQLException e) {            
     
121.             e.printStackTrace();  
     
122.         } finally {
     
123.                 if (con!=null) {
     
124.                         try {
     
125.                                         con.close();
     
126.                                 } catch (SQLException e) {
     
127.                                         e.printStackTrace();
     
128.                                 }
     
129.                 }
     
130.         }
     
131.         return result;  
     
132.     }  
     
133.         
     
134.         /**
     
135.          * 分页查询
     
136.          * @param sql
     
137.          * @param rsh
     
138.          * @param page
     
139.          * @param pageSize
     
140.          * @return
     
141.          */
     
142.         public static List<?> query(String sql, ResultSetHandler<?> rsh, int page, int pageSize) {  
     
143.         List<?> result = null;  
     
144.         Connection con = null;
     
145.         try {  
     
146.                 con = getConnection();
     
147.                 result = (List<?>) runner.query(con, sql + " limit " + page*pageSize + "," + pageSize, rsh);
     
148.         } catch (SQLException e) {            
     
149.             e.printStackTrace();  
     
150.         } finally {
     
151.                 if (con!=null) {
     
152.                         try {
     
153.                                         con.close();
     
154.                                 } catch (SQLException e) {
     
155.                                         e.printStackTrace();
     
156.                                 }
     
157.                 }
     
158.         }
     
159.         return result;  
     
160.     }
     
161.         

复制代码

游客，如果您要查看本帖隐藏内容请回复

这正是我想要的

我之前也封装了一个DBUtil类，这个也是不错的。

果断拿走、

果断拿走、

aghgajsg鬼地方郭德纲的说的

不错哟。

赞赞赞！

看看是什么东西

谢谢分享

学习学习！

学习学习！

学习学习！

这个比较实用，谢谢了！

学习学习！

学习学习！

:lol:lol:lol:lol

确实是简单。。。仅仅满足最基本的功能

学习学习！

:)赞一个