| 知乎专栏 |
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;
}
});