package com.ai.ipu.mybatisplus.controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

/**

 * <p>

 *  前端控制器

 * </p>

 *

 * @author weihf

 * @since 2020-11-27

 */

@RestController

@RequestMapping("/mybatisplus/user-info")

public class UserInfoController {

}

package com.ai.ipu.mybatisplus.entity;

import com.baomidou.mybatisplus.annotation.TableName;

import java.util.Date;

import com.baomidou.mybatisplus.annotation.TableField;

import java.io.Serializable;

import lombok.Data;

import lombok.EqualsAndHashCode;

/**

 * <p>

 * 

 * </p>

 *

 * @author weihf

 * @since 2020-11-27

 */

@Data

@EqualsAndHashCode(callSuper = false)

@TableName("tab_product_info")

public class ProductInfo implements Serializable {

    private static final long serialVersionUID = 1L;

    @TableField("PRODUCT_ID")

    private Integer productId;

    @TableField("PRODUCT_NAME")

    private String productName;

    @TableField("PRODUCT_FOLDER")

    private Integer productFolder;

    @TableField("PRODUCT_LOGO_URL")

    private String productLogoUrl;

    @TableField("PRODUCT_DESC")

    private String productDesc;

    /**

     * 部分范围 0：根据权限公开；1：CMC；2：所有部门

     */

    @TableField("DEPT_RANGE")

    private Integer deptRange;

    @TableField("STATE")

    private Integer state;

    @TableField("PRODUCT_STAGE")

    private Integer productStage;

    @TableField("CREATE_TIME")

    private Date createTime;

    @TableField("MODIFY_TIME")

    private Date modifyTime;

    @TableField("CREATE_USER")

    private Integer createUser;

    @TableField("MANAGE_USER")

    private Integer manageUser;

    @TableField("VALID_DATE")

    private Date validDate;

    @TableField("EXPIRE_DATE")

    private Date expireDate;

    @TableField("HOME_URL")

    private String homeUrl;

    @TableField("SUCCESS_CASE_URL")

    private String successCaseUrl;

    @TableField("HAS_CODE_URL")

    private Integer hasCodeUrl;

    @TableField("CODE_URL")

    private String codeUrl;

    @TableField("ONLINE_DOCUMENT")

    private String onlineDocument;

    @TableField("TENANT_ID")

    private Integer tenantId;

    @TableField("RESERV1")

    private Integer reserv1;

    @TableField("RESERV2")

    private String reserv2;

}

package com.ai.ipu.mybatisplus.entity;

import com.baomidou.mybatisplus.annotation.TableName;

import com.baomidou.mybatisplus.annotation.FieldFill;

import com.baomidou.mybatisplus.annotation.IdType;

import java.util.Date;

import com.baomidou.mybatisplus.annotation.TableId;

import com.baomidou.mybatisplus.annotation.TableField;

import java.io.Serializable;

import lombok.Data;

import lombok.EqualsAndHashCode;

/**

 * <p>

 * 

 * </p>

 *

 * @author weihf

 * @since 2020-11-27

 */

@Data

@EqualsAndHashCode(callSuper = false)

@TableName("tab_user_info")

public class UserInfo implements Serializable {

    private static final long serialVersionUID = 1L;

    @TableId(value = "USER_ID", type = IdType.ASSIGN_ID)

    private Long userId;

    @TableField("USER_TYPE")

    private Integer userType;

    @TableField("USER_ACCOUNT")

    private String userAccount;

    @TableField("USER_NAME")

    private String userName;

    @TableField("USER_DEPT")

    private String userDept;

    @TableField("USER_EMAIL")

    private String userEmail;

    @TableField("USER_PHONE")

    private String userPhone;

    @TableField("USER_PASSWORD")

    private String userPassword;

    @TableField("CREATE_TIME")

    private Date createTime;

    @TableField("MODIFY_TIME")

    private Date modifyTime;

    @TableField(fill = FieldFill.INSERT_UPDATE)

    private String operator;

    @TableField("RESERV1")

    private Integer reserv1;

    @TableField("RESERV2")

    private String reserv2;

}

package com.ai.ipu.mybatisplus.entity;

import com.baomidou.mybatisplus.annotation.TableName;

import com.baomidou.mybatisplus.annotation.Version;

import com.baomidou.mybatisplus.extension.activerecord.Model;

import com.baomidou.mybatisplus.annotation.FieldFill;

import com.baomidou.mybatisplus.annotation.IdType;

import com.baomidou.mybatisplus.annotation.TableId;

import com.baomidou.mybatisplus.annotation.TableField;

import java.io.Serializable;

import java.util.Date;

import lombok.Data;

import lombok.EqualsAndHashCode;

/**

 * <p>

 * 

 * </p>

 *

 * @author weihf

 * @since 2020-11-27

 */

@Data

@EqualsAndHashCode(callSuper = false)

@TableName("tab_user_info")

public class UserInfoAR extends Model<UserInfoAR> {

    /**

	 * 

	 */

	private static final long serialVersionUID = 5606997867147972334L;

	@TableId(value = "USER_ID", type = IdType.ASSIGN_ID)

    private Long userId;

    @TableField("USER_TYPE")

    private Integer userType;

    @TableField("USER_ACCOUNT")

    private String userAccount;

    @TableField("USER_NAME")

    private String userName;

    @TableField("USER_DEPT")

    private String userDept;

    @TableField("USER_EMAIL")

    private String userEmail;

    @TableField("USER_PHONE")

    private String userPhone;

    @TableField("USER_PASSWORD")

    private String userPassword;

    @TableField(value="CREATE_TIME")

    private Date createTime;

    @TableField(value="MODIFY_TIME")

    private Date modifyTime;

    @TableField(value="OPERATOR", fill = FieldFill.INSERT_UPDATE)

    private String operator;

    @TableField(exist = false)

    private String year;

    @Version

    private Integer version;

    @TableField("RESERV1")

    private Integer reserv1;

    @TableField("RESERV2")

    private String reserv2;

    @Override

    protected Serializable pkVal() {

        /**

         * AR 模式这个必须有，否则 xxById 的方法都将失效！

         * 另外 UserMapper 也必须 AR 依赖该层注入，有可无 XML

         */

        return userId;

    }

}

package com.ai.ipu.mybatisplus.handle;

import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler;

import lombok.extern.slf4j.Slf4j;

import org.apache.ibatis.reflection.MetaObject;

import org.springframework.stereotype.Component;

@Slf4j

@Component

public class MyMetaObjectHandler implements MetaObjectHandler {

    @Override

    public void insertFill(MetaObject metaObject) {

        log.info("start insert fill ....");

        this.setInsertFieldValByName("operator", "Jetty", metaObject);

//        this.strictInsertFill(metaObject, "operator", String.class, "Jetty");

    }

    @Override

    public void updateFill(MetaObject metaObject) {

    	//3.4.0更新填充的bug又复现了

        log.info("start update fill ....");

        this.setUpdateFieldValByName("operator", "Tom", metaObject);

        //this.strictUpdateFill(metaObject, "operator", String.class, "Tom");

    }

}

package com.ai.ipu.mybatisplus.injector;

import java.util.List;

import com.ai.ipu.mybatisplus.method.DeleteAll;

import com.baomidou.mybatisplus.core.injector.AbstractMethod;

import com.baomidou.mybatisplus.core.injector.DefaultSqlInjector;

import com.baomidou.mybatisplus.core.injector.methods.SelectById;

/**

 * 自定义 SqlInjector

 *

 * @author miemie

 * @since 2018-08-13

 */

public class MyLogicSqlInjector extends DefaultSqlInjector {

    /**

     * 如果只需增加方法，保留MP自带方法

     * 可以super.getMethodList() 再add

     * @return

     */

    @Override

    public List<AbstractMethod> getMethodList(Class<?> mapperClass) {

        List<AbstractMethod> methodList = super.getMethodList(mapperClass);

        methodList.add(new DeleteAll());

        methodList.add(new SelectById());

        return methodList;

    }

}

package com.ai.ipu.mybatisplus.interceptor;

import com.baomidou.mybatisplus.core.conditions.AbstractWrapper;

import lombok.extern.slf4j.Slf4j;

import org.apache.ibatis.binding.MapperMethod.ParamMap;

import org.apache.ibatis.cache.CacheKey;

import org.apache.ibatis.executor.Executor;

import org.apache.ibatis.mapping.BoundSql;

import org.apache.ibatis.mapping.MappedStatement;

import org.apache.ibatis.mapping.SqlCommandType;

import org.apache.ibatis.plugin.*;

import org.apache.ibatis.session.ResultHandler;

import org.apache.ibatis.session.RowBounds;

import org.springframework.stereotype.Component;

import java.util.Iterator;

import java.util.Map;

import java.util.Properties;

/**

 * mybatis拦截器，去掉字符串参数的前后空格

 *

 * @see {https://www.cnblogs.com/buguge/p/13749101.html}

 */

@Slf4j

@Component

@Intercepts({

        @Signature(type = Executor.class, method = "query", args = {MappedStatement.class, Object.class, RowBounds.class, ResultHandler.class}),

        @Signature(type = Executor.class, method = "query", args = {MappedStatement.class, Object.class, RowBounds.class, ResultHandler.class, CacheKey.class, BoundSql.class})})

public class MybatisQueryInterceptor implements Interceptor {

    @Override

    public Object intercept(Invocation invocation) throws Throwable {

        MappedStatement mappedStatement = (MappedStatement) invocation.getArgs()[0];

        String sqlId = mappedStatement.getId();

        log.debug("------sqlId------" + sqlId);

        SqlCommandType sqlCommandType = mappedStatement.getSqlCommandType();

        log.debug("------sqlCommandType------" + sqlCommandType);

        Object parameter = invocation.getArgs()[1];

        if (parameter == null || SqlCommandType.SELECT != sqlCommandType) {

            return invocation.proceed();

        }

        if (parameter instanceof ParamMap

                && ((ParamMap) parameter).get("ew") instanceof AbstractWrapper) {

            Map nameValuePairs = ((AbstractWrapper) ((ParamMap) parameter).get("ew")).getParamNameValuePairs();

            Iterator<Map.Entry<String, Object>> iterator = nameValuePairs.entrySet().iterator();

            while (iterator.hasNext()) {

                Map.Entry<String, Object> next = iterator.next();

                if (next.getValue() instanceof String) {

                    next.setValue(((String) next.getValue()).trim());

                }

            }

        }

        return invocation.proceed();

    }

    @Override

    public Object plugin(Object target) {

        return Plugin.wrap(target, this);

    }

    @Override

    public void setProperties(Properties properties) {

    	log.debug("------properties------" + properties);

    }

}

package com.ai.ipu.mybatisplus.mapper;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;

public interface MyBaseMapper<T> extends BaseMapper<T> {

    /**

     * 自定义通用方法

     */

    Integer deleteAll();

}

package com.ai.ipu.mybatisplus.mapper;

import com.ai.ipu.mybatisplus.entity.ProductInfo;

/**

 * <p>

 *  Mapper 接口

 * </p>

 *

 * @author weihf

 * @since 2020-11-27

 */

public interface ProductInfoMapper extends MyBaseMapper<ProductInfo> {

}

package com.ai.ipu.mybatisplus.mapper;

import com.ai.ipu.mybatisplus.entity.UserInfoAR;

/**

 * <p>

 *  Mapper 接口

 * </p>

 *

 * @author weihf

 * @since 2020-11-27

 */

public interface UserInfoARMapper extends MyBaseMapper<UserInfoAR> {

}

package com.ai.ipu.mybatisplus.mapper;

import com.ai.ipu.mybatisplus.entity.UserInfo;

import com.ai.ipu.mybatisplus.config.UserInfoPage;

/**

 * <p>

 *  Mapper 接口

 * </p>

 *

 * @author weihf

 * @since 2020-11-27

 */

public interface UserInfoMapper extends MyBaseMapper<UserInfo> {

	/**

     * 自定义分页查询

     *

     * @param userPage 单独 user 模块使用的分页

     * @return 分页数据

     */

    UserInfoPage selectUserInfoPage(UserInfoPage userInfoPage);

}

package com.ai.ipu.mybatisplus.method;

import com.baomidou.mybatisplus.core.injector.AbstractMethod;

import com.baomidou.mybatisplus.core.metadata.TableInfo;

import org.apache.ibatis.mapping.MappedStatement;

import org.apache.ibatis.mapping.SqlSource;

/**

 * 删除全部

 *

 */

public class DeleteAll extends AbstractMethod {

    @Override

    public MappedStatement injectMappedStatement(Class<?> mapperClass, Class<?> modelClass, TableInfo tableInfo) {

        /* 执行 SQL ，动态 SQL 参考类 SqlMethod */

        String sql = "delete from " + tableInfo.getTableName();

        /* mapper 接口方法名一致 */

        String method = "deleteAll";

        SqlSource sqlSource = languageDriver.createSqlSource(configuration, sql, modelClass);

        return this.addDeleteMappedStatement(mapperClass, method, sqlSource);

    }

}

package com.ai.ipu.mybatisplus.service;

import com.ai.ipu.mybatisplus.entity.ProductInfo;

import com.baomidou.mybatisplus.extension.service.IService;

/**

 * <p>

 *  服务类

 * </p>

 *

 * @author weihf

 * @since 2020-11-27

 */

public interface ProductInfoService extends IService<ProductInfo> {

}

package com.ai.ipu.mybatisplus.service;

import com.ai.ipu.mybatisplus.entity.UserInfoAR;

import com.baomidou.mybatisplus.extension.service.IService;

/**

 * <p>

 *  服务类

 * </p>

 *

 * @author weihf

 * @since 2020-11-27

 */

public interface UserInfoARService extends IService<UserInfoAR> {

}

package com.ai.ipu.mybatisplus.service;

import com.ai.ipu.mybatisplus.entity.UserInfo;

import com.baomidou.mybatisplus.extension.service.IService;

/**

 * <p>

 *  服务类

 * </p>

 *

 * @author weihf

 * @since 2020-11-27

 */

public interface UserInfoService extends IService<UserInfo> {

}

package com.ai.ipu.mybatisplus.service.impl;

import com.ai.ipu.mybatisplus.entity.ProductInfo;

import com.ai.ipu.mybatisplus.mapper.ProductInfoMapper;

import com.ai.ipu.mybatisplus.service.ProductInfoService;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

import org.springframework.stereotype.Service;

/**

 * <p>

 *  服务实现类

 * </p>

 *

 * @author weihf

 * @since 2020-11-27

 */

@Service

public class ProductInfoServiceImpl extends ServiceImpl<ProductInfoMapper, ProductInfo> implements ProductInfoService {

}

package com.ai.ipu.mybatisplus.service.impl;

import com.ai.ipu.mybatisplus.entity.UserInfoAR;

import com.ai.ipu.mybatisplus.mapper.UserInfoARMapper;

import com.ai.ipu.mybatisplus.service.UserInfoARService;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

import org.springframework.stereotype.Service;

/**

 * <p>

 *  服务实现类

 * </p>

 *

 * @author weihf

 * @since 2020-11-27

 */

@Service

public class UserInfoARServiceImpl extends ServiceImpl<UserInfoARMapper, UserInfoAR> implements UserInfoARService {

}

package com.ai.ipu.mybatisplus.service.impl;

import com.ai.ipu.mybatisplus.entity.UserInfo;

import com.ai.ipu.mybatisplus.mapper.UserInfoMapper;

import com.ai.ipu.mybatisplus.service.UserInfoService;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

import org.springframework.stereotype.Service;

/**

 * <p>

 *  服务实现类

 * </p>

 *

 * @author weihf

 * @since 2020-11-27

 */

@Service

public class UserInfoServiceImpl extends ServiceImpl<UserInfoMapper, UserInfo> implements UserInfoService {

}

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

spring.datasource.driver-class-name=com.p6spy.engine.spy.P6SpyDriver

spring.datasource.username=aiosc

spring.datasource.password=aiosc

#spring.datasource.url=jdbc:mysql://10.1.234.70:6611/ipu?useUnicode=true&characterEncoding=utf8

spring.datasource.type=com.alibaba.druid.pool.DruidDataSource

spring.datasource.url=jdbc:p6spy:mysql://10.1.234.70:6611/ipu?useUnicode=true&characterEncoding=utf8

spring.profiles.active=dev

spring.main.allow-bean-definition-overriding=true

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

# 主键策略

mybatis-plus.global-config.db-config.id-type=INPUT

# 表名前缀

mybatis-plus.global-config.db-config.table-prefix=tab_

# 表名是否使用下划线间隔，默认：是

mybatis-plus.global-config.db-config.table-underline=true

# 添加mybatis配置文件路径

#mybatis-plus.config-location=mybatis-config.xml

# 配置实体类包地址

#mybatis-plus.type-aliases-package=com.ai.ipu.mybatisplus

# 驼峰转下划线

mybatis-plus.configuration.map-underscore-to-camel-case=true

mybatis-plus.configuration.jdbc-type-for-null='null'

logging.level.com.ai.ipu.mybatisplus.mapper=debug

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

<!DOCTYPE log4j:configuration SYSTEM "log4j.dtd">

<log4j:configuration xmlns:log4j="http://jakarta.apache.org/log4j/">

 <appender name="STDOUT" class="org.apache.log4j.ConsoleAppender">

   <param name="Encoding" value="UTF-8" />

   <layout class="org.apache.log4j.PatternLayout">

    <param name="ConversionPattern" value="%-5p %d{MM-dd HH:mm:ss,SSS} %m  (%F:%L) \n" />

   </layout>

 </appender>

 <logger name="java.sql">

   <level value="debug" />

 </logger>

 <logger name="org.apache.ibatis">

   <level value="info" />

 </logger>

 <root>

   <level value="debug" />

   <appender-ref ref="STDOUT" />

 </root>

</log4j:configuration>

<?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.ai.ipu.mybatisplus.mapper.UserInfoMapper">

<select id="selectUserInfoPage" resultType="com.ai.ipu.mybatisplus.entity.UserInfo">

        select *

        from tab_user_info

        <trim prefix="where" prefixOverrides="AND">

            <if test="selectStr != null">

                user_name = #{selectStr}

            </if>

        </trim>

    </select>

</mapper>

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

<!DOCTYPE configuration

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

"http://mybatis.org/dtd/mybatis-3-config.dtd">

<configuration>

</configuration>

dynamic.tablenames=tab_product_info,tab_user_info

tenant.ignoretables=tab_product_info

tenant.idcolumn=tenant_id

tenant.idvalue=1

#3.2.1以上使用

modulelist=com.baomidou.mybatisplus.extension.p6spy.MybatisPlusLogFactory,com.p6spy.engine.outage.P6OutageFactory

#3.2.1以下使用或者不配置

#modulelist=com.p6spy.engine.logging.P6LogFactory,com.p6spy.engine.outage.P6OutageFactory

# 自定义日志打印

logMessageFormat=com.baomidou.mybatisplus.extension.p6spy.P6SpyLogger

#日志输出到控制台

appender=com.baomidou.mybatisplus.extension.p6spy.StdoutLogger

# 使用日志系统记录 sql

#appender=com.p6spy.engine.spy.appender.Slf4JLogger

#logfile=/E:/1/mybatisplus/sql.log

# 设置 p6spy driver 代理

deregisterdrivers=true

# 取消JDBC URL前缀

useprefix=true

# 配置记录 Log 例外,可去掉的结果集有error,info,batch,debug,statement,commit,rollback,result,resultset.

excludecategories=info,debug,result,commit,resultset

# 日期格式

dateformat=yyyy-MM-dd HH:mm:ss

# 实际驱动可多个

#driverlist=org.h2.Driver

# 是否开启慢SQL记录

outagedetection=true

# 慢SQL记录标准 2 秒

outagedetectioninterval=1

package com.ai.ipu.mybatisplus;

import org.junit.jupiter.api.Test;

import com.baomidou.mybatisplus.annotation.IdType;

import com.baomidou.mybatisplus.generator.AutoGenerator;

import com.baomidou.mybatisplus.generator.config.DataSourceConfig;

import com.baomidou.mybatisplus.generator.config.GlobalConfig;

import com.baomidou.mybatisplus.generator.config.PackageConfig;

import com.baomidou.mybatisplus.generator.config.StrategyConfig;

import com.baomidou.mybatisplus.generator.config.rules.DateType;

import com.baomidou.mybatisplus.generator.config.rules.NamingStrategy;

class MybatisplusGenerator {

	@Test

	void generator() {

		// Step1：代码生成器

		AutoGenerator mpg = new AutoGenerator();

		// Step2：全局配置

		GlobalConfig gc = new GlobalConfig();

		// 填写代码生成的目录(需要修改)

		String projectPath = "E:\\1\\mybatisplus";

		// 拼接出代码最终输出的目录

		gc.setOutputDir(projectPath + "/src/main/java");

		// 配置开发者信息（可选）（需要修改）

		gc.setAuthor("weihf");

		// 配置是否打开目录，false 为不打开（可选）

		gc.setOpen(false);

		// 实体属性 Swagger2 注解，添加 Swagger 依赖，开启 Swagger2 模式（可选）

		//gc.setSwagger2(true);

		// 重新生成文件时是否覆盖，false 表示不覆盖（可选）

		gc.setFileOverride(true);

		// 配置主键生成策略，此处为 ASSIGN_ID（可选）

		//SnowFlake 算法，是 Twitter 开源的分布式 id 生成算法。其核心思想就是：使用一个 64 bit 的 long 型的数字作为全局唯一 id。

		//在分布式系统中的应用十分广泛，且ID 引入了时间戳，基本上保持自增的，后面的代码中有详细的注解。

		//这 64 个 bit 中，其中 1 个 bit 是不用的，然后用其中的 41 bit 作为毫秒数，用 10 bit 作为工作机器 id，12 bit 作为序列号。

		gc.setIdType(IdType.ASSIGN_ID);

		// 配置日期类型，此处为 ONLY_DATE（可选）

		gc.setDateType(DateType.ONLY_DATE);

		// 默认生成的 service 会有 I 前缀

		gc.setServiceName("%sService");

		//默认不使用ActiveRecord

		//gc.setActiveRecord(true);

		mpg.setGlobalConfig(gc);

		// Step3：数据源配置（需要修改）

		DataSourceConfig dsc = new DataSourceConfig();

		// 配置数据库 url 地址

		dsc.setUrl("jdbc:mysql://10.1.234.70:6611/ipu?useUnicode=true&characterEncoding=utf8");

		// dsc.setSchemaName("ipu"); // 可以直接在 url 中指定数据库名

		// 配置数据库驱动

		dsc.setDriverName("com.mysql.cj.jdbc.Driver");

		// 配置数据库连接用户名

		dsc.setUsername("aiosc");

		// 配置数据库连接密码

		dsc.setPassword("aiosc");

		mpg.setDataSource(dsc);

		// Step:4：包配置

		PackageConfig pc = new PackageConfig();

		// 配置父包名（需要修改）

		pc.setParent("com.ai.ipu");

		// 配置模块名（需要修改）

		pc.setModuleName("mybatisplusdemo");

		// 配置 entity 包名

		pc.setEntity("entity");

		// 配置 mapper 包名

		pc.setMapper("mapper");

		// 配置 service 包名

		pc.setService("service");

		// 配置 controller 包名

		pc.setController("controller");

		mpg.setPackageInfo(pc);

        // 策略配置

        StrategyConfig strategy = new StrategyConfig();

        strategy.setTablePrefix(new String[]{"tab_"});// 此处可以修改为您的表前缀

        strategy.setNaming(NamingStrategy.underline_to_camel);// 表名生成策略

        strategy.setColumnNaming(NamingStrategy.underline_to_camel);

        String[] tables = {"tab_product_info","tab_user_info"};

        // 需要生成的表，不设置则生成所有表

        strategy.setInclude(tables); 

        //strategy.setSuperControllerClass("BaseController");

        strategy.setControllerMappingHyphenStyle(true);

        strategy.setSuperMapperClass("com.ai.ipu.mybatisplus.mapper.MyBaseMapper");

        strategy.setRestControllerStyle(true);

        strategy.setEntityLombokModel(true);    //开启lombook支持

        mpg.setStrategy(strategy);

		// Step6：执行代码生成操作

		mpg.execute();

	}

}

