點滴

關于spring事務管理以及異常處理的帖子，本論壇爭論頗多，各有各的測試代碼，也各有各的測試結果，
不知道是spring版本的不同還是各測試的例子的不同而導致測試結果出現差異．
本人也很想弄清楚spring是如何對Service進行事務管理的，并且還去看了一下spring框架關于事務管理幾個相關類的源碼，可惜由于本人功力有限，只看懂了皮毛．
既然源代碼看不懂，那么只有運用例子進行測試，雖然笨了點，不過管是白貓還是黑貓，能捉老鼠就是好貓．：）
為引起不必要的爭論，本帖子只針對本案例的測試結果進行小結，并保證此測試代碼在本人的運行環境絕對正確．

開發環境：
ＯＳ：windows 2003 Server
Web Server: jakarta-tomcat-5.0.28
DataBase Server: MS SQL Server 2000 (打了ＳＰ３補丁)
IDE:  Eclipse 3.2.0+MyEclipse 5.0GA

測試案例系統結構：
web層<---->Service層<---->DAO層

web層使用struts 1.1，DAO使用的spring的JDBC，spring版本1.2

數據庫中有兩張表：
student1和Student2，表結構相同：id,name,address．其中id為主鍵且為自增長型.
student1表中有一條記錄：
Java代碼 
1.    id  name       address 
2.    1   xiaoming    wuhan 
3.     
4.    student2表中記錄為空 


測試情形一：
web層捕獲異常并處理，DAO層不捕獲異常，Service也不捕獲異常．

Service層接口：
Java代碼 
1.    public interface StudentManagerService { 
2.       
3.        public void  bus_method(); 
4.    } 


DAO層接口
Java代碼 
1.    public interface StudentDAO { 
2.       
3.        public void  deleteStudent1(); 
4.        public void  insertStudent2(); 
5.    } 


StudentDAO接口的實現：
Java代碼 
1.    public class StudentDAOImp extends JdbcDaoSupport implements StudentDAO{ 
2.         //刪除student1表中的id=1的記錄 
3.         public void  deleteStudent1(){ 
4.    　　　　　JdbcTemplate jt=this.getJdbcTemplate(); 
5.    　　　　　jt.update("delete from student1 where id=1");      
6.    　　　} 
7.          
8.         //將student1表中刪除的記錄插入到student2中,但是此方法實現有錯，因為 
9.    　　　//id字段設置為自增長的，所以在插入記錄時我們不能指定值 
10.        　 public void  insertStudent2(){ 
11.    　　　　　　　JdbcTemplate jt=this.getJdbcTemplate(); 
12.                String arg[]=new String[3]; 
13.           arg[0]="1"; 
14.                arg[1]="xiaoming"; 
15.           arg[2]="wuhan"; 
16.                jt.update("insert student2(id,name,address) values(?,?,?)",arg); 
17.         } 
18.     
19.    }  


StudentManagerService 接口的實現：
Java代碼 
1.    public class StudentManagerServiceImp implements StudentManagerService{ 
2.      private StudentDAO  stdDAO; 
3.      
4.      public void setStdDAO(StudentDAO   stdDAO){ 
5.         this.stdDAO=stdDAO; 
6.      } 
7.        
8.      //此方法為事務型的：刪除student1中的記錄成功且插入student2的記錄也成功， 
9.    　//如果insertStudent2()方法執行失敗，那么deleteStudent1()方法也應該會失敗 
10.      public void  bus_method(){ 
11.        this.stdDAO.deleteStudent1(); 
12.        this.stdDAO.insertStudent2(); 
13.      } 
14.       
15.    }  



web層:
三個jsp,一個action:
index.jsp ==>首頁面．上面僅僅有一個超鏈接<a herf="test.do">執行</a>
chenggong.jsp ==>Service執行成功后轉向的JSP頁面
shibai.jsp　====>Service執行失敗后轉向的JSP頁面

action實現：
Java代碼 
1.    public class StudentManagerAction  extends  Action{ 
2.     
3.         public ActionForward execute(ActionMapping mapping, ActionForm form, 
4.        HttpServletRequest request, HttpServletResponse response) { 
5.             try{ 
6.                 WebApplicationContext appContext=WebApplicationContextUtils.  
7.                      getWebApplicationContext(this.getServlet().getServletContext()); 
8.            StudentManagerService stdm=(StudentManagerService)appContext. 
9.                                            getBean("stdServiceManager"); 
10.                stdm.bus_method(); 
11.                return mapping.findForward("chenggong"); 
12.         } 
13.         catch(DataAccessException e){ 
14.            System.err.println("action execute service exception!"); 
15.            return mapping.findForward("shibai"); 
16.          } 
17.     
18.        } 
19.    } 



