使用MyBatis操作数据库

news2024/11/15 12:09:36

hi,大家好,今天为大家带来MyBatis操作数据库的知识
在这里插入图片描述

文章目录

  • 🐷1.根据MyBatis操作数据库
    • 🧊1.1查询操作
      • 🍇1.1.1无参查询
      • 🍇1.1.2有参查询
    • 🧊1.2删除操作
    • 🧊1.3修改操作
    • 🧊1.4增加操作
    • 🧊1.5特殊的添加:返回自增id
    • 🧊1.6like查询
    • 🧊1.7多表查询
      • 🍇1.7.1一对一查询
      • 🍇1.7.2一对多查询
    • 🧊1.8动态sql
  • 🐷2.动态标签
    • 🧊2.1 <if>标签
    • 🧊2.2<trim>标签
    • 🧊2.3<where>标签
    • 🧊2.4<set>标签
    • 🧊2.5<foreach>标签

🐷1.根据MyBatis操作数据库

1.接口:方法的声明(给Service层调用)
2. XML:实现接口

🧊1.1查询操作

🍇1.1.1无参查询

1.定义接口

@Mapper//代表数据持久层
public interface UserMapper {
        List<Userinfo> getAll();
}

2.在xml里面写接口的实现
在这里插入图片描述
这里的namespace里面的内容表明了当前xml实现的是哪个接口,和文件名关系不大

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.example.demo.mapper.UserMapper">

    <select id="getAll" resultType="com.example.demo.model.Userinfo">
        select * from userinfo
    </select>
</mapper>

根据接口写测试类

package com.example.demo.mapper;

import com.example.demo.model.Userinfo;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.test.context.SpringBootTest;

import java.util.List;

import static org.junit.jupiter.api.Assertions.*;

/**
 * Created with IntelliJ IDEA.
 * Description:
 * User: WHY
 * Date: 2023-08-08
 * Time: 9:56
 */
@SpringBootTest //不能省略,表明当前测试程序当前项目是运行在spring boot项目中的
class UserMapperTest {
    @Autowired
    private UserMapper userMapper;

    @Test
    void getAll() {
        List<Userinfo> list=userMapper.getAll();
        System.out.println(list);
    }
}

在这里插入图片描述
从结果中可以看到运行是成功的,打印了sql语句,也打印了结果
为了方便开发MyBatis,实现XML和对应的接口之间的快速跳转,我们可以安装一个MyBatisX插件
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
红色的小鸟和蓝色的小鸟相互点击就可以跳转

🍇1.1.2有参查询

在这里插入图片描述

    <select id="getById" resultType="com.example.demo.model.Userinfo">
        select * from userinfo where id=${uid}
    </select>

在这里插入图片描述
在这里插入图片描述
加上这个@Param注解,在传参的时候就必须用该注解里面的名字
我们可以测试一下
在这里插入图片描述
在这里插入图片描述
错误显示说ID不存在
改成id
在这里插入图片描述
在这里插入图片描述
运行成功了

MyBatis有参查询的时候传递参数的方法有两个
1.使用$符

在这里插入图片描述这俩相对应,结果 显示的是直接替换,也叫做及时执行
在这里插入图片描述

这是直接将id位置的数字替换成出传过来的参数
2.采用#
运行结果是采用了JDBC里面那种占位符的形式

在这里插入图片描述
意味sql执行是预编译执行的
问题:${}和#{}的区别

1.${}是直接替换,#{}是预执行

2.${}不安全,存在sql注入,#{}安全,不存在sql注入

sql注入:使用一些特殊的sql语句完成一些非法操作,比如一个登录功能,只有用户名和密码均输入正确,才能登录成功,但是当密码胡乱输入也登陆成功,也就是sql注入

${}可以实现的功能#{}都能实现.

👀👀👀而且${}还存在sql注入的问题,为啥还要用它?

因为有一种场景预编译做不到!

比如在网上购物时,浏览商品的时候有按照价格升序或者降序,此时如果使用#{}那么就会把升序或者降序当做value值,加一个单引号,那么在sql语句中自然是错误的,使用${}就直接替换,采用string拼接的方式,不会报错,举个例子
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

