• spring Boot使用Mybatis实践

    Mybatis作为一款优秀的持久层框架，具有简化SQL编写、灵活性、易于集成、等特点深受开发人员青睐，下文将为大家讲到在Spring Boot中如何使用Mybatis

    1、依赖引入

    数据库驱动

    1.         
    2.             mysql
    3.             mysql-connector-java
    4.             8.0.26
    5.

    数据源管理

    1.         
    2.             com.alibaba
    3.             druid-spring-boot-starter
    4.             1.2.8
    5.

     Mybatis

    1.         
    2.             org.mybatis.spring.boot
    3.             mybatis-spring-boot-starter
    4.             2.1.4
    5.

    2、配置信息

    数据源配置

    1. spring.datasource.druid.url=jdbc:mysql://IP:PORT/库名?characterEncoding=UTF-8&allowMultiQueries=true&useSSL=true
    2. spring.datasource.druid.username=用户名
    3. spring.datasource.druid.password=密码
    4. spring.datasource.druid.driver-class-name=com.mysql.jdbc.Driver
    5. spring.datasource.druid.type=com.alibaba.druid.pool.DruidDataSource
    6. spring.datasource.druid.max-idle=10
    7. spring.datasource.druid.max-active=20
    8. spring.datasource.druid.max-wait=10000
    9. spring.datasource.druid.min-idle=5
    10. spring.datasource.druid.initial-size=5
    11. #自动重连
    12. spring.datasource.druid.autoReconnect=true
    13. #连接空闲时是否执行健康检查
    14. spring.datasource.druid.test-while-idle=true
    15. #连接池用于健康检查的 SQL 语句。在每次获取连接时都会执行该语句来判断连接是否有效
    16. spring.datasource.druid.validation-query=SELECT 1
    17. #健康检查间隔时间，单位毫秒
    18. spring.datasource.druid.validation-interval=18000
    19. #连接最大寿命，单位毫秒
    20. spring.datasource.druid.max-lifetime=180000

     mybatis配置

    1. #mybatis
    2. #xml文件路径
    3. mybatis.mapper-locations=classpath:mybatis/*.xml
    4. logging.level.com.baomidou.mybatisplus=DEBUG
    5. #将mapper包下的日志级别设置为DEBUG
    6. logging.level.com.jd.XXX.mapper=DEBUG
    7. mybatis.configuration.log-impl=org.apache.ibatis.logging.slf4j.Slf4jImpl

    使Mybatis生效

    在Spring Boot启动主类上添加

    @MapperScan("com.jd.XX.mapper")//使用MapperScan批量扫描所有的Mapper接口；

    3、操作数据

    3.1、声明和数据表字段一一映射的简单对象

    1. package XXX;
    2.  
    3. import java.math.BigDecimal;
    4. import java.util.Date;
    5. import java.util.StringJoiner;
    6.  
    7. /**
    8.  * 企业商户
    9.  * User
    10.  * 数据库表：user
    11.  */
    12. public class User {
    13.  
    14.     /**
    15.      * 自增ID
    16.      * 表字段 : user.id
    17.      */
    18.     private Long id;
    19.  
    20.     private String merchantNo;
    21.  
    22.     private String registrationNo;
    23.  
    24.     /**
    25.      * 组织结构代码
    26.      */
    27.     private String organizationCode;
    28.  
    29.     /**
    30.      * 统一社会信用代码
    31.      */
    32.     private String companyUscc;
    33.  
    34.     private String companyName;
    35.  
    36.     private Integer companyType;
    37.  
    38.     private String role;
    39.  
    40.     /**
    41.      * 企业经营范围
    42.      */
    43.     private String companyScope;
    44.  
    45.     private String provinceName;
    46.  
    47.     /**
    48.      * 企业所在城市
    49.      * 表字段 : user.city_name
    50.      */
    51.     private String cityName;
    52.  
    53.     private BigDecimal creditScore;
    54.  
    55.     /**
    56.      * 企业地址
    57.      * 表字段 : user.address
    58.      */
    59.     private String address;
    60.  
    61.     /**
    62.      * 企业联系人
    63.      * 表字段 : user.contact
    64.      */
    65.     @Crypt
    66.     private String contact;
    67.  
    68.     private String contactCardType;
    69.  
    70.     private String contactCardNo;
    71.  
    72.     /**
    73.      * 企业法人证件正面图片地址
    74.      */
    75.     private String contactFaceUrl;
    76.  
    77.     /**
    78.      * 企业法人证件反面图片地址
    79.      */
    80.     private String contactConUrl;
    81.  
    82.     /**
    83.      * 手持证件照片地址
    84.      */
    85.     private String contactUrl;
    86.  
    87.     /**
    88.      * 企业联系人邮箱
    89.      * 表字段 : user.contact_tel
    90.      */
    91.     private String contactTel;
    92.  
    93.     /**
    94.      * 企业中征码
    95.      * 表字段 : user.crc_code
    96.      */
    97.     private String crcCode;
    98.  
    99.     /**
    100.      * 银行类型，国股 三农 城商
    101.      * 表字段 : user.is_bank_org
    102.      */
    103.     private Integer bankType;
    104.  
    105.     private Integer supportCredit;
    106.     private Integer isAuth;
    107.  
    108.     private String companyMold;
    109.  
    110.     /**
    111.      * 企业营业执照图片地址
    112.      */
    113.     private String companyUrl;
    114.  
    115.     /**
    116.      * 邮寄地址
    117.      */
    118.     private String mailingAddress;
    119.     private Integer acceptProtocol;
    120.  
    121.     private Date startTime;
    122.  
    123.     /**
    124.      * 逻辑删除字段：0正常，1删除
    125.      */
    126.     private Integer ldeleteFlag;
    127.  
    128.     /**
    129.      * 是否接受平台协议
    130.      */
    131.     public boolean hasAcceptProtocol() {
    132.         return this.acceptProtocol != null && this.acceptProtocol.equals(1);
    133.     }
    134.     /**
    135.      * 创建时间
    136.      * 表字段 : user.created_date
    137.      */
    138.     private Date createdDate;
    139.  
    140.     /**
    141.      * 修改时间
    142.      * 表字段 : user.modified_date
    143.      */
    144.     private Date modifiedDate;
    145.  
    146.     private Integer channel;
    147.  
    148.     /**
    149.      * 企业用户 id.
    150.      */
    151.     private String companyUserId;
    152.  
    153.     public Long getId() {
    154.         return id;
    155.     }
    156.  
    157.     /**
    158.      * 设置 自增ID 字段:user.id
    159.      *
    160.      * @param id the value for user.id, 自增ID
    161.      */
    162.     public void setId(Long id) {
    163.         this.id = id;
    164.     }
    165.  
    166.     public String getMerchantNo() {
    167.         return merchantNo;
    168.     }
    169.  
    170.     public void setMerchantNo(String merchantNo) {
    171.         this.merchantNo = merchantNo == null ? null : merchantNo.trim();
    172.     }
    173.  
    174.     public String getOrganizationCode() {
    175.         return organizationCode;
    176.     }
    177.  
    178.     public void setOrganizationCode(String organizationCode) {
    179.         this.organizationCode = organizationCode;
    180.     }
    181.  
    182.     public String getCompanyScope() {
    183.         return companyScope;
    184.     }
    185.  
    186.     public void setCompanyScope(String companyScope) {
    187.         this.companyScope = companyScope;
    188.     }
    189.  
    190.     public String getCompanyUscc() {
    191.         return companyUscc;
    192.     }
    193.  
    194.     public void setCompanyUscc(String companyUscc) {
    195.         this.companyUscc = companyUscc;
    196.     }
    197.  
    198.     public String getRegistrationNo() {
    199.         return registrationNo;
    200.     }
    201.  
    202.     public void setRegistrationNo(String registrationNo) {
    203.         this.registrationNo = registrationNo == null ? null : registrationNo.trim();
    204.     }
    205.  
    206.     /**
    207.      * 获取 企业名称 字段:user.company_name
    208.      *
    209.      * @return user.company_name, 企业名称
    210.      */
    211.     public String getCompanyName() {
    212.         return companyName;
    213.     }
    214.  
    215.     /**
    216.      * 设置 企业名称 字段:user.company_name
    217.      *
    218.      * @param companyName the value for user.company_name, 企业名称
    219.      */
    220.     public void setCompanyName(String companyName) {
    221.         this.companyName = companyName == null ? null : companyName.trim();
    222.     }
    223.  
    224.     public Integer getCompanyType() {
    225.         return companyType;
    226.     }
    227.  
    228.     public void setCompanyType(Integer companyType) {
    229.         this.companyType = companyType;
    230.     }
    231.  
    232.     public String getProvinceName() {
    233.         return provinceName;
    234.     }
    235.  
    236.     public void setProvinceName(String provinceName) {
    237.         this.provinceName = provinceName == null ? null : provinceName.trim();
    238.     }
    239.  
    240.     /**
    241.      * 获取 企业所在城市 字段:user.city_name
    242.      *
    243.      * @return user.city_name, 企业所在城市
    244.      */
    245.     public String getCityName() {
    246.         return cityName;
    247.     }
    248.  
    249.     /**
    250.      * 设置 企业所在城市 字段:user.city_name
    251.      *
    252.      * @param cityName the value for user.city_name, 企业所在城市
    253.      */
    254.     public void setCityName(String cityName) {
    255.         this.cityName = cityName == null ? null : cityName.trim();
    256.     }
    257.  
    258.     public BigDecimal getCreditScore() {
    259.         return creditScore;
    260.     }
    261.  
    262.     public void setCreditScore(BigDecimal creditScore) {
    263.         this.creditScore = creditScore;
    264.     }
    265.  
    266.     /**
    267.      * 获取 企业地址 字段:user.address
    268.      *
    269.      * @return user.address, 企业地址
    270.      */
    271.     public String getAddress() {
    272.         return address;
    273.     }
    274.  
    275.     /**
    276.      * 设置 企业地址 字段:user.address
    277.      *
    278.      * @param address the value for user.address, 企业地址
    279.      */
    280.     public void setAddress(String address) {
    281.         this.address = address == null ? null : address.trim();
    282.     }
    283.  
    284.     /**
    285.      * 获取 企业联系人 字段:user.contact
    286.      *
    287.      * @return user.contact, 企业联系人
    288.      */
    289.     public String getContact() {
    290.         return contact;
    291.     }
    292.  
    293.     /**
    294.      * 设置 企业联系人 字段:user.contact
    295.      *
    296.      * @param contact the value for user.contact, 企业联系人
    297.      */
    298.     public void setContact(String contact) {
    299.         this.contact = contact == null ? null : contact.trim();
    300.     }
    301.  
    302.     /**
    303.      * 获取 企业联系人邮箱 字段:user.contact_tel
    304.      *
    305.      * @return user.contact_tel, 企业联系人邮箱
    306.      */
    307.     public String getContactTel() {
    308.         return contactTel;
    309.     }
    310.  
    311.     /**
    312.      * 设置 企业联系人邮箱 字段:user.contact_tel
    313.      *
    314.      * @param contactTel the value for user.contact_tel, 企业联系人邮箱
    315.      */
    316.     public void setContactTel(String contactTel) {
    317.         this.contactTel = contactTel == null ? null : contactTel.trim();
    318.     }
    319.  
    320.     /**
    321.      * 获取 企业中征码 字段:user.crc_code
    322.      *
    323.      * @return user.crc_code, 企业中征码
    324.      */
    325.     public String getCrcCode() {
    326.         return crcCode;
    327.     }
    328.  
    329.     /**
    330.      * 设置 企业中征码 字段:user.crc_code
    331.      *
    332.      * @param crcCode the value for user.crc_code, 企业中征码
    333.      */
    334.     public void setCrcCode(String crcCode) {
    335.         this.crcCode = crcCode == null ? null : crcCode.trim();
    336.     }
    337.  
    338.     public Integer getBankType() {
    339.         return bankType;
    340.     }
    341.  
    342.     public User setBankType(Integer bankType) {
    343.         this.bankType = bankType;
    344.         return this;
    345.     }
    346.  
    347.     /**
    348.      * 获取 是否支持授信 字段:user.support_credit
    349.      *
    350.      * @return user.support_credit, 是否支持授信
    351.      */
    352.     public Integer getSupportCredit() {
    353.         return supportCredit;
    354.     }
    355.  
    356.     /**
    357.      * 设置 是否支持授信 字段:user.support_credit
    358.      *
    359.      * @param supportCredit the value for user.support_credit, 是否支持授信
    360.      */
    361.     public void setSupportCredit(Integer supportCredit) {
    362.         this.supportCredit = supportCredit;
    363.     }
    364.  
    365.     public Integer getIsAuth() {
    366.         return isAuth;
    367.     }
    368.  
    369.     public void setIsAuth(Integer isAuth) {
    370.         this.isAuth = isAuth;
    371.     }
    372.  
    373.     /**
    374.      * 获取 创建时间 字段:user.created_date
    375.      *
    376.      * @return user.created_date, 创建时间
    377.      */
    378.     public Date getCreatedDate() {
    379.         return createdDate;
    380.     }
    381.  
    382.     /**
    383.      * 设置 创建时间 字段:user.created_date
    384.      *
    385.      * @param createdDate the value for user.created_date, 创建时间
    386.      */
    387.     public void setCreatedDate(Date createdDate) {
    388.         this.createdDate = createdDate;
    389.     }
    390.  
    391.     /**
    392.      * 获取 修改时间 字段:user.modified_date
    393.      *
    394.      * @return user.modified_date, 修改时间
    395.      */
    396.     public Date getModifiedDate() {
    397.         return modifiedDate;
    398.     }
    399.  
    400.     /**
    401.      * 设置 修改时间 字段:user.modified_date
    402.      *
    403.      * @param modifiedDate the value for user.modified_date, 修改时间
    404.      */
    405.     public void setModifiedDate(Date modifiedDate) {
    406.         this.modifiedDate = modifiedDate;
    407.     }
    408.  
    409.     public String getContactCardType() {
    410.         return contactCardType;
    411.     }
    412.  
    413.     public void setContactCardType(String contactCardType) {
    414.         this.contactCardType = contactCardType;
    415.     }
    416.  
    417.     public String getContactCardNo() {
    418.         return contactCardNo;
    419.     }
    420.  
    421.     public void setContactCardNo(String contactCardNo) {
    422.         this.contactCardNo = contactCardNo;
    423.     }
    424.  
    425.     public String getContactFaceUrl() {
    426.         return contactFaceUrl;
    427.     }
    428.  
    429.     public void setContactFaceUrl(String contactFaceUrl) {
    430.         this.contactFaceUrl = contactFaceUrl;
    431.     }
    432.  
    433.     public String getContactConUrl() {
    434.         return contactConUrl;
    435.     }
    436.  
    437.     public void setContactConUrl(String contactConUrl) {
    438.         this.contactConUrl = contactConUrl;
    439.     }
    440.  
    441.     public String getContactUrl() {
    442.         return contactUrl;
    443.     }
    444.  
    445.     public void setContactUrl(String contactUrl) {
    446.         this.contactUrl = contactUrl;
    447.     }
    448.  
    449.     public String getCompanyMold() {
    450.         return companyMold;
    451.     }
    452.  
    453.     public void setCompanyMold(String companyMold) {
    454.         this.companyMold = companyMold;
    455.     }
    456.  
    457.     public String getCompanyUrl() {
    458.         return companyUrl;
    459.     }
    460.  
    461.     public void setCompanyUrl(String companyUrl) {
    462.         this.companyUrl = companyUrl;
    463.     }
    464.  
    465.     public String getMailingAddress() {
    466.         return mailingAddress;
    467.     }
    468.  
    469.     public void setMailingAddress(String mailingAddress) {
    470.         this.mailingAddress = mailingAddress;
    471.     }
    472.  
    473.     public Integer getAcceptProtocol() {
    474.         return acceptProtocol;
    475.     }
    476.  
    477.     public String getRole() {
    478.         return role;
    479.     }
    480.  
    481.     public void setRole(String role) {
    482.         this.role = role;
    483.     }
    484.  
    485.     public User setAcceptProtocol(Integer acceptProtocol) {
    486.         this.acceptProtocol = acceptProtocol;
    487.         return this;
    488.     }
    489.  
    490.     public Date getStartTime() {
    491.         return startTime;
    492.     }
    493.  
    494.     public User setStartTime(Date startTime) {
    495.         this.startTime = startTime;
    496.         return this;
    497.     }
    498.  
    499.     public Integer getChannel() {
    500.         return channel;
    501.     }
    502.  
    503.     public void setChannel(Integer channel) {
    504.         this.channel = channel;
    505.     }
    506.  
    507.     public String getCompanyUserId() {
    508.         return companyUserId;
    509.     }
    510.  
    511.     public void setCompanyUserId(String companyUserId) {
    512.         this.companyUserId = companyUserId;
    513.     }
    514.  
    515.     public Integer getLdeleteFlag() {
    516.         return ldeleteFlag;
    517.     }
    518.  
    519.     public User setLdeleteFlag(Integer ldeleteFlag) {
    520.         this.ldeleteFlag = ldeleteFlag;
    521.         return this;
    522.     }
    523.  
    524.   
    525. }

    3.2、编写操作语句

    在resources目录下，新建mybatis文件夹，新建表名.xml文件

    1. "1.0" encoding="UTF-8"?>
    2. "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    3. "com.xx.mapper.UserMapper">
    5.     "BaseResultMap" type="com.xx.User">
    6.         "id" jdbcType="BIGINT" property="id"/>
    7.         "merchant_no" jdbcType="VARCHAR" property="merchantNo"/>
    8.         "company_user_id" jdbcType="VARCHAR" property="companyUserId"/>
    9.         "registration_no" jdbcType="VARCHAR" property="registrationNo"/>
    10.         "organization_code" jdbcType="VARCHAR" property="organizationCode"/>
    11.         "company_uscc" jdbcType="VARCHAR" property="companyUscc"/>
    12.         "company_scope" jdbcType="VARCHAR" property="companyScope"/>
    13.         "company_name" jdbcType="VARCHAR" property="companyName"/>
    14.         "company_type" jdbcType="TINYINT" property="companyType"/>
    15.         "role" jdbcType="VARCHAR" property="role"/>
    16.         "company_mold" jdbcType="VARCHAR" property="companyMold"/>
    17.         "company_url" jdbcType="VARCHAR" property="companyUrl"/>
    18.         "province_name" jdbcType="VARCHAR" property="provinceName"/>
    19.         "city_name" jdbcType="VARCHAR" property="cityName"/>
    20.         "credit_score" jdbcType="DECIMAL" property="creditScore"/>
    21.         "address" jdbcType="VARCHAR" property="address"/>
    22.         "contact" jdbcType="VARCHAR" property="contact"/>
    23.         "contact_tel" jdbcType="VARCHAR" property="contactTel"/>
    24.         "contact_card_type" jdbcType="VARCHAR" property="contactCardType"/>
    25.         "contact_card_no" jdbcType="VARCHAR" property="contactCardNo"/>
    26.         "contact_face_url" jdbcType="VARCHAR" property="contactFaceUrl"/>
    27.         "contact_con_url" jdbcType="VARCHAR" property="contactConUrl"/>
    28.         "contact_url" jdbcType="VARCHAR" property="contactUrl"/>
    29.         "crc_code" jdbcType="VARCHAR" property="crcCode"/>
    30.         "bank_type" jdbcType="INTEGER" property="bankType"/>
    31.         "support_credit" jdbcType="TINYINT" property="supportCredit"/>
    32.         "is_auth" jdbcType="TINYINT" property="isAuth"/>
    33.         "mailing_address" jdbcType="VARCHAR" property="mailingAddress"/>
    34.         "accept_protocol" jdbcType="TINYINT" property="acceptProtocol"/>
    35.         "start_time" jdbcType="TIMESTAMP" property="startTime"/>
    36.         "created_date" jdbcType="TIMESTAMP" property="createdDate"/>
    37.         "modified_date" jdbcType="TIMESTAMP" property="modifiedDate"/>
    38.         "ldelete_flag" jdbcType="TINYINT" property="ldeleteFlag"/>
    39.     
    40.  
    41.     "Base_Column_List">
    42.         id, merchant_no, company_user_id, registration_no, company_name, company_type,role, province_name, city_name,
    43.         address, contact, contact_tel, crc_code, bank_type, support_credit, is_auth, created_date,
    44.         modified_date, company_mold, company_url,contact_card_type, contact_card_no,contact_face_url,
    45.         contact_con_url,contact_url, organization_code,
    46.         company_uscc,company_scope,mailing_address,accept_protocol,start_time,credit_score, ldelete_flag
    47.     
    48.  
    49.     
    50.

    3.3、定义Mapper接口

    1. package xx.mapper;
    2.  
    3. import com.xx.User;
    4. import org.apache.ibatis.annotations.Mapper;
    5. import org.apache.ibatis.annotations.Param;
    6.  
    7. import java.util.List;
    8. @Mapper
    9. public interface UserMapper {
    10. 	
    11. 	/**
    12. 	 * 根据商户号查询用户信息
    13. 	 * @param merchantNo	商户号
    14. 	 * @return	商户信息
    15. 	 */
    16. 	User findByMerchantNo(String merchantNo);
    17.  
    18. }

     此处的接口名应与xml文件中select查询语句中的id一致。

    3.4、测试

    使用单元测试框架进行测试

    1. @Autowired
    2. 	UserMapper userMapper;
    3. @Test
    4. void test(){
    5. userMapper.findByMerchantNo();
    6. }

    4、常见问题

    4.1、spring Boot中mybatis是怎样自动获取DataSource的

    在Spring Boot中，MyBatis的整合通常会依赖于Spring Boot的自动配置和注解驱动。MyBatis在Spring Boot中自动获取DataSource的过程主要涉及以下几个关键点：

    依赖配置： 在pom.xml（如果是Maven项目）中引入Spring Boot Starter和MyBatis的相关依赖。例如：

    2.     
    3.     
    4.         org.mybatis.spring.boot
    5.         mybatis-spring-boot-starter
    6.         2.2.0 
    7.     
    8.     
    9.     
    10.     
    11.         com.h2database
    12.         h2
    13.         runtime
    14.

    数据源配置： 在application.properties或application.yml中配置数据源信息，Spring Boot会根据这些配置自动创建DataSource Bean。例如：

    1. spring.datasource.url=jdbc:mysql://localhost:3306/mydatabase
    2. spring.datasource.username=myuser
    3. spring.datasource.password=mypassword
    4. spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

    MyBatis配置： Spring Boot提供了自动配置，会根据依赖和配置自动创建SqlSessionFactory和SqlSessionTemplate。你可以在application.properties或application.yml中配置MyBatis相关属性，例如：

    mybatis.mapper-locations=classpath:/mapper/*.xml

    这里指定了MyBatis的Mapper文件所在的位置。

    使用注解： 在MyBatis的Mapper接口上使用@Mapper注解，或者在Spring Boot的主应用程序类上使用@MapperScan注解扫描Mapper接口所在的包。

    1. // 在主应用程序类上使用@MapperScan
    2. @SpringBootApplication
    3. @MapperScan("com.example.mapper")
    4. public class MyApplication {
    5.     public static void main(String[] args) {
    6.         SpringApplication.run(MyApplication.class, args);
    7.     }
    8. }

    或者在Mapper接口上使用@Mapper注解：

    1. @Mapper
    2. public interface UserMapper {
    3.     // ...
    4. }

    总的来说，Spring Boot会根据约定和配置自动创建数据源，并将其注入到MyBatis中，使得整合过程非常便捷。只需配置相关属性，使用注解标注Mapper接口，Spring Boot就能完成自动化的MyBatis整合

  • 相关阅读:
    华为数通方向HCIP-DataCom H12-821题库(单选题：221-240)
    java版工程管理系统Spring Cloud+Spring Boot+Mybatis实现工程管理系统源码
    接口测试工具Postman的基本使用
    Python open with as---文件处理
    A - Til the Cows Come Home
    数字时代 低代码赋能新零售系统
    26 WEB漏洞-XSS跨站之订单及Shell箱子反杀记
    线程的6种状态
    小程序源码：王者荣耀吃鸡气泡等等头像框DIY在线生成N种风格-多玩法安装简单
    【字符串】后缀数组
  • 原文地址：https://blog.csdn.net/weixin_43447989/article/details/133715487