配置文件：

web.xml
Java代碼 
1.    <?xml version="1.0" encoding="UTF-8"?> 
2.    <web-app xmlns="http://java.sun.com/xml/ns/j2ee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" version="2.4" xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee   http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd"> 
3.      <context-param> 
4.        <param-name>log4jConfigLocation</param-name> 
5.        <param-value>/WEB-INF/log4j.properties</param-value> 
6.      </context-param> 
7.      <context-param> 
8.        <param-name>contextConfigLocation</param-name> 
9.        <param-value>/WEB-INF/applicationContext.xml</param-value> 
10.      </context-param> 
11.      <listener> 
12.        <listener-class>org.springframework.web.util.Log4jConfigListener</listener-class> 
13.      </listener> 
14.      <listener> 
15.        <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class> 
16.      </listener> 
17.      <servlet> 
18.        <servlet-name>action</servlet-name> 
19.        <servlet-class>org.apache.struts.action.ActionServlet</servlet-class> 
20.        <init-param> 
21.          <param-name>config</param-name> 
22.          <param-value>/WEB-INF/struts-config.xml</param-value> 
23.        </init-param> 
24.        <init-param> 
25.          <param-name>debug</param-name> 
26.          <param-value>3</param-value> 
27.        </init-param> 
28.        <init-param> 
29.          <param-name>detail</param-name> 
30.          <param-value>3</param-value> 
31.        </init-param> 
32.        <load-on-startup>0</load-on-startup> 
33.      </servlet> 
34.      <servlet-mapping> 
35.        <servlet-name>action</servlet-name> 
36.        <url-pattern>*.do</url-pattern> 
37.      </servlet-mapping> 
38.    </web-app> 


sturts-config.xml
Java代碼 
1.    <struts-config> 
2.      <action-mappings > 
3.        <action  input="/index.jsp"  path="/test"  type="test.StudentManagerAction   > 
4.          <forward name="chenggong" path="/chenggong.jsp" /> 
5.          <forward name="shibai" path="/shibai.jsp" /> 
6.        </action> 
7.      </action-mappings> 
8.      <message-resources parameter="test.ApplicationResources" /> 
9.    </struts-config> 



applicationContext.xml
Java代碼 
1.    <?xml version="1.0" encoding="UTF-8"?> 
2.    <!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd"> 
3.    <beans> 
4.        <bean id="dataSource" 
5.          class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close" > 
6.          <property name="driverClassName" value="com.microsoft.jdbc.sqlserver.SQLServerDriver"></property> 
7.          <property name="url" value="jdbc:microsoft:sqlserver://127.0.0.1:1433;databasename=test"></property> 
8.           <property name="username" value="sa"></property> 
9.           <property name="password" value="sa"></property> 
10.        </bean> 
11.         
12.         <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> 
13.            <property name="dataSource" ref="dataSource"/> 
14.         </bean> 
15.             
16.        <bean id="baseTxProxy" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean"  lazy-init="true"> 
17.            <property name="transactionManager"> 
18.            <ref bean="transactionManager" /> 
19.             </property> 
20.             <property name="transactionAttributes"> 
21.             <props> 
22.                 <prop key="*">PROPAGATION_REQUIRED</prop> 
23.            </props> 
24.             </property> 
25.        </bean> 
26.     
27.        <bean id="stdServiceManager"  parent="baseTxProxy" > 
28.            <property name="target"> 
29.                 <bean class="test.StudentManagerServiceImp">     
30.                           <property name="stdDAO"> 
31.    　　　　　　　　　             <ref bean="stdDAO"/> 
32.                           </property>     
33.                      </bean>  
34.            </property>  
35.        </bean> 
36.     
37.        <bean id="stdDAO" class="test.StudentDAOImp"> 
38.           <property name="dataSource" ref="dataSource"/> 
39.        </bean> 
40.    </beans> 


運行程序：啟動服務器，并部署．進入index.jsp頁面，點擊"執行"超鏈接"---->頁面跳向shibai.jsp
查看控制臺：打印有：action execute service exception!
查看數據庫：　student1表中的[1 xiaoming  wuhan] 記錄仍然存在，student2表仍然為空．
小結：如果DAO層和Service不捕獲異常而在web層捕獲異常，web成功捕獲異常，spring事務管理成功！


測試情形二：
web層捕獲異常并處理，Service捕獲異常并處理，DAO層不捕獲異常．