换成$符号
在这里插入图片描述
在这里插入图片描述
运行成功了

总结:$应用场景:当业务需要传递sql命令的时候

注意事项:使用$符传的的参数一定要被穷举
我们刚才的例子里面参数可以被穷举,一个是asc,一个是desc,符合条件

🧊1.2删除操作

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
因为id=85的用户压根不存在
在这里插入图片描述

在这里插入图片描述
当在测试的时候想要保证不影响数据库的数据,可以加上一个transitional注解,代表开启是事务,可以回滚
在这里插入图片描述

在这里插入图片描述
我们可以看到受影响的行数,但是也不影响数据库的数据
在这里插入图片描述
注意但类中属性和数据库表中的字段名不一样时.查询结果可能为null

解决办法:

🥝1.将类名属性和表中字段名改为一致
🥝2.使用sqi语句的as进行字段名重命名
在这里插入图片描述

在这里插入图片描述

🥝3.定义一个resultMap,将属性名和字段名进行手动映射
在这里插入图片描述

在这里插入图片描述

<resultMap id="AseMap" type="com.example.demo.model.Userinfo">
    <id column="id" property="id"></id>
    <result column="username" property="name"></result>
    <result column="password" property="password"></result>
    <result column="photo" property="photo"></result>
    <result column="createtime" property="createtime"></result>
    <result column="updatetime" property="updatetime"></result>
    <result column="state" property="state"></result>
</resultMap>

column代表的是字段名,property代表的是属性名
在这里插入图片描述
在这里插入图片描述
可以看到显示了名字

🧊1.3修改操作

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

在这里插入图片描述
在这里插入图片描述
可以看到修改成功
修改,删除,增加都默认返回受影响的行数

🧊1.4增加操作

在这里插入图片描述
在这里插入图片描述

在这里插入图片描述
在这里插入图片描述
插入成功

🧊1.5特殊的添加:返回自增id

在这里插入图片描述

