Hadoop的伪分布式搭建，主要是方便自己👀
</br>
# Hadoop伪分布式搭建
### 一、环境准备
1. 安装虚拟机
2. IP地址
3. 主机名称
4. 内存2G
5. 硬盘20G
</br>
**以上配置可根据自己电脑配置进行修改**
</br>
**虚拟机配置要求如下（本文Linux系统全部以CentOS-7.5-x86-1804为例）**

#### 1. 能够ping通外网
#### 
```shell
[root@hadoop ~]# ping www.baidu.com
PING www.baidu.com (14.215.177.39) 56(84) bytes of data.
64 bytes from 14.215.177.39 (14.215.177.39): icmp_seq=1 ttl=128 time=8.60 ms
64 bytes from 14.215.177.39 (14.215.177.39): icmp_seq=2 ttl=128 time=7.72 ms

```
#### 2. 安装epel-release

:::info{title="相关信息"}
注：Extra Packages for Enterprise Linux是为“红帽系”的操作系统提供额外的软件包，适用于RHEL、CentOS和Scientific Linux。相当于是一个软件仓库，大多数rpm包在官方 repository 中是找不到的）
:::

```shell
yum install -y epel-release
```
#### 3. 如果Linux安装的是最小系统版，还需要安装如下工具；如果安装的是Linux桌面标准版，不需要执行如下操作

```shell
#net-tool：工具包集合，包含ifconfig等命令
yum install -y net-tools 
#vim：编辑器
yum install -y vim
```
#### 4. 关闭防火墙和防火墙开机自启动

```shell
systemctl stop firewalld #关闭防火墙
systemctl disable firewalld.service  #禁止开机自启动
```
#### 5.创建Hadoop用户

```shell
#以下命令均用root用户操作
useradd hadoop #创建hadoop用户
passwd hadoop #设置hadoop用户密码
```
#### 6.配置hadoop用户具有root权限，方便后期加sudo执行root权限的命令

```shell
[root@hadoop ~]# vim /etc/sudoers 
#修改/etc/sudoers文件，在%wheel这行下面添加一行，如下所示：
## Allow root to run any commands anywhere
root    ALL=(ALL)     ALL

## Allows people in group wheel to run all commands
%wheel  ALL=(ALL)       ALL #这一行下面添加
hadoop   ALL=(ALL)     NOPASSWD:ALL
```

:::warning{title="注意"}
注意：hadoop这一行不要直接放到root行下面，因为所有用户都属于wheel组，你先配置了hadoop具有免密功能，但是程序执行到%wheel行时，该功能又被覆盖回需要密码。所以hadoop要放到%wheel这行下面。
:::
#### 7.在/opt目录下创建文件夹，并修改所属主和所属组
1) 在/opt目录下创建module、software文件夹

```shell
[root@hadoop ~]# mkdir /opt/module
[root@hadoop ~]# mkdir /opt/software
```
2) 修改module、software文件夹的所有者和所属组均为hadoop用户

```shell
[root@hadoop ~]# chown hadoop:hadoop /opt/module 
[root@hadoop ~]# chown hadoop:hadoop /opt/software
```
3) 查看module、software文件夹的所有者和所属组

```shell
[root@hadoop ~]# ll /opt
```
8. 卸载虚拟机自带的JDK

```shell
#注意：如果你的虚拟机是最小化安装不需要执行这一步。
[root@hadoop ~]# rpm -qa | grep -i java | xargs -n1 rpm -e --nodeps 
```

:::info{title="相关信息"}
相关信息</br>
rpm -qa：查询所安装的所有rpm软件包</br>
grep -i：忽略大小写</br>
xargs -n1：表示每次只传递一个参数</br>
rpm -e –nodeps：强制卸载软件
:::
9. 重启虚拟机

```shell
[root@hadoop ~]# reboot
```
### 二、配置网络环境
#### 1. 修改虚拟机的静态IP
```shell
[root@hadoop ~]# vim /etc/sysconfig/network-scripts/ifcfg-ens33

#改成
DEVICE=ens33
TYPE=Ethernet
ONBOOT=yes
BOOTPROTO=static #开启静态IP
NAME="ens33"
IPADDR=192.168.10.102 #IP地址
PREFIX=24 #子网掩码
GATEWAY=192.168.10.2 #网关
DNS1=192.168.10.2 #DNS
```
#### 2. 查看Linux虚拟机的虚拟网络编辑器，编辑->虚拟网络编辑器->VMnet8