修改StudentManagerServiceImp類
Java代碼 
1.    public class StudentManagerServiceImp implements StudentManagerService{ 
2.      private StudentDAO  stdDAO; 
3.      
4.      public void setStdDAO(StudentDAO   stdDAO){ 
5.         this.stdDAO=stdDAO; 
6.      } 
7.        
8.      //此方法為事務型的，刪除student1中的記錄成功且插入student2的記錄也成功 
9.    　//如果insertStudent2()方法執行失敗，那么deleteStudent1()也應該會失敗 
10.      public void  bus_method(){ 
11.       try{ 
12.          this.stdDAO.deleteStudent1(); 
13.          this.stdDAO.insertStudent2(); 
14.       } 
15.       catch(DataAccessException de) 
16.           System.err.println("service execute exception!"); 
17.        } 
18.      } 
19.       
20.    } 


運行程序：啟動服務器，并部署．進入index.jsp頁面，點擊"執行"超鏈接"---->頁面跳向chenggong.jsp
查看控制臺：打印有：service execute exception!
查看數據庫：　student1表中的[1  xiaoming  wuhan] 記錄不存在，student2表仍然為空．
小結：如果Service捕獲異常并處理而不向外拋出，web層捕獲不到異常，spring事務管理失敗！


測試情形(還原表中的數據)三：
web層捕獲異常，Service捕獲異常，DAO層也捕獲異常．

修改StudentDAOImp類代碼
Java代碼 
1.    public class StudentDAOImp extends JdbcDaoSupport implements StudentDAO{ 
2.         //刪除student1表中的id=1的記錄 
3.         public void  deleteStudent1(){ 
4.            try{ 
5.    　　　　　JdbcTemplate jt=this.getJdbcTemplate(); 
6.    　　　　　jt.update("delete from student1 where id=1"); 
7.           } 
8.           catch(DataAccessException e){ 
9.             System.err.println("dao deleteStudent1　execute exception!"); 
10.           }      
11.    　　　} 
12.          
13.         //將student1表中刪除的記錄插入到student2中,但是此方法實現有錯，因為 
14.    　　　//id字段設置為自增長的，所以在插入記錄時我們不能指定值 
15.        　 public void  insertStudent2(){ 
16.              try{ 
17.    　　　　　　　JdbcTemplate jt=this.getJdbcTemplate(); 
18.                String arg[]=new String[3]; 
19.           arg[0]="1"; 
20.                arg[1]="xiaoming"; 
21.           arg[2]="wuhan"; 
22.                jt.update("insert student2(id,name,address) values(?,?,?)",arg); 
23.             } 
24.             catch(DataAccessException  e){ 
25.                System.err.println("dao insertStudent2  execute exception!"); 
26.     
27.             } 
28.         } 
29.     
30.    }  


運行程序：啟動服務器，并部署．進入index.jsp頁面，點擊"執行"超鏈接"---->頁面跳向chenggong.jsp
查看控制臺：打印有：dao insertStudent2  execute exception!
查看數據庫：　student1表中的 1,xiaoming,wuhan 記錄不存在，student2表仍然為空．
小結如果DAO的每一個方法自己捕獲異常并處理而不向外拋出，Service層捕獲不到異常，Web層同樣捕獲不到異常，spring事務管理失敗！


測試情形四：

還原數據庫中的數據
還原StudentDAOImp類中的方法為測試情形一中的實現
web層捕獲異常Service拋出的自定義異常StudentManagerException
Service捕獲DataAccessException并拋出StudentManagerException，
StudentManagerException為DataAccessException的子類
DAO層不捕獲異常

修改StudentManagerServiceImp類的實現：
Java代碼 
1.    public class StudentManagerServiceImp implements StudentManagerService{ 
2.      private StudentDAO  stdDAO; 
3.      
4.      public void setStdDAO(StudentDAO   stdDAO){ 
5.         this.stdDAO=stdDAO; 
6.      } 
7.        
8.      //此方法為事務型的，刪除student1中的記錄成功且插入student2的記錄也成功 
9.    　//如果insertStudent2()方法執行失敗，那么deleteStudent1()也應該會失敗 
10.      public void  bus_method() throws StudentManagerException{ 
11.       try{ 
12.          this.stdDAO.deleteStudent1(); 
13.          this.stdDAO.insertStudent2(); 
14.       } 
15.       catch(DataAccessException de) 
16.           System.err.println("service execute exception!"); 
17.    　　　　　throw new StudentManagerException();//StudentManagerException類繼承DataAcce　　　　　　　　　　　　　　　　　　　　　　　　　　//ssException異常 
18.        } 
19.      } 
20.    } 