<insert id="add2" useGeneratedKeys="true" keyColumn="id" keyProperty="id">
        insert into userinfo(username,password,photo) values(#{username},#{password},#{photo})
    </insert>

在这里插入图片描述

 @Test
    void add2() {
        Userinfo userinfo=new Userinfo();
        userinfo.setUsername("詹妮");
        userinfo.setPassword("5896");
        userinfo.setPhoto("null");
        int result=userMapper.add2(userinfo);
        System.out.println("受影响的行数"+result+"id"+userinfo.getId());
    }

为什么我这里没有设置id我却可以使用getid方法?
因为数据库的id已经设置到了该属性中

在这里插入图片描述
在这里插入图片描述

🧊1.6like查询

List<Userinfo> getByLike();

<select id="getByLike" resultType="com.example.demo.model.Userinfo">
        select * from userinfo where username like '_%三'
    </select>
 @Test
    void getByLike() {
        List<Userinfo> list=userMapper.getByLike();
        System.out.println(list.toString());
    }

在这里插入图片描述
当查询的时候不一定是按照这个字匹配,可以换成一个动态的,把匹配条件放到测试类里面

<select id="getByLike" resultType="com.example.demo.model.Userinfo">
        select * from userinfo where username like #{username}
    </select>
  @Test
    void getByLike() {
        String username="_三%";
        List<Userinfo> list=userMapper.getByLike(username);
        System.out.println(list.toString());
    }

在这里插入图片描述
2.使用mysql内置函数concat

<select id="getByLike" resultType="com.example.demo.model.Userinfo">
        select * from userinfo where username like concat('%',#{username},'%')
    </select>
 @Test
    void getByLike() {
        String username="三";
        List<Userinfo> list=userMapper.getByLike(username);
        System.out.println(list.toString());
    }
}

在这里插入图片描述

🧊1.7多表查询

🍇1.7.1一对一查询

在查询文章表的过程中显示用户姓名
我们不采用xml实现接口,我们采用注解的方式
增删改查都有对应的注解

package com.example.demo.model;

import lombok.Data;

import java.time.LocalDateTime;

/**
 * Created with IntelliJ IDEA.
 * Description:
 * User: WHY
 * Date: 2023-08-08
 * Time: 18:43
 */
@Data
public class Articleinfo {
    private int id;
    private  String title;
    private  String content;
    private LocalDateTime createtime;
    private LocalDateTime updatetime;
    private int uid;
    private int rcount;
    private int state;
    //联表字段
    private  String username;

}

@Mapper
public interface ArticleMapper {
    @Select("select * from articleinfo")
        List<Articleinfo> getAll();
}
package com.example.demo.mapper;

import com.example.demo.model.Articleinfo;
import com.example.demo.model.Userinfo;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

import java.util.List;

import static org.junit.jupiter.api.Assertions.*;

/**
 * Created with IntelliJ IDEA.
 * Description:
 * User: WHY
 * Date: 2023-08-08
 * Time: 18:52
 */
@SpringBootTest
class ArticleMapperTest {
    @Autowired
    private  ArticleMapper articleMapper

    @Test
    void getAll() {
        
        List<Articleinfo> list=articleMapper.getAll();

        System.out.println(list.toString());
        

    }
}

在这里插入图片描述
将联合查询的语写在注解里面即可

@Mapper
public interface ArticleMapper {
    @Select("select articleinfo.*,userinfo.username from articleinfo,userinfo where articleinfo.uid=userinfo.id")
        List<Articleinfo> getAll();
}

在这里插入图片描述

所以MyBatis不仅可以采用接口+xml实现
还可以采用接口+注解的方式实现

🍇1.7.2一对多查询

查询一个用户的多篇文章
我们采用线程的方式
一个查用户表,一个查文章表,最后拼接起来
先采用单线程的方式来写

@Data
public class Userinfo {
    //这里的属性要和数据库表的字段对应
    private int  id;
    private  String username;
    private String password;
    private String photo;
    private LocalDateTime createtime;
    private LocalDateTime updatetime;
    private  int state;
    private List<Articleinfo> article;
}
 List<Userinfo> getByLike(@Param("username") String username);
        @Select("select * from userinfo where id=#{id}")
       Userinfo getByid(@Param("id") Integer id);
@Select("select * from articleinfo where uid=#{uid}")
    List<Articleinfo> getByarticle(@Param("uid") Integer uid);
 @Test
    void getUserList(){
        int uid=1;
        //1.先根据uid查询用户表
       Userinfo userinfo= userMapper.getByid(uid);
        System.out.println(userinfo);
        //2.根据uid查询文章
     List<Articleinfo> list=  articleMapper.getByarticle(uid);
     //组装数据
     userinfo.setArticle(list);
        System.out.println(userinfo);

    }
}

在这里插入图片描述

采用多线程的方式

 @Test
    void getUserList(){
        int uid=1;
        //定义线程池
        ThreadPoolExecutor threadPoolExecutor=new ThreadPoolExecutor(5,10,3000, TimeUnit.SECONDS,
                new LinkedBlockingDeque<>(100));
       final Object[] result=new Object[2];
        //1.先根据uid查询用户表
        threadPoolExecutor.submit(new Runnable() {
            @Override
            public void run() {
           result[0] =    userMapper.getByid(uid);
            }
        });
        //2.根据uid查询文章
        threadPoolExecutor.submit(new Runnable() {
            @Override
            public void run() {
           result[1]    = articleMapper.getByarticle(uid);
            }
        });
            //组装数据(等线程池执行结束以后)
        while (threadPoolExecutor.getTaskCount() !=
                threadPoolExecutor.getCompletedTaskCount()
        ) {

        }
        Userinfo userinfo=(Userinfo) result[0];
        userinfo.setArticle((List<Articleinfo>)result[1]);
        System.out.println(userinfo);

    }

在这里插入图片描述

🧊1.8动态sql

动态sql是MyBatis的强大特性之一
在填写某一个页面的时候,有些页面不需要填写,不插入这个字段
动态sql主要是在xml里面动态的进行判断
我们拿userinfo表中的photo来进行举例
在这里插入图片描述
看到photo默认是空
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
现在的问题是当不设定时photo啥也没有,符合预期,当设定photo的时候,就出现了值,我们想要的效果是当该字段默认为空,不可进行显示设置,所以我们需要使用标签

