跳过hibernate获取DBConnection工具类，通过JDBC API访问数据库

在系统中利用hibernate的API我们可以做很多事情，数据的读，存，删等，都比较的方便，但是如批量添加、更新、删除操作，量大的话会严重影响系统的性能，有两个算是比较好的办法解决。

1、直接通过JDBC API来执行该SQL语句

2、通过存储过程

在这两个操作中首先都要得到Connection,当然这也可以通过

 

1. tx = session.beginTransaction();
2. Connection con=session.connection();

来得到，在我现在使用的一个系统中是hibernate与spring的整合。通过一个.properties文件的配置来得到与数据库的连接。文件如下：

 

1. hibernate.connection.driver_class=oracle.jdbc.driver.OracleDriver
2. hibernate.connection.url=jdbc:oracle:thin:@192.168.2.11:1521:oracle
3. hibernate.connection.username=db_test
4. hibernate.connection.password=test
5. hibernate.show_sql=true

在此我们也是要利用这个属性文件来写一个DBConnection类来获取JDBC的连接。DBConnection类如下：

1. package com.***.***.util;
3. import java.io.FileInputStream;
4. import java.io.FileNotFoundException;
5. import java.io.IOException;
6. import java.net.URL;
7. import java.sql.Connection;
8. import java.sql.DriverManager;
9. import java.sql.SQLException;
10. import java.util.Properties;
12. public class DBConnection {
13.     
14.      public  Connection getConnection() {
15.           
16.           Properties properties = new Properties(); 
17.           URL in = this.getClass().getClassLoader().getResource("jdbc.properties");
18.         try {
19.             properties.load(new FileInputStream(in.getFile()));
20.         } catch (FileNotFoundException e1) {
21.             // TODO Auto-generated catch block
22.             e1.printStackTrace();
23.         } catch (IOException e1) {
24.             // TODO Auto-generated catch block
25.             e1.printStackTrace();
26.         } 
27.          String driver =properties.getProperty("hibernate.connection.driver_class");
28.          String  url=properties.getProperty("hibernate.connection.url");
29.          String user=properties.getProperty("hibernate.connection.username");
30.          String password=properties.getProperty("hibernate.connection.password");
31.         Connection con;
32.         try{
33.         
34.         Class.forName(driver);
35.         con=DriverManager.getConnection(url,user,password);
36.         return con;
38.         }catch (ClassNotFoundException e){
39.         System.out.println(e.getMessage());
40.         }catch (SQLException e){
41.         System.out.println(e.getMessage());
42.         }
43.         return null;
44.       }
45. }

要想获取Connection,只需要

1. DBConnection db = new DBConnection();
2. Connection conn = db.getConnection();

接下来的操作就是普通的JDBC操作了。以下是一段参考代码：

1. //serviceImpl中的一个方法
2. public boolean addForm(String code,String name,String content)throws MailException{
3.         DBConnection db = new DBConnection();
4.         Connection conn = db.getConnection();
5.         try {
6.             conn.setAutoCommit(false);
7.             String queryStr = "insert into form(code,name,content)values(?,?,?)";
8.             PreparedStatement pstm = conn.prepareStatement(queryStr);
9.             pstm.setString(1,code);
10.             pstm.setString(2,name);
11.             Reader clobReader = new StringReader(content); // 将 text转成流形式
12.             pstm.setCharacterStream(3, clobReader, content.length());// 替换sql语句中的           
13.             pstm.executeUpdate();
14.             conn.commit();
15.         } catch (SQLException e) {
16.             // TODO 自动生成 catch 块
17.             e.printStackTrace();
18.             return false;
19.         }finally{
20.             if(conn!=null){
21.                 try {
22.                     conn.close();
23.                 } catch (SQLException e) {
24.                     // TODO 自动生成 catch 块
25.                     e.printStackTrace();
26.                 }
27.             }
28.         }
29.         return true;
30.         
31.     }