Spring编程式事务管理采用JDBC

-----------------------------------------------------------------------------------------------------------
Spring编程式事务管理
直接采用JDBC操作数据库
-----------------------------------------------------------------------------------------------------------
   drop TABLE sampledb.orders;
CREATE TABLE sampledb.orders(
`ID` BIGINT NOT NULL,
`ORDER_NUMBER` VARCHAR(15),
`CUSTOMER_ID` BIGINT,
PRIMARY KEY(`ID`)
)
ENGINE = InnoDB;

drop TABLE `sampledb`.`customers`;
CREATE TABLE `sampledb`.`customers` (
   `ID` BIGINT NOT NULL,
`NAME` VARCHAR(45),
PRIMARY KEY(`ID`)
)
ENGINE = InnoDB;


alter table sampledb.orders
add constraint constraint_constraint_fk
foreign key (CUSTOMER_ID)
references sampledb.customers(ID);
   
-----------------------------------------------------------------------------------------------------------
applicationContext.xml
-----------------------------------------------------------------------------------------------------------

    xmlns:xsi=""
    xsi:schemaLocation=" /spring-beans-2.0.xsd">

   
            class="org.springframework.jdbc.datasource.DriverManagerDataSource">
       
                    value="jdbc:mysql://localhost:3306/SAMPLEDB" />
       
       
   





   

            class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
       
   





-----------------------------------------------------------------------------------------------------------
Demo.java
-----------------------------------------------------------------------------------------------------------
package test;

import static java.lang.System.err;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;

import javax.sql.DataSource;

import org.springframework.beans.factory.xml.XmlBeanFactory;
import org.springframework.core.io.ClassPathResource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.DefaultTransactionDefinition;

import db.Customers;

public class Demo {
    public static void main(String[] args) {
        XmlBeanFactory factory = new XmlBeanFactory(new ClassPathResource(
                "applicationContext.xml"));
        DataSource dataSource = (DataSource) factory.getBean("dataSource");

        queryAllBooks(dataSource);
        // 获取PlatformTransactionManager:
        PlatformTransactionManager transManager = (PlatformTransactionManager) factory
                .getBean("transactionManager");
        try {
            doTransaction(transManager, dataSource);
        } finally {
            queryAllBooks(dataSource);
            // System.exit(0);
        }

        System.out.println("END");

    }

    private static void doTransaction(PlatformTransactionManager transManager,
            DataSource dataSource) {
        // 定义TransactionDefinition:
        DefaultTransactionDefinition transDef = new DefaultTransactionDefinition();
        transDef
                .setIsolationLevel(TransactionDefinition.ISOLATION_READ_COMMITTED);
        transDef
                .setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
        // 开始一个Transaction:
        TransactionStatus ts = transManager.getTransaction(transDef);
        try {
            insertBook(dataSource);
            // insertBook(dataSource);
        } catch (RuntimeException e) {
            e.printStackTrace();
            // 回滚事务:
            transManager.rollback(ts);
            throw e;
        } catch (Error e) {
            e.printStackTrace();
            // 回滚事务:
            transManager.rollback(ts);
            throw e;
        }
        // 提交事务:
        transManager.commit(ts);
    }

    private static void queryAllBooks(DataSource dataSource) {
        List customers = new JdbcTemplate(dataSource).query(
                "select * from customers", new CustomerRowMapper());
        System.err.println("-- All Customers ---------------------------");
        for (Customers customer : customers) {
            System.err.println(" " + customer.getName() + ", by "
                    + customer.getName());
        }
        System.err.println("----------------------------------------");
    }

    private static void insertBook(DataSource dataSource) {
        JdbcTemplate jdbcTemp = new JdbcTemplate(dataSource);
        jdbcTemp.update("insert into customers(id, name) values(?, ?)",
                new Object[] { 123, "New Author" });
    }
}

class CustomerRowMapper implements RowMapper {

    public Object mapRow(ResultSet rs, int rowNum) throws SQLException {
        Customers book = new Customers();
        book.setId(Long.parseLong(rs.getString("id")));
        book.setName(rs.getString("name"));

        return book;
    }
}