![image.png](/static/img/e7da9fe4f28c1ae7cb1bf1b1ae911bc6.image.webp)


![image.png](/static/img/0fcd08b80586c4db0c71db779372fb59.image.webp)
#### 3. 查看Windows系统适配器VMware Network Adapter VMnet8的IP地址

![image.png](/static/img/a5900eb25ec01c0bfdc53ff9d1bb1478.image.webp)

#### 4. 保证Linux系统ifcfg-ens33文件中IP地址、虚拟网络编辑器地址和Windows系统VM8网络IP地址相同。

### 三、修改主机名
#### 1. 修改主机名称

```shell
[root@hadoop100 ~]# vim /etc/hostname
#删除原来的，添加hadoop
hadoop
```
#### 2. 配置Linux克隆机主机名称映射hosts文件，打开/etc/hosts

```shell
[root@hadoop ~]# vim /etc/hosts

#添加以下内容
192.168.10.100 hadoop
```
3. 重启虚拟机

```shell
[root@hadoop ~]# reboot
```
### 四、安装JDK
#### 1. 卸载自带的JDK

```shell
[root@hadoop ~]# rpm -qa | grep -i java | xargs -n1 rpm -e --nodeps 
```

:::warning{title="注意"}
注意：安装JDK前，一定确保提前删除了虚拟机自带的JDK
:::
#### 2. 用XShell传输工具将JDK导入到opt目录下面的software文件夹下面

![image.png](/static/img/a05d10bafebc29785cee58283bd4d934.image.webp)

#### 3. 在Linux系统下的opt目录中查看软件包是否导入成功

```shell
[hadoop@hadoop ~]$ ls /opt/software/
```
看到如下结果:
`jdk-8u212-linux-x64.tar.gz`
#### 4. 解压JDK到/opt/module目录下


```shell
[hadoop@hadoop software]$ tar -zxvf jdk-8u212-linux-x64.tar.gz -C /opt/module/
```
#### 5. 配置JDK环境变量
##### 1) 新建/etc/profile.d/my_env.sh文件

```shell
[hadoop@hadoop ~]$ sudo vim /etc/profile.d/my_env.sh

#添加如下内容
#JAVA_HOME
export JAVA_HOME=/opt/module/jdk1.8.0_212
export PATH=$PATH:$JAVA_HOME/bin
```
##### 2) 保存退出
`Esc键  :wq`

:::info{title="相关信息"}
相关信息：profile文件在运行时会加载profile.d目录下的所有 *.sh文件
:::
##### 3) source一下/etc/profile文件，让新的环境变量PATH生效

```shell
[hadoop@hadoop ~]$ source /etc/profile
```
#### 6. 测试JDK是否安装成功

```shell
[hadoop@hadoop ~]$ java -version
如果能看到以下结果，则代表Java安装成功。
java version "1.8.0_212"
```

:::warning{title="注意"}
注意：重启（如果java -version可以用就不用重启）</br>
`[hadoop@hadoop ~]$ sudo reboot`
:::

### 五、安装Hadoop
**官网下载Hadopp**：https://archive.apache.org/dist/hadoop/common/hadoop-3.1.3/

#### 1. 用XShell文件传输工具将hadoop-3.1.3.tar.gz导入到opt目录下面的software文件夹下面

![image.png](/static/img/8e08e27642c2759e96b9b496b0311862.image.webp)
#### 2. 进入到Hadoop安装包路径下

```shell
[hadoop@hadoop ~]$ cd /opt/software/
```
#### 3. 解压安装文件到/opt/module下面


```shell
[hadoop@hadoop software]$ tar -zxvf hadoop-3.1.3.tar.gz -C /opt/module/
```
#### 4. 查看是否解压成功

```shell
[hadoop@hadoop software]$ ls /opt/module/
hadoop-3.1.3
```
#### 5. 将Hadoop添加到环境变量
##### 1) 获取Hadoop安装路径

```shell
[hadoop@hadoop hadoop-3.1.3]$ pwd
/opt/module/hadoop-3.1.3
```
##### 2) 打开/etc/profile.d/my_env.sh文件

