Spring 3.x企业应用开发实战(13)----Spring JDBC访问数据库


		Spring JDBC是Spring所提供的持久层技术。他的目的是降低JDBC API门槛,以一种更直接、更简洁的方式使用JDBC API。
JdbcTemplate小试牛刀
[java] 
package com.smart.dao;  
  
import java.sql.CallableStatement;  
import java.sql.Connection;  
import java.sql.PreparedStatement;  
import java.sql.ResultSet;  
import java.sql.SQLException;  
import java.sql.Types;  
import java.util.HashMap;  
import java.util.List;  
import java.util.Map;  
  
import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.dao.DataAccessException;  
import org.springframework.jdbc.core.BatchPreparedStatementSetter;  
import org.springframework.jdbc.core.CallableStatementCallback;  
import org.springframework.jdbc.core.CallableStatementCreator;  
import org.springframework.jdbc.core.CallableStatementCreatorFactory;  
import org.springframework.jdbc.core.JdbcTemplate;  
import org.springframework.jdbc.core.PreparedStatementCreator;  
import org.springframework.jdbc.core.RowCallbackHandler;  
import org.springframework.jdbc.core.RowMapper;  
import org.springframework.jdbc.core.SqlOutParameter;  
import org.springframework.jdbc.core.SqlParameter;  
import org.springframework.jdbc.support.GeneratedKeyHolder;  
import org.springframework.jdbc.support.KeyHolder;  
import org.springframework.stereotype.Repository;  
  
import com.smart.domain.User;  
  
@Repository  
public class ViewSpaceDao   
{  
    @Autowired  
    private JdbcTemplate jdbcTemplate;  
      
    public void initDb()  
    {  
        String sql="create table t_user_2(user_id int primary key,user_name varchar(60))";  
        jdbcTemplate.execute(sql);  
    }  
      
    public void updateJdbc1()  
    {  
        final String sql="INSERT INTO t_user(user_name,password) VALUES(?,?)";  
        Object[] params=new Object[]{"MonkeyKing","孫悟空"};  
        jdbcTemplate.update(sql,params);  
    }  
      
    public void updateJdbc2()  
    {  
        final String sql="INSERT INTO t_user(user_name,password) VALUES(?,?)";  
        Object[] params=new Object[]{"MonkeyKing","孫悟空"};  
        jdbcTemplate.update(sql,params,new int[]{Types.VARCHAR,Types.VARCHAR});  
    }  
      
    //獲得主鍵的更新  
    public  void updateJdbc3()  
    {  
        final String sql="INSERT INTO t_user(user_name,password) VALUES(?,?)";  
          
        KeyHolder keyHolder=new GeneratedKeyHolder();//創建一個主鍵執有       
        jdbcTemplate.update(new PreparedStatementCreator() {              
            @Override  
            public PreparedStatement createPreparedStatement(Connection arg0)  
                    throws SQLException {  
                // TODO Auto-generated method stub  
                PreparedStatement ps=arg0.prepareStatement(sql);  
                ps.setString(1, "MonkeyKing");  
                ps.setString(2, "孫悟空");  
                return ps;  
            }  
        },keyHolder);  
        //獲得主鍵并打印出主鍵  
        System.out.println(keyHolder.getKey().intValue());  
        //jdbcTemplate.  
    }  
      
    //批量更改數據  
    public void batchUpdateSql(final List<User> users)  
    {  
        final String sql="INSERT INTO t_user(user_name,password) VALUES(?,?)";  
        jdbcTemplate.batchUpdate(sql,new BatchPreparedStatementSetter() {  
              
            @Override  
            public void setValues(PreparedStatement arg0, int arg1) throws SQLException {  
                // TODO Auto-generated method stub  
                User user=users.get(arg1);  
                arg0.setString(1,user.getUserName());  
                arg0.setString(2, user.getPassword());  
            }  
              
            @Override  
            public int getBatchSize() {  
                // TODO Auto-generated method stub  
                return users.size();  
            }  
        });  
    }  
      
    //查詢單條數據集,多條只需修改返回類型和一些定義數據類型  
    public User getDataSql(final int userId)  
    {  
        String sql="SELECT user_name,password from t_user where user_id=?";  
        final User user=new User();  
        jdbcTemplate.query(sql, new Object[]{userId},new RowCallbackHandler(){  
  
            @Override  
            public void processRow(ResultSet rs) throws SQLException {  
                // TODO Auto-generated m

补充：移动开发 , Android ,