廢話不多說，直接上源代碼，最後有使用方法，當然，也可以作為普通公用類使用，只是封裝成JAR更方便使用。

1. package db.util;
3. import java.io.BufferedReader;
4. import java.io.File;
5. import java.io.FileInputStream;
6. import java.io.InputStreamReader;
7. import java.sql.CallableStatement;
8. import java.sql.Connection;
9. import java.sql.DriverManager;
10. import java.sql.PreparedStatement;
11. import java.sql.ResultSet;
12. import java.sql.ResultSetMetaData;
13. import java.sql.SQLException;
14. import java.util.ArrayList;
15. import java.util.HashMap;
16. import java.util.List;
17. import java.util.Map;
19. import org.json.JSONObject;
21. /*
22. * 說明：封裝JDBC數據庫增刪改查、存儲過程
23. * 作者：Jiro.Chen
24. * 時間：2016-12-12 15:13:54
25. * */
27. public class ConnectionUtil {
29. private static String DRIVER = null;
31. private static String URL = null;
33. private static String USERNAME = null;
35. private static String PASSWORD = null;
37. private Connection conn = null;
39. private PreparedStatement pstmt = null;
41. private CallableStatement callableStatement = null;
43. private ResultSet resultSet = null;
45. private void init(){
46. try {
47. Class.forName(DRIVER);
48. } catch (ClassNotFoundException e) {
49. System.out.println("加載驅動錯誤");
50. System.out.println(e.getMessage());
51. }
52. }
54. public ConnectionUtil(String dbParam){
55. String path = getCurrentPath();
56. String filePath = path + "\\db.JSON";
58. String text = null;
59. try{
60. text = this.readFile(new File(filePath));
61. if(text.equals(null) || text.equals("")){
62. filePath = path + "\\db.json";
63. text = this.readFile(new File(filePath));
64. if(text.equals(null) || text.equals("")){
65. System.out.println("找不到指定文件");
66. }
67. }
68. }catch(Exception e){
69. e.printStackTrace();
70. }
72. JSONObject json = new JSONObject(text);
73. JSONObject DB = json.getJSONObject(dbParam);
75. DRIVER = DB.getString("DRIVER");
76. URL = DB.getString("URL");
77. USERNAME = DB.getString("USERNAME");
78. PASSWORD = DB.getString("PASSWORD");
80. this.init();
81. }
83. private String readFile(File file){
84. String text = null;
86. try{
87. if(file.isFile() && file.exists()){
88. InputStreamReader read = new InputStreamReader(new FileInputStream(file),"UTF-8");
89. BufferedReader bufferedReader = new BufferedReader(read);
90. String lineTxt = null;
92. while((lineTxt = bufferedReader.readLine()) != null){
93. text += lineTxt;
94. }
95. read.close();
96. }
97. }catch(Exception e){
98. e.printStackTrace();
99. }
101. return text;
102. }
104. private String getCurrentPath(){
105. String rootPath = null;
107. java.net.URL url = ConnectionUtil.class.getProtectionDomain().getCodeSource().getLocation();
108. String filePath = null;
110. try{
111. filePath = java.net.URLDecoder.decode(url.getPath(), "utf-8");
112. }catch (Exception e) {
113. e.printStackTrace();
114. }
116. if(filePath.endsWith(".jar")){
117. filePath = filePath.substring(0, filePath.lastIndexOf("/") + 1);
118. }
120. java.io.File file = new java.io.File(filePath);
121. rootPath = file.getAbsolutePath();
123. rootPath = rootPath.substring(0, rootPath.lastIndexOf("\\"));
124. rootPath += "\\classes";
126. return rootPath;
127. }
130. public Connection getConnection(){
131. try{
132. conn = DriverManager.getConnection(URL, USERNAME,
133. PASSWORD);
134. }catch (SQLException e){
135. System.out.println(e.getMessage());
136. }
138. return conn;
139. }
141. public int executeUpdate(String sql, Object[] params){
142. int affectedLine = 0;
144. try{
145. conn = this.getConnection();
147. pstmt = conn.prepareStatement(sql);
149. if (params != null){
150. for (int i = 0; i < params.length; i++){
151. pstmt.setObject(i + 1, params[i]);
152. }
153. }
155. affectedLine = pstmt.executeUpdate();
157. }catch (SQLException e){
158. System.out.println(e.getMessage());
159. }finally {
160. closeAll();
161. }
163. return affectedLine;
164. }
166. /**
167. * SQL 查詢將查詢結果直接放入ResultSet中
168. */
169. private ResultSet executeQueryRS(String sql, Object[] params){
170. try{
171. conn = this.getConnection();
173. pstmt = conn.prepareStatement(sql);
175. if (params != null){
176. for (int i = 0; i < params.length; i++){
177. pstmt.setObject(i + 1, params[i]);
178. }
179. }
181. resultSet = pstmt.executeQuery();
183. }catch (SQLException e){
184. System.out.println(e.getMessage());
185. }
187. return resultSet;
188. }
190. /**
191. * 獲取結果集，並將結果放在List中
192. */
193. public List<Object> excuteQuery(String sql, Object[] params){
194. ResultSet rs = executeQueryRS(sql, params);
196. ResultSetMetaData rsmd = null;
198. int columnCount = 0;
199. try{
200. rsmd = rs.getMetaData();
202. columnCount = rsmd.getColumnCount();
203. }catch (SQLException e1) {
204. System.out.println(e1.getMessage());
205. }
207. List<Object> list = new ArrayList<Object>();
209. try{
210. while (rs.next()) {
211. Map<String, Object> map = new HashMap<String, Object>();
212. for (int i = 1; i <= columnCount; i++) {
213. map.put(rsmd.getColumnLabel(i), rs.getObject(i));
214. }
215. list.add(map);
216. }
217. }catch (SQLException e) {
218. System.out.println(e.getMessage());
219. }finally {
220. closeAll();
221. }
223. return list;
224. }
226. /**
227. * 存儲過程帶有一個輸出參數的方法
228. * @param sql 存儲過程語句
229. * @param params 參數數組
230. * @param outParamPos 輸出參數位置
231. * @param SqlType 輸出參數類型
232. * @return 輸出參數的值
233. */
234. public Object excuteQuery(String sql, Object[] params,int outParamPos, int SqlType){
235. Object object = null;
236. conn = this.getConnection();
238. try{
239. callableStatement = conn.prepareCall(sql);
241. if(params != null){
242. for(int i = 0; i < params.length; i++) {
243. callableStatement.setObject(i + 1, params[i]);
244. }
245. }
247. callableStatement.registerOutParameter(outParamPos, SqlType);
249. callableStatement.execute();
251. object = callableStatement.getObject(outParamPos);
253. }catch (SQLException e){
254. System.out.println(e.getMessage());
255. }finally{
256. closeAll();
257. }
259. return object;
260. }
262. private void closeAll(){
263. if (resultSet != null){
264. try {
265. resultSet.close();
266. } catch (SQLException e){
267. System.out.println(e.getMessage());
268. }
269. }
271. if(pstmt != null){
272. try{
273. pstmt.close();
274. } catch (SQLException e){
275. System.out.println(e.getMessage());
276. }
277. }
279. if(callableStatement != null){
280. try{
281. callableStatement.close();
282. }catch (SQLException e) {
283. System.out.println(e.getMessage());
284. }
285. }
287. if(conn != null){
288. try{
289. conn.close();
290. } catch (SQLException e) {
291. System.out.println(e.getMessage());
292. }
293. }
294. }
295. }

