梦幻之旅

DEBUG - 天道酬勤

   :: 首页 :: 新随笔 :: 联系 :: 聚合  :: 管理 ::
  671 随笔 :: 6 文章 :: 256 评论 :: 0 Trackbacks
package hvp.spring.jdbc.jdbctemplate;

import hvp.spring.commons.inim.UserPO;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.PreparedStatementCreator;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.support.GeneratedKeyHolder;
import org.springframework.jdbc.support.KeyHolder;

public class UserDAO
{
    JdbcTemplate jt;
    
    
public UserDAO()
    
{
        
this.jt = this.getJdbcTemplate2();
    }

    
    
public JdbcTemplate getJdbcTemplate2()
    
{
        String configPath 
= "hvp/spring/jdbc/jdbctemp/beans.xml";
        ApplicationContext ctx 
= new ClassPathXmlApplicationContext(configPath);
        
return (JdbcTemplate) ctx.getBean("jdbcTemplate");
    }

    
    
public void createTable()
    
{
        StringBuffer sql 
= new StringBuffer();
        sql.append(
"CREATE TABLE t_user(");
        sql.append(
"user_id int AUTO_INCREMENT PRIMARY KEY,");
        sql.append(
"user_name VARCHAR(32)");
        sql.append(
")");
        jt.execute(sql.toString());
    }

    
    
public UserPO addUser(final UserPO po)
    
{
        
final String sql = "INSERT INTO t_user(user_name) VALUES (?)";
        KeyHolder keyHolder 
= new GeneratedKeyHolder();
        jt.update(
new PreparedStatementCreator()
            
{
                
public PreparedStatement createPreparedStatement(Connection conn)
                        
throws SQLException
                
{
                    PreparedStatement ps 
= conn.prepareStatement(sql);
                    ps.setString(
1, po.getUserName());
                    
return ps;
                }

            }
, keyHolder);
        po.setUserId(keyHolder.getKey().intValue());
        System.out.println(po.getUserId() 
+ ":" + po.getUserName());
        
return po;
    }

    
    @SuppressWarnings(
"unchecked")
    
public List<UserPO> queryUserPOs()
    
{
        StringBuffer sql 
= new StringBuffer();
        sql.append(
"SELECT user_id,user_name FROM t_user");
        sql.append(
" LIMIT ");
        sql.append(
0);
        sql.append(
",");
        sql.append(
10);
        
        
return jt.query(sql.toString(), new RowMapper()
            
{
                
public Object mapRow(ResultSet rs, int index)
                        
throws SQLException
                
{
                    UserPO userPO 
= new UserPO();
                    userPO.setUserId(rs.getInt(
"user_id"));
                    userPO.setUserName(rs.getString(
"user_name"));
                    
return userPO;
                }

            }
);
    }

    
    
public UserPO findUser(Integer userId)
    
{
        String sql 
= "SELECT user_id,user_name FROM t_user WHERE user_id=?";
        
return (UserPO) jt.queryForObject(sql, new Object[] { userId },
                
new RowMapper()
                    
{
                        
public Object mapRow(ResultSet rs, int index)
                                
throws SQLException
                        
{
                            UserPO userPO 
= new UserPO();
                            userPO.setUserId(rs.getInt(
"user_id"));
                            userPO.setUserName(rs.getString(
"user_name"));
                            
return userPO;
                        }

                    }
);
    }

    
    
public int getCount()
    
{
        String sql 
= "SELECT COUNT(*) FROM t_user";
        
return jt.queryForInt(sql);
    }

    
    
public static void main(String[] args)
    
{
        UserDAO ct 
= new UserDAO();
        
// UserPO user = new UserPO();
        
// user.setUserName("Huy Vanlee");
        
// ct.addUser(user);
        System.out.println(ct.queryUserPOs());
    }

}

posted on 2008-08-10 17:46 HUIKK 阅读(1484) 评论(1)  编辑  收藏 所属分类: Spring

评论

# re: Spring JdbcTemplate 2014-05-04 10:34 zuidaima
请参考代码:Spring JdbcTemplate框架搭建及其增删改查使用指南,下载地址:http://www.zuidaima.com/share/1724429678644224.htm  回复  更多评论
  


只有注册用户登录后才能发表评论。


网站导航: