作业提交

侯春建_Mybatis2/.gitignore

+######################################################################
+######################################################################
+# Build Tools
+
+.gradle
+/build/
+!gradle/wrapper/gradle-wrapper.jar
+
+target/
+!.mvn/wrapper/maven-wrapper.jar
+
+######################################################################
+# IDE
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### NetBeans ###
+nbproject/private/
+build/*
+nbbuild/
+dist/
+nbdist/
+.nb-gradle/
+
+######################################################################
+# Others
+*.log
+*.xml.versionsBackup
+*.txt
+
+!*/build/*.java
+!*/build/*.html
+!*/build/*.xml
\ No newline at end of file

侯春建_Mybatis2/readme.md

+
+
+	1.打开项目执行 transaction.MybatisTest测试用例 selectUser , insertUser 方法
+
+	2. 另，可通过sql生成数据库表结构， users表
\ No newline at end of file

侯春建_Mybatis2/src/main/java/com/Config/AppConfig1.java

+package com.Config;
+package com.Config;
+
+import com.Mapper.*;
+import com.alibaba.druid.pool.DruidDataSource;
+import org.apache.ibatis.session.SqlSessionFactory;
+import org.mybatis.spring.SqlSessionFactoryBean;
+import org.mybatis.spring.mapper.MapperScannerConfigurer;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.core.io.ClassPathResource;
+import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
+import org.springframework.jdbc.datasource.DataSourceTransactionManager;
+
+@Configuration
+public class AppConfig1 {
+
+  @Bean
+  public DruidDataSource dataSource() {
+    DruidDataSource ds = new DruidDataSource();
+    ds.setDriverClassName("com.mysql.cj.jdbc.Driver");
+    ds.setUrl("jdbc:mysql://localhost:3306/import_server?characterEncoding=utf8&useSSL=true&serverTimezone=Asia/Shanghai");
+    ds.setUsername("root");
+    ds.setPassword("root");
+    ds.setInitialSize(5);
+    return ds;
+  }
+
+  //
+  @Bean
+  public DataSourceTransactionManager dataSourceTransactionManager() {
+    return new DataSourceTransactionManager(dataSource());
+  }
+
+//  @Bean
+//  public SqlSessionTemplate sqlSessionTemplate(SqlSessionFactory sqlSessionFactory) {
+//    return new SqlSessionTemplate(sqlSessionFactory);
+//  }
+
+  @Bean
+  public SqlSessionFactory sqlSessionFactory() throws Exception {
+    SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
+    sessionFactory.setDataSource(dataSource());
+    sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
+        .getResources("classpath:bean/UserMapper.xml"));
+    sessionFactory.setTypeAliasesPackage("com/Domain"); // 扫包
+    // 配置路径
+    sessionFactory.setConfigLocation(new ClassPathResource("sqlMapConfig.xml"));
+
+    return sessionFactory.getObject();
+  }
+
+
+  // 包扫描
+  @Bean
+  public MapperScannerConfigurer mapperScannerConfigurer() {
+    MapperScannerConfigurer mScannerConfigurer = new MapperScannerConfigurer();
+
+    mScannerConfigurer.setSqlSessionFactoryBeanName("sqlSessionFactory");
+    mScannerConfigurer.setBasePackage("com/Mapper"); // 扫mapper
+    // 只扫描test.class 类型注解的mapper
+//    mScannerConfigurer.setAnnotationClass(test.class);
+    return mScannerConfigurer;
+  }
+
+}
\ No newline at end of file

侯春建_Mybatis2/src/main/java/com/Config/CustomPlugin.java

+package com.Config;
+package com.Config;
+
+import lombok.extern.slf4j.Slf4j;
+import org.apache.ibatis.binding.MapperMethod;
+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.ParameterMapping;
+import org.apache.ibatis.plugin.*;
+import org.apache.ibatis.session.ResultHandler;
+import org.apache.ibatis.session.RowBounds;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Properties;
+
+@Slf4j
+@Intercepts(
+        {
+                @Signature(type = Executor.class, method = "query", args = {MappedStatement.class, Object.class, RowBounds.class, ResultHandler.class, CacheKey.class, BoundSql.class}),
+                @Signature(type = Executor.class, method = "query", args = {MappedStatement.class, Object.class, RowBounds.class, ResultHandler.class}),
+                @Signature(type = Executor.class, method = "update", args = {MappedStatement.class, Object.class})
+//                @Signature(type = StatementHandler.class, method = "query", args = {MappedStatement.class, Object.class, RowBounds.class, ResultHandler.class}),
+
+        }
+)
+public class CustomPlugin implements Interceptor {
+
+    @Override
+    public Object intercept(Invocation invocation) throws Throwable {
+        Object[] args = invocation.getArgs();
+        MappedStatement ms = (MappedStatement) args[0];
+        Object parameter = args[1];
+        Executor executor = (Executor) invocation.getTarget();
+        CacheKey cacheKey = null;
+        BoundSql boundSql = null;
+        Class<?> type = ms.getParameterMap().getType();
+
+        if (args.length >= 4) {
+            boundSql = ms.getBoundSql(parameter);
+            ResultHandler resultHandler = (ResultHandler) args[3];
+            RowBounds rowBounds = (RowBounds) args[2];
+            cacheKey = executor.createCacheKey(ms, parameter, rowBounds, boundSql);
+            if (args.length == 6) {
+                cacheKey = (CacheKey) args[4];
+                boundSql = (BoundSql) args[5];
+            }
+            String sql = getSql(boundSql, type);
+            log.debug("runing query(dql) sql:{}", sql);
+            return executor.query(ms, parameter, rowBounds, resultHandler, cacheKey, boundSql);
+        } else if (args.length == 2) {
+            // update
+            boundSql = ms.getBoundSql(parameter);
+            String sql = getSql(boundSql, type);
+            log.debug("runing update(dml) sql:{}", sql);
+            return executor.update(ms, parameter);
+        } else {
+            throw new RuntimeException("无效拦截");
+        }
+
+    }
+
+    /***
+     * @author houchunjian
+     * @date 2020/1/1 0001 15:04
+     * @param boundSql
+     * @param type
+     * @return java.lang.String
+     */
+    private String getSql(BoundSql boundSql, Class<?> type) {
+        String sql = boundSql.getSql();
+        final String[] temp = {sql};
+        if (sql.contains("?") && boundSql.getParameterMappings().size() > 0 && boundSql.getParameterObject() != null) {
+            List<ParameterMapping> parameterMappings = boundSql.getParameterMappings();
+            Object parameterObject = boundSql.getParameterObject();
+            //多参数
+            if (parameterObject instanceof HashMap) {
+                MapperMethod.ParamMap parameterObject1 = (MapperMethod.ParamMap) parameterObject;
+                parameterMappings.forEach(parameters -> {
+                    String property = parameters.getProperty();
+                    // todo 拦截过滤，大小过滤
+                    String strs = String.valueOf(parameterObject1.get(property));
+                    if (strs != null) {
+                        temp[0] = temp[0].replaceFirst("\\?", "'" + strs + "'");
+                    }
+                });
+            } else if (parameterObject instanceof String) {
+                // 单参数
+                parameterMappings.forEach(parameters -> {
+                    // todo 拦截过滤，大小过滤
+                    String strs = String.valueOf(parameterObject);
+                    temp[0] = temp[0].replaceFirst("\\?", "'" + strs + "'");
+
+                });
+            } else if (parameterObject.getClass().isAssignableFrom(type)) {
+                // 对象类型
+                String ss = parameterObject.toString();
+                String substring = ss;
+                String[] strings = new String[1];
+                strings[0]=ss;
+                substring = substring.replaceFirst("\\(", "");
+                substring = substring.replaceFirst("\\)", "");
+                if (substring.contains("(") || substring.contains(")")) {
+                    // 不管, 显示全部j对象数据
+                } else {
+                    substring =  strings[0];
+                    substring = substring.replaceAll(" ", "");
+                    HashMap<String, String> map = new HashMap<>();
+                    int i = substring.indexOf("(");
+                    int i1 = substring.lastIndexOf(")");
+                    if (i != -1 && i1 != -1) {
+                        substring = substring.substring(i + 1, i1);
+                    }
+                    // 若不存在复合类型的精准提供
+                    String[] split = substring.split(",");
+                    if (split.length > 0) {
+                        for (String s : split) {
+                            int i2 = s.indexOf("=");
+                            String key = s.substring(0, i2);
+                            String value = s.substring(i2 + 1);
+                            map.put(key, value);
+                        }
+                    }
+                    parameterMappings.forEach(parameters -> {
+                        String property = parameters.getProperty();
+                        String strs = String.valueOf(map.get(property));
+                        temp[0] = temp[0].replaceFirst("\\?", "'" + strs + "'");
+
+                    });
+
+                }
+
+
+            }
+
+        }
+        //TODO 自己要进行的各种处理
+        return temp[0];
+    }
+
+    @Override
+    public Object plugin(Object target) {
+        return Plugin.wrap(target, this);
+    }
+
+    @Override
+    public void setProperties(Properties properties) {
+        //
+    }
+
+}

