一个Springboot的初始项目
- IOC DI
  - UserController
  - Dao
    - UserDao
    - UserDaoImpl
  - Sevice
    - UserService
    - UserServiceImpl
Meituan
多表关系
多表查询
动态SQL
事务
- 控制事务
- Spring事务管理
  - @Transactional
    - rollbackFor
封装回显
全局异常处理器
HttpClient

[toc]

一个Springboot的初始项目

项目的src\main结构

PS C:\Intellij\Pro\Test1\Pojo_Sec\src\main> tree
卷 系统 的文件夹 PATH 列表
卷序列号为 E4AC-4A0F
C:.
├─java
│  └─gdylt
│      └─com
│          └─pojo_sec
│              ├─Controller
│              ├─dao
│              │  └─impl
│              ├─pojo
│              └─service
│                  └─impl
└─resources
    ├─static
    │  └─js
    └─templates

index.html

<!--index.html-->
<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>User List</title>
    <style>
        table {
            width: 100%;
            border-collapse: collapse;
        }
        table, th, td {
            border: 1px solid black;
        }
        th, td {
            padding: 10px;
            text-align: left;
        }
    </style>
</head>
<body>
<h1>User List</h1>
<table id="userTable">
    <thead>
    <tr>
        <th>ID</th>
        <th>Username</th>
        <th>Password</th>
        <th>Name</th>
        <th>Age</th>
        <th>Update Time</th>
    </tr>
    </thead>
    <tbody>
    <!-- User data will be inserted here -->
    </tbody>
</table>

<script src="script.js"></script>
</body>
</html>

script.js

<!--script.js-->
document.addEventListener("DOMContentLoaded", function() {
    fetch('/list')
        .then(response => response.json())
        .then(data => {
            const userTableBody = document.querySelector('#userTable tbody');
            data.forEach(user => {
                const row = document.createElement('tr');

                const idCell = document.createElement('td');
                idCell.textContent = user.id;
                row.appendChild(idCell);

                const usernameCell = document.createElement('td');
                usernameCell.textContent = user.username;
                row.appendChild(usernameCell);

                const passwordCell = document.createElement('td');
                passwordCell.textContent = user.password;
                row.appendChild(passwordCell);

                const nameCell = document.createElement('td');
                nameCell.textContent = user.name;
                row.appendChild(nameCell);

                const ageCell = document.createElement('td');
                ageCell.textContent = user.age;
                row.appendChild(ageCell);

                const updateTimeCell = document.createElement('td');
                updateTimeCell.textContent = user.updateTime;
                row.appendChild(updateTimeCell);

                userTableBody.appendChild(row);
            });
        })
        .catch(error => console.error('Error fetching user data:', error));
});

UserController

//UserController.java
@RestController
public class UserController {


    @RequestMapping("/list")
    public List<User> list() throws Exception {
        //1. 加载并读取user.txt文件，获取用户数据
        InputStream in = this.getClass().getClassLoader().getResourceAsStream("user.txt");
        ArrayList<String> lines = IoUtil.readLines(in, StandardCharsets.UTF_8, new ArrayList<>());

        //2. 解析用户信息，封装为User对象 -> list集合
        List<User> userList = lines.stream().map(line -> {
            String[] parts = line.split(",");
            Integer id = Integer.parseInt(parts[0]);
            String username = parts[1];
            String password = parts[2];
            String name = parts[3];
            Integer age = Integer.parseInt(parts[4]);
            LocalDateTime updateTime = LocalDateTime.parse(parts[5], DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
            return new User(id, username, password, name, age, updateTime);
        }).toList();
        //3. 返回数据（json）
        return userList;
    }
}

//User
@Data
@NoArgsConstructor
@AllArgsConstructor
public class User {
    private Integer id;
    private String username;
    private String password;
    private String name;
    private Integer age;
    
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    private LocalDateTime updateTime;
}

IOC DI

项目结构

通过controller service dao重构

PS C:\Intellij\Pro\Test1\Pojo_Sec\src\main> tree /F
卷 系统 的文件夹 PATH 列表
卷序列号为 E4AC-4A0F
C:.
├─java
│  └─gdylt
│      └─com
│          └─pojo_sec
│              │  PojoSecApplication.java
│              │
│              ├─Controller
│              │      UserController.java
│              │
│              ├─dao
│              │  │  UserDao.java
│              │  │
│              │  └─impl
│              │          UserDaoImpl.java
│              │
│              ├─pojo
│              │      User.java
│              │
│              └─service
│                  │  UserService.java
│                  │
│                  └─impl
│                          UserServiceImpl.java
│
└─resources
    │  application.properties
    │  user.txt
    │
    ├─static
    │  │  index.html
    │  │  script.js
    │  │
    │  └─js
    └─templates

UserController

@RestController
public class UserController {
    @Autowired
    private UserService userService;

    @RequestMapping("/list")
    public List<User> list() throws Exception{
        //1. 调用service，获取数据
        List<User>userList = userService.findAll();//


        //2. 返回数据（json）
        return userList;
    }
}

Dao

UserDao

public interface UserDao {

