手牵手SpringBoot之ORM操作MySql

举报
QGS 发表于 2023/04/10 20:40:06 2023/04/10
【摘要】 手牵手SpringBoot之ORM操作MySql


总体框架


@Mapper注解

@Mapper注解:放在dao接口上面。表示该接口会由Mybaits创建mapper代理对象

@MapperScan注解

在主类中使用@MapperScan注解,可解决多个dao接口中使用@Mapper注解的繁琐。

@MapperScan("com.example.dao")
或@MapperScan(basePackages = "com.example.dao")




Pom.xml配置文件

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">

    <modelVersion>4.0.0</modelVersion>

    <parent>

        <groupId>org.springframework.boot</groupId>

        <artifactId>spring-boot-starter-parent</artifactId>

        <version>2.7.10</version>

        <relativePath/> <!-- lookup parent from repository -->

    </parent>

    <groupId>com.example</groupId>

    <artifactId>springboot-Mybatis</artifactId>

    <version>0.0.1-SNAPSHOT</version>

    <name>springboot-Mybatis</name>

    <description>springboot-Mybatis</description>

    <properties>

        <java.version>1.8</java.version>

    </properties>

    <dependencies>

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-web</artifactId>

        </dependency>

        <dependency>

            <groupId>org.mybatis.spring.boot</groupId>

            <artifactId>mybatis-spring-boot-starter</artifactId>

            <version>2.3.0</version>

        </dependency>



        <dependency>

            <groupId>com.mysql</groupId>

            <artifactId>mysql-connector-j</artifactId>

            <scope>runtime</scope>

        </dependency>

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-test</artifactId>

            <scope>test</scope>

        </dependency>

    </dependencies>

    <build>

        <resources>

            <resource>

                <!--所在的目录-->

                <directory>src/main/java</directory>

                <includes>

                    <!--包括目录下的.properties .xml文件都会扫描到-->

                    <include>**/*.properties</include>

                    <include>**/*.xml</include>

                </includes>

                <filtering>false</filtering>

            </resource>

        </resources>

        <plugins>

            <plugin>

                <groupId>org.springframework.boot</groupId>

                <artifactId>spring-boot-maven-plugin</artifactId>

            </plugin>

        </plugins>

    </build>

</project>


创建Dao接口与Mapper文件

dao

//@Mapper //表示该接口会创建mapper代理

public interface StaffDao {

    //查询所有

    List<Staff> selectALL();

}

Mapper

<?xml version="1.0" encoding="UTF-8" ?>

<!DOCTYPE mapper

        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"

        "https://mybatis.org/dtd/mybatis-3-mapper.dtd">

<mapper namespace="com.example.dao.StaffDao">



    <select id="selectALL" resultType="com.example.pojo.Staff">

        SELECT * FROM staff;

    </select>

</mapper>

Pojo

public class Staff {

    private int id;

    private String name;

    private String diploma;

    private String title;

    private String marriage;

    private String status;

    private String workTime;
        //get+set+toString
}

 

Server接口

public interface StaffService {

    List<Staff> selectALL();

}

 

Server实现类

@Service

public class StaffServiceImpl implements StaffService {

    @Resource

    private StaffDao staffDao;

    @Override

    public List<Staff> selectALL() {

        List<Staff> staffs = staffDao.selectALL();

        return staffs;

    }

}

application.properties配置文件

#application.properties配置文件

server.port=8080

server.servlet.context-path=/boot



#指定时区

serverTimezone=Asia/Shanghai

#serverTimezone=GMT%2B8



#连接数据库

spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

spring.datasource.url=jdbc:mysql://IP:3306/mysql?useUnicode=true&characterEncoding=UTF-8

spring.datasource.username=root

spring.datasource.password=pwd

Application类启动

浏览器访问

Daomapper分开管理


需要在application.properties配置mapper路径


#指定mapper文件路径

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

Pom.xml配置