侯春建_Mybatis2/src/main/java/com/Config/MyTypeHandler.java

+package com.Config;
+package com.Config;
+
+import com.Domain.Context;
+import com.Domain.User;
+import com.alibaba.fastjson.JSONObject;
+import org.apache.ibatis.type.JdbcType;
+import org.apache.ibatis.type.MappedJdbcTypes;
+import org.apache.ibatis.type.MappedTypes;
+import org.apache.ibatis.type.TypeHandler;
+
+import java.sql.CallableStatement;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+/**
+ * Created by hcj on 18-7-18
+ */
+@MappedTypes({Context.class})
+@MappedJdbcTypes({JdbcType.VARCHAR})
+public class MyTypeHandler implements TypeHandler<Context> {
+
+    @Override
+    public void setParameter(PreparedStatement preparedStatement, int i, Context user, JdbcType jdbcType) throws SQLException {
+        System.out.println("自定义类型转换");
+        String s = JSONObject.toJSONString(user);
+        preparedStatement.setString(i, s);
+    }
+
+    @Override
+    public Context getResult(ResultSet rs, String columnName) throws SQLException {
+        System.out.println("自定义类型转换");
+        String string = rs.getString(columnName);
+        return JSONObject.parseObject(string, Context.class);
+    }
+
+    @Override
+    public Context getResult(ResultSet rs, int columnIndex) throws SQLException {
+        System.out.println("自定义类型转换");
+        String string = rs.getString(columnIndex);
+        return JSONObject.parseObject(string, Context.class);
+    }
+
+    @Override
+    public Context getResult(CallableStatement cs, int columnIndex) throws SQLException {
+        System.out.println("自定义类型转换");
+        String string = cs.getString(columnIndex);
+        return JSONObject.parseObject(string, Context.class);
+    }
+}