```shell
[hadoop@hadoop hadoop-3.1.3]$ sudo vim /etc/profile.d/my_env.sh
#添加以下内容

#HADOOP_HOME
export HADOOP_HOME=/opt/module/hadoop-3.1.3
export PATH=$PATH:$HADOOP_HOME/bin
export PATH=$PATH:$HADOOP_HOME/sbin

#保存并退出： :wq
```
##### 3) 让修改后的文件生效

```shell
[hadoop@hadoop hadoop-3.1.3]$ source /etc/profile
```
#### 4. 测试是否安装成功

```shell
[hadoop@hadoop hadoop-3.1.3]$ hadoop version
Hadoop 3.1.3
```
### 六. Hadoop目录结构
#### 1. 查看Hadoop目录结构

```shell
[hadoop@hadoop hadoop-3.1.3]$ ll
总用量 52
drwxr-xr-x. 2 hadoop hadoop  4096 5月  22 2017 bin
drwxr-xr-x. 3 hadoop hadoop  4096 5月  22 2017 etc
drwxr-xr-x. 2 hadoop hadoop  4096 5月  22 2017 include
drwxr-xr-x. 3 hadoop hadoop  4096 5月  22 2017 lib
drwxr-xr-x. 2 hadoop hadoop  4096 5月  22 2017 libexec
-rw-r--r--. 1 hadoop hadoop 15429 5月  22 2017 LICENSE.txt
-rw-r--r--. 1 hadoop hadoop   101 5月  22 2017 NOTICE.txt
-rw-r--r--. 1 hadoop hadoop  1366 5月  22 2017 README.txt
drwxr-xr-x. 2 hadoop hadoop  4096 5月  22 2017 sbin
drwxr-xr-x. 4 hadoop hadoop  4096 5月  22 2017 share

```
#### 2. 重要目录

1) bin目录：存放对Hadoop相关服务（hdfs，yarn，mapred）进行操作的脚本
2) etc目录：Hadoop的配置文件目录，存放Hadoop的配置文件
3) lib目录：存放Hadoop的本地库（对数据进行压缩解压缩功能）
4) sbin目录：存放启动或停止Hadoop相关服务的脚本
5) share目录：存放Hadoop的依赖jar包、文档、和官方案例

### 七、设置免密登录
#### 1. 生成公钥和私钥

```shell
[hadoop@hadoop .ssh]$ pwd
/home/hadoop/.ssh

[hadoop@hadoop .ssh]$ ssh-keygen -t rsa
```
**然后敲（三个回车），就会生成两个文件id_rsa（私钥）、id_rsa.pub（公钥）**
#### 2. 将公钥拷贝到要免密登录的目标机器上

```shell
[hadoop@hadoop .ssh]$ ssh-copy-id hadoop
```
### 八、搭建伪分布式
#### 1. 配置集群
##### 1) 核心配置文件

```shell
 #配置core-site.xml
 [hadoop@hadoop ~]$ cd $HADOOP_HOME/etc/hadoop
 [hadoop@hadoop hadoop]$ vim core-site.xml
```
**修改内容如下**
```xml
<?xml version="1.0" encoding="UTF-8"?>
<?xml-stylesheet type="text/xsl" href="configuration.xsl"?>

<configuration>
    
    <property>
        <name>fs.defaultFS</name>
        <value>hdfs://hadoop:8020</value>
    </property>

    
    <property>
        <name>hadoop.tmp.dir</name>
        <value>/opt/module/hadoop-3.1.3/data</value>
    </property>

    
    <property>
        <name>hadoop.http.staticuser.user</name>
        <value>hadoop</value>
    </property>
</configuration>
```
#### 2) HDFS配置文件

```shell
#配置hdfs-site.xml
[hadoop@hadoop hadoop]$ vim hdfs-site.xml
```
**文件内容如下**：


```xml
<?xml version="1.0" encoding="UTF-8"?>
<?xml-stylesheet type="text/xsl" href="configuration.xsl"?>

<configuration>
	
	<property>
        <name>dfs.namenode.http-address</name>
        <value>hadoop:9870</value>
    </property>
	
    <property>
        <name>dfs.namenode.secondary.http-address</name>
        <value>hadoop:9868</value>
    </property>
    	
    <property>
        <name>dfs.replication</name>
        <value>1</value>
    </property>

</configuration>

```
#### 3) YARN配置文件


