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

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

博客分类：

∙ JAVA积累

SQLOracleJDBCDAO

Java代码

1. package

2.

3. import

4. import

5.

6. public class DAOFactory

7. {

8. public static PersonDAO getPersonDAOInstance(

9. {

10. return new PersonDAOImpl( ;

11. }

12. };

Java代码

1. package

2. import

3.

4. // 主要功能就是连接数据库、关闭数据库

5. public class DataBaseConnection

6. {

7. private final String DBDRIVER = ;

8. private final String DBURL = "jdbc:oracle:thin:@localhost:1521:MLDN" ;

9. private final String DBUSER = "scott" ;

10. private final String DBPASSWORD = "tiger" ;

11. private Connection conn = null ;

12.

13. public DataBaseConnection(

14. {

15. try

16. {

17. e(DBDRIVER ;

18. = nection(DBURL,DBUSER,DBPASSWORD ;

19. }

20. catch (Exception e

21. {

22. }

23. }

24.

25. // 取得数据库连接

26. public Connection getConnection(

27. {

28. return ;

29. }

30.

31. // 关闭数据库连接

32. public void close(

33. {

34. try

35. {

36. ( ;

37. }

38. catch (Exception e

39. {

40. }

41. }

42. };

Java代码

1. package

2.

3. // 值对象，包含属性，setter，getter方法

4. public class Person

5. {

6. private String id ;

7. private String name ;

8. private String password ;

9. private int age ;

10. private String email ;

11.

12. // 生成getter、setter方法

13. public void setId(String id

14. {

15. = id ;

16. }

17. public void setName(String name

18. {

19. = name ;

20. }

21. public void setPassword(String password

22. {

23. rd = password ;

24. }

25. public void setAge(int age

26. {

27. = age ;

28. }

29. public void setEmail(String email

30. {

31. = email ;

32. }

33. public String getId(

34. {

35. return ;

36. }

37. public String getName(

38. {

39. return ;

40. }

41. public String getPassword(

42. {

43. return rd ;

44. }

45. public int getAge(

46. {

47. return ;

48. }

49. public String getEmail(

50. {

51. return ;

52. }

53. };

Java代码

1. package

2.

3. import

4. import

5.

6. // 规定出了操作person表在此项目里的全部方法

7. public interface PersonDAO

8. {

9. // 增加操作

10. public void insert(Person person throws Exception ;

11. // 修改操作

12. public void update(Person person throws Exception ;

13. // 删除操作

14. public void delete(String id throws Exception ;

15. // 按ID查询操作

16. public Person queryById(String id throws Exception ;

17. // 查询全部

18. public List queryAll( throws Exception ;

19. // 模糊查询

20. public List queryByLike(String cond throws Exception ;

21. }

Java代码

1. package

2. import

3. import

4. import

5. import

6. import

7.

8. // 此类需要完成具体的数据库操作，需要JDB代码

9. public class PersonDAOImpl implements PersonDAO

10. {

11. // 增加操作

12. public void insert(Person person throws Exception

13. {

14. String sql = "INSERT INTO person (id,name,password,age,email VALUES (?,?,?,?,?" ;

15. PreparedStatement pstmt = null ;

16. DataBaseConnection dbc = null ;

17.

18. // 下面是针对数据库的具体操作

19. try

20. {

21. // 连接数据库

22. dbc = new DataBaseConnection( ;

23. pstmt = nection(.prepareStatement(sql ;

24. ing(1,( ;

25. ing(2,e( ;

26. ing(3,sword( ;

27. (4,( ;

28. ing(5,il( ;

29. // 进行数据库更新操作

30. eUpdate( ;

31. ( ;

32. }

33. catch (Exception e

34. {

35. throw new Exception("操作出现异常" ;

36. }

37. finally

38. {

39. // 关闭数据库连接

40. ( ;

41. }

42. }

43. // 修改操作

44. public void update(Person person throws Exception

45. {

46. String sql = "UPDATE person SET name=?,password=?,age=?,email=? WHERE id=?" ;

47. PreparedStatement pstmt = null ;

48. DataBaseConnection dbc = null ;

49.

50. // 下面是针对数据库的具体操作

51. try

52. {

53. // 连接数据库

54. dbc = new DataBaseConnection( ;

55. pstmt = nection(.prepareStatement(sql ;

56. ing(1,e( ;

57. ing(2,sword( ;

58. (3,( ;

59. ing(4,il( ;

60. ing(5,( ;

61. // 进行数据库更新操作

62. eUpdate( ;

63. ( ;

64. }

65. catch (Exception e

66. {

67. throw new Exception("操作出现异常" ;

68. }

69. finally

70. {

71. // 关闭数据库连接

72. ( ;

73. }

74. }

75. // 删除操作

76. public void delete(String id throws Exception

77. {

78. String sql = "DELETE FROM person WHERE id=?" ;

79. PreparedStatement pstmt = null ;

80. DataBaseConnection dbc = null ;

81.

82. // 下面是针对数据库的具体操作

83. try

84. {

85. // 连接数据库

86. dbc = new DataBaseConnection( ;

87. pstmt = nection(.prepareStatement(sql ;

88. ing(1,id ;

89. // 进行数据库更新操作

90. eUpdate( ;

91. ( ;

92. }

93. catch (Exception e

94. {

95. throw new Exception("操作出现异常" ;

96. }

97. finally

98. {

99. // 关闭数据库连接

100. ( ;

101. }

102. }

103. // 按ID查询操作

104. public Person queryById(String id throws Exception

105. {

106. Person person = null ;

107. String sql = "SELECT id,name,password,age,email FROM person WHERE id=?" ;

108. PreparedStatement pstmt = null ;

109. DataBaseConnection dbc = null ;

110.

111. // 下面是针对数据库的具体操作

112. try

113. {

114. // 连接数据库

115. dbc = new DataBaseConnection( ;

116. pstmt = nection(.prepareStatement(sql ;

117. ing(1,id ;

118. // 进行数据库查询操作

119. ResultSet rs = eQuery( ;

120. if((

121. {

122. // 查询出内容，之后将查询出的内容赋值给person对象

123. person = new Person( ;

124. (ing(1 ;

125. e(ing(2 ;

126. sword(ing(3 ;

127. ((4 ;

128. il(ing(5 ;

129. }

130. ( ;

131. ( ;

132. }

133. catch (Exception e

134. {

135. throw new Exception("操作出现异常" ;

136. }

137. finally

138. {

139. // 关闭数据库连接

140. ( ;

141. }

142. return person ;

143. }

144. // 查询全部

145. public List queryAll( throws Exception

146. {

147. List all = new ArrayList( ;

148. String sql = "SELECT id,name,password,age,email FROM person" ;

149. PreparedStatement pstmt = null ;

150. DataBaseConnection dbc = null ;

151.

152. // 下面是针对数据库的具体操作

153. try

154. {

155. // 连接数据库

156. dbc = new DataBaseConnection( ;

157. pstmt = nection(.prepareStatement(sql ;

158. // 进行数据库查询操作

159. ResultSet rs = eQuery( ;

160. while((

161. {

162. // 查询出内容，之后将查询出的内容赋值给person对象

163. Person person = new Person( ;

164. (ing(1 ;

165. e(ing(2 ;

166. sword(ing(3 ;

167. ((4 ;

168. il(ing(5 ;

169.

170. // 将查询出来的数据加入到List对象之中

171. (person ;

172. }

173. ( ;

174. ( ;

175. }

176. catch (Exception e

177. {

178. throw new Exception("操作出现异常" ;

179. }

180. finally

181. {

182. // 关闭数据库连接

183. ( ;

184. }

185. return all ;

186. }

187. // 模糊查询

188. public List queryByLike(String cond throws Exception

189. {

190. List all = new ArrayList( ;

191. String sql = "SELECT id,name,password,age,email FROM person WHERE name LIKE ? or email LIKE ?" ;

192. PreparedStatement pstmt = null ;

193. DataBaseConnection dbc = null ;

194.

195. // 下面是针对数据库的具体操作

196. try

197. {

198. // 连接数据库

199. dbc = new DataBaseConnection( ;

200. pstmt = nection(.prepareStatement(sql ;

201. // 设置模糊查询条件

202. ing(1,"%"+cond+"%" ;

203. ing(2,"%"+cond+"%" ;

204. // 进行数据库查询操作

205. ResultSet rs = eQuery( ;

206. while((

207. {

208. // 查询出内容，之后将查询出的内容赋值给person对象

209. Person person = new Person( ;

210. (ing(1 ;

211. e(ing(2 ;

212. sword(ing(3 ;

213. ((4 ;

214. il(ing(5 ;

215.

216. // 将查询出来的数据加入到List对象之中

217. (person ;

218. }

219. ( ;

220. ( ;

221. }

222. catch (Exception e

223. {

224. throw new Exception("操作出现异常" ;

225. }

226. finally

227. {

228. // 关闭数据库连接

229. ( ;

230. }

231. return all ;

232. }

233. };