侯春建_Mybatis2/src/main/java/com/Controller/Controller.java

+package com.Controller;
+package com.Controller;
+
+import com.Domain.User;
+import com.Service.UserService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * Created by hcj on 18-7-16
+ */
+@RestController
+public class Controller {
+
+    @Autowired
+    UserService userService;
+
+    @RequestMapping("insertUser")
+    public void save(@RequestBody User user) {
+        userService.insertUser(user);
+    }
+
+    @RequestMapping("insertUserNoObject")
+    public void insertUserNoObject(@RequestBody User user) {
+        userService.insertUserNoObject(user);
+    }
+
+    @GetMapping("insert")
+    public void transactionTestWithInsert() {
+        userService.insert();
+    }
+
+    @GetMapping("select")
+    public ResponseEntity transactionTestWithSelect() {
+
+        return ResponseEntity.ok(userService.findUser().size());
+
+    }
+
+    @GetMapping("selectByOne")
+    public ResponseEntity transactionTestWithSelectByOne() {
+        String name = "pop0";
+        return ResponseEntity.ok(userService.selectUserByUsername(name).size());
+
+    }
+
+
+    @GetMapping("selectOne")
+    public void selectUser() {
+        String name = "username";
+        String password = "123";
+        User user = userService.selectUser(name, password);
+        System.out.println(user);
+    }
+}

侯春建_Mybatis2/src/main/java/com/Domain/Context.java

+package com.Domain;
+package com.Domain;
+
+import lombok.*;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+
+@ToString
+@Builder
+@Getter
+@Setter
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+public class Context {
+
+    public Context() {
+    }
+
+    public Context(String username, String password, Boolean enabled, String context) {
+        this.username = username;
+        this.password = password;
+        this.enabled = enabled;
+        this.context = context;
+    }
+
+    private String username;
+    private String password;
+    private Boolean enabled;
+    private String context;
+
+
+}
\ No newline at end of file