```shell
#配置yarn-site.xml
[hadoop@hadoop hadoop]$ vim yarn-site.xml
```
**文件内容如下：**

```xml
<?xml version="1.0" encoding="UTF-8"?>
<?xml-stylesheet type="text/xsl" href="configuration.xsl"?>

<configuration>
    
    <property>
        <name>yarn.nodemanager.aux-services</name>
        <value>mapreduce_shuffle</value>
    </property>

    
    <property>
        <name>yarn.resourcemanager.hostname</name>
        <value>hadoop</value>
    </property>

    
    <property>
        <name>yarn.nodemanager.env-whitelist</name>
        <value>JAVA_HOME,HADOOP_COMMON_HOME,HADOOP_HDFS_HOME,HADOOP_CONF_DIR,CLASSPATH_PREPEND_DISTCACHE,HADOOP_YARN_HOME,HADOOP_MAPRED_HOME</value>
    </property>
</configuration>
```
#### 4) MapReduce配置文件

```shell
#配置mapred-site.xml
[hadoop@hadoop hadoop]$ vim mapred-site.xml
```
**文件内容如下**：


```xml
<?xml version="1.0" encoding="UTF-8"?>
<?xml-stylesheet type="text/xsl" href="configuration.xsl"?>

<configuration>
	
    <property>
        <name>mapreduce.framework.name</name>
        <value>yarn</value>
    </property>
</configuration>

```
#### 2. 启动集群
##### 1) 第一次启动 需要格式化NameNode

```shell
[hadoop@hadoop hadoop-3.1.3]$ hdfs namenode -format
```

:::warning{title="注意"}
注意：格式化NameNode，会产生新的集群id，导致NameNode和DataNode的集群id不一致，集群找不到已往数据。如果集群在运行过程中报错，需要重新格式化NameNode的话，一定要先停止namenode和datanode进程，并且要删除所有机器的data和logs目录，然后再进行格式化。
:::
##### 2) 启动HDFS 和 YARN

```shell
[hadoop@hadoop hadoop-3.1.3]$ sbin/start-dfs.sh
[hadoop@hadoop hadoop-3.1.3]$ sbin/start-yarn.sh
```
##### 3) 执行命令jps能看到6个Java程序

```txt
jps
namenode
secondarynamenode
datanode
resourcemanager
nodemanager
```
##### 4) 能看到一个存放日志的目录$HADOOP_HOME/logs
##### 5) 并能看到一个存放索引和数据的目录$HADOOP_HOME/data
#### 3. 测试
##### 1) 上传文件到集群
**上传小文件**

```shell
[hadoop@hadoop ~]$ hadoop fs -mkdir /input
[hadoop@hadoop ~]$ hadoop fs -put $HADOOP_HOME/wcinput/word.txt /input
```

```shell
[hadoop@hadoop ~]$ hadoop jar share/hadoop/mapreduce/hadoop-mapreduce-examples-3.1.3.jar wordcount /input/word.txt /output
```




参考尚硅谷:【尚硅谷大数据Hadoop教程，hadoop3.x搭建到集群调优，百万播放】 https://www.bilibili.com/video/BV1Qp4y1n7EN/?p=57&share_source=copy_web&vd_source=89b9de79c8f374309c5791db6796b62f

Hadoop伪分布式搭建

**2024年3月27日星期三**</br>
今天学到了动态SQL,以下全是我个人总结的，如果有问题可以联系我修改👀
# 第三章 动态SQL
:::info{title="学习目标"}
1. 掌握MyBatis中动态SQL元素的使用
2. 掌握MyBatis中条件查询操作
3. 掌握MyBatis的更新操作
4. 掌握MyBatis的复杂查询操作
:::
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;在实际项目的开发中，开发人员在使用JDBC或其他持久层框架进行开发时，经常需要根据不同条件拼接SQL语句，拼接SQL语句时还要确保不能遗漏必要的空格、标点符号等，这种编程方式给开发人员带来了极大的不便，而MyBatis提供的SQL语句动态组装功能，恰能很好地解决这一问题。

## 3.1 动态SQL中的元素

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;动态SQL是Mybatis的强大特性之一，MyBatis采用了功能强大的基于对象导航图语言(Object Graph Navigation Language,**OGNL**)