    /**
     * 加载用户数据
     * @return
     */
    public List<String>findAll();
}

UserDaoImpl

@Component //将当前类交给IOC容器管理
public class UserDaoImpl implements UserDao {

    @Override
    public List<String> findAll() {
        //1. 加载并读取user.txt文件，获取用户数据
        InputStream in = this.getClass().getClassLoader().getResourceAsStream("user.txt");
        ArrayList<String> lines = IoUtil.readLines(in, StandardCharsets.UTF_8,new ArrayList<>());
        return lines;
    }
}

Sevice

UserService

public interface UserService {

    /**
     * 查询所有用户信息
     * @return
     */
        public List<User> findAll();
}

UserServiceImpl

@Component
public class UserServiceImpl implements UserService {
    @Autowired //应用程序运行时，会自动的查询该类型的bean对象，并赋值给该成员变量
    private UserDao userDao;
    @Override
    public List<User> findAll() {
        //1.调用dao，获取数据
        List<String>lines = userDao.findAll();

        //2. 解析用户信息，封装为User对象 -> list集合
        List<User> userList = lines.stream().map(line ->{
            String[] parts = line.split(",");
            Integer id = Integer.parseInt(parts[0]);
            String username = parts[1];
            String password = parts[2];
            String name = parts[3];
            Integer age = Integer.parseInt(parts[4]);
            LocalDateTime updateTime = LocalDateTime.parse(parts[5], DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
            return new User(id,username,password,name,age,updateTime);
        }).toList();
        return userList;
    }
}

Meituan

字段名与实体类属性名不一致

/**
     * 方式一：手动映射
     * @return
     */
    @Results({
            @Result(column = "create_time", property = "createTime"),
            @Result(column = "update_time", property = "updateTime"),
    })

    /**
     * 方式二：在SQL语句中，对不一样的列名起别名，别名和实体类属性名一样
     */
    @Select("select id,name,create_time createTime,update_time updateTime from meituan order by update_time desc")

    /**
     * 方式三：开启驼峰命名
     * @return
     */
        map-underscore-to-camel-case: true

删除

/**
  * 方式一：HttpServletRequest 获取请求参数
  * @param request
  * @return
  */
 @DeleteMapping("/depts")
 public Result delete(HttpServletRequest request){
     String idStr = request.getParameter("id");
     int id = Integer.parseInt(idStr);
     System.out.println("根据ID删除部门" + id);
     return Result.success();
 }


 /**
  * 方式二：@RequestParam
  * 注意事项：一旦声明了@RequestParam 该参数在请求时必须传递 如果不船体将会报错 （默认required为true）
  * @param deptId
  * @return
  */
 @DeleteMapping("/depts")
 public Result delete(@RequestParam("id") Integer deptId){
         System.out.println("根据ID删除部门" + deptId);
         return Result.success();
 }

 /**
  * 方式三：省略@RequestParam（前端传递的请求参数名与服务端方法形参名一致）[推荐]
  */
 @DeleteMapping("/depts")
 public Result delete(Integer id){
     System.out.println("根据ID删除部门" + id);
     meituanService.deleteById(id);
     return Result.success();
 }

配置文件详解

配置文件名：logback.xml
该配置文件是对Logback日志框架输出的日志进行控制的，可以来配置输出的格式，位置及日志开关等

常用的两种输出日志的位置：控制台，系统文件

    <!--    控制台输出-->
    <appender name="STDOUT" class = "ch.qos.logback.core.ConsoleAppender">
        ......
</appender>