<resources>

    <resource>

        <!--所在的目录-->

        <directory>src/main/resources</directory>

        <includes>

            <!--包括目录下的所有文件都会扫描到-->

            <include>**/*.*</include>

        </includes>

        <filtering>false</filtering>

    </resource>

</resources>

开启Mybatis日志

application.properties配置

#配置mybatis启动日志

mybatis.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl


开启事务控制

事务管理器:DataSourceTransactionManager

Spring实现事务的两种方式

编程式事务:编写代码来实现事务的管理

声明式事务*:基于注解的方式、基于xml配置方式

声明式事务处理

只需要通过配置就可以完成对事务的管理,而无需手动编程。

 

事务隔离级别的四个级别:

读未提交:READ_UNCOMMITTEN

       这种隔离级别:存在脏读问题,所谓的脏读(dirty read)表示能够读取到其他事务未提交的数据。

读提交:READ_COMMITTED            (oracle)

       解决了脏读问题,其他事务提交之后才能读到,但存在不可重复读问题

可重复读:REPEATABLE_READ     (MYSQL)

       解决了不可重复读,可以达到可重复读效果,只要当前事务不结束,读取到的数据移植都是一样的。但存在幻读问题。

序列化:SERIALLZABLE

       解决了幻读问题,事务排毒执行。不支持并发。

 

事务处理方式:1Spring框架的@Transaction注解。2aspectj框架xml配置,声明事务控制的内容。

SpringBoot中事务的使用的两种方式:1、业务方法上使用@Transaction注解。2、启动类使用@EnableTransactionManagement


application.properties配置

#application.properties配置文件
server.port=8080
server.servlet.context-path=/boot

#指定时区
serverTimezone=Asia/Shanghai


#连接数据库
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
#serverTimezone=GMT%2B8
spring.datasource.url=jdbc:mysql://IP:3306/mysql?useUnicode=true&characterEncoding=UTF-8
spring.datasource.username=root
spring.datasource.password=pwd

#指定mapper文件路径
mybatis.mapper-locations=classpath:mapper/*.xml
#配置mybatis启动日志
mybatis.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl

Server层实现

public interface StaffServer {

    int insert(Staff staff);

    Staff selectById(Integer id);

}

 

@Service
public class StaffServerImpl implements StaffServer {

    @Resource
    private StaffMapper staffDao;

    @Transactional
    @Override
    public int insert(Staff staff) {
        int insert = staffDao.insert(staff);
        return insert;
    }

    @Transactional
    @Override
    public Staff selectById(Integer id) {
        Staff staff = staffDao.selectByPrimaryKey(id);
        return staff;
    }

}

 

Controller

@Controller

public class StaffController {

    @Resource
    private StaffServer staffServer;

    @RequestMapping("/selectById")
    @ResponseBody
    public String selectById(int id){
        System.out.println("id:"+id);
        Staff staff = staffServer.selectById(id);
        System.out.println(staff.toString());
        return staff.toString();
    }
}


使用Mybatis生成器

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE generatorConfiguration
        PUBLIC "-//mybatis.org//DTD MyBatis Generator Configuration 1.0//EN"
        "http://mybatis.org/dtd/mybatis-generator-config_1_0.dtd">

<generatorConfiguration>

    <!-- 指定连接数据库的JDBC驱动包所在位置,指定到你本机的完整路径,需确保本地路径下存在该jar -->
    <classPathEntry location="C:\Users\13631\.m2\repository\com\mysql\mysql-connector-j\8.0.32\mysql-connector-j-8.0.32.jar"/>

    <!-- 配置table表信息内容体,targetRuntime指定采用MyBatis3的版本 -->
    <context id="tables" targetRuntime="MyBatis3">
        <!--序列化-->
        <plugin type="org.mybatis.generator.plugins.SerializablePlugin"/>

        <!--以下需要插件  -->

        <!--
            插入成功后返回ID
           <plugin type="cn.doity.common.generator.plugin.InsertAndReturnKeyPlugin"/>

           分页查询功能
           <plugin type="cn.doity.common.generator.plugin.SelectByPagePlugin"/>

           生成带有for update后缀的select语句插件
           <plugin type="cn.doity.common.generator.plugin.SelectForUpdatePlugin"/> -->


        <!-- 抑制生成注释,由于生成的注释都是英文的,可以不让它生成 -->
        <commentGenerator>
            <property name="suppressAllComments" value="true" />
        </commentGenerator>


        <!-- 配置数据库连接信息 -->
        <jdbcConnection driverClass="com.mysql.cj.jdbc.Driver"
                        connectionURL="jdbc:mysql://IP:3306/mysql?useUnicode=true&amp;characterEncoding=UTF-8&amp;#serverTimezone=GMT%2B8"
                        userId="root"
                        password="pwd">
        </jdbcConnection>

        <!-- 生成model(pojo)类,targetPackage指定model类的包名, targetProject指定生成的model放在eclipse的哪个工程下面-->
        <javaModelGenerator
                targetPackage="com.example.pojo"
                targetProject="src/main/java">
            <property name="enableSubPackages" value="false" />
            <property name="trimStrings" value="false" />
        </javaModelGenerator>

        <!-- 生成MyBatis的Mapper.xml文件,targetPackage指定mapper.xml文件的包名, targetProject指定生成的mapper.xml放在eclipse的哪个工程下面 -->
        <sqlMapGenerator
                targetPackage="mapper"
                targetProject="src/main/resources">
            <property name="enableSubPackages" value="false" />
        </sqlMapGenerator>

        <!-- 生成MyBatis的dao接口类文件,targetPackage指定dao接口类的包名, targetProject指定生成的Mapper接口放在eclipse的哪个工程下面 -->
        <javaClientGenerator type="XMLMAPPER"
                             targetPackage="com.example.dao"
                             targetProject="src/main/java">
            <property name="enableSubPackages" value="false" />
        </javaClientGenerator>

        <!-- 数据库表名及对应的Java模型类名 -->
        <table tableName="staff" domainObjectName="Staff"
               enableCountByExample="false"
               enableUpdateByExample="false"
               enableDeleteByExample="false"
               enableSelectByExample="false"
               selectByExampleQueryId="false"/>
    </context>
</generatorConfiguration>


生成

Application

@SpringBootApplication

@EnableTransactionManagement

@MapperScan("com.example.dao")

public class Application {

    public static void main(String[] args) {

        SpringApplication.run(Application.class, args);

    }

}


浏览器访问:

http://localhost:8080/boot/selectById?id=2

【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。