| 元素 | 说明 |
| --- | --- |
| \<if> |判断语句，用于单条件判断  |
| \<choose> (\<when>、\<otherwise>) |相当于Java中的switch...case...default语句，用于多条件判断  |
| \<where> |简化SQL语句中where的条件判断 |
| \<trim> |可以灵活低去除多余的关键字  |
| \<set> |用于SQL语句的动态更新  |
| \<foreach> |循环语句，常用于in语句等列举条件中  |

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;以上是MyBatis动态SQL中常用的一些元素，下面将对这些动态SQL元素的使用进行详细讲解。
## 3.2 条件查询操作
### 3.2.1 \<if>元素
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;\<if>元素是最常用的判断元素，类似于Java中的if语句，主要实现某些简单的条件判断。</br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;**运用场景**：当某个用户填写信息时，可以通过姓名或者年龄来查找用户，也可以不填写年龄直接通过姓名来查找用户，可以什么都不填写查询出所有用户，此时的姓名和年龄就是非必需条件，
以上情况就可以使用\<if>元素来实现。
#### 1. 数据库准备
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;在名为mybatis的数据库中，创建一个t_customer数据表，并插入几条测试数据，具体代码如下：


```SQL
use mybatis;

create table t_customer (
    id int(32) primary key auto_increment,
    username varchar(50),
    jobs varchar(50),
    phone varchar(16)
);

insert into t_customer values ('1','joy','teacher','13733333333'),('2','jack','teacher','13522222222'),('3','tom','worker','15111111111');
```
#### 2. POJO类准备
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;在org.example.pojo包下创建持久化类Customer,在类中声明id、username、jobs和phone属性，以及对应的getter/setter方法。


```Java
public class Customer {
    private int id; //客户id
    private String username; //客户姓名
    private String jobs; //职业
    private String phone; //电话

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getJobs() {
        return jobs;
    }

    public void setJobs(String jobs) {
        this.jobs = jobs;
    }

    public String getPhone() {
        return phone;
    }

    public void setPhone(String phone) {
        this.phone = phone;
    }
}
```
#### 3. 创建映射文件

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;在项目src/main/resources/mapper包下创建映射文件CustomerMapper.xml ，在映射文件中，根据客户姓名和年龄组合成的条件查询客户信息，使用\<if>元素编写该组合条件的动态SQL。

```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="org.example.pojo.Customer">
    
    <select id="findCustomerByNameAndJobs" parameterType="org.example.pojo.Customer" resultType="org.example.pojo.Customer">
        select * from t_customer where 1=1 
        <if test="username != null and username != ''">
            and username like concat('%',#{username},'%')
        </if>
        <if test="jobs != null and jobs != ''">
            and jobs like concat('%',#{jobs}'%')
        </if>
    </select>
</mapper>
```
使用\<if>元素的test属性分别对username和jobs进行非空判断，

