SpringMvc, JDBC Template的例子

package com.dao; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Types; import java.util.HashMap; import java.util.Map; import javax.annotation.Resource; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.RowCallbackHandler; import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate; import org.springframework.jdbc.core.simple.ParameterizedRowMapper; import org.springframework.jdbc.core.simple.SimpleJdbcInsert; import org.springframework.stereotype.Repository; import com.domain.Table3; import com.domain.Table3Mapper; @Repository public class Table3Dao extends BasicDao { @Resource(name = "jdbcTemplate") private JdbcTemplate jdbcTemplate; public Table3 findTable3ByName1(String name) { ParameterizedRowMapper<Table3> mapper = new ParameterizedRowMapper<Table3>() { public Table3 mapRow(ResultSet rs, int rowNum) throws SQLException { Table3 table3 = new Table3(rs.getInt("ID"), rs.getString("NAME"), rs.getString("PASSWORD"), rs.getString("EMAIL")); return table3; } }; try { Table3 pb = (Table3) getJdbcTemplate().queryForObject( "select ID,NAME,PASSWORD,EMAIL from TABLE3 where NAME = ?", new Object[] { name }, mapper); return pb; } catch (org.springframework.dao.EmptyResultDataAccessException e) { return new Table3(); } } /** * 与上方法有点不一样,是直接在方法里面创建Mapper * * @param name * @return */ @SuppressWarnings("unchecked") public Table3 findTable3ByName(String name) { try { Table3 pb = (Table3) getJdbcTemplate().queryForObject( "select ID,NAME,PASSWORD,EMAIL from TABLE3 where NAME = ?", new Object[] { name }, new Table3Mapper()); return pb; } catch (org.springframework.dao.EmptyResultDataAccessException e) { return new Table3(); } } @SuppressWarnings("unchecked") public Table3 listAll() { Table3 pb = (Table3) getJdbcTemplate() .queryForObject("select ID,NAME,PASSWORD,EMAIL from TABLE3", new Table3Mapper()); return pb; } public void insert() { getJdbcTemplate().update( "INSERT INTO TABLE3(NAME,PASSWORD,EMAIL) VALUES(?, ?, ?)", new Object[] { "Pandy-Jdbc", "Pandy-PASSWORD", "Pandy-EMAIL" }, new int[] { Types.VARCHAR, Types.VARCHAR, Types.VARCHAR }); } public void update(String name) { getJdbcTemplate() .update("UPDATE TABLE3 SET NAME = ?,PASSWORD = ?,EMAIL = ? WHERE NAME = ?", new Object[] { "Pandy-UPDATE", "Pandy-UPDATE", "Pandy-UPDATE", name }, new int[] { Types.VARCHAR, Types.VARCHAR, Types.VARCHAR, Types.VARCHAR }); } public void delete(String name) { getJdbcTemplate().update("DELETE FROM dbo.TABLE3 WHERE NAME = ?", new Object[] { name }, new int[] { Types.VARCHAR }); } public Object inserOneActor() { SimpleJdbcInsert inserActor = new SimpleJdbcInsert(getDataSource()) .withTableName("TABLE3").usingColumns("NAME", "PASSWORD")// 插入这些字段 .usingGeneratedKeyColumns("ID");// 带回生成的id Map<String, Object> parameters = new HashMap<String, Object>(); parameters.put("NAME", "NAME"); parameters.put("PASSWORD", "PASSWORD"); parameters.put("EMAIL", "EMAIL"); return inserActor.executeAndReturnKey(parameters).longValue(); } /** * NamedParameterJdbcTemplate会简化许多代码 * * @param name * @return */ @SuppressWarnings({ "rawtypes", "unchecked" }) public Table3 findByName(String name) { String sql = "select ID,NAME,PASSWORD,EMAIL from TABLE3 where NAME = :NAME"; NamedParameterJdbcTemplate simpleJdbcTemplate = new NamedParameterJdbcTemplate( getDataSource()); Map paramMap = new HashMap(); paramMap.put("NAME", name); final Table3 table3 = new Table3(); simpleJdbcTemplate.query(sql, paramMap, new RowCallbackHandler() { @Override public void processRow(ResultSet rs) throws SQLException { table3.setId(rs.getInt("ID")); table3.setName(rs.getString("NAME")); table3.setPassword(rs.getString("PASSWORD")); table3.setEmail(rs.getString("EMAIL")); } }); return table3; } }