package com.ai.ipu.mybatisplus;

import java.util.Date;

import java.util.List;

import javax.annotation.Resource;

import org.junit.Assert;

import org.junit.jupiter.api.Test;

import org.springframework.boot.test.context.SpringBootTest;

import org.springframework.util.CollectionUtils;

import com.ai.ipu.mybatisplus.entity.ProductInfo;

import com.ai.ipu.mybatisplus.mapper.ProductInfoMapper;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;

import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;

import com.baomidou.mybatisplus.core.metadata.IPage;

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;

import lombok.extern.slf4j.Slf4j;

@Slf4j

@SpringBootTest

class ProductInfoTests {

	@Resource

    private ProductInfoMapper productInfoMapper;

	@Test

	void select() {

		List<ProductInfo> productInfos = productInfoMapper.selectList(null);

		productInfos.forEach(System.out::println);

	}

	@Test

	void selectPage() {

		Page<ProductInfo> page = new Page<>(1, 5);

        IPage<ProductInfo> productIPage = productInfoMapper.selectPage(page, new QueryWrapper<ProductInfo>());

        Assert.assertSame(productIPage, page);

        log.info("总条数 ------> " + productIPage.getTotal());

        log.info("当前页数 ------> " + productIPage.getCurrent());

        log.info("当前每页显示数 ------> " + productIPage.getSize());

        print(productIPage.getRecords());

	}

	@Test

	void selectByColumnName() {

		QueryWrapper<ProductInfo> queryWrapper = new QueryWrapper<ProductInfo>();

		queryWrapper.like("product_Name","社区");

		List<ProductInfo> productInfos = productInfoMapper.selectList(queryWrapper);

		productInfos.forEach(System.out::println);

	}

	@Test

	void selectByName() {

//		LambdaQueryWrapper<ProductInfo> lambda = new LambdaQueryWrapper<ProductInfo>();

		LambdaQueryWrapper<ProductInfo> lambda = new QueryWrapper<ProductInfo>().lambda();

		lambda.eq(ProductInfo::getProductName,"  开源社区  ");

		//会自动去空格

		List<ProductInfo> productInfos = productInfoMapper.selectList(lambda);

		productInfos.forEach(System.out::println);

	}

	@Test

	void update() {

		UpdateWrapper<ProductInfo> updateWrapper = new UpdateWrapper<>();

		updateWrapper.eq("product_id", 0).set("product_desc", "test");

		productInfoMapper.update(null, updateWrapper);

	}

	@Test

	void delete() {

		QueryWrapper<ProductInfo> queryWrapper = new QueryWrapper<ProductInfo>();

		queryWrapper.eq("product_id", 2);

		productInfoMapper.delete(queryWrapper);

	}

	@Test

	void insert() {

		ProductInfo productInfo = new ProductInfo();

		productInfo.setProductId(2);

		productInfo.setProductName("test");

		productInfo.setProductFolder(0);

		productInfo.setDeptRange(0);

		productInfo.setState(0);

		productInfo.setProductStage(0);

		productInfo.setCreateTime(new Date());

		productInfo.setModifyTime(new Date());

		productInfo.setCreateUser(0);

		productInfo.setValidDate(new Date());

		productInfo.setExpireDate(new Date());

		productInfo.setHasCodeUrl(0);

		productInfoMapper.insert(productInfo);

	}

    private <T> void print(List<T> list) {

        if (!CollectionUtils.isEmpty(list)) {

            list.forEach(System.out::println);

        }

    }

}

package com.ai.ipu.mybatisplus;

import java.util.Date;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import javax.annotation.Resource;

import org.junit.Assert;

import org.junit.jupiter.api.Test;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.boot.test.context.SpringBootTest;

import org.springframework.util.CollectionUtils;

import com.ai.ipu.mybatisplus.config.MybatisPlusConfig;

import com.ai.ipu.mybatisplus.config.UserInfoPage;

import com.ai.ipu.mybatisplus.entity.UserInfo;

import com.ai.ipu.mybatisplus.entity.UserInfoAR;