本文共 3779 字，大约阅读时间需要 12 分钟。

– Start

package shangbo.spring.transaction.jdbc.schema;public class Job {	private String jobId;	private String jobTitle;	private Integer minSalary;	private Integer maxSalary;	public String getJobId() {		return jobId;	}	public void setJobId(String jobId) {		this.jobId = jobId;	}	public String getJobTitle() {		return jobTitle;	}	public void setJobTitle(String jobTitle) {		this.jobTitle = jobTitle;	}	public Integer getMinSalary() {		return minSalary;	}	public void setMinSalary(Integer minSalary) {		this.minSalary = minSalary;	}	public Integer getMaxSalary() {		return maxSalary;	}	public void setMaxSalary(Integer maxSalary) {		this.maxSalary = maxSalary;	}	public String toString() {		return "Job[jobId=" + jobId + ", jobTitle=" + jobTitle + ", minSalary=" + minSalary + ", maxSalary=" + maxSalary + "]";	}}

package shangbo.spring.transaction.jdbc.schema;import org.apache.commons.dbcp.BasicDataSource;public interface BusinessService {	Job getJob(String jobId);	void insertJob(Job job) throws Exception;	void updateJob(Job job) throws Exception;	void setDataSource(BasicDataSource dataSource);}

package shangbo.spring.transaction.jdbc.schema;import java.sql.ResultSet;import java.sql.SQLException;import org.apache.commons.dbcp.BasicDataSource;import org.springframework.jdbc.core.JdbcTemplate;import org.springframework.jdbc.core.RowMapper;public class DefaultBusinessService implements BusinessService {	private JdbcTemplate jdbcTemplate;	public Job getJob(String jobId) {		String sql = "SELECT * FROM HR.JOBS WHERE JOB_ID = ?";		return jdbcTemplate.queryForObject(sql, new JobRowMapper(), jobId);	}	public void updateJob(Job job) throws Exception {		String sql = "UPDATE HR.JOBS SET JOB_TITLE=?, MIN_SALARY = ?, MAX_SALARY = ? WHERE JOB_ID = ?";		jdbcTemplate.update(sql, job.getJobTitle(), job.getMinSalary(), job.getMaxSalary(), job.getJobId());		// 测试回滚		// throw new Exception("test");	}	public void insertJob(Job job) throws Exception {		String sql = "INSERT INTO HR.JOBS VALUES (?, ?, ?, ?)";		jdbcTemplate.update(sql, job.getJobId(), job.getJobTitle(), job.getMinSalary(), job.getMaxSalary());		// 测试回滚		// throw new Exception("test");	}	public void setDataSource(BasicDataSource dataSource) {		this.jdbcTemplate = new JdbcTemplate(dataSource);	}	private static class JobRowMapper implements RowMapper
   
     {		public Job mapRow(ResultSet rs, int rowNum) throws SQLException {			Job job = new Job();			job.setJobId(rs.getString(1));			job.setJobTitle(rs.getString(2));			job.setMinSalary(rs.getInt(3));			job.setMaxSalary(rs.getInt(4));			return job;		}	}}
   

package shangbo.spring.transaction.jdbc.schema;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;public class App {	public static void main(String[] args) throws Exception {		// 实例化 Spring IoC 容器		ApplicationContext context = new ClassPathXmlApplicationContext("example.xml", BusinessService.class);		// 从容器中获得 BusinessService 的实例		BusinessService service = context.getBean(BusinessService.class);		// 使用 BusinessService		// 插入 job		Job job = newJob();		// service.insertJob(job);		// 更新 job		service.updateJob(job);		// 查询 job		System.out.println(service.getJob("IT"));	}	private static Job newJob() {		Job job = new Job();		job.setJobId("IT");		job.setJobTitle("IT Engineer");		job.setMinSalary(3);		job.setMaxSalary(100000);		return job;	}}

–