java操作DB2，增删改查

Java代码  

1. //:Db2ConnTest
2. /**
3. *功能：实现连接DB2数据库，并实现基本获取数据功能
4. *jiangbin
5. */
6. import java.sql.*;
7. import java.util.*;
8. @SuppressWarnings("unchecked")
9. public class Db2ConnTest{
10. Connection conn;
11. Statement stat;
12. ResultSet rs;
13. ResultSetMetaData rsmd;
14. PreparedStatement pstat; //预编译
15. List ll = new ArrayList();
16. /**
17. *建立连接
18. */
19. public void connDb2(){
20. try{
21. //第一步：加载驱动
22. Class.forName("COM.ibm.db2.jdbc.app.DB2Driver");
23. //第二步：得到连接
24. conn = DriverManager.getConnection("jdbc:db2:mydb","db2admin","123");
25. //第三步：建立statement,同一时间每个 Statement 对象在只能打开一个 ResultSet 对象。
26. stat = conn.createStatement();
27. }
28. catch(ClassNotFoundException ee){
29. System.out.println("ClassNotFoundException:"+ee.getMessage());
30. }
31. catch(SQLException e){
32. System.out.println(e);
33. }
34. }
35. /**
36. *断开连接
37. */
38. public void closeDb2(){
39. try{
40. if(rs!=null) rs.close();
41. if(stat!=null) stat.close();
42. if(conn!=null) conn.close();
43. }
44. catch(SQLException e){
45. System.out.println(e);
46. }
47. }
48. /**
49. *查询数据
50. */
51. public void searchData(){
52. try{
53. //得到结果集
54. rs = stat.executeQuery("select * from db.tblStudent");
55. //用于获取关于 ResultSet 对象中列的类型和属性信息的对象
56. rsmd = rs.getMetaData();
57. while(rs.next()){
58. Map rowData = new HashMap();
59. for(int i=1;i<=rsmd.getColumnCount();i++)
60. rowData.put(rsmd.getColumnName(i),rs.getString(i));
61. ll.add(rowData);
62. }
63. }
64. catch(SQLException e){
65. System.out.println(e);
66. }
67. }
68. /**
69. *打印数据
70. */
71. public void printData(){
72. for(int i=0;i<ll.size();i++ ){
73. System.out.println(ll.get(i));
74. }
75. }
76. /**
77. *插入数据
78. */
79. public void insert(){
80. try{
81. //插入语句
82. String str = "INSERT INTO db.tblStudent(strName,intAge,strAddress,strSex,grandId)"
83. +"VALUES(?,?,?,?,?)";
84. pstat = conn.prepareStatement(str);
85. pstat.setString(1,"王文远");
86. pstat.setInt(2,20);
87. pstat.setString(3,"北京");
88. pstat.setString(4,"T");
89. pstat.setInt(5,4);
90. int record = pstat.executeUpdate();
91. System.out.println("插入"+record+"数据");
92. }
93. catch(SQLException e){
94. System.out.println(e);
95. }
96. }
97. /**
98. *删除数据
99. */
100. public void delete(){
101. try{
102. //删除语句
103. String str = "DELETE FROM db.tblStudent where strName='王五'";
104. stat.executeUpdate(str);
105. }
106. catch(SQLException e){
107. System.out.println(e);
108. }
109. System.out.println("删除数据成功");
110. }
111. /**
112. *修改数据
113. */
114. public void update(){
115. try{
116. //修改语句
117. String str = "UPDATE db.tblstudent SET strAddress='北京',intAge=intAge+5 where intId=1";
118. stat.executeUpdate(str);
119. }
120. catch(SQLException e){
121. System.out.println(e);
122. }
123. System.out.println("修改数据成功");
124. }
125. public static void main(String[] args){
126. Db2ConnTest dc = new Db2ConnTest();
127. dc.connDb2();
128. dc.insert();
129. //dc.searchData();
130. //dc.delete();
131. //dc.update();
132. dc.searchData();
133. dc.printData();
134. dc.closeDb2();
135. }
136. }