欧洲亚洲国产清在高,国产亚洲欧美在线观看,国产精品亚洲精品观看不卡

Spring JdbcTemplate

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 閱讀(1578) 評論(1) 編輯收藏所屬分類: Spring


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




網站導航: 博客園 IT新聞 Chat2DB C++博客博問管理
相關文章: spring 屬性文件加密碼及解密 acegi基于數據庫存儲用戶的身份認證 acegi基于內存存儲用戶的身份認證 spring 里配置 quartz HibernateTemplate DAO HibernateTemplate Spring JdbcTemplate 再溫 c3p0 連接池使用 @AspectJ 的一個例子 jar 包說明總結

夢幻之旅

公告

常用鏈接

留言簿(21)

隨筆分類(644)

隨筆檔案(669)

文章檔案(6)

最新隨筆

積分與排名

最新評論

閱讀排行榜

評論排行榜

評論