hk2000c技術專欄
          
				
          技術源于哲學，哲學來源于生活

關心生活，關注健康，關心他人

          
			          		
		
          
	
          

          

          
	
          
		
          
			
 
BlogJava ::
首頁 ::
新隨筆 ::
聯系 ::
聚合
 ::
管理 ::


			
			
				

          
	
          
		
          
			
			
			
				 
				111 
				隨筆 ::
				1 文章
				::
				28 評論
				::
				0 Trackbacks
			
		
          
	
          

          

			          		
		
          
	
          

          


          


          
	
					

          
	
	
	
          
		
          這是總結以前使用spring調用Oracle存儲過程，并用cursor返回結果集的一個完整實例，希望能對大家有幫助。 
          

          1. 創建表： 
          

          代碼
          

          

          

          

            
    
          1. create table TEST_USERS    
            2. 
    
          2. (    
            3. 
    
          3.   USER_ID  VARCHAR2(10) not null,    
            4. 
    
          4.   NAME     VARCHAR2(10) not null,    
            5. 
    
          5.   PASSWORD VARCHAR2(20) not null    
            6. 
    
          6. )  
            7. 

          

          

          


           
          

          2. 創建存儲過程： 
          

          代碼
          

          

          

          

            
    
          1. create or replace package display_users_package is    
            2. 
    
          2.      type search_results is ref cursor;    
            3. 
    
          3.      procedure display_users_proc(results_out out search_results, userId in test_users.user_id%type);    
            4. 
    
          4. end display_users_package;    
            5. 
    
          5.   
            6. 
    
          6. create or replace package body display_users_package is    
            7. 
    
          7.      procedure display_users_proc(results_out out search_results, userId in test_users.user_id%type)    
            8. 
    
          8.           is    
            9. 
    
          9.           begin    
            10. 
    
          10.           if userId is not null then    
            11. 
    
          11.               open results_out for select * from test_users where user_id like userId || '%';    
            12. 
    
          12.           else    
            13. 
    
          13.               open results_out for  select * from test_users;    
            14. 
    
          14.           end if;    
            15. 
    
          15.       end display_users_proc;    
            16. 
    
          16. end display_users_package;  
            17. 

          

          

          


           
          

          這個results_out是一個游標類型，用來返回查找的結果集。
          

          3.　完整實現代碼： 
          

          代碼
          

          

          

          

            
    
          1. import java.sql.CallableStatement;   
            2. 
    
          2. import java.sql.Connection;   
            3. 
    
          3. import java.sql.ResultSet;   
            4. 
    
          4. import java.sql.SQLException;   
            5. 
    
          5. import java.util.ArrayList;   
            6. 
    
          6. import java.util.HashMap;   
            7. 
    
          7. import java.util.List;   
            8. 
    
          8. import java.util.Map;   
            9. 
    
          9.   
            10. 
    
          10. import javax.sql.DataSource;   
            11. 
    
          11.   
            12. 
    
          12. import oracle.jdbc.OracleTypes;   
            13. 
    
          13.   
            14. 
    
          14. import org.springframework.dao.DataAccessException;   
            15. 
    
          15. import org.springframework.jdbc.core.CallableStatementCallback;   
            16. 
    
          16. import org.springframework.jdbc.core.CallableStatementCreator;   
            17. 
    
          17. import org.springframework.jdbc.core.JdbcTemplate;   
            18. 
    
          18.   
            19. 
    
          19. import com.spring.stored.procedure.util.DataContextUtil;   
            20. 
    
          20.   
            21. 
    
          21. /**  
            22. 
    
          22.  * @author Jane Jiao  
            23. 
    
          23.  *  
            24. 
    
          24.  */  
            25. 
    
          25. public class SpringStoredProce {   
            26. 
    
          26.        
            27. 
    
          27.     public List<Map> execute(String storedProc, String params){   
            28. 
    
          28.         List<Map> resultList = null;   
            29. 
    
          29.         try{   
            30. 
    
          30.             final DataSource ds = DataContextUtil.getInstance().getDataSource();   
            31. 
    
          31.             final JdbcTemplate template = new JdbcTemplate(ds);   
            32. 
    
          32.             resultList = (List<Map>)template.execute(new ProcCallableStatementCreator(storedProc, params),   
            33. 
    
          33.                                                      new ProcCallableStatementCallback());   
            34. 
    
          34.         }catch(DataAccessException e){   
            35. 
    
          35.             throw new RuntimeException("execute method error : DataAccessException " + e.getMessage());   
            36. 
    
          36.         }   
            37. 
    
          37.          return resultList;   
            38. 
    
          38.     }   
            39. 
    
          39.        
            40. 
    
          40.        
            41. 
    
          41.     /**  
            42. 
    
          42.      * Create a callable statement in this connection.  
            43. 
    
          43.      */  
            44. 
    
          44.     private class ProcCallableStatementCreator implements CallableStatementCreator {   
            45. 
    
          45.         private String storedProc;   
            46. 
    
          46.         private String params;   
            47. 
    
          47.            
            48. 
    
          48.        
            49. 
    
          49.         /**  
            50. 
    
          50.          * Constructs a callable statement.  
            51. 
    
          51.          * @param storedProc                  The stored procedure's name.  
            52. 
    
          52.          * @param params                      Input parameters.  
            53. 
    
          53.          * @param outResultCount              count of output result set.  
            54. 
    
          54.          */  
            55. 
    
          55.         public ProcCallableStatementCreator(String storedProc, String params) {   
            56. 
    
          56.             this.params = params;   
            57. 
    
          57.             this.storedProc = storedProc;   
            58. 
    
          58.         }   
            59. 
    
          59.            
            60. 
    
          60.         /**  
            61. 
    
          61.          * Returns a callable statement  
            62. 
    
          62.          * @param conn          Connection to use to create statement  
            63. 
    
          63.          * @return cs           A callable statement  
            64. 
    
          64.          */  
            65. 
    
          65.         public CallableStatement createCallableStatement(Connection conn) {   
            66. 
    
          66.             StringBuffer storedProcName = new StringBuffer("call ");   
            67. 
    
          67.             storedProcName.append(storedProc + "(");   
            68. 
    
          68.             //set output parameters   
            69. 
    
          69.             storedProcName.append("?");   
            70. 
    
          70.             storedProcName.append(", ");   
            71. 
    
          71.                
            72. 
    
          72.             //set input parameters   
            73. 
    
          73.             storedProcName.append("?");   
            74. 
    
          74.             storedProcName.append(")");   
            75. 
    
          75.   
            76. 
    
          76.             CallableStatement cs = null;   
            77. 
    
          77.             try {   
            78. 
    
          78.                 // set the first parameter is OracleTyep.CURSOR for oracel stored procedure   
            79. 
    
          79.                 cs = conn.prepareCall(storedProcName.toString());   
            80. 
    
          80.                 cs.registerOutParameter (1, OracleTypes.CURSOR);   
            81. 
    
          81.                // set the sencond paramter   
            82. 
    
          82.                 cs.setObject(2, params);   
            83. 
    
          83.             } catch (SQLException e) {   
            84. 
    
          84.                 throw new RuntimeException("createCallableStatement method Error : SQLException " + e.getMessage());   
            85. 
    
          85.             }   
            86. 
    
          86.             return cs;   
            87. 
    
          87.         }   
            88. 
    
          88.            
            89. 
    
          89.     }   
            90. 
    
          90.        
            91. 
    
          91.     /**  
            92. 
    
          92.      *   
            93. 
    
          93.      * The ProcCallableStatementCallback return a result object,   
            94. 
    
          94.      * for example a collection of domain objects.  
            95. 
    
          95.      *  
            96. 
    
          96.      */  
            97. 
    
          97.     private class ProcCallableStatementCallback implements CallableStatementCallback {   
            98. 
    
          98.            
            99. 
    
          99.         /**  
            100. 
    
          100.          * Constructs a ProcCallableStatementCallback.  
            101. 
    
          101.          */  
            102. 
    
          102.         public ProcCallableStatementCallback() {   
            103. 
    
          103.         }   
            104. 
    
          104.   
            105. 
    
          105.         /**  
            106. 
    
          106.          * Returns a List(Map) collection.  
            107. 
    
          107.          * @param cs                       object that can create a CallableStatement given a Connection  
            108. 
    
          108.          * @return resultsList             a result object returned by the action, or null  
            109. 
    
          109.          */  
            110. 
    
          110.         public Object doInCallableStatement(CallableStatement cs){   
            111. 
    
          111.             List<Map> resultsMap =  new ArrayList<Map>();   
            112. 
    
          112.             try {   
            113. 
    
          113.                 cs.execute();    
            114. 
    
          114.                 ResultSet rs = (ResultSet) cs.getObject(1);   
            115. 
    
          115.                 while (rs.next()) {   
            116. 
    
          116.                     Map<String, String> rowMap = new HashMap<String, String>();   
            117. 
    
          117.                     rowMap.put("userId", rs.getString("USER_ID"));   
            118. 
    
          118.                     rowMap.put("name", rs.getString("NAME"));   
            119. 
    
          119.                     rowMap.put("password", rs.getString("PASSWORD"));   
            120. 
    
          120.                     resultsMap.add(rowMap);   
            121. 
    
          121.                 }      
            122. 
    
          122.                 rs.close();   
            123. 
    
          123.             }catch(SQLException e) {   
            124. 
    
          124.                 throw new RuntimeException("doInCallableStatement method error : SQLException " + e.getMessage());   
            125. 
    
          125.             }   
            126. 
    
          126.             return resultsMap;   
            127. 
    
          127.        }   
            128. 
    
          128.     }   
            129. 
    
          129. }   
            130. 

          

          

          


           
          

          4.　測試代碼，在這里使用了Junit4測試： 
          

          代碼
          

          

          

          

            
    
          1. import static org.junit.Assert.assertNotNull;    
            2. 
    
          2. import static org.junit.Assert.assertTrue;    
            3. 
    
          3.   
            4. 
    
          4. import java.util.List;    
            5. 
    
          5. import java.util.Map;    
            6. 
    
          6.   
            7. 
    
          7. import org.junit.After;    
            8. 
    
          8. import org.junit.Before;    
            9. 
    
          9. import org.junit.Test;    
            10. 
    
          10.   
            11. 
    
          11. /**   
            12. 
    
          12.  * @author Jane Jiao   
            13. 
    
          13.  *   
            14. 
    
          14.  */    
            15. 
    
          15. public class SpringStoredProceTest {    
            16. 
    
          16.        
            17. 
    
          17.    private SpringStoredProce springStoredProce;    
            18. 
    
          18.   
            19. 
    
          19.    /**   
            20. 
    
          20.     * @throws java.lang.Exception   
            21. 
    
          21.     */    
            22. 
    
          22.    @Before    
            23. 
    
          23.    public void setUp() throws Exception {    
            24. 
    
          24.       springStoredProce = new SpringStoredProce();    
            25. 
    
          25.    }    
            26. 
    
          26.   
            27. 
    
          27.    /**   
            28. 
    
          28.     * @throws java.lang.Exception   
            29. 
    
          29.     */    
            30. 
    
          30.    @After    
            31. 
    
          31.    public void tearDown() throws Exception {    
            32. 
    
          32.       springStoredProce = null;    
            33. 
    
          33.    }    
            34. 
    
          34.   
            35. 
    
          35.    /**   
            36. 
    
          36.     * Test method for {@link com.hactl.listingframework.dao.SpringStoredProce#execute(java.lang.String, java.lang.String)}.   
            37. 
    
          37.     */    
            38. 
    
          38.    @Test    
            39. 
    
          39.    public void testExecute() {    
            40. 
    
          40.       final String storedProcName = "display_users_package.display_users_proc";    
            41. 
    
          41.       final String param = "test";    
            42. 
    
          42.       List<Map> resultList = springStoredProce.execute(storedProcName, param);    
            43. 
    
          43.       assertNotNull(resultList);    
            44. 
    
          44.       assertTrue(resultList.size() > 0);    
            45. 
    
          45.       for (int i = 0; i < resultList.size(); i++) {    
            46. 
    
          46.          Map rowMap = resultList.get(i);    
            47. 
    
          47.          final String userId = rowMap.get("userId").toString();    
            48. 
    
          48.          final String name = rowMap.get("name").toString();    
            49. 
    
          49.          final String password = rowMap.get("password").toString();    
            50. 
    
          50.          System.out.println("USER_ID=" + userId + "\t name=" + name + "\t password=" + password);    
            51. 
    
          51.       }    
            52. 
    
          52.           
            53. 
    
          53.    }    
            54. 
    
          54. }  
            55. 

          

          

          


           
          

          5. 測試的輸出結果：

          代碼
          

          

          

            
    
          1. USER_ID=test1    name=aa    password=aa    
            2. 
    
          2. USER_ID=test2    name=bb    password=bb    
            3. 
    
          3. USER_ID=test3    name=cc    password=cc  
            4. 

          

          

          


	
          
	
	
          
		posted on 2007-11-16 17:31 hk2000c 閱讀(3557) 評論(2)  編輯  收藏  所屬分類: JMS 
	
          

          







          
	    
    


          

          
	
          評論
          
		
		
				
          			
					
          
						# re: spring調用Oracle存儲過程,并返回結果集的完整實例 
							
								2008-09-08 23:43
							
						mu
					
          
					
          
						寫點注釋啊，這么看著你自己很明白，別人云里來霧里去的  回復  更多評論
						
          
						  
					
          
				
          
				
          
			
				
          			
					
          
						# re: spring調用Oracle存儲過程,并返回結果集的完整實例 
							
								2010-09-26 16:39
							
						asdtiang
					
          
					
          
						學習標記下  回復  更多評論
						
          
						  
					
          
				
          
				
          
			

          




          








          

				

          




    







          
        
	




主站蜘蛛池模板：
丰都县|
云和县|
丰顺县|
谷城县|
西乌珠穆沁旗|
麻江县|
莎车县|
土默特右旗|
包头市|
新平|
揭东县|
成武县|
巨野县|
无极县|
江达县|
微山县|
万安县|
余姚市|
新疆|
合阳县|
内乡县|
娱乐|
安达市|
全州县|
航空|
关岭|
四子王旗|
冷水江市|
合作市|
遵化市|
唐山市|
沛县|
收藏|
民丰县|
新闻|
浦县|
南陵县|
碌曲县|
大埔县|
合肥市|
台湾省|