    <!--系统文件输出-->
    <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
    ......
</appender>

开启日志（ALL），关闭日志（OFF）

<root level="off">
    <appender-ref ref="STDOUT" />
    <appender-ref ref="FILE" />
</root>

日志级别

日志级别指的是日志信息的类型，日志都会分级别，常见的日志级别如下（级别由低到高）：

日志级别	说明	记录方式
trace	追踪，记录程序运行轨迹【使用很少】	log.trace(“…”)
debug	调试，记录程序调试过程中的信息，实际应用中一般将其视为最低级别【使用很多】	log.debug(“…”)
info	记录一般信息，描述程序运行的关键事件，如：网络连接，io操作【使用很多】	log.info(“…”)
warn	警告信息：记录潜在有害的情况【使用很多】	log.warn(“…”)
error	错误信息【使用很多】	log.error(“…”)

大于等于配置的日志级别的日志才会输出

多表关系

一对多

外键约束

可以在创建表时或表结构创建完成后，为字段添加外键约束

-- 创建表时限定
create table 表名{
		字段名 数据类型,
		....
		[constraint] [外键名称] foreign key (外键字段名) references 主表(字段名)
};

-- 建完表后，添加外键
alter table 表名 add constraint 外键名称 foreign key (外键字段名) references 主表 (字段名);

一对一

实现：在任意一方加入外键，关联另外一方的主键，并且设置外键为唯一的（UNIQUE）

多对多

实现：建立第三张中间表，中间表至少包含两个外键，分别关联两方主键

多表查询

连接查询
- 内连接：相当于查询A，B交集部分数据
- 外连接
  - 左外连接：查询左表所有数据（包括两张表交集部分数据）
  - 右外连接：查询右表所有数据（包括两张表交集部分数据）
子查询

内连接

-- 1.隐式内连接
select 字段列表 from 表1，表2 where 连接条件 ...;

-- 2.显式内连接
select 字段列表 from 表1 [inner] join 表2 on 连接条件 ...;

-- 给表起别名，简化书写
select 字段列表 from 表1 [as] 别名1 , 表名2 [as] 别名2 where 条件 ...;

外连接

-- 左外连接
select 字段列表 from 表1 left [outer] join 表2 on 连接条件;


-- 右外连接
select 字段列表 from 表1 right [outer] join 表2 on 连接条件;

子查询

SQL语句中嵌套select语句，称为嵌套查询，又称为子查询
select * from t1 where column1 = (select column2 from t2 …);
子查询外部的语句可以是insert update delete select 的任何一个
分类：
- 标量子查询：子查询返回的结果为单个值
- 列子查询：子查询返回的结果为一列
- 行子查询：子查询返回的结果为一行
- 表子查询：子查询返回的结果为多行多列

动态SQL

随着用户的输入或外部条件而变化的SQL语句
: 判断条件是否成立
:根据查询条件，来生成where关键字，并会自动去除条件前面多余的and或or
- collection: 集合名称 - item：集合遍历出来的元素/项 - separator：每一次遍历使用的分隔符 - open：遍历开始前拼接的片段 - close：遍历结束后拼接的片段

事务

事务是一组操作的集合，是一个不可分割的工作单位。这组操作要么全部成功，要么失败

控制事务

开始事务： start transaction/begin；
提交事务： commit;(全部成功)
回滚事务： rollback; (只要有一项失败）

Spring事务管理

@Transactional

@Transactional：会在方法运行之前，开启事务，运行完毕后，根据运行结果，来提交或回滚事务
位置：方法上，类上，接口上

rollbackFor
rollbackFor 属性用于控制出现何种异常类型，回滚事务（默认情况下，只有出现RuntimeException才会回滚）
```
 ####       propagation
```

事务传播行为：指的是当一个事务方法被另一个事务方法调用时，这个事务方法应该如何进行事务控制

封装回显

如果查询返回的字段名与实体的属性名可以直接对应上，用resultType
如果查询返回的字段名与实体的属性名对应不上，或实体属性比较复杂，可以通过resultMap手动封装

全局异常处理器

@RestControllerAdvice = @ControllerAdvice + @ResponseBody
@ExceptionHandler

HttpClient

发送请求的步骤：
- 创建HttpClient对象
- 创建Http请求对象
- 调用HttpClient的execute方法发送请求

//Get
 @SpringBootTest
public class HttpClientTest {
    @Test
    public void testGet() throws Exception{
        //创建httpclient对象
        CloseableHttpClient httpClient = HttpClients.createDefault();


        //创建请求对象
        HttpGet httpGet  = new HttpGet("http://localhost:8080/user/shop/status");

        //发送请求，接受响应结果
        CloseableHttpResponse response = httpClient.execute(httpGet);

        //获取服务端返回的状态码
        int statusCode = response.getStatusLine().getStatusCode();
        System.out.println("服务端返回的状态码为："+statusCode);

        HttpEntity httpEntity = response.getEntity();
        String body= EntityUtils.toString(httpEntity);
        System.out.println("服务端返回的数据为："+body);
        //关闭资源
        httpClient.close();
        response.close();
    }
}

//Post
    @Test
    public void testPost() throws  Exception{

        CloseableHttpClient client = HttpClients.createDefault();

        HttpPost httpPost = new HttpPost("http://localhost:8080/admin/employee/login");

        JSONObject jsonObject = new JSONObject();
        jsonObject.put("username","admin");
        jsonObject.put("password","123456");

        StringEntity entity = new StringEntity(jsonObject.toString());

        //指定请求与编码方式
        entity.setContentEncoding("utf-8");
        //数据格式
        entity.setContentType("application/json");
        httpPost.setEntity(entity);

        CloseableHttpResponse response = client.execute(httpPost);

        int statusCode = response.getStatusLine().getStatusCode();
        System.out.println("服务端返回的状态码为："+statusCode);

        HttpEntity httpEntity = response.getEntity();
        String body= EntityUtils.toString(httpEntity);
        System.out.println("服务端返回的数据为："+body);
    }

Springboot

Guduyili 发布于 2024-11-28

文章访问量

一个Springboot的初始项目

index.html

script.js

UserController

IOC DI

UserController

Dao

UserDao

UserDaoImpl

Sevice

UserService

UserServiceImpl

Meituan

字段名与实体类属性名不一致

删除

配置文件详解

日志级别

多表关系

一对多

外键约束

一对一

多对多

多表查询

内连接

外连接

子查询

动态SQL

事务

控制事务

Spring事务管理

@Transactional

rollbackFor

封装回显

全局异常处理器

HttpClient

Guduyili