:::warning{title="注意"}
注意 ：**where 1=1 是为了防止 if内执行的语句无法使用 ，凭空多出一个 and username like concat('%',#{username},'%') 语句 SQL就无法执行，为什么要加 where 1=1呢 如果不加的话后面if里面的语句就执行不到就会因为没有 where 关键字导致错误，为什么 要加上 1=1 呢因为这种情况是因为用户什么都没输入的情况，就会去查询所有记录。**
:::

#### 4. 修改核心配置文件
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;在配置文件mybatis-config.xml中，引入CustomerMapper.xml映射文件到\<mappers>元素中</br>

```xml
<mapper resource="mapper/CustomerMapper.xml"/>
```
#### 5.创建获取SQlSession对象

```Java
        String resources = "mybatis-config.xml";

        //创建流
        Reader reader = null;
        try {
            //读取mybatis-config.xml文件到reader对象中
            reader = Resources.getResourceAsReader(resources);
        }catch (IOException e){
            e.printStackTrace();
        }

        //初始化Mybatis数据库，创建SqlSessionFactory类的实例
        SqlSessionFactory sqlMapper = new SqlSessionFactoryBuilder().build(reader);

        //创建SqlSession实例
        SqlSession session = sqlMapper.openSession();
```
#### 6. 修改测试类

添加测试方法 findCustomerByNameAndJobs()


```Java
    @Test
    public void findCustomerByNameAndJobs(){
        String resources = "mybatis-config.xml";

        //创建流
        Reader reader = null;
        try {
            //读取mybatis-config.xml文件到reader对象中
            reader = Resources.getResourceAsReader(resources);
        }catch (IOException e){
            e.printStackTrace();
        }

        //初始化Mybatis数据库，创建SqlSessionFactory类的实例
        SqlSessionFactory sqlMapper = new SqlSessionFactoryBuilder().build(reader);

        //创建SqlSession实例
        SqlSession session = sqlMapper.openSession();

        //获取Customer对象
        Customer customer = new Customer();
        //设置属性值
        customer.setUsername("jack");
        customer.setJobs("teacher");

        List<Customer> customers = session.selectList("org.example.pojo.Customer.findCustomerByNameAndJobs", customer);

        for (Customer customer1 : customers) {
            System.out.println(customer1.toString());
        }
        session.close();
    }
```
运行成功截图

![image.png](/static/img/167afa00d755dac679ee8245df6f498e.image.webp)
### 3.2.2 \<choose>、\<when>、\<otherwise>元素
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;在使用\<if>元素时，只要test属性中的表达式为true，就会执行元素中的条件语句，但是在实际应用中，有时只需要从多个选项中选择一个去执行。
</br>
**使用场景:**</br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;当客户名称不为空，则只根据客户名称进行客户筛选。</br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;当客户名称为空，而客户职业不为空，则只根据客户职业进行客户筛选。</br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;当客户名称和客户职业都为空，则要求查询出所有电话不为空的客户信息。
</br>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;这种场景下使用\<if>元素进行处理是非常不合适的，MyBatis提供了\<choose>、\<when>、\<otherwise>元素进行处理。接下来将演示如何使用\<choose>、\<when>、\<otherwise>元素。</br>
(1)在映射文件CustomerMapper.xml中，添加使用\<choose>、\<when>、\<otherwise>元素执行上述情况的动态SQL

```xml
    <select id="findCustomerByNameOrJobs" parameterType="org.example.pojo.Customer" resultType="org.example.pojo.Customer">
        select * from t_customer where 1=1
        <choose>
            <when test="username != null and username !=''">
                and username like concat('%',#{username}'%')
            </when>
            <when test="jobs != null and jobs != ''">
                and jobs = #{jobs}
            </when>
            <otherwise>
                and phone is not null 
            </otherwise>
        </choose>
    </select>
```
(2) 在测试类中，编写测试方法findCustomerByNameOrJobsTest()


```Java
 @Test
    public void findCustomerByNameOrJobsTest(){
        String resources = "mybatis-config.xml";

        //创建流
        Reader reader = null;
        try {
            //读取mybatis-config.xml文件到reader对象中
            reader = Resources.getResourceAsReader(resources);
        }catch (IOException e){
            e.printStackTrace();
        }

        //初始化Mybatis数据库，创建SqlSessionFactory类的实例
        SqlSessionFactory sqlMapper = new SqlSessionFactoryBuilder().build(reader);

        //创建SqlSession实例
        SqlSession session = sqlMapper.openSession();
        //创建customer对象
        Customer customer = new Customer();
        customer.setUsername("tom");
        customer.setJobs("teacher");

        List<Customer> customers = session.selectList("org.example.pojo.Customer.findCustomerByNameOrJobs",customer);

        for (Customer customer1 : customers) {
            System.out.println(customer1.toString());
        }

        session.close();
    }
```
运行成功截图

![image.png](/static/img/3bb006a0da4df1242a8ed16ebcd8f01b.image.webp)

由上图可见，只要条件满足条件的when，就会执行里面的sql语句，尽管tom的职业不是teacher，也一样能查询出来，更改代码

```Java
 //customer.setUsername("tom");
```

将以上代码注释后就会满足第二个when的条件就会查询出所有职业为 teacher 的客户

![image.png](/static/img/f2a679d715881d74c34ab2792282a759.image.webp)

将以下代码也注释后就会执行\<otherwise>中的条件，就会查询出所有用户的phone

```Java
 customer.setJobs("teacher");
```

运行截图
![image.png](/static/img/ce0ee5c8c578515a99826603961f5475.image.webp)

**未完待续......
**

Hadoop伪分布式搭建

一、环境准备

第三章 动态SQL

第三章动态SQL