弹簧事务隔离可序列化不起作用

Question

Code for Main.java：

public class Main {
    public static void main(String[] args) {
        final ApplicationContext ctx = new ClassPathXmlApplicationContext("spring.xml");
        final UserManager userManager = (UserManager) ctx.getBean("userManagerImpl");
        new Thread() {
            public void run() {
                User user = new User();
                user.setUsername("hari18");
                user.setName("haris1");
                userManager.insertUser(user);
                System.out.println("User inserted!");
            }
        } .start();
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        new Thread() {
            public void run() {
                List<User> users = userManager.getUsers();
                System.out.println("nUser list fetched!" + "nUser count: " + users.size());
                for (User user1 : users) {
                    System.out.println(user1.getUsername());
                }
            }
        } .start();
    }
}    

UserManagerImpl.java的代码：

@Service
@Scope("prototype")
public class UserManagerImpl implements UserManager {
    @Autowired
    private UserDAO userDAO;
    @Override
    @Transactional( propagation=Propagation.REQUIRED , isolation=Isolation.SERIALIZABLE)
    public void insertUser(User user) {
        userDAO.insertUser(user);
    }
    @Override
    @Transactional( propagation=Propagation.REQUIRED , isolation=Isolation.SERIALIZABLE)
    public List<User> getUsers() {
        return userDAO.getUsers();
    }
}

UserDAOImpl.java的代码：

@Service
public class UserDAOImpl extends JdbcDaoSupport implements UserDAO {
    @Autowired
    public UserDAOImpl(DataSource dataSource) {
        setDataSource(dataSource);
    }
    @Override
    public void insertUser(User user) {
        getJdbcTemplate().update("INSERT INTO USER (USERNAME, NAME) VALUES (?, ?)",
            new Object[] {
                user.getUsername(),
                user.getName()
            }
        );
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    @Override
    public List<User> getUsers() {
        List<User> users = getJdbcTemplate().query("SELECT * FROM USER",new UserMapper());
        return users;
    }
}    

弹簧.xml代码：

<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:tx="http://www.springframework.org/schema/tx"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
    http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
    http://www.springframework.org/schema/context
    http://www.springframework.org/schema/context/spring-context-3.0.xsd 
    http://www.springframework.org/schema/tx 
    http://www.springframework.org/schema/tx/spring-tx.xsd">
    <tx:annotation-driven transaction-manager="transactionManager"/>
    <context:component-scan base-package="com.byteslounge.spring" />
    <!-- context:component-scan base-package="com.byteslounge.spring" /-->
    <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
        destroy-method="close">
        <property name="driverClassName" value="com.mysql.jdbc.Driver" />
        <property name="url" value="jdbc:mysql://localhost:3306/test" />
        <property name="username" value="root" />
        <property name="password" value="password" />
    </bean>
    <bean id="transactionManager"
        class="org.springframework.jdbc.datasource.DataSourceTransactionManager" >
        <property name="dataSource" ref="dataSource" />
    </bean>
</beans>

当运行上面的主类时，理论上线程 1 将首先启动，它必须锁定表USER（因为isolation = Isolation.SERIALIZABLE），当线程 2 运行时，它必须等到锁从表 USER 释放而不从表中读取表，但是当我运行此代码时，它正在读取表并打印而无需等待第一个事务完成。为什么USER表锁定不起作用，甚至认为隔离是SERIALIZABLE ???

Answer 1

我得到了这个问题的答案。这里的问题是线程 1 和 tow 之间的时间延迟，这里我给出的时间延迟为 100ms，但这种延迟还不够，因为在 insertUser（） 获取表锁之前 getUsers（） 占用锁并获取数据并处理它，所以一旦我将时间延迟更改为 1000ms，这个问题就解决了。所以 insertUser（） 占据了锁，getUsers（） 等到 insertUser（） 完成并提交插入部分。

Answer 2

我认为解决方案是..

在读取的情况下，锁将在多线程（切碎模式）之间共享。 因此，"选择"查询正在正确执行。如果您尝试使用更新/删除查询，您将获得您的想法（另一个线程必须等到第一个线程完成）。 尝试以这种方式。