package com.example.mpstudy.domain;

import com.baomidou.mybatisplus.extension.activerecord.Model;
import lombok.Data;
import lombok.EqualsAndHashCode;

@Data
// [关键点 1] 继承 Model <T>，泛型指定为当前类
// [关键点 2] 必须重写 equals 和 hashCode，Lombok 用注解即可解决
@EqualsAndHashCode(callSuper = true) 
@TableName("tb_user")
public class UserDO extends Model<UserDO> {
    // 属性定义保持不变...
}

@SpringBootTest
public class ActiveRecordTest {

    @Test
    void testAr() {
        // 1. 插入：直接 new 一个对象并调用 insert()
        UserDO user = new UserDO().setName("AR-User").setAge(30);
        boolean success = user.insert();
        System.out.println("插入成功? " + success + ", ID=" + user.getId());

        // 2. 查询：利用对象调用 selectById
        // 注意：这里需要一个新的对象实例，或者使用静态方法（如果在 Kotlin 中）
        UserDO result = new UserDO().selectById(user.getId());
        System.out.println("查询结果: " + result);

        // 3. 更新：在查询出的对象上修改，然后调用 updateById
        result.setName("AR-Updated");
        result.updateById();

        // 4. 删除
        result.deleteById();
    }
}

package com.example.mpstudy.config;

import com.baomidou.mybatisplus.annotation.DbType;
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class MybatisPlusConfig {

    /**
     * MP 插件核心配置
     * 所有的增强功能（分页、乐观锁、租户等）都需要添加到 interceptor 中
     */
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        
        // 添加分页插件
        // DbType.MYSQL: 指定数据库类型，不同数据库的 LIMIT 语法不同
        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
        
        return interceptor;
    }
}

@Test
void testPage() {
    // 1. 创建分页参数对象
    // current: 第 1 页, size: 每页 2 条
    Page<UserDO> page = new Page<>(1, 2);

    // 2. 执行查询
    // selectPage(page 对象, Wrapper 条件)
    // 这里的返回值 result 实际上就是传入的 page 对象，两者是同一个引用
    Page<UserDO> result = userMapper.selectPage(page, null);

    // 3. 获取分页数据
    System.out.println("总页数: " + result.getPages());
    System.out.println("总记录数: " + result.getTotal());
    System.out.println("当前页数据: ");
    result.getRecords().forEach(System.out::println);
}

// MybatisPlusConfig.java

@Bean
public MybatisPlusInterceptor mybatisPlusInterceptor() {
    MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
    interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
    
    // [新增] 添加乐观锁插件
    interceptor.addInnerInterceptor(new OptimisticLockerInnerInterceptor());
    return interceptor;
}

// UserDO.java

/**
 * 乐观锁版本号
 * 默认值为 1
 */
@Version
private Integer version;

@Test
void testOptimisticLocker() {
    // 1. 模拟用户 A 查询数据
    UserDO userA = userMapper.selectById(1L); // 假设此时 version = 1
    
    // 2. 模拟用户 B 查询同一条数据
    UserDO userB = userMapper.selectById(1L); // 此时 version = 1

    // 3. 用户 A 修改并提交
    userA.setAge(88);
    userMapper.updateById(userA); 
    // SQL: UPDATE tb_user SET age = 88, version = 2 WHERE id = 1 AND version = 1
    // 成功，数据库 version 变为 2

    // 4. 用户 B 修改并提交
    userB.setAge(99);
    int result = userMapper.updateById(userB);
    // SQL: UPDATE tb_user SET age = 99, version = 2 WHERE id = 1 AND version = 1
    // 失败！因为此时数据库 version 已经是 2 了，WHERE version = 1 匹配不到记录
    
    if (result == 0) {
        System.out.println("用户 B 更新失败，因为数据已被其他人修改！");
    }
}

package com.example.mpstudy.handler;

import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler;
import org.apache.ibatis.reflection.MetaObject;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;

@Component // 交给 Spring 管理
public class MyMetaObjectHandler implements MetaObjectHandler {

    @Override
    public void insertFill(MetaObject metaObject) {
        // 插入时自动填充：gmtCreate 和 gmtModified
        // 参数 1: 实体属性名 (是 Java 属性名，不是数据库字段名)
        // 参数 2: 填充的值
        // 参数 3: 元数据对象
        this.strictInsertFill(metaObject, "gmtCreate", LocalDateTime.class, LocalDateTime.now());
        this.strictInsertFill(metaObject, "gmtModified", LocalDateTime.class, LocalDateTime.now());
        
        // 如果有 version 和 isDeleted 也可以在这里初始化
        this.strictInsertFill(metaObject, "version", Integer.class, 1);
        this.strictInsertFill(metaObject, "isDeleted", Integer.class, 0);
    }

    @Override
    public void updateFill(MetaObject metaObject) {
        // 更新时自动填充：gmtModified
        this.strictUpdateFill(metaObject, "gmtModified", LocalDateTime.class, LocalDateTime.now());
    }
}

// UserDO.java

@TableField(fill = FieldFill.INSERT) // 仅插入时填充
private LocalDateTime gmtCreate;

@TableField(fill = FieldFill.INSERT_UPDATE) // 插入和更新时都填充
private LocalDateTime gmtModified;

@Test
void testSimpleQuery() {
    // 1. list(): 查询某一列，返回 List <Value>
    // 需求：获取所有用户的邮箱列表
    List<String> emails = SimpleQuery.list(
        new LambdaQueryWrapper<UserDO>(), // 查询条件
        UserDO::getEmail                  // 提取字段
    );
    System.out.println("邮箱列表: " + emails);

    // 2. keyMap(): 查询结果转 Map <Key, Entity>
    // 需求：将用户转为 Map，Key 为 ID，Value 为用户对象
    Map<Long, UserDO> idUserMap = SimpleQuery.keyMap(
        new LambdaQueryWrapper<UserDO>(), 
        UserDO::getId
    );
    System.out.println("用户Map: " + idUserMap);

    // 3. map(): 查询结果转 Map <Key, Value>
    // 需求：获取 Map <ID, Name>
    Map<Long, String> idNameMap = SimpleQuery.map(
        new LambdaQueryWrapper<UserDO>(), 
        UserDO::getId,  // Key
        UserDO::getName // Value
    );
    
    // 4. group(): 分组查询 Map <GroupKey, List<Entity> >
    // 需求：按年龄分组
    Map<Integer, List<UserDO>> ageGroup = SimpleQuery.group(
        new LambdaQueryWrapper<UserDO>(), 
        UserDO::getAge
    );
}

// Controller 层
public IPage<UserDO> page(int current, int size) {
    return userMapper.selectPage(new Page<>(current, size), null);
}
// 返回的 JSON 包含：records(数据), total(总数), pages(总页数)