Go语言视频零基础入门到精通

javalearner

封装数据库操作，目的就是为了隐藏java.sql包内的类，在编码中去掉核心的数据库操作代码。以杜绝直接数据库操作容易带来的资源未释放问题。同时也减少了数据库操作的编码量。

     但是很多网友在封装时，却喜欢返回结果集(ResultSet对象)，那么这个封装就没有意义了。
1. 又是直接操作核心数据库类，跟封装前几乎没什么变化。
2. 结果集总是依赖于它使用的连接(Connection)对象。因此当连接对象在方法内被关闭后，你返回的ResultSet就没有用了。

    如果真的要获得查询数据库的结果集，就把结果集对象内的所有数据，转储到以Map为元素的List对象内。
当然,这种方式,不能适应大数据量的查询,不过如果真的碰到大数据量的查询,那用什么封装都不好,还是得直接数据库操作. :)))

下面是简单的数据库操作Javabean的代码:
  
   
   
     
   

   
   
  


  
   
   DbWrapper.java
   
   
  

1. [b]import[/b] java.sql.*;
   
2. [b]import[/b] java.util.*;
   
3. [b]public[/b] [b]class[/b] DbWrapper
   
4. {
   
5.     [i]// 定义连接池对象为静态变量，将一直存在，直到工作目录关闭。[/i]
   
6.     [b]private[/b] [b]static[/b] DataSource ds = [b]null[/b];
7. 
   
8.     [i]// 1.用连接池的方式获得连接[/i]
   
9.     [i]// 如果不是做多数据库程序，推荐使用此方法[/i]
   
10.     [i]// 相关内容：[url=http://blog.csdn.net/cm4ever/archive/2004/10/22/147446.aspx]在tomcat管理界面配置连接池[/url][/i]
    
11.     [b]public[/b] [b]static[/b] Connection [b]openConnection[/b]() [b]throws[/b] Exception
    
12.     {
    
13.         [i]// 只需要初始化1次[/i]
    
14.         [b]if[/b] ( ds == [b]null[/b] )
    
15.         {
    
16.             Context initContext = [b]new[/b] [b]InitialContext[/b]();
    
17.             Context envContext = (Context) initContext.[b]lookup[/b]("java:/comp/env");
    
18.             DataSource ds = (DataSource) envContext.[b]lookup[/b]("jdbc/MyDataSource");
    
19.         }
    
20.         [b]return[/b] ds.[b]getConnection[/b]();
    
21.     }
    
22.    
    
23.     [i]// 2.用jdbc驱动获得连接[/i]
    
24.     [i]// 相关内容：[url=http://blog.csdn.net/cm4ever/archive/2004/09/30/121770.aspx]JSP数据库连接大全[/url][/i]
    
25.     [b]public[/b] [b]static[/b] Connection [b]openConnection[/b](
    
26.         String driver,
    
27.         String url,
    
28.         String username,
    
29.         String password)
    
30.             [b]throws[/b] Exception
    
31.     {
    
32.         Class.[b]forName[/b](driver).[b]newInstance[/b]();
    
33.         [b]return[/b] DriverManager.[b]getConnection[/b](url, username, password);
    
34.     }
    
35.    
    
36.     [b]public[/b] [b]static[/b] void [b]closeConnection[/b](Connection conn) [b]throws[/b] Exception
    
37.     {
    
38.         [b]if[/b] ( conn != [b]null[/b] )
    
39.         {
    
40.             conn.[b]close[/b]();
    
41.         }
    
42.     }
43. 
    
44.     [b]public[/b] [b]static[/b] int [b]executeUpdate[/b](String sql) [b]throws[/b] Exception
    
45.     {
    
46.        int count = 0;
    
47.         
    
48.         Connection conn = [b]null[/b];
    
49.         Statement  stmt = [b]null[/b];
    
50.         
    
51.         [b]try[/b]
    
52.         {
    
53.             conn = [b]openConnection[/b]();
    
54.             stmt = conn.[b]createStatement[/b]();
    
55.         
    
56.             count = stmt.[b]executeUpdate[/b](sql);
    
57.         }
    
58.         [b]catch[/b] ( Exception e )
    
59.         {
    
60.             [b]throw[/b] e;
    
61.         }
    
62.         [b]finally[/b]
    
63.         {
    
64.             [b]closeConnection[/b](conn);
    
65.         }
    
66.         
    
67.         [b]return[/b] count;
    
68.     }
    
69.    
    
70.     [b]public[/b] [b]static[/b] List [b]executeQuery[/b](String sql) [b]throws[/b] Exception
    
71.     {
    
72.         List list = [b]new[/b] [b]ArrayList[/b]();
    
73.         
    
74.         Connection conn = [b]null[/b];
    
75.         Statement  stmt = [b]null[/b];
    
76.         ResultSet  rs   = [b]null[/b];
    
77.         
    
78.         [b]try[/b]
    
79.         {
    
80.             conn = [b]openConnection[/b]();
    
81.             stmt = conn.[b]createStatement[/b]();
    
82.             rs   = stmt.[b]executeQuery[/b](sql);
    
83.             
    
84.             ResultSetMetaData rsmd = rs.[b]getMetaData[/b]();
    
85.         
    
86.             [b]while[/b] ( rs.[b]next[/b]() )
    
87.             {
    
88.                 Map map = [b]new[/b] [b]HashMap[/b]();
    
89.                
    
90.                 [b]for[/b] ( int i = 1; i <= rsmd.[b]getColumnCount[/b](); i++ )
    
91.                 {
    
92.                     map.[b]put[/b](rsmd.[b]getColumnName[/b](i), rs.[b]getObject[/b](i));
    
93.                 }
    
94.                
    
95.                 list.[b]add[/b](map);
    
96.             }
97.         }
    
98.         [b]catch[/b] ( Exception e )
    
99.         {
    
100.             e.[b]printStackTrace[/b]();
     
101.         }
     
102.         [b]finally[/b]
     
103.         {
     
104.             [b]if[/b] ( rs != [b]null[/b] ) rs.[b]close[/b]();
     
105.             [b]closeConnection[/b](conn);
     
106.         }
     
107.         
     
108.         [b]return[/b] list;
109.     }
     
110. }