🐷2.动态标签

🧊2.1 标签

 <insert id="add3">
            insert into userinfo(username,password
            <if test="photo!=null">
                ,photo
            </if>
            )values(#{username},#{password}
            <if test="photo!=null">
                ,#{photo}
            </if>
            )
        </insert>

单元测试来一波~~~

 @Test
    void add3() {
        Userinfo userinfo=new Userinfo();
        userinfo.setUsername("张三");
        userinfo.setPassword("123");
        userinfo.setPhoto("dor.png");
        int result=userMapper.add3(userinfo);
        System.out.println("受影响的行数"+result);


    }

在这里插入图片描述
现在将photo的设定取消
在这里插入图片描述
在这里插入图片描述
可以看到没有photo再出现

🧊2.2标签

标签针对单个字段是选填项的时候比较方便,当所有字段都是选填项时,我们可以使用标签
标签中有如下属性:
prefix:表示整个语句块,以prefix的值作为前缀
suffix:表示整个语句块,以suffix的值作为后缀
prefixOverrides:表示整个语句块要去除掉的前缀
suffixOverrides:表示整个语句块要去除掉的后缀

<insert id="add4">
        insert into userinfo
        <trim  prefix="(" suffix=")" suffixOverrides=",">
        <if test="username!=null">
            username,
        </if>
            <if test="password!=null">
                password,
            </if>
            <if test="photo!=null">
                photo
            </if>
        </trim>
        values
        <trim prefix="(" suffix=")" suffixOverrides="," >
        <if test="username!=null">
            #{username},
        </if>
            <if test="password!=null">
                #{password},

            </if>
            <if test="photo!=null">
                #{photo}

            </if>
        </trim>
    </insert>

在这里插入图片描述

在这里插入图片描述

🧊2.3标签

该标签也是和标签一起使用的.但是仅仅使用在where查询当中

<select id="getBywhere" resultType="com.example.demo.model.Userinfo">
            select * from userinfo
        <where>
            <if test="id>0">
                id=#{id}
            </if>
            <if test="username!=null">
               and username=#{username}
            </if>
            <if test="photo!=null">
                and password=#{password}
            </if>
        </where>
    </select>

这个and为什么要加在属性的前面
在这里插入图片描述
在这里插入图片描述
可以看到没有sql语句,没有多余的and
这也恰恰体现了标签的特性
1.根据标签里面的内容决定是否生成关键字
2.去除最前面的and
那么where的功能用trim可以实现吗?
当然啦

 <select id="getBywhere" resultType="com.example.demo.model.Userinfo">
            select * from userinfo
        <trim prefix="where" prefixOverrides="and">
            <if test="id>0">
                id=#{id}
            </if>
            <if test="username!=null">
                and username=#{username}
            </if>
            <if test="photo!=null">
                and password=#{password}
            </if>
        </trim>
         </select>

🧊2.4标签

用来修改数据,有值生成set,去掉的是最后面的符号

<update id="update2">
        update userinfo
        <set>
            <if test="username!=null">
                username=#{username},
            </if>
            <if test="password!=null">
                password=#{password}

            </if>
            <if test="photo!=null">
                photo=#{photo}

            </if>

        </set>
        where id=#{id}
    </update>

在这里插入图片描述

🧊2.5标签

<foreach> 标签常用于遍历集合或数组类型的数据。其属性如下:

  • collection: 指定要遍历的集合或数组类型的数据
  • item: 指定遍历的集合中的元素别名,可以在标签中使用该别名访问元素
  • index: 指定遍历的集合中的元素索引别名,可以在标签中使用该别名访问元素索引
  • open: 指定遍历的开始标记
  • close: 指定遍历的结束标记
  • separator: 指定遍历元素之间的分隔符
  • javaType: 指定集合或数组所对应的 Java 类型,如果未指定,则 MyBatis 会自动选择最匹配的类型。

适用情况:适用于多条sql删除的时候
在这里插入图片描述