使用方法：

在Web工程src目錄下新建db.JSON或者db.json文件

1. {
2. "DB":{
3. "DRIVER" :"com.microsoft.sqlserver.jdbc.SQLServerDriver",
4. "URL" :"jdbc:sqlserver://223.68.143.21:12922;DatabaseName=TwRailway_ECP",
5. "USERNAME":"sa",
6. "PASSWORD":"senao"
7. }
8. }

其中，DB可以有多個

工程導入JAR包之後，通過

1. ConnectionUtil conn = new ConnectionUtil("DB");

配置文件db.JSON可以寫多個數據庫，參數DB指定使用哪種數據庫建立連接

方法介紹：

1.public Connection getConnection()

功能：

JAR中提供了全套的增刪改查的方法，但為了應對某種特殊情況下的需求，方法不能滿足程序員需求時，可以使用此方法建立與數據庫的連接，自行編寫DAO層方法。

參數說明：

無

傳回值：

傳回Connection連接或NULL

2.public int executeUpdate(String sql, Object[] params)

功能：

使用PrepareStatement預處理執行sql，適用於數據新增、修改、刪除等操作。

參數說明：

sql 執行的sql語句

params 對象數組，存儲要新增、修改或刪除的數據。可以為空。

傳回值：

傳回1表示成功

傳回0表示失敗

3.public List<Object> excuteQuery(String sql, Object[] params)

功能:

使用PrepareStatement預處理執行sql，適用於數據查詢。

參數說明:

sql 執行的sql語句

params 對象數組，sql語句中預設的值。可以為空。

傳回值:

帶有Map索引的List類型數據

只是適用於小型項目，減少DAO層編碼量，增強代碼的重用性。可以封裝為公用類使用，也可以作為JAR檔。

註意：此JAR依賴json.jar包。

Java封裝JDBC數據庫增、刪、改、查操作成JAR文件，以供Web工程調用，適用於多種數據庫