知乎专栏 |
Integer age = queryForObject("select age from emp", Integer.class); String name = queryForObject("select name from emp",String.class);
private double getSumByMemberId(int memberId) { double result = 0.0d; String sql = "SELECT sum(o.price::NUMERIC) as total FROM public.order o group by member_id ="+ memberId; try { result = jdbcTemplate.queryForObject(sql, Double.class); } catch (org.springframework.dao.EmptyResultDataAccessException e) { log.info("{} {}", MemberId, e.toString()); } return result; }
注意 Date 是 java.util 不是 java.sql
private static final Logger log = LoggerFactory.getLogger(ScheduledTasks.class); private static final SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-mm-dd HH:mm:ss"); @Autowired private JdbcTemplate jdbcTemplate; @Scheduled(initialDelay = 1000, fixedRate = 60000) public void currentDate() { Date date = jdbcTemplate.queryForObject("select sysdate from dual", Date.class); log.info("The oracle sysdate is {}", dateFormat.format(date)); }
@Autowired private JdbcTemplate jdbcTemplate; @RequestMapping(value = "/article") public @ResponseBody String dailyStats(@RequestParam Integer id) { String query = "SELECT id, title, content from article where id = " + id; return jdbcTemplate.queryForObject(query, (resultSet, i) -> { System.out.println(resultSet.getLong(1) + "," + resultSet.getString(2) + "," + resultSet.getString(3)); return (resultSet.getLong(1) + "," + resultSet.getString(2) + "," + resultSet.getString(3)); }); }
package com.example.api.restful; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RestController; import com.example.api.pojo.ResponseRestful; @RestController @RequestMapping("/restful/cms") public class CmsRestController { @Autowired private JdbcTemplate jdbcTemplate; @RequestMapping(value = "/article/update/count/{articleId}", method = RequestMethod.GET, produces = { "application/xml", "application/json" }) public ResponseRestful updateCount(@PathVariable int articleId) { String sql = "SELECT count(*) FROM cms.article WHERE id > ?"; int count = jdbcTemplate.queryForObject(sql, new Object[] { articleId }, Integer.class); return new ResponseRestful(true, 1, "文章更新", count); } }
package cn.netkiller.model; import java.sql.ResultSet; import java.sql.SQLException; import org.springframework.jdbc.core.RowMapper; public class CustomerRowMapper implements RowMapper { public Object mapRow(ResultSet rs, int rowNum) throws SQLException { Customer customer = new Customer(); customer.setId(rs.getInt("ID")); customer.setName(rs.getString("NAME")); customer.setAge(rs.getInt("AGE")); return customer; } }
public Customer findByCustomerId(int id){ String sql = "SELECT * FROM CUSTOMER WHERE ID = ?"; Customer customer = (Customer)getJdbcTemplate().queryForObject( sql, new Object[] { id }, new CustomerRowMapper()); return customer; }
Member member = this.jdbcTemplate.queryForObject("select first_name, last_name from member where id = ?",new Object[]{112L}, new RowMapper<Member>() { public Actor mapRow(ResultSet rs, int rowNum) throws SQLException { Member member = new Member(); member.setFirstName(rs.getString("first_name")); member.setLastName(rs.getString("last_name")); return member; } });