侯春建_Mybatis2/src/main/java/com/Domain/User.java

+package com.Domain;
+package com.Domain;
+
+import lombok.*;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+
+@ToString
+@Builder
+@Getter
+@Setter
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+public class User  {
+
+    public User() {
+    }
+
+    public User(String username, String password, Boolean enabled, Context context) {
+        this.username = username;
+        this.password = password;
+        this.enabled = enabled;
+        this.context = context;
+    }
+
+    private String username;
+    private String password;
+    private Boolean enabled;
+    private Context context;
+
+
+}
\ No newline at end of file

侯春建_Mybatis2/src/main/java/com/Mapper/UserMapper.java

+package com.Mapper;
+package com.Mapper;
+
+import com.Domain.User;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+@test
+public interface UserMapper {
+
+    public void insert(User user);
+    public User selectUser(@Param(value = "username") String userName, @Param(value = "password")String password);
+
+    public List<User> selectUserByUsername(String userName);
+    public List<User> selectAll();
+    User findOne(String username);
+
+}
\ No newline at end of file

侯春建_Mybatis2/src/main/java/com/Mapper/test.java

+package com.Mapper;
+package com.Mapper;
+
+import java.lang.annotation.Documented;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Inherited;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+/**
+ * Created by hcj on 18-7-16
+ */
+@Target({ElementType.FIELD, ElementType.METHOD, ElementType.PARAMETER, ElementType.TYPE, ElementType.ANNOTATION_TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+@Inherited
+@Documented
+public @interface test {
+
+  String value() default "";
+
+}

侯春建_Mybatis2/src/main/java/com/Service/UserService.java

+package com.Service;
+package com.Service;
+
+import com.Domain.Context;
+import com.Domain.User;
+import com.Mapper.UserMapper;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Isolation;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+
+/**
+ * cglib 代理 Created by hcj on 18-7-16
+ */
+@Service
+public class UserService {
+
+    @Autowired
+    private UserMapper userMapper;
+
+    // 脏读
+    @Transactional(isolation = Isolation.READ_UNCOMMITTED)
+    public void insert() {
+        User user = new User();
+        user.setUsername("hch");
+        user.setPassword("123");
+        user.setEnabled(true);
+        Context build = Context.builder().username("hcj").password("123")
+                .context("hello world").enabled(true).build();
+        user.setContext(build);
+        userMapper.insert(user);
+        try {
+            Thread.sleep(10000);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+        throw new RuntimeException();
+    }
+
+    public void insertUser(User user) {
+        user.setEnabled(true);
+        Context build = Context.builder().username("hcj").password("123")
+                .context("hello world").enabled(true).build();
+        user.setContext(build);
+        userMapper.insert(user);
+
+    }
+    // 不开启事务
+//  @Transactional(readOnly = true)
+    public List<User> findUser() {
+        return userMapper.selectAll();
+    }
+
+    public User selectUser(String username,String password) {
+        return userMapper.selectUser(username,password);
+    }
+
+    public List<User> selectUserByUsername(String username) {
+        return userMapper.selectUserByUsername(username);
+    }
+
+    public void insertUserNoObject(User user) {
+
+        user.setEnabled(true);
+        userMapper.insert(user);
+    }
+
+//    public static void main(String[] args) {
+//        User build = User.builder().username("hcj").password("123")
+//                .context("hello world").enabled(true).build();
+//        String s = JSONObject.toJSONString(build);
+//        System.out.println(s);
+//
+//    }
+
+}

侯春建_Mybatis2/src/main/java/com/StartUp.java

+package com;
+package com;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.transaction.annotation.EnableTransactionManagement;
+
+/**
+ * 开启 springboot Created by hcj on 18-7-10
+ */
+@EnableTransactionManagement
+@SpringBootApplication
+public class StartUp {
+
+
+    public static void main(String[] args) {
+        SpringApplication app = new SpringApplication(StartUp.class);
+        app.run(args);
+    }
+
+}
+

侯春建_Mybatis2/src/main/resources/bean/UserMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper  PUBLIC "-//mybatis.org//DTD com.Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.Mapper.UserMapper"> <!--mapper  -->
+
+    <resultMap type="user" id="userList">
+        <!-- type为返回列表元素的类全名或别名 -->
+        <result column="username" property="username"/>
+        <result column="password" property="password"/>
+        <result column="enabled" property="enabled"/>
+        <result column="context" property="context"
+                typeHandler="com.Config.MyTypeHandler"/>
+    </resultMap>
+
+
+    <insert id="insert" parameterType="user">
+    insert into users(username,
+    password,enabled,context) values(#{username}, #{password},#{enabled},#{context})
+  </insert>
+    <select id="selectUser" parameterType="String" resultType="user">
+    SELECT #{username},#{password} FROM users WHERE username = #{username} and password=#{password}
+  </select>
+    <select id="selectUserByUsername" parameterType="String" resultType="user">
+    SELECT #{username} FROM users WHERE username = #{username}
+  </select>
+    <select id="selectAll" resultMap="userList">
+    SELECT * FROM users
+  </select>
+</mapper>
\ No newline at end of file

侯春建_Mybatis2/src/main/resources/config/application-preprodtest.yml

+# ===================================================================
+# ===================================================================
+# Spring Boot configuration for the "dev" profile.
+#
+# This configuration overrides the application.yml file.
+#
+# More information on profiles: http://www.jhipster.tech/profiles/
+# More information on configuration properties: http://www.jhipster.tech/common-application-properties/
+# ===================================================================
+
+# ===================================================================
+# Standard Spring Boot properties.
+# Full reference is available at:
+# http://docs.spring.io/spring-boot/docs/current/reference/html/common-application-properties.html
+# ===================================================================
+# springboot 提供的日志,
+logging:
+    level:
+        ROOT: DEBUG
+#        spittr: DEBUG
+#    file: my.log
+
+spring:
+    profiles:
+        active: StartUp
+    jackson:
+        serialization.indent_output: true
+    redis:
+        port: 6379
+        database: 7
+        lettuce:
+          pool:
+            max-active: 10
+            min-idle: 3
+            max-idle: 8
+#    mail:
+#      host: mail.mso-china.com
+#      port: 25
+#      username: Tom.hou@mso-china.com
+#      password: woaini111
+
+server:
+    port: 8081
+    address: 0.0.0.0
+
+#mailServer:
+#    from: Tom.hou@mso-china.com
+#    to: Tom.hou@mso-china.com
+#    backupfile: /home/hcj/backup/
\ No newline at end of file

侯春建_Mybatis2/src/main/resources/config/application.yml

+spring:
+spring:
+    application:
+        name: StartUp
+    profiles:
+        active: preprodtest
+info:
+    project:
+        version: 1.0 #project.version# kerberosprod preprod
+
+application:

侯春建_Mybatis2/src/main/resources/sqlMapConfig.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE configuration  PUBLIC "-//mybatis.org//DTD com.Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-config.dtd">
+<configuration>
+
+    <settings>
+        <!--<setting name="cacheEnabled" value="true"/>-->
+        <!--<setting name="lazyLoadingEnabled" value="true"/>-->
+        <!--<setting name="aggressiveLazyLoading" value="false"/>-->
+        <!--<setting name="defaultExecutorType" value="BATCH"/>-->
+        <setting name="defaultStatementTimeout" value="25000"/>
+    </settings>
+    <typeHandlers>
+        <typeHandler handler="com.Config.MyTypeHandler" jdbcType="VARCHAR" javaType="com.Domain.Context"/>
+    </typeHandlers>
+    <plugins>
+        <plugin interceptor="com.Config.CustomPlugin"/>
+    </plugins>
+
+    <!--<plugins>-->
+        <!--<plugin interceptor="com.Mapper.MyPlugins">-->
+            <!--<property name="dbType" value="Mysql"/>-->
+        <!--</plugin>-->
+        <!--<plugin interceptor="com.github.pagehelper.PageHelper">-->
+            <!--<property name="dialect" value="mysql"/>-->
+            <!--<property name="offsetAsPageNum" value="false"/>-->
+            <!--<property name="rowBoundsWithCount" value="false"/>-->
+            <!--<property name="pageSizeZero" value="true"/>-->
+            <!--<property name="reasonable" value="false"/>-->
+            <!--<property name="supportMethodsArguments" value="false"/>-->
+            <!--<property name="returnPageInfo" value="none"/>-->
+        <!--</plugin>-->
+        <!--<plugin interceptor="com.Mapper.SelectLimitPlugins">-->
+        <!--<property name="limit" value="1"/>-->
+        <!--</plugin>-->
+        <!--<plugin interceptor="com.Mapper.PagePlugins">-->
+        <!--<property name="page" value="1"/>-->
+        <!--<property name="pageSize" value="5"/>-->
+        <!--<property name="useFlag" value="true"/>-->
+        <!--<property name="checkFlag" value="true"/>-->
+        <!--</plugin>-->
+    <!--</plugins>-->
+</configuration>
\ No newline at end of file

侯春建_Mybatis2/src/test/java/transaction/MybatisTest.java

+package transaction;
+package transaction;
+
+import com.Config.AppConfig1;
+import com.Domain.Context;
+import com.Domain.User;
+import com.Mapper.UserMapper;
+import com.Service.UserService;
+import com.StartUp;
+import org.apache.ibatis.session.ExecutorType;
+import org.apache.ibatis.session.SqlSession;
+import org.apache.ibatis.session.SqlSessionFactory;
+import org.apache.ibatis.session.TransactionIsolationLevel;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.context.annotation.AnnotationConfigApplicationContext;
+import org.springframework.test.context.junit4.SpringRunner;
+
+import java.util.List;
+
+/**
+ * Created by hcj on 18-7-16
+ */
+@RunWith(SpringRunner.class)
+@SpringBootTest(classes = {StartUp.class})
+public class MybatisTest {
+    private static final AnnotationConfigApplicationContext context =
+            new AnnotationConfigApplicationContext(AppConfig1.class);
+    @Autowired
+    UserService userService;
+    //=====================================mybatis 2 homework start=============================================================
+
+    /**
+     * 提供单对象，和多对象参数， sql打印功能 => 查询
+     */
+    @Test
+    public void selectUser() {
+        String name = "hcj";
+        User user = userService.selectUser(name, "123");
+        System.out.println(user);
+    }
+
+    /**
+     * 提供单对象，， sql打印功能 => 修改删除，新增，  注意： 目前多对象参数暂不支持
+     */
+    @Test
+    public void insertUser() {
+        userService.insertUserNoObject(User.builder().username("1").password("2").enabled(true).build());
+    }
+
+    //=========================`================mybatis 2 homework end=========================================================
+
+    /**
+     * 1. 自定义TypeHandler类
+     *
+     * @param
+     * @return void
+     * @author houchunjian
+     * @date 2019/12/1 0001 14:01
+     */
+    @Test
+    public void test() {
+        List<User> user = userService.findUser();
+        System.out.println(user);
+    }
+
+    /**
+     * 1. Mybatis 批量插入数据库代码
+     *
+     * @param
+     * @return void
+     * @author houchunjian
+     * @date 2019/12/1 0001 14:01
+     */
+    @Test
+    public void insertOptimistic() {
+        SqlSessionFactory sqlSessionFactory = context
+                .getBean("sqlSessionFactory", SqlSessionFactory.class);
+        // sqlSession 开启事务。 ExecutorType.REUSE   保证batch 事务的合理使用，
+        SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED);
+        UserMapper mapper = sqlSession.getMapper(UserMapper.class);
+
+        for (int i = 10; i < 20; i++) {
+            User user = new User();
+            user.setUsername("pop" + i);
+            user.setPassword(i + "");
+            user.setEnabled(true);
+            if (i % 2 == 0) {
+                Context build = Context.builder().username("hcj").password("123")
+                        .context("hello world").enabled(true).build();
+                build.setContext("hello world: " + i);
+                user.setContext(build);
+            } else {
+                Context build = Context.builder().username("hcj").password("123")
+                        .context("hello world").enabled(true).build();
+                build.setContext("world: " + i);
+                user.setContext(build);
+            }
+            mapper.insert(user);
+        }
+        // 刷新
+        sqlSession.flushStatements();
+    }
+}

侯春建_Mybatis2/users.sql

+-- test
+-- test
+CREATE TABLE `users` (
+  `username` varchar(255) DEFAULT NULL,
+  `password` varchar(255) DEFAULT NULL,
+  `enabled` bit(1) DEFAULT NULL,
+  `context` varchar(1000) DEFAULT NULL
+) ENGINE=InnoDB DEFAULT CHARSET=utf8;
\ No newline at end of file