数据库 oracle

凝望长空

数据库 oracle

1. /**
   
2. 02
   
3. 首先在数据库中创建存储过程(如:pl_pro),代码如下:
   
4. 03
   
5. create or replace procedure pl_emp(pl_name varchar2,salary number) is
   
6. 04
   
7. begin
   
8. 05
   
9.   --根据用户名去修改职工工资
   
10. 06
    
11.   update emp set sal=salary where ename=pl_name;
    
12. 07
    
13. end pl_pro;
    
14. 08
    
15. /
    
16. 09
    
17. */
    
18. 10
    
19. package testOraclePLSQL;
    
20. 11
    
21. 
    
22. 12
    
23. import java.io.File;
    
24. 13
    
25. import java.io.FileInputStream;
    
26. 14
    
27. import java.io.IOException;
    
28. 15
    
29. import java.sql.CallableStatement;
    
30. 16
    
31. import java.sql.Connection;
    
32. 17
    
33. import java.sql.DriverManager;
    
34. 18
    
35. import java.sql.SQLException;
    
36. 19
    
37. import java.util.Properties;
    
38. 20
    
39. 
    
40. 21
    
41. /**
    
42. 22
    
43. * 利用JDBC调用Oracle存储过程
    
44. 23
    
45. *
    
46. 24
    
47. * @author Nilux
    
48. 25
    
49. *
    
50. 26
    
51. */
    
52. 27
    
53. public class GetPLSQL {
    
54. 28
    
55. 
    
56. 29
    
57.     // test
    
58. 30
    
59.     public static void main(String[] args) {
    
60. 31
    
61.         getConn();
    
62. 32
    
63.         execPLSQL();
    
64. 33
    
65.     }
    
66. 34
    
67. 
    
68. 35
    
69.     static Connection conn;
    
70. 36
    
71. 
    
72. 37
    
73.     // 获得连接
    
74. 38
    
75.     public static void getConn() {
    
76. 39
    
77.         FileInputStream fis = null;
    
78. 40
    
79.         // 读取Properties的配置
    
80. 41
    
81.         try {
    
82. 42
    
83.             fis = new FileInputStream(new File(
    
84. 43
    
85.                     "src/testOraclePLSQL/db.properties"));
    
86. 44
    
87.             Properties properties = new Properties();
    
88. 45
    
89.             properties.load(fis);
    
90. 46
    
91.             String url = properties.getProperty("db.url");
    
92. 47
    
93.             String user = properties.getProperty("db.user");
    
94. 48
    
95.             String password = properties.getProperty("db.password");
    
96. 49
    
97.             // 加载Oracle驱动
    
98. 50
    
99.             Class.forName("oracle.jdbc.driver.OracleDriver").newInstance();
    
100. 51
     
101.             // 得到数据库连接
     
102. 52
     
103.             conn = DriverManager.getConnection(url, user, password);
     
104. 53
     
105. 
     
106. 54
     
107.         } catch (Exception e) {
     
108. 55
     
109.             e.printStackTrace();
     
110. 56
     
111.         } finally {
     
112. 57
     
113.             try {
     
114. 58
     
115.                 fis.close();
     
116. 59
     
117.             } catch (IOException e) {
     
118. 60
     
119.                 e.printStackTrace();
     
120. 61
     
121.             }
     
122. 62
     
123.         }
     
124. 63
     
125. 
     
126. 64
     
127.     }
     
128. 65
     
129. 
     
130. 66
     
131.     // ................................//
     
132. 67
     
133.     public static void execPLSQL() {
     
134. 68
     
135.         CallableStatement cs = null;
     
136. 69
     
137.         try {
     
138. 70
     
139.             String sql = "{call pl_emp(?,?)}";
     
140. 71
     
141.             // 创建CallableStatement
     
142. 72
     
143.             cs = conn.prepareCall(sql);
     
144. 73
     
145.             // 给?赋相应的值
     
146. 74
     
147.             cs.setString(1, "SMITH");
     
148. 75
     
149.             cs.setInt(2, 1800);
     
150. 76
     
151.             // 执行
     
152. 77
     
153.             cs.execute();
     
154. 78
     
155.         } catch (Exception e) {
     
156. 79
     
157.             e.printStackTrace();
     
158. 80
     
159.         } finally {
     
160. 81
     
161.             if (conn != null) {
     
162. 82
     
163.                 try {
     
164. 83
     
165.                     // 关闭连接
     
166. 84
     
167.                     cs.close();
     
168. 85
     
169.                     conn.close();
     
170. 86
     
171.                 } catch (SQLException e1) {
     
172. 87
     
173.                     e1.printStackTrace();
     
174. 88
     
175.                 }
     
176. 89
     
177.             }
     
178. 90
     
179.         }
     
180. 91
     
181.     }
     
182. 92
     
183. }

复制代码

梦境照进现实

谢谢分享