修改StudentManagerAction 
Java代碼 
1.    public class StudentManagerAction  extends  Action{ 
2.     
3.         public ActionForward execute(ActionMapping mapping, ActionForm form, 
4.        HttpServletRequest request, HttpServletResponse response) { 
5.             try{ 
6.                 WebApplicationContext appContext=WebApplicationContextUtils.  
7.                      getWebApplicationContext(this.getServlet().getServletContext()); 
8.            StudentManagerService stdm=(StudentManagerService)appContext. 
9.                                            getBean("stdServiceManager"); 
10.                stdm.bus_method(); 
11.                return mapping.findForward("chenggong"); 
12.         } 
13.         catch(StudentManagerException　e){ 
14.            System.err.println("action execute service exception!"); 
15.            return mapping.findForward("shibai"); 
16.          } 
17.     
18.        } 
19.    } 

運行程序：啟動服務器，并部署．進入index.jsp頁面，點擊"執行"超鏈接"---->頁面跳向shibai.jsp
查看控制臺：打印有：service execute exception!
action execute service exception!
查看數據庫：　student1表中的 [1,xiaoming,wuhan] 記錄仍然存在，student2表仍然為空．
小結如果DAO的每一個方法不捕獲異常,Service層捕獲DataAccessException異常并拋出自己定義異常(自定義異常為DataAccessException的子類)，Web層可以捕獲到異常，spring事務管理成功！



結合源碼總結：
1.spring在進行聲明時事務管理時，通過捕獲Service層方法的DataAccessException來提交和回滾事務的，而Service層方法的DataAccessException又是來自調用DAO層方法所產生的異常．

2.我們一般在寫DAO層代碼時，如果繼承JdbcDaoSupport 類，并使用此類所實現的JdbcTemplate來執行數據庫操作，此類會自動把低層的SQLException轉化成 DataAccessException以及DataAccessException
的子類．

3.一般在Service層我們可以自己捕獲DAO方法所產成的DataAccessException，然后再拋出一個業務方法有意義的異常 (ps:此異常最好繼承DataAccessException)，然后在Web層捕獲，這樣我們就可以手動編碼的靈活實現通過業務方法執行的成功和失敗 來向用戶轉發不同的頁面．

用Java編程語言和JDBC開發的程序是可以跨平臺運行的,并且是不受供應商限制的.

4.1 JDBC的設計

JDBC由兩層組成,上面一層是JDBC API,負責與JDBC管理器驅動程序API進行通信,將各個不同的SQL語句發送給它;該管理器(對程序員是透明的)再與實際連接到數據庫的各個第三方驅動程序進行通信,并且返回查詢的信息,或者執行由查詢規定的操作.

JDBC驅動程序分為以下幾種類型:

類型1驅動程序

負責將JDBC轉換為ODBC,并且使用一個ODBC驅動程序與數據庫進行通信

類型2驅動程序

部分使用Java編程語言編寫的和部分使用本機代碼編寫的驅動程序,用于與數據庫的客戶機API進行通信

類型3驅動程序

純粹的Java客戶程序庫,它使用跨數據庫協議,將數據庫訪問請求傳輸給服務器組件,然后該服務器組件將訪問請求轉換成特定的數據庫協議

類型4驅動程序

純粹的Java庫,用于JDBC訪問請求直接轉換成特定數據庫協議

4.2 結構化查詢語言

JDBC是個到SQL(結構化查詢語言)的接口,而SQL實際上是與所有最新型的關系數據庫之間的接口.

4.3 安裝JDBC

建議最好不要使用Java2 SDK配備的JDBC/ODBC橋接器驅動程序,更加反對將該驅動程序用于Access這樣的桌面數據庫.

4.4 JDBC編程的基本概念

1. 數據庫URL

語法: jdbc:subprotocol name:other stuff

其中subprotocol特定驅動程序, other stuff參數的格式要根據它使用的子協議而定.

2. 建立連接

Class.forName(驅動程序類); 注冊驅動程序

String url = …;

String username = …;

String password = …;

Connetion conn = DriverManager.getConnection(url, username, password);

讀取屬性文件建立連接

Properties props = new Properties();

FileInputStream in = new FileInputStream(“database.properties”);

props.load(in);

in.close();

String drivers = props.getProperty(“jdbc.drivers”);

String url = props.getProperty(“jdbc.drivers”);

String username = props.getProperty(“jdbc.username”);

String password = props.getProperty(“jdbc.password”);

Connetion conn = DriverManager.getConnection(url, username, password);

3. 執行SQL命令

Statement stat = conn.createStatement();

String sql = …;

ResultSet rs = stat.executeQuery(sql);/stat.executeUpdate(sql);

while(rs.next()){

…

}

4. 高級SQL類型