<delete id="deleteById2">
        delete from userinfo
        where id in
        <foreach collection="ids" open="(" close=")" item="id" separator=",">
                #{id}
        </foreach>
    </delete>
 @Test
    void deleteById2() {
        List<Integer> list =
                new ArrayList<Integer>() {{
                add(10);
                add(11);
                add(12);
                add(13);
                }};
        int result=userMapper.deleteById2(list);
        System.out.println("result"+result);

    }

在这里插入图片描述

这期的内容就到这,我们下期再见咯~~
在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/853748.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

quill 富文本编辑器 @提及

使用插件quill-mention&#xff0c;实现在quill 富文本编辑器使用或#提及用户。 1. 安装 npm install quill-mention --save2. 官方给的示例quill-mention import "quill-mention";const atValues [{ id: 1, value: "Fredrik Sundqvist" },{ id: 2, va…

产线信息化、智能化|汽车座椅产线中的RFID技术方案

引言 在今天的快速发展的制造业中&#xff0c;信息化和智能化已经成为不可或缺的部分。信息化和智能化能够极大地提高生产效率、减少浪费&#xff0c;降低成本&#xff0c;提升产品的质量。汽车座椅产线信息化和智能化是汽车座椅产线升级的重要方向&#xff0c;RFID技术方案在…

大多数单片机程序采用全局变量的形式是为什么呢?

内存占用的可预测性&#xff1a;在单片机程序中&#xff0c;可预测的内存占用是很重要的因素。静态分配可以在编译过程中确定所需的内存&#xff0c;并且分配过程在程序启动之前就已完成。这使得静态分配成为单片机程序的理想选择。栈空间的限制和风险&#xff1a;栈分配具有一…

嘉楠勘智k230开发板上手记录(四)--HHB神经网络模型部署工具

按照K230_AI实战_HHB神经网络模型部署工具.md&#xff0c;HHB文档&#xff0c;RISC-V 编译器和模拟器安装来 一、环境 1. 拉取docker 镜像然后创建docker容器并进入容器 docker pull hhb4tools/hhb:2.4.5 docker run -itd --namehhb2_4 -p 22 "hhb4tools/hhb:2.4.5"…

主调函数与被调函数之间的数据传递

在调用函数时&#xff0c;大多数情况下&#xff0c;主调函数都需要将有关数据传递给被调函数。这就是有参函数。在定义函数时指定的用来接收从主调函数传递过来的值的变量称为形参变量&#xff0c;简称形参&#xff0c;在主调函数的调用函数表达式中&#xff0c;函数名后面圆括…

Zabbix自动注册服务器及部署代理服务器

文章目录 一.zabbix自动注册1.什么是自动注册2.环境准备3.zabbix客户端配置4.在 Web 页面配置自动注册5.验证自动注册 二.部署 zabbix 代理服务器1.分布式监控的作用&#xff1a;2.环境部署3.代理服务器配置4.客户端配置5.web页面配置5.1 删除原来配置5.2 添加代理5.3 创建主机…

在x86下运行的Ubuntu系统上部署QEMU用于模拟RISC-V硬件系统

1.配置工作环境 sudo apt install gcc bison flex libncurses-dev ninja-build \pkg-config build-essential zlib1g-dev pkg-config libglib2.0-dev \binutils-dev libboost-all-dev autoconf libtool libssl-dev \libpixman-1-dev python-capstone virtualenv software-prop…

冶金作业VR虚拟仿真厂家

对于高风险行业来说&#xff0c;开展安全教育培训是企业的重点工作&#xff0c;传统培训逐渐跟不上时代变化和工人需求&#xff0c;冶金安全VR模拟仿真培训系统作为一种新型的教育和培训工具&#xff0c;借助VR虚拟现实技术为冶金行业的工人提供一个安全、高效的培训环境。 冶金…

看看这个硬盘备份方法,简单又好用!

为什么需要备份硬盘数据&#xff1f; 使用计算机的过程中&#xff0c;我们可能偶尔会遭遇各类挑战&#xff0c;如系统崩溃&#xff0c;病毒侵袭&#xff0c;硬盘坏扇区等等。这些问题都有可能引发数据丢失&#xff0c;甚至更严重的情况&#xff0c;使得计算机无法正常开机。…

总结 进程调度的基本过程

