Java蜘蛛人 歡迎大家

          歡迎大家 來到我的blog , 如果我身邊的朋友 有什么不懂可以直接來問我 我會細心的幫助你的. 如果網絡上的朋友有什么不懂的 可以加我Java蜘蛛人 QQ48187537
          posts - 54, comments - 192, trackbacks - 0, articles - 1

          JdbcTemplate學習筆記

          Posted on 2009-02-06 14:35 Java蜘蛛人 --鄭成橋 閱讀(691) 評論(0)  編輯  收藏

          1、使用JdbcTemplate的execute()方法執行SQL語句

          代碼
          1. jdbcTemplate.execute("CREATE TABLE USER (user_id integer, name varchar(100))");  

          2、如果是UPDATE或INSERT,可以用update()方法。
          代碼
          1. jdbcTemplate.update("INSERT INTO USER VALUES('"  
          2.             + user.getId() + "', '"  
          3.             + user.getName() + "', '"  
          4.             + user.getSex() + "', '"  
          5.             + user.getAge() + "')");   

          3、帶參數的更新
          代碼
          1. jdbcTemplate.update("UPDATE USER SET name = ? WHERE user_id = ?", new Object[] {name, id});  

          代碼
          1. jdbcTemplate.update("INSERT INTO USER VALUES(?, ?, ?, ?)", new Object[] {user.getId(), user.getName(), user.getSex(), user.getAge()});   

          4、使用JdbcTemplate進行查詢時,使用queryForXXX()等方法
          代碼
          1. int count = jdbcTemplate.queryForInt("SELECT COUNT(*) FROM USER");  

           

           

          代碼
          1. String name = (String) jdbcTemplate.queryForObject("SELECT name FROM USER WHERE user_id = ?", new Object[] {id}, java.lang.String.class);  

           

           

          代碼
          1. List rows = jdbcTemplate.queryForList("SELECT * FROM USER");  

           

           

          代碼
          1. List rows = jdbcTemplate.queryForList("SELECT * FROM USER");   
          2. Iterator it = rows.iterator();   
          3. while(it.hasNext()) {   
          4.      Map userMap = (Map) it.next();   
          5.      System.out.print(userMap.get("user_id") + "\t");   
          6.      System.out.print(userMap.get("name") + "\t");   
          7.      System.out.print(userMap.get("sex") + "\t");   
          8.      System.out.println(userMap.get("age") + "\t");   
          9. }   

           

          JdbcTemplate將我們使用的JDBC的流程封裝起來,包括了異常的捕捉、SQL的執行、查詢結果的轉換等等。spring大量使用Template Method模式來封裝固定流程的動作,XXXTemplate等類別都是基于這種方式的實現。
          除了大量使用Template Method來封裝一些底層的操作細節,spring也大量使用callback方式類回調相關類別的方法以提供JDBC相關類別的功能,使傳統的JDBC的使用者也能清楚了解spring所提供的相關封裝類別方法的使用。

          JDBC的PreparedStatement

          代碼
          1. final String id = user.getId();   
          2. final String name = user.getName();   
          3. final String sex = user.getSex() + "";   
          4. final int age = user.getAge();   
          5.   
          6. jdbcTemplate.update("INSERT INTO USER VALUES(?, ?, ?, ?)",   
          7.                      new PreparedStatementSetter() {   
          8.                          public void setValues(PreparedStatement ps) throws SQLException {   
          9.                               ps.setString(1, id);   
          10.                               ps.setString(2, name);             
          11.                               ps.setString(3, sex);   
          12.                               ps.setInt(4, age);   
          13.                           }   
          14.                       });   
          15.   

           

           

          代碼
          1. final User user = new User();   
          2. jdbcTemplate.query("SELECT * FROM USER WHERE user_id = ?",   
          3.                     new Object[] {id},   
          4.                     new RowCallbackHandler() {   
          5.                         public void processRow(ResultSet rs) throws SQLException {   
          6.                              user.setId(rs.getString("user_id"));   
          7.                              user.setName(rs.getString("name"));   
          8.                              user.setSex(rs.getString("sex").charAt(0));   
          9.                              user.setAge(rs.getInt("age"));   
          10.                          }   
          11.                      });   
          12.   

           

           

          代碼
          1. class UserRowMapper implements RowMapper {   
          2.     public Object mapRow(ResultSet rs, int index) throws SQLException {   
          3.          User user = new User();   
          4.   
          5.          user.setId(rs.getString("user_id"));   
          6.          user.setName(rs.getString("name"));   
          7.          user.setSex(rs.getString("sex").charAt(0));   
          8.          user.setAge(rs.getInt("age"));   
          9.   
          10.         return user;   
          11.      }   
          12. }   
          13.   
          14. public List findAllByRowMapperResultReader() {   
          15.      String sql = "SELECT * FROM USER";   
          16.     return jdbcTemplate.query(sql, new RowMapperResultReader(new UserRowMapper()));   
          17. }   
          18.   

           

          在getUser(id)里面使用UserRowMapper

          代碼
          1. public User getUser(final String id) throws DataAccessException {   
          2.      String sql = "SELECT * FROM USER WHERE user_id=?";   
          3.     final Object[] params = new Object[] { id };   
          4.      List list = jdbcTemplate.query(sql, params, new RowMapperResultReader(new UserRowMapper()));   
          5.   
          6.     return (User) list.get(0);   
          7. }   

           

          網上收集
          org.springframework.jdbc.core.PreparedStatementCreator 返回預編譯SQL 不能于Object[]一起用

          代碼
          1. public PreparedStatement createPreparedStatement(Connection con) throws SQLException {   
          2. return con.prepareStatement(sql);   
          3. }   

          1.增刪改
          org.springframework.jdbc.core.JdbcTemplate 類(必須指定數據源dataSource)
          代碼
          1. template.update("insert into web_person values(?,?,?)",Object[]);   


          代碼
          1. template.update("insert into web_person values(?,?,?)",new PreparedStatementSetter(){ 匿名內部類 只能訪問外部最終局部變量   
          2.   
          3. public void setValues(PreparedStatement ps) throws SQLException {   
          4.    ps.setInt(index++,3);   
          5. });   

          org.springframework.jdbc.core.PreparedStatementSetter 接口 處理預編譯SQL
          代碼
          1. public void setValues(PreparedStatement ps) throws SQLException {   
          2. ps.setInt(index++,3);   
          3. }   

          2.查詢JdbcTemplate.query(String,[Object[]/PreparedStatementSetter],RowMapper/RowCallbackHandler)
          org.springframework.jdbc.core.RowMapper 記錄映射接口 處理結果集
          代碼
          1. public Object mapRow(ResultSet rs, int arg1) throws SQLException {   int表當前行數   
          2.    person.setId(rs.getInt("id"));   
          3. }   
          4. List template.query("select * from web_person where id=?",Object[],RowMapper);   

          org.springframework.jdbc.core.RowCallbackHandler 記錄回調管理器接口 處理結果集
          代碼
          1. template.query("select * from web_person where id=?",Object[],new RowCallbackHandler(){   
          2. public void processRow(ResultSet rs) throws SQLException {   
          3.    person.setId(rs.getInt("id"));   
          4. });

          只有注冊用戶登錄后才能發表評論。


          網站導航:
          博客園   IT新聞   Chat2DB   C++博客   博問  
           
          主站蜘蛛池模板: 明光市| 南阳市| 云浮市| 凌云县| 游戏| 磴口县| 富川| 综艺| 乐山市| 册亨县| 罗源县| 塔城市| 水城县| 福清市| 江城| 石阡县| 卢湾区| 独山县| 元氏县| 三穗县| 龙胜| 阿城市| 怀远县| 丘北县| 乃东县| 壶关县| 绍兴县| 额济纳旗| 郴州市| 丹寨县| 安顺市| 康定县| 安宁市| 寻乌县| 宜兴市| 张家口市| 调兵山市| 东丽区| 秦安县| 隆回县| 景德镇市|