Blob b=resultSet.getBlob(1);
InputStream bin=b.getBinaryStryeam();
Clob c=resultSet.getClob(2);
Reader cReader=c.getCharacterStream();

寫入:

FileInputStream fis=new FileInputStream(f,Connection conn);
byte[] buffer=new byte[1024];
data=null;
int sept=0;int len=0;

while((sept=fis.read(buffer))!=-1){
if(data==null){
len=sept;
data=buffer;
}else{
byte[] temp;
int tempLength;
tempLength=len+sept;
temp=new byte[tempLength];
data=temp;
len=tempLength;
}
if(len!=data.length()){
byte temp=new byte[len];
data=temp;
}
}
String sql="insert into fileData (filename,blobData) value(?,?)";
PreparedStatement ps=conn.prepareStatement(sql);
ps.setString(1,f.getName());
ps.setObject(2,data);
ps.executeUpdate();

讀出:

try {

Clob c=resultSet.getClob(2);

Reader reader=c.getCharacterStream():

if (reader == null) {

return null;

}

StringBuffer sb = new StringBuffer();

char[] charbuf = new char[4096];

for (int i = reader.read(charbuf); i > 0; i = reader.read(charbuf)) {
sb.append(charbuf, 0, i);

}

return sb.toString();

} catch (Exception e) {

return "";

}

4.5 執行查詢操作

采用宿主變量方式:

String userId = 1;

String sql = “select * form user where user_id=?”;

PreparedStatement pStat = conn.prepareStatement(sql);

pStat.setString(1,userId);

ResultSet rs = pStat.executeQuery();

4.6 可滾動的和可更新的結果集

1. 可滾動的結果集

Statement stat = conn.createStatement(type,concurrency);

或

PreparedStatement stat = conn.prepareStatement(command,type, concurrency);

其中

Type包括:

ResultSet.TYPE_FORWARD_ONLY 不能滾動

ResultSet.TYPE_SCROLL_INSENSITIVE 可以滾動,但變化不敏感

ResultSet.TYPE_SCROLL_SENSITIVE 可以滾動,但變化敏感

Concurrency包括:

ResultSet.CONCUR_READ_ONLY 不能更新

ResultSet.CONCUR_UPDATABLE 可以更新

常用方法:

rs.previous() 滾動結果集

rs.relative(n) 將光標向后或向前移動n行

rs.absolute(n) 將光標設置到某個特定的行號上

rs.getRow() 獲得當前的行號

2. 可更新的結果集

常用方法:

rs.getConcurrency() 查看結果集是否可更新

rs.updateXxx() 只能用于修改行的值,不能修改數據庫

rs.updateRow() 將當前行中所有信息更新發送給數據庫

rs.cancelRowUpdates() 撤銷對當前行的更新

rs.moveToInsertRow() 將光標移到一個特定的位置

rs.insertRow() 將該新行傳遞給數據庫

rs.moveToCurrentRow() 將光標移回之前位置

rs.deleteRow() 刪除光標下的行

例子:

rs. moveToInsertRow();

rs.updateString(“Title”,title);

rs.updateString(“Isbn”,isbn);

rs.insertRow();

rs.moveToCurrentRow();

4.7 元數據

元數據是在SQL中用于描述數據庫或者它的各個部分之一的數據;分為關于數據庫的元數據和關于結構集合的元數據.

DatabaseMetaData conn.getMetaData() 用于提供關于數據庫的元數據

ResultSetMetaData rs.getMetaData() 用于提供關于結構集合的元數據

4.8 事務

如果將各個更新命令組合成一個事務,可以實現數據庫數據的完整性;在提交事務時,如果在它中間某個位置上運行失敗,它可以執行回退操作,并且該數據庫將自動撤銷提交事務以來進行的所有更新及所產生的影響.

在默認情況下,數據庫連接處于自動提交方式,并且每個SQL命令一旦被執行,便被提交給該數據庫.一旦命令被提交,就無法進行回退操作.

批量更新: 一序列命令將作為一個批量來集中和提交,命令不包括Select查詢.

String sql = …;

stat.addBatch(sql);

while(…){

sql = …

stat.addBatch(sql);

}

stat.executeBatch();

4.9    高級連接管理

在企業級環境中部署JDBC應用程序時,數據庫連接的管理納入了JNDI(Java命令與目錄接口)之中.一個目錄負責管理整個企業中的數據源的位置.使用目錄后,就可以對用戶名、口令、數據庫名字和JDBC URL實施集中管理.

Context jndi = …;

DataSource source = (DataSource)jndi.lookup(“jdbc/corejava”);

Connection conn = source.getConnection(username,password);