Spring5 source code (39) – an introduction to Aop transactional management and programmatic transactional implementation

Public interface TransactionDefinition {// If there is no current object, create a new object; If one already exists, add to it. int PROPAGATION_REQUIRED = 0; // Support the current thing, if there is no current thing, then non-thing. int PROPAGATION_SUPPORTS = 1; // Use the current thing, if there is no current thing, throw an exception. int PROPAGATION_MANDATORY = 2; // Create a new thing, and suspend the current thing if it already exists. int PROPAGATION_REQUIRES_NEW = 3; // Execute in non-transaction mode, suspends current transaction if current transaction exists. int PROPAGATION_NOT_SUPPORTED = 4; // Executes in a non-transaction manner, throwing an exception if something currently exists. int PROPAGATION_NEVER = 5; // Execute inside a nested object if the object currently exists; Int PROPAGATION_NESTED = 6 if there is no current thing, the same as PROPAGATION_REQUIRED; // Use the default isolation level for the back-end database. int ISOLATION_DEFAULT = -1; Int ISOLATION_READ_UNCOMMITTED = connection. TRANSACTION_READ_UNCOMMITTED; // READ_UNCOMMITTED isolation level int ISOLATION_READ_UNCOMMITTED = connection. TRANSACTION_READ_UNCOMMITTED; // READ_COMMITTED Isolation level int ISOLATION_READ_COMMITTED = connection. TRANSACTION_READ_COMMITTED; // REPEATABLE_READ isolation level int ISOLATION_REPEATABLE_READ = connection.transaction_REPEATABLE_read; // SERIALIZABLE isolation level int ISOLATION_SERIALIZABLE = connection.transaction_serializable; // Default timeout duration int TIMEOUT_DEFAULT = -1; Int getPropagationBehavior(); Int getIsolationLevel(); Int getTimeout(); Boolean isReadOnly(); @nullable String getName(); }Copy the code

Public interface PlatformTransactionManager {/ / according to the specified propagation behavior, returns the current active transaction or create a new transaction. TransactionStatus getTransaction(@Nullable TransactionDefinition definition) throws TransactionException; // Commit the given transaction for the state of the given transaction. void commit(TransactionStatus status) throws TransactionException; // Perform a rollback for the given transaction. void rollback(TransactionStatus status) throws TransactionException; }Copy the code

Public interface TransactionStatus extends SavepointManager, Flushable {// Returns whether the current transaction is a new transaction (otherwise it will participate in an existing transaction, Or it may not be running in an actual transaction to begin with.) Boolean isNewTransaction(); // Returns whether the transaction carries savepoints internally, that is, has been created as a nested transaction based on savepoints. boolean hasSavepoint(); // Set transaction rollback only. voidsetRollbackOnly(); Boolean isRollbackOnly(); // Returns whether the transaction is marked for rollback only. // Flush the session to the datastore @override void flush(); // Returns whether the thing has been completed, whether committed or rolled back. boolean isCompleted(); }Copy the code

Public interface SavepointManager {// Create a new savepoint. Object createSavepoint() throws TransactionException; // Roll back to the given savepoint. // Note that a savepoint is not automatically released after being rolled back to a given savepoint. The releaseSavepoint method can be released. void rollbackToSavepoint(Object savepoint) throws TransactionException; // Explicitly release the given savepoint. (Most transaction managers automatically release savepoints upon transaction completion.) Void releaseSavepoint(Object SavePoint) throws TransactionException; }Copy the code

Public interface Flushable {// Flushes sessions to the data store void Flush () throws IOException; }Copy the code

CREATE TABLE `account` (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'Increment primary key',
  `balance` int(11) DEFAULT NULL COMMENT 'Account balance',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=5 DEFAULT CHARSET=utf8 COMMENT='-- Account table '
Copy the code

package com.lyc.cn.v2.day08; import org.apache.commons.dbcp.BasicDataSource; import org.springframework.dao.DataAccessException; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.datasource.DataSourceTransactionManager; import org.springframework.transaction.TransactionDefinition; import org.springframework.transaction.TransactionStatus; import org.springframework.transaction.support.DefaultTransactionDefinition; import javax.sql.DataSource; /** * Spring programming things * @author: LiYanChao * @create: 2018-11-09 11:41 */ public class MyTransaction { private JdbcTemplate jdbcTemplate; private DataSourceTransactionManager txManager; private DefaultTransactionDefinition txDefinition; private String insert_sql ="insert into account (balance) values ('100')";

    public void save{// 1, initialize jdbcTemplate DataSource DataSource = DataSource(); jdbcTemplate = new JdbcTemplate(dataSource); / / 2, create content manager txManager = new DataSourceTransactionManager (); txManager.setDataSource(dataSource); / / 3, define things attribute txDefinition = new DefaultTransactionDefinition (); txDefinition.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED); TransactionStatus txStatus = txManager.getTransaction(txDefinition); Try {jdbctemplate. execute(insert_sql); //int i = 1/0; jdbcTemplate.execute(insert_sql); txManager.commit(txStatus); } catch (DataAccessException e) { txManager.rollback(txStatus); e.printStackTrace(); } } public DataSourcegetDataSource() {
        BasicDataSource dataSource = new BasicDataSource();
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql://localhost:3306/my_test? useSSL=false&useUnicode=true&characterEncoding=UTF-8");
        dataSource.setUsername("root");
        dataSource.setPassword("liyanchao1989@");
        returndataSource; }}Copy the code

// Add spring-JDBC module optional(project(":spring-jdbc"))
// https://mvnrepository.com/artifact/commons-dbcp/commons-dbcp
compile group: 'commons-dbcp', name: 'commons-dbcp', version: '1.4'
// https://mvnrepository.com/artifact/mysql/mysql-connector-java
compile group: 'mysql', name: 'mysql-connector-java', version: '5.1.38'
Copy the code

package com.lyc.cn.v2.day08;

import org.junit.Test;

/**
 * @author: LiYanChao
 * @create: 2018-11-07 18:45
 */
public class MyTest {
    @Test
    public void test1() { MyTransaction myTransaction = new MyTransaction(); myTransaction.save(); }}Copy the code