JDBC工具类（DBUtils.java & SqlHelp.java & dbinfo.properties）

Delver_Si

1. package com.zjw.jdbc;
   
2. 
   
3. import java.io.InputStream;
   
4. import java.sql.Connection;
   
5. import java.sql.DriverManager;
   
6. import java.sql.PreparedStatement;
   
7. import java.sql.ResultSet;
   
8. import java.sql.SQLException;
   
9. import java.util.Properties;
   
10. 
    
11. public class DBUtils {
    
12.         static Connection ct = null;
    
13.         
    
14.         // 连接数据库参数
    
15.         private static String url = "";
    
16.         private static String username = "";
    
17.         private static String driver = "";
    
18.         private static String password = "";
    
19. 
    
20.         // 读配置文件
    
21.         private static Properties pp = null;
    
22.         private static InputStream fis = null;
    
23. 
    
24.         static {
    
25.                 // 加载驱动，只需要一次
    
26.                 try {
    
27.                         pp = new Properties();
    
28.                         //fis = new FileInputStream("src/dbinfo.properties");
    
29.                         //在java web中，读取文件要使用类加载器，资源目录默认src
    
30.                         fis=SqlHelp.class.getClassLoader().getResourceAsStream("com/zjw/jdbc/dbinfo.properties");
    
31.                         pp.load(fis);
    
32.                         //从属性文件中读取信息
    
33.                         url = pp.getProperty("url");
    
34.                         username = pp.getProperty("username");
    
35.                         driver = pp.getProperty("driver");
    
36.                         password = pp.getProperty("password");
    
37.                         Class.forName(driver);
    
38.                 } catch (Exception e) {
    
39.                         e.printStackTrace();
    
40.                         System.exit(-1);
    
41.                 }
    
42.         }
    
43. 
    
44.         // 得到连接
    
45.         public static Connection getConnection() {
    
46.                
    
47.                         try {
    
48.                                 ct= DriverManager.getConnection(url, username, password);
    
49.                         } catch (SQLException e) {
    
50.                                 // TODO Auto-generated catch block
    
51.                                 e.printStackTrace();
    
52.                         }
    
53.                         return ct;
    
54.                
    
55.         }
    
56.         
    
57.         //关闭连接
    
58.         public static void closeConn(ResultSet rs,PreparedStatement ps,Connection ct) {
    
59.                
    
60.                         if(rs!= null)
    
61.                                 try {
    
62.                                         rs.close();
    
63.                                 } catch (SQLException e) {
    
64.                                         // TODO Auto-generated catch block
    
65.                                         e.printStackTrace();
    
66.                                 }
    
67.             if(ps!= null)
    
68.                                 try {
    
69.                                         ps.close();
    
70.                                 } catch (SQLException e) {
    
71.                                         // TODO Auto-generated catch block
    
72.                                         e.printStackTrace();
    
73.                                 }
    
74.             if(ct != null)
    
75.                                 try {
    
76.                                         ct.close();
    
77.                                 } catch (SQLException e) {
    
78.                                         // TODO Auto-generated catch block
    
79.                                         e.printStackTrace();
    
80.                                 }
    
81.                         
    
82.         }
    
83. 
    
84. }
    
85. 
    
86. 
    
87. 
    
88. /*
    
89. * 主要用于对数据库的crud操作
    
90. */
    
91. package com.zjw.jdbc;
    
92. 
    
93. import java.io.*;
    
94. import java.sql.*;
    
95. import java.util.*;
    
96. 
    
97. /**
    
98. * @author Delver_Si
    
99. *
    
100. */
     
101. public class SqlHelp {
     
102.         private Connection ct = null;
     
103.         private PreparedStatement ps = null;
     
104. 
     
105.         private ResultSet rs = null;
     
106. 
     
107.         
     
108.         // 查询方法，得到ArrayList集合
     
109.         public ArrayList<Object[]> executeQuery(String sql,String...paras) {//...可变参数
     
110.                
     
111.                 ArrayList<Object[]> al = new ArrayList<Object[]>();
     
112.                 try {
     
113.                         ct=DBUtils.getConnection();
     
114.                         ps = ct.prepareStatement(sql);
     
115.                         for(int i=0;i<paras.length;i++){
     
116.                                 ps.setString(i+1, paras);
     
117.                         }
     
118.                         rs = ps.executeQuery();
     
119.                         
     
120.                         ResultSetMetaData rsmd=rs.getMetaData();
     
121.                         //返回结果集有多少列
     
122.                         int columNum= rsmd.getColumnCount();
     
123.                         while(rs.next()){
     
124.                                 Object[] objects=new Object[columNum];
     
125.                         for(int i=0;i<objects.length;i++){
     
126.                                 objects=rs.getObject(i+1);
     
127.                         }
     
128.                         al.add(objects);
     
129.                         }
     
130. 
     
131.                 } catch (SQLException e) {
     
132.                         // TODO Auto-generated catch block
     
133.                         e.printStackTrace();
     
134.                 }finally{
     
135.                         
     
136.                         DBUtils.closeConn(rs, ps, ct);
     
137.                 }
     
138.                
     
139.                
     
140.                 return al;
     
141. 
     
142.         }
     
143.         
     
144.         //增删改方法
     
145.         public int executeUpdate(String sql) {
     
146.                 int i=0;
     
147.                 // 获得连接
     
148.                 try {
     
149.                         ct=DBUtils.getConnection();
     
150.                         // 创建一个基于该连接的语句对象
     
151.                         ps = ct.prepareStatement(sql);
     
152.                         // 执行sql语句
     
153.                         i =ps.executeUpdate();
     
154.                         
     
155.                 } catch (SQLException e) {
     
156.                         e.printStackTrace();
     
157.                 } finally {
     
158.                         DBUtils.closeConn(rs, ps, ct);
     
159.                 }
     
160.                 return i;
     
161.         }
     
162. }
     
163. 
     
164. 
     
165. 
     
166. dbinfo.properties.bak（oracle ）
     
167. 
     
168. url=jdbc:oracle:thin:@127.0.0.1:1521:ORCL
     
169. username=scott
     
170. driver=oracle.jdbc.driver.OracleDriver
     
171. password=tiger

复制代码

admin

Java操作Oracle 数据库？

Delver_Si

admin 发表于 2014-11-17 21:57
Java操作Oracle 数据库？

嗯。。。。。。。。。。。。。。。。

admin

Delver_Si 发表于 2014-11-17 22:05
嗯。。。。。。。。。。。。。。。。

额  我们现在只学习过sql server其他数据库暂时没有学

Delver_Si

admin 发表于 2014-11-17 22:06
额  我们现在只学习过sql server其他数据库暂时没有学

我能说老师今天才讲sqlserver的增删改查吗？

admin

Delver_Si 发表于 2014-11-17 22:07
我能说老师今天才讲sqlserver的增删改查吗？

。。。。。我能说我们把sql server都学完了吗？

北城织温22度

楼主看起来好厉害

test

学习Java挺不容易的