夢(mèng)幻之旅

DEBUG - 天道酬勤

:: 首頁(yè) :: 新隨筆 :: 聯(lián)系 :: 聚合

:: 管理 ::

671 隨筆 :: 6 文章 :: 256 評(píng)論 :: 0 Trackbacks

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

評(píng)論

# re: Spring JdbcTemplate 2014-05-04 10:34 zuidaima

請(qǐng)參考代碼：Spring JdbcTemplate框架搭建及其增刪改查使用指南,下載地址：http://www.zuidaima.com/share/1724429678644224.htm 回復(fù) 更多評(píng)論

新用戶注冊(cè) 刷新評(píng)論列表


只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。




網(wǎng)站導(dǎo)航: 博客園 IT新聞 Chat2DB C++博客博問(wèn) 管理
相關(guān)文章: spring 屬性文件加密碼及解密 acegi基于數(shù)據(jù)庫(kù)存儲(chǔ)用戶的身份認(rèn)證 acegi基于內(nèi)存存儲(chǔ)用戶的身份認(rèn)證 spring 里配置 quartz HibernateTemplate DAO HibernateTemplate Spring JdbcTemplate 再溫 c3p0 連接池使用 @AspectJ 的一個(gè)例子 jar 包說(shuō)明總結(jié)

夢(mèng)幻之旅

公告

常用鏈接

留言簿(21)

隨筆分類(644)

隨筆檔案(669)

文章檔案(6)

最新隨筆

積分與排名

最新評(píng)論

閱讀排行榜

評(píng)論排行榜

評(píng)論