一.进程管理 一个运行起来的程序就是进程&#xff0c;点开一个软件的.exe可执行文件&#xff0c;这个程序就跑起来就产生了一个进程。我们可以打开任务管理器 - 首页进程&#xff0c;可以看到3个正在使用的应用&#xff0c;还有71个后台进程。 对于多进程,需要进行管理。进程管…

个推数据驱动运营增长城市巡回沙龙首发北京站

如今很多互联网企业正在加速数智化升级&#xff0c;希望通过运用数据以实现降本提效和运营增长。为帮助更多伙伴在工作中“用好”数据&#xff0c;提升运营效率与效果&#xff1b;同时和更多对用户运营感兴趣的伙伴&#xff0c;共创、共享数智运营实践成果&#xff0c;个推重磅…

学习系统编程终章【多线程剩余知识】

引言&#xff1a; 北京时间&#xff1a;2023/8/3/19:21&#xff0c;刚刚将文章更新&#xff0c;是近期以来为数不多的一次早更&#xff0c;不然每次更文都要卡在12点左右&#xff0c;这是我们实现日更的一个好开端&#xff0c;再接再厉实现日更不是梦。最近失眠一直困扰着我&a…

智慧影院--java开源电影票优惠券制作系统快速开发

搭建一个智慧影院可以通过使用Java开源电影票优惠券制作系统来快速开发。这个系统可以帮助影院管理电影票的销售和优惠活动&#xff0c;提供便捷的购票方式和优惠券的生成与使用功能。 首先&#xff0c;我们需要建立一个数据库来存储电影、影厅、放映计划、订单等信息。在数据…

查看日志信息

查看日志信息 在我们编写代码的过程中可能看不懂错误提示信息&#xff0c;或者不知道错出在什么地方的情况&#xff0c;我们可以打印输出日志信息来检查 使用lombok提供的日志记录器&#xff0c;自定义编程查看调试信息 1、引入lombok依赖 2、在application.properties中配置日…

Observable设计模式简介

Observable设计模式存在于许多Java API和响应式编程中。下面介绍Java中永恒的Observable模式。 Observable设计模式用于许多重要的Java API。一个众所周知的示例是使用ActionListenerAPI执行操作的JButton。在这个例子中&#xff0c;我们ActionListener在按钮上进行了监听或…

玩嵌入式,一般怎么入门?

入门阶段&#xff1a;&#xff08;不要只看书&#xff0c;要多动手&#xff0c;但千万不是直接动手&#xff0c;不去看书&#xff09; C语言&#xff1a;嵌入式编程大多用C语言、少量汇编&#xff0c;先学习C语言&#xff0c;汇编用到的时候再上网查询。教材&#xff1a;随便一…

快讯|新 CEO:Tubi 将成为下一代观众的首选

在每月一期的 Tubi 快讯中&#xff0c;你将全面及时地获取 Tubi 最新发展动态&#xff0c;欢迎关注【比图科技】&#xff0c;一起成长变强&#xff01; 你将通过本文了解 Tubi 在 2023 年 7 月的重要大事&#xff1a; 新 CEO&#xff1a;Tubi 将成为下一代观众的首选 Tubi…

【数学】协方差介绍、相关系数介绍,Python代码

协方差 协方差&#xff08;Covariance&#xff09;是统计学中用来衡量两个随机变量之间关系的一种度量。它反映了这两个变量的变化趋势是否一致&#xff0c;即当一个变量偏离其均值时&#xff0c;另一个变量是否也倾向于偏离其均值。协方差可以帮助我们了解变量之间的线性关系…

❤ TypeError: Assignment to constant variable-Vue3 项目使用

❤ TypeError: Assignment to constant variable 背景&#xff1a; Vue3 项目使用 TypeError: Assignment to constant variable. 原因&#xff1a; 因为我对const定义的常量重新赋值了 解决方法&#xff1a; 换成 var 声明

Flink源码之JobManager启动流程

从启动命令flink-daemon.sh中可以看出StandaloneSession入口类为org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypoint, 从该类的main方法会进入ClusterEntrypoint::runCluster中, 该方法中会创建出主要服务和组件。 StandaloneSessionClusterEntrypoint:…