基礎知識回顧第三篇資料庫訪問

前言：本篇主要針對資料庫的操作，在這裡不適用hibernate或者mybatis，用最原始的JDBC進行講解，通過瞭解這些原理以後更容易理解和學習hibernate或mybatis。 1：jdbc的簡單操作首先需要下載jdbc驅動的jar包如果不想下載在C:\Program Files (x86 ...

前言：本篇主要針對資料庫的操作，在這裡不適用hibernate或者mybatis，用最原始的JDBC進行講解，通過瞭解這些原理以後更容易理解和學習hibernate或mybatis。

1：jdbc的簡單操作

首先需要下載jdbc驅動的jar包如果不想下載在C:\Program Files (x86)\MySQL\Connector J 5.1.26位置也可以找到如果是maven項目的話需要在pom上引入下麵的依賴包

1 <dependency>
2             <groupId>mysql</groupId>
3             <artifactId>mysql-connector-java</artifactId>
4             <version>5.1.26</version>
5         </dependency>

View Code

1.1：配置連接資料庫

1 Class.forName("com.mysql.jdbc.Driver");//載入資料庫驅動
2             String url="jdbc:mysql://localhost:3306/blog";//數據連接地址
3             String username="root";//登錄名
4             String password="123456";//密碼
5             connection=DriverManager.getConnection(url, username, password);//獲取資料庫的連接

View Code

1.2：向資料庫發起請求（增刪改查）

1.2.1：statement

statement用於已經建立好資料庫連接的基礎上發送sql語句的對象，不帶參數簡單的sql語句

1.2.2：PreparedStatement

由於在程式中傳遞sql語句必須要經過預編譯，包括分析，優化等，如果重覆執行一條只是參數不同的sql是比較低效的，那麼久可以使用preparedStatement對象對sql語句進行預編譯。（推薦使用）

1.2.3：CallableStatement

這個表示處理存儲過程的對象。

1.3：ResultSet的作用

這個主要是sql執行以後返回的結果集，然後通過next屬性來轉換相關的結果

1.4：executeUpdate()、executeQuery()、execute()三者區別

executeUpdate()主要處理增刪改語句，返回受影響的行數，也可以處理創建或更新資料庫、以及創建或更新表結構

executeQuery()主要是用來查詢的，主要針對select開頭的語句

execute()表示一個特殊的執行，主要針對返回多個結果集、多個更新計數，相對來說用的少些

粘貼一下代碼

  1 public class JDBCHelper {
  2     private  Connection connection;
  3     private  PreparedStatement preparedStatement;
  4     public JDBCHelper(){
  5         try {
  6             Class.forName("com.mysql.jdbc.Driver");
  7             String url="jdbc:mysql://localhost:3306/blog";
  8             String username="root";
  9             String password="123456";
 10             connection=DriverManager.getConnection(url, username, password);
 11         }
 12         catch (ClassNotFoundException e) {
 13             e.printStackTrace();
 14         } catch (SQLException e) {
 15             e.printStackTrace();
 16         }
 17     }
 18     /**
 19      * 創建資料庫
 20      * sql語句
 21      */
 22     public  void createDatabase(String sql)
 23     {
 24         Statement statement=null;
 25         try {
 26             statement=connection.createStatement();//主要用戶不帶參數的簡單sql語句（）執行靜態SQL語句返回它生成結果
 27             statement.executeUpdate(sql);
 28             System.out.println("資料庫創建成功");
 29         } catch (SQLException e) {
 30             e.printStackTrace();
 31         }    
 32         finally {
 33             if (statement!=null) {
 34                 try {
 35                     statement.close();
 36                 } catch (SQLException e) {
 37                 }
 38                 statement=null;
 39             }
 40         }
 41     }
 42     /**
 43      * 增刪改
 44      * @param sql
 45      * @param paramters
 46      * @return
 47      * @throws SQLException
 48      */
 49     public  int update(String sql,Object... paramters) throws SQLException
 50     {
 51         try{
 52             preparedStatement =connection.prepareStatement(sql);
 53             for (int i = 0; i < paramters.length; i++) {
 54                 preparedStatement.setObject(i+1, paramters[i]);
 55             }
 56             return preparedStatement.executeUpdate();
 57         }
 58         catch(SQLException e)
 59         {
 60             e.printStackTrace();
 61         }
 62         finally {
 63             if(preparedStatement!=null)
 64             {
 65                 preparedStatement.close();
 66             }
 67             preparedStatement=null;
 68         }
 69         return 0;
 70     }
 71     /**
 72      * 用與查詢
 73      * @param sql
 74      * @param paramters
 75      * @return
 76      * @throws SQLException
 77      */
 78     public  ResultSet query(String sql,Object... paramters) throws SQLException
 79     {
 80         try{
 81             preparedStatement =connection.prepareStatement(sql);
 82             for (int i = 0; i < paramters.length; i++) {
 83                 preparedStatement.setObject(i+1, paramters[i]);
 84             }
 85             return preparedStatement.executeQuery();
 86         }
 87         catch(SQLException e)
 88         {
 89             e.printStackTrace();
 90         }
 91         finally {
 92             if(preparedStatement!=null)
 93             {
 94                 preparedStatement.close();
 95             }
 96             preparedStatement=null;
 97         }
 98         return null;
 99     }
100 }

JDBCHelper

1.4：資料庫事務

事務的定義：訪問並可能更新資料庫中各種數據項的一個程式執行單元（籠統的將就是一段程式執行所有的sql要麼同時成功，要麼就全部失敗回滾）

我們瞭解事務之前先看三個定義

臟讀：一個事務正在修改某行數據但是並未提交，而另一個事務正好讀取了這行數據，這就是臟讀

不可重覆讀：一個事務讀取了一行數據，在這個事務結束前另一個事務對這條數據進行修改，但是這種修改並沒有提交資料庫中，此時第一個事務再次讀取這條數據時，出現了2次數據不一致這就是不可重覆讀

幻讀：當一個事務讀取滿足條件的數據後，另一個事務卻插入一條數據，當第一個事務再次讀取時，發現多了一條數據。這就是幻讀。

因為上面三種情況存在所以就出現了隔離級別，當然隔離級別越高效率會越低，下麵是4中隔離級別

connection.TRANSACTION_READ_UNCOMMITTED：這種隔離級別最低三種情況都可能發生

connection.TRANSACTION_READ_COMMITTED：這種隔離級別避免臟讀

connection.TRANSACTION_REPEATABLE_READ：這種隔離級別避免臟讀和不可重讀讀

connection.TRANSACTION_SERIALIZABLE：這種隔離級別最高三種都可避免

當瞭解完這種情況以後我們就可開始進行事務處理，在預設的情況下是不執行事務的。

第一步是要開啟事務：connection.setAutoCommit(false);//關閉自動提交功能（預設是true）

然後在設置隔離級別：connection.setTransactionIsolation(connection.TRANSACTION_REPEATABLE_READ);

ok有了上面的我們就可以進行事務了下麵把代碼貼出來，僅供參考

 1 public void addUserAndRole(UserBean userbean,UserRoleBean userRoleBean) throws SQLException
 2     {
 3         connection.setAutoCommit(false);//關閉自動提交功能
 4         connection.setTransactionIsolation(connection.TRANSACTION_REPEATABLE_READ);
 5 
 6 
 7         String userSql="insert into b_user(name,password,level,des,tel)values"+
 8                 "(?,?,?,?,?)";
 9         String roleSql="insert into b_user_role(userId,roleId)values(?,?)";
10         try {
11 
12             preparedStatement =connection.prepareStatement(userSql);
13             preparedStatement.setString(1, userbean.getName());
14             preparedStatement.setString(2, userbean.getPassword());
15             preparedStatement.setInt(3, userbean.getLevel());
16             preparedStatement.setString(4, userbean.getDes());
17             preparedStatement.setString(5, userbean.getTel());
18             preparedStatement.executeUpdate();
19             if (userRoleBean.getRoleId()==0) {
20                 throw new Exception();
21             }
22             preparedStatement=connection.prepareStatement(roleSql);
23             preparedStatement.setInt(1, userRoleBean.getUserId());
24             preparedStatement.setInt(2, userRoleBean.getRoleId());
25             preparedStatement.execute();
26             connection.commit();
27             System.out.println("執行成功");
28         } catch (Exception e) {
29             System.out.println("執行失敗");
30             connection.rollback();
31         }
32     }

Transaction

 1 public static void main(String[] args)
 2     {  
 3         JDBCHelper jdbcHelper=new JDBCHelper();
 4         UserBean userBean=new UserBean();
 5         userBean.setName("張三");
 6         userBean.setPassword("123456");
 7         userBean.setLevel(1);
 8         userBean.setDes("...");
 9         userBean.setTel("123456");
10         
11         UserRoleBean userRoleBean=new UserRoleBean();
12         userRoleBean.setRoleId(0);
13         userRoleBean.setUserId(2);
14         
15         try {
16             jdbcHelper.addUserAndRole(userBean, userRoleBean);
17         } catch (SQLException e) {
18             // TODO Auto-generated catch block
19             e.printStackTrace();
20         }
21     }

main

經過測試發現

資料庫中也不存在相應的數據。

1.5：資料庫連接池

本人推薦看寫的很詳細http://www.cnblogs.com/xdp-gacl/p/4002804.html