jdbc操作oracle数据库(增删改查).docx

jdbc操作oracle数据库(增删改查)博客分类： JAVA积累SQLOracleJDBCDAODAOFactory.javaJava代码1. packagecn.mldn.lxh.factory;2. 3. importcn.mldn.lxh.dao.*;4. importcn.mldn.lxh.dao.impl.*;5. 6. publicclassDAOFactory7. 8. publicstaticPersonDAOgetPersonDAOInstance()9. 10. returnnewPersonDAOImpl();11. 12. ;DataBaseConnection.javaJava代码1. packagecn.mldn.lxh.dbc;2. importjava.sql.*;3. 4. /主要功能就是连接数据库、关闭数据库5. publicclassDataBaseConnection6. 7. privatefinalStringDBDRIVER=oracle.jdbc.driver.OracleDriver;8. privatefinalStringDBURL=jdbc:oracle:thin:localhost:1521:MLDN;9. privatefinalStringDBUSER=scott;10. privatefinalStringDBPASSWORD=tiger;11. privateConnectionconn=null;12. 13. publicDataBaseConnection()14. 15. try16. 17. Class.forName(DBDRIVER);18. this.conn=DriverManager.getConnection(DBURL,DBUSER,DBPASSWORD);19. 20. catch(Exceptione)21. 22. 23. 24. 25. /取得数据库连接26. publicConnectiongetConnection()27. 28. returnthis.conn;29. 30. 31. /关闭数据库连接32. publicvoidclose()33. 34. try35. 36. this.conn.close();37. 38. catch(Exceptione)39. 40. 41. 42. ;Person.javaJava代码1. packagecn.mldn.lxh.vo;2. 3. /值对象，包含属性，setter，getter方法4. publicclassPerson5. 6. privateStringid;7. privateStringname;8. privateStringpassword;9. privateintage;10. privateStringemail;11. 12. /生成getter、setter方法13. publicvoidsetId(Stringid)14. 15. this.id=id;16. 17. publicvoidsetName(Stringname)18. 19. =name;20. 21. publicvoidsetPassword(Stringpassword)22. 23. this.password=password;24. 25. publicvoidsetAge(intage)26. 27. this.age=age;28. 29. publicvoidsetEmail(Stringemail)30. 31. this.email=email;32. 33. publicStringgetId()34. 35. returnthis.id;36. 37. publicStringgetName()38. 39. ;40. 41. publicStringgetPassword()42. 43. returnthis.password;44. 45. publicintgetAge()46. 47. returnthis.age;48. 49. publicStringgetEmail()50. 51. returnthis.email;52. 53. ;PersonDAO.javaJava代码1. packagecn.mldn.lxh.dao;2. 3. importjava.util.*;4. importcn.mldn.lxh.vo.*;5. 6. /规定出了操作person表在此项目里的全部方法7. publicinterfacePersonDAO8. 9. /增加操作10. publicvoidinsert(Personperson)throwsException;11. /修改操作12. publicvoidupdate(Personperson)throwsException;13. /删除操作14. publicvoiddelete(Stringid)throwsException;15. /按ID查询操作16. publicPersonqueryById(Stringid)throwsException;17. /查询全部18. publicListqueryAll()throwsException;19. /模糊查询20. publicListqueryByLike(Stringcond)throwsException;21. PersonDAOImpl.javaJava代码1. packagecn.mldn.lxh.dao.impl;2. importjava.sql.*;3. importjava.util.*;4. importcn.mldn.lxh.vo.*;5. importcn.mldn.lxh.dbc.*;6. importcn.mldn.lxh.dao.*;7. 8. /此类需要完成具体的数据库操作，需要JDB代码9. publicclassPersonDAOImplimplementsPersonDAO10. 11. /增加操作12. publicvoidinsert(Personperson)throwsException13. 14. Stringsql=INSERTINTOperson(id,name,password,age,email)VALUES(?,?,?,?,?);15. PreparedStatementpstmt=null;16. DataBaseConnectiondbc=null;17. 18. /下面是针对数据库的具体操作19. try20. 21. /连接数据库22. dbc=newDataBaseConnection();23. pstmt=dbc.getConnection().prepareStatement(sql);24. pstmt.setString(1,person.getId();25. pstmt.setString(2,person.getName();26. pstmt.setString(3,person.getPassword();27. pstmt.setInt(4,person.getAge();28. pstmt.setString(5,person.getEmail();29. /进行数据库更新操作30. pstmt.executeUpdate();31. pstmt.close();32. 33. catch(Exceptione)34. 35. thrownewException(操作出现异常);36. 37. finally38. 39. /关闭数据库连接40. dbc.close();41. 42. 43. /修改操作44. publicvoidupdate(Personperson)throwsException45. 46. Stringsql=UPDATEpersonSETname=?,password=?,age=?,email=?WHEREid=?;47. PreparedStatementpstmt=null;48. DataBaseConnectiondbc=null;49. 50. /下面是针对数据库的具体操作51. try52. 53. /连接数据库54. dbc=newDataBaseConnection();55. pstmt=dbc.getConnection().prepareStatement(sql);56. pstmt.setString(1,person.getName();57. pstmt.setString(2,person.getPassword();58. pstmt.setInt(3,person.getAge();59. pstmt.setString(4,person.getEmail();60. pstmt.setString(5,person.getId();61. /进行数据库更新操作62. pstmt.executeUpdate();63. pstmt.close();64. 65. catch(Exceptione)66. 67. thrownewException(操作出现异常);68. 69. finally70. 71. /关闭数据库连接72. dbc.close();73. 74. 75. /删除操作76. publicvoiddelete(Stringid)throwsException77. 78. Stringsql=DELETEFROMpersonWHEREid=?;79. PreparedStatementpstmt=null;80. DataBaseConnectiondbc=null;81. 82. /下面是针对数据库的具体操作83. try84. 85. /连接数据库86. dbc=newDataBaseConnection();87. pstmt=dbc.getConnection().prepareStatement(sql);88. pstmt.setString(1,id);89. /进行数据库更新操作90. pstmt.executeUpdate();91. pstmt.close();92. 93. catch(Exceptione)94. 95. thrownewException(操作出现异常);96. 97. finally98. 99. /关闭数据库连接100. dbc.close();101. 102. 103. /按ID查询操作104. publicPersonqueryById(Stringid)throwsException105. 106. Personperson=null;107. Stringsql=SELECTid,name,password,age,emailFROMpersonWHEREid=?;108. PreparedStatementpstmt=null;109. DataBaseConnectiondbc=null;110. 111. /下面是针对数据库的具体操作112. try113. 114. /连接数据库115. dbc=newDataBaseConnection();116. pstmt=dbc.getConnection().prepareStatement(sql);117. pstmt.setString(1,id);118. /进行数据库查询操作119. ResultSetrs=pstmt.executeQuery();120. if(rs.next()121. 122. /查询出内容，之后将查询出的内容赋值给person对象123. person=newPerson();124. person.setId(rs.getString(1);125. person.setName(rs.getString(2);126. person.setPassword(rs.getString(3);127. person.setAge(rs.getInt(4);128. person.setEmail(rs.getString(5);129. 130. rs.close();131. pstmt.close();132. 133. catch(Exceptione)134. 135. thrownewException(操作出现异常);136. 137. finally138. 139. /关闭数据库连接140. dbc.close();141. 142. returnperson;143. 144. /查询全部145. publicListqueryAll()throwsException146. 147. Listall=newArrayList();148. Stringsql=SELECTid,name,password,age,emailFROMperson;149. PreparedStatementpstmt=null;150. DataBaseConnectiondbc=null;151. 152. /下面是针对数据库的具体操作153. try154. 155. /连接数据库156. dbc=newDataBaseConnection();157. pstmt=dbc.getConnection().prepareStatement(sql);158. /进行数据库查询操作159. ResultSetrs=pstmt.executeQuery();160. while(rs.next()161. 162. /查询出内容，之后将查询出的内容赋值给person对象163. Personperson=newPerson();164. person.setId(rs.getString(1);165. person.setName(rs.getString(2);166. person.setPassword(rs.getString(3);167. person.setAge(rs.getInt(4);168. person.setEmail(rs.getString(5);169. 170. /将查询出来的数据加入到List对象之中171. all.add(person);172. 173. rs.close();174. pstmt.close();175. 176. catch(Exceptione)177. 178. thrownewException(操作出现异常);179. 180. finally181. 182. /关闭数据库连接183. dbc.close();184. 185. returnall;186. 187. /模糊查询188. publicListqueryByLike(Stringcond)throwsException189. 190. Listall=newArrayList();191. Stringsql=SELECTid,name,password,age,emailFROMpersonWHEREnameLIKE?oremailLIKE?;192. PreparedStatementpstmt=null;193. DataBaseConnectiondbc=null;194. 195. /下面是针对数据库的具体操作196. try197. 198. /连接数据