步骤

多个进程、多个线程访问共同组件数据库

通过select……for update 访问同一条数据

for update锁定数据，其他线程只能等待

先设计一张表
image.png
打开两个查询窗口

  1. SELECT @@autocommit;

查询事务，如果结果是1，那么就是事务还没有打开
我们需要打开事务，来进行后续的测试

  1. set @@autocommit = 0;

在两个窗口执行这个sql，你会发现第一个执行成功，但是第二个则会提示不成功！

  1. select * from distribute_lock where business_code = 'demo' for update;

只有另一查询commit后，才能执行。

  1. select * from distribute_lock where business_code = 'demo';

而我们执行这条sql，又不会出现锁住的情况。
这是因为for update 只是锁住这行数据不会被修改，而正常的查询仍然没有问题。

接着，我们用代码实现一下：

  1.     <parent>
  2.         <groupId>org.springframework.boot</groupId>
  3.         <artifactId>spring-boot-starter-parent</artifactId>
  4.         <version>2.1.3.RELEASE</version>
  5.         <relativePath/> <!-- lookup parent from repository -->
  6.     </parent>
  8.     <dependencies>
  9.         <dependency>
  10.             <groupId>org.springframework.boot</groupId>
  11.             <artifactId>spring-boot-starter-web</artifactId>
  12.         </dependency>
  14.         <dependency>
  15.             <groupId>org.springframework.boot</groupId>
  16.             <artifactId>spring-boot-starter-data-jpa</artifactId>
  17.         </dependency>
  19.         <dependency>
  20.             <groupId>org.mybatis.spring.boot</groupId>
  21.             <artifactId>mybatis-spring-boot-starter</artifactId>
  22.             <version>2.2.2</version>
  23.         </dependency>
  25.         <dependency>
  26.             <groupId>mysql</groupId>
  27.             <artifactId>mysql-connector-java</artifactId>
  28.         </dependency>
  30.         <dependency>
  31.             <groupId>org.projectlombok</groupId>
  32.             <artifactId>lombok</artifactId>
  33.             <scope>provided</scope>
  34.         </dependency>
  36.         <dependency>
  37.             <groupId>org.springframework.boot</groupId>
  38.             <artifactId>spring-boot-starter-test</artifactId>
  39.             <scope>test</scope>
  40.         </dependency>
  41.     </dependencies>
  42.     <build>
  43.         <plugins>
  44.             <plugin>
  45.                 <groupId>org.mybatis.generator</groupId>
  46.                 <artifactId>mybatis-generator-maven-plugin</artifactId>
  47.                 <version>1.3.7</version>
  48.                 <dependencies>
  49.                     <dependency>
  50.                         <groupId>mysql</groupId>
  51.                         <artifactId>mysql-connector-java</artifactId>
  52.                         <version>8.0.15</version>
  53.                     </dependency>
  54.                 </dependencies>
  55.                 <executions>
  56.                     <execution>
  57.                         <id>Generate MyBatis Artifacts</id>
  58.                         <goals>
  59.                             <goal>generate</goal>
  60.                         </goals>
  61.                     </execution>
  62.                 </executions>
  63.                 <configuration>
  64.                     <!-- 输出详细信息 -->
  65.                     <verbose>true</verbose>
  66.                     <!-- 覆盖生成文件 -->
  67.                     <overwrite>true</overwrite>
  68.                     <!-- 定义配置文件 -->
  69.                     <configurationFile>${basedir}/src/main/resources/generator-configuration.xml</configurationFile>
  70.                 </configuration>
  71.             </plugin>
  72.         </plugins>
  73.         <resources>
  74.             <resource>
  75.                 <directory>src/main/java</directory><!--所在的目录-->
  76.                 <includes><!--包括目录下的.properties,.xml文件都会扫描到-->
  77.                     <include>**/*.yaml</include>
  78.                     <include>**/*.xml</include>
  79.                 </includes>
  80.                 <filtering>false</filtering>
  81.             </resource>
  82.         </resources>
  83.     </build>
  1. spring:
  2.   application:
  3.     name: my-app
  4.   datasource:
  5.     url: jdbc:mysql://localhost:3306/fzs?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC&allowPublicKeyRetrieval=true
  6.     username: root
  7.     password: 123456
  8.     driver-class-name: com.mysql.cj.jdbc.Driver
  9. mybatis:
  10.   mapper-locations: /mapper/*.xml
  12.   jpa:
  13.     # 数据库类型
  14.     database: MySQL
  15.     hibernate:
  16.       ddl-auto: update
  17.     # -控制台显示sql语句
  18.     show-sql: true
  19.     # 是否自动创建数据库表
  20.     generate-ddl: true
  21.     database-platform: org.hibernate.dialect.MySQL5InnoDBDialect

使用mybatis的代码生成器

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE generatorConfiguration PUBLIC "-//mybatis.org//DTD MyBatis Generator Configuration 1.0//EN"
  3.         "http://mybatis.org/dtd/mybatis-generator-config_1_0.dtd">
  4. <!-- 配置生成器 -->
  5. <generatorConfiguration>
  7.   <context id="testTables" targetRuntime="MyBatis3">
  9.     <property name="beginningDelimiter" value="`"/>
  10.     <property name="endingDelimiter" value="`"/>
  12.     <property name="javaFileEncoding" value="UTF-8"/>
  14.     <!-- 生成注释配置 -->
  15.     <commentGenerator>
  16.       <!-- 是否去除自动生成的注释 true：是 ： false:否 -->
  17.       <property name="suppressAllComments" value="true"/>
  18.       <property name="javaFileEncoding" value="UTF8"/>
  19.       <!--生成的注释包含时间戳(避免重复提交SVN,设为true)-->
  20.       <property name="suppressDate" value="true"/>
  21.     </commentGenerator>
  22.     <!--数据库连接的信息：驱动类、连接地址、用户名、密码 -->
  23.     <!--
  24.         <jdbcConnection driverClass="oracle.jdbc.driver.OracleDriver"
  25.             connectionURL="jdbc:oracle:thin:@150.16.17.22:1521/wsbs" userId="hr"
  26.             password="hr123">
  27.         </jdbcConnection>-->
  28.     <jdbcConnection driverClass="com.mysql.cj.jdbc.Driver"
  29.                     connectionURL="jdbc:mysql://localhost:3306/fzs?useUnicode=true&amp;characterEncoding=utf8&amp;useSSL=false&amp;serverTimezone=UTC"
  30.                     userId="root"
  31.                     password="123456">
  32.     </jdbcConnection>
  34.     <!-- 默认false，把JDBC DECIMAL 和 NUMERIC 类型解析为 Integer，为 true时把JDBC DECIMAL 和
  35.             NUMERIC 类型解析为java.math.BigDecimal -->
  36.     <javaTypeResolver>
  37.       <property name="forceBigDecimals" value="false"/>
  38.     </javaTypeResolver>
  40.     <!-- targetProject:生成PO类的位置 -->
  41.     <javaModelGenerator targetPackage="com.hikktn.domain"
  42.                         targetProject="src\main\java">
  43.       <!-- enableSubPackages:是否让schema作为包的后缀 -->
  44.       <property name="enableSubPackages" value="false"/>
  45.       <!-- 从数据库返回的值被清理前后的空格 -->
  46.       <property name="trimStrings" value="true"/>
  47.     </javaModelGenerator>
  48.     <!-- targetProject:mapper.xml映射文件生成的位置 -->
  49.     <sqlMapGenerator targetPackage="mapper"
  50.                      targetProject="src\main\resources">
  51.       <!-- enableSubPackages:是否让schema作为包的后缀 -->
  52.       <property name="enableSubPackages" value="false"/>
  53.     </sqlMapGenerator>
  54.     <!-- targetPackage：mapper.java接口生成的位置 -->
  55.     <javaClientGenerator type="XMLMAPPER"
  56.                          targetPackage="com.hikktn.dao"
  57.                          targetProject="src\main\java">
  58.       <!-- enableSubPackages:是否让schema作为包的后缀 -->
  59.       <property name="enableSubPackages" value="false"/>
  60.     </javaClientGenerator>
  63.     <!-- 指定数据库表 -->
  64.     <!--  enableCountByExample="false" enableUpdateByExample="false" enableDeleteByExample="false"
  65.         enableSelectByExample="false" selectByExampleQueryId="false"-->
  66.     <!--不生成example-->
  67.     <!--<table tableName="items"></table> -->
  68.     <table schema="distribute" tableName="distribute_lock" domainObjectName="DistributeLock"
  69.            enableCountByExample="false" enableUpdateByExample="false" enableDeleteByExample="false"
  70.            enableSelectByExample="false" selectByExampleQueryId="false">
  71.       <!--下划线转驼峰命名-->
  72.       <property name="useActualColumnNames" value="false"/>
  73.       <!--指定自动生成主键的属性-->
  74.       <generatedKey column="id" sqlStatement="MySql" identity="true"></generatedKey>
  75.       <!--元素从将某些属性默认计算的值更改为指定的值。-->
  76.       <!--<columnOverride  column="message_content" javaType="List&lt;Teacher&gt;"></columnOverride >-->
  77.       <!--忽略字段-->
  78.       <!--<ignoreColumn column="file_id"></ignoreColumn>-->
  79.       <!--<ignoreColumn column="lyric_id"></ignoreColumn>-->
  80.     </table>
  83.   </context>
  84. </generatorConfiguration>

点击按钮，自动生成
image.png
然后，在启动类配置一下，读取mapper：

  1. @SpringBootApplication
  2. @EnableTransactionManagement
  3. @MapperScan("com.hikktn.dao")
  4. public class Application {
  6.     public static void main(String[] args) {
  7.         SpringApplication.run(Application.class, args);
  8.     }
  9. }

image.png
image.png
最后修改controller
image.png
在通过postman测试，访问两个应用，我们会发现当第一个请求到8080端口，数据库就会锁住，而第二个请求到8081端口时，这个数据就查询不出来，无法进行到下一步了。
甚至会出现数据库超时，从而造成报错！

image.png