复制代码

   
  
   

  
   
  

1. [i]// 1.对于insert, update, delete语句
2. [/i]int count = DbWrapper.[b]executeUpdate[/b](sql);
3. 
   
4. [i]// 2.对于selete语句[/i]
   
5. java.util.List list = DbWrapper.[b]executeQuery[/b](sql);
6. 
   
7. [i]// 方法一:按名字取值，注意大小写是严格区分的[/i]
   
8. [b]for[/b] ( int i = 0; i < list.[b]size[/b](); i++ )
   
9. {
   
10.     java.util.Map map = (java.util.Map)list.[b]get[/b](i);
    
11.     out.[b]println[/b](mag.[b]get[/b]("column_name").[b]toString[/b]());
    
12. }
13. 
    
14. [i]// 方法二：遍历取值[/i]
    
15. [b]for[/b] ( int i = 0; i < list.[b]size[/b](); i++ )
    
16. {
    
17.     java.util.Map map = (java.util.Map)list.[b]get[/b](i);
18. 
    
19.     [b]for[/b] (java.util.Iterator it = map.[b]keySet[/b]().[b]iterator[/b](); it.[b]hasNext[/b]();)
    
20.     {
    
21.         String column_name = it.[b]next[/b]().[b]toString[/b]());
23.         [i]// 取值[/i]时注意null判断
    
24.         out.[b]println[/b](column_name + " = " + map.[b]get[/b](column_name)  == [b]null[/b] ? "" : map.[b]get[/b](column_name).[b]toString[/b]());
    
25.     }
    
26. }

复制代码