Mybatis关于mysql简单操作学习
1.概述
对mybatis常用的操作命令做一下总结,数据库基于mysql。后面章节会涉及数据的批量插入、批量更新和更新后返回主键ID等内容。
1.数据库信息
1.1.表结构定义
CREATE TABLE users (
id int(11) NOT NULL AUTO_INCREMENT,
NAME varchar(20) DEFAULT NULL,
age int(11) DEFAULT NULL,
remark varchar(200) DEFAULT NULL,
PRIMARY KEY (id)
) ENGINE=InnoDB AUTO_INCREMENT=682 DEFAULT CHARSET=utf8;
1.2.数据库配置db.properties
mysql.driver=com.mysql.jdbc.Driver
需要开启多行执行功能 jdbc:mysql://localhost:3306/mybatis?userUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&autoReconnect=true&failOverReadOnly=false" jdbc:mysql://localhost:3306/mybatis?userUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=UTC&allowMultiQueries=true" mysql.url=jdbc:mysql://localhost:3306/mybatis?userUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true
mysql.username=root
mysql.password=123456
1.3.实体类
package com.tech.ability.mybatis.Entity;
/**

• Created by kikop on 2019/1/17.
  */
  public class MyUser {
  //实体类的属性和表的字段名称一一对应
  private int id;
  private String name;
  private int age;
  public String getRemark() {
  return remark;
  }
  public void setRemark(String remark) {
  this.remark = remark;
  }
  private String remark;
  public int getId() {
  return id;
  }
  public void setId(int id) {
  this.id = id;
  }
  public String getName() {
  return name;
  }
  public void setName(String name) {
  this.name = name;
  }
  public int getAge() {
  return age;
  }
  public void setAge(int age) {
  this.age = age;
  }
  @Override
  public String toString() {
  return "MyUser{" +
  "age=" + age +
  ", id=" + id +
  ", name='" + name + ''' +
  ", remark='" + remark + ''' +
  '}';
  }
  

}
2.mybatis mapper接口文件
package com.tech.ability.mybatis.Mapper;
import com.alibaba.fastjson.JSONObject;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.SelectKey;
import org.springframework.data.repository.query.Param;
/**

• Created by kikop on 2019/5/19.
  */
  public interface MyUserMapper {

}
3.mybatis sqlmap映射文件








select * from users where id=#{intid}

select * from users where id in (#{strQueryIds})select * from users where id in #{id} select * from users where id in ${id}

4.mybatis工具类
package com.tech.ability.mybatis;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.ExecutorType;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import java.io.IOException;
import java.io.InputStream;
/**

• Created by kikop on 2019/5/19.
  */
  public class mybatisUtils {
  //mybatis核心配置文件
  private static final String mybatis_configPath = "mybatisconfig.xml";

/** * 读取SqlSession * * @return */ public static SqlSession getSqlSession(ExecutorType execType, boolean isAutoCommit) {SqlSession sqlSession = null; try { //1.读取mybatis的配置文件 //String resource = "mybatisconfig.xml"; //2.构建sqlSession的工厂 //使用类加载器加载 mybatis 的 classspath中配置文件 InputStream inputStream = null;

// InputStream inputStream = mybatisTest.class.getClassLoader().getResourceAsStream(resource);
inputStream = Resources.getResourceAsStream(mybatis_configPath);
SqlSessionFactory sessionFactory = new SqlSessionFactoryBuilder().build(inputStream);

//2.构建sqlSession的工厂 //使用MyBatis提供的Resources类加载mybatis的配置文件（它也加载关联的映射文件） //Reader reader = Resources.getResourceAsReader(resource); //SqlSessionFactory sessionFactory = new SqlSessionFactoryBuilder().build(reader); //3.创建能执行映射文件中sql的sqlSession

// sqlSession = sessionFactory.openSession(isAutoCommit);
sqlSession = sessionFactory.openSession(execType, isAutoCommit);

} catch (IOException e) { e.printStackTrace(); }return sqlSession; }/** * 关闭session(回收连接池必须) * * @param session */ public static void closeSqlSession(SqlSession session) { session.close(); }/** * 关闭inputStream * * @param inputStream */ public static void closeInputSream(InputStream inputStream) { try { inputStream.close(); } catch (IOException e) { e.printStackTrace(); } }

}
5.测试代码
5.1.测试1
package com.tech.ability.mybatis;
import com.alibaba.fastjson.JSONObject;
import com.tech.ability.mybatis.Entity.MyUser;
import org.apache.ibatis.session.ExecutorType;
import org.apache.ibatis.session.SqlSession;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.ArrayList;
import java.util.List;
/**

• Created by kikop on 2019/1/17.
  */
  public class mybatisTest {
  private static final Logger logger = LogManager.getLogger(mybatisTest.class);
  /**
  
  • getUserInfoByIDTest
    */
    public static void getUserInfoByIDTest() {
    //1.构建sqlSession
    SqlSession session = mybatisUtils.getSqlSession(ExecutorType.SIMPLE, false);
    //2.映射sql的标识字符串
    //String statement = "com.skill.tech.mybatis.Mapper.MyUserMapper.getUserInfoByID"; //映射sql的标识字符串
    StringBuffer statement = new StringBuffer();
    statement.append("com.tech.ability.mybatis.Mapper.MyUserMapper"); //mapper标签的namespace属性的值
    statement.append(".getUserInfoByID"); //select标签的id属性值
    //3.定义查询条件
    int intid = 2;
    //4.执行查询返回一个唯一user对象的sql
    MyUser myUser = session.selectOne(statement.toString(), intid);
    mybatisUtils.closeSqlSession(session);
    //5.输出结果
    System.out.println(myUser);
    
  【2019-01-22_Mybatis关于mysql简单操作学习】}
  5.2.测试2
  /**
  
  • getUserInfoByInTest
    */
    private static void getUserInfoByInTest() {
    //1.构建sqlSession
    SqlSession session = mybatisUtils.getSqlSession(ExecutorType.SIMPLE, false);
    //2.映射sql的标识字符串
    StringBuffer statement = new StringBuffer();
    statement.append("com.tech.ability.mybatis.Mapper.MyUserMapper"); //mapper标签的namespace属性的值
    statement.append(".getUserInfoByIn"); //select标签的id属性值
    //3.定义查询条件
    String strQueryIds = "1,2";
    //4.执行查询返回一个唯一user对象的sql
    List myUser = session.selectList(statement.toString(), strQueryIds);
    mybatisUtils.closeSqlSession(session);
    //5.输出结果
    System.out.println(myUser);
    
  }
  5.3.测试3
  /**
  
  • getUserInfoByInnerForeachTest
    */
    private static void getUserInfoByInnerForeachTest() {
    //1.构建sqlSession
    SqlSession session = mybatisUtils.getSqlSession(ExecutorType.SIMPLE, false);
    //3.映射sql的标识字符串
    StringBuffer statement = new StringBuffer();
    statement.append("com.tech.ability.mybatis.Mapper.MyUserMapper"); //mapper标签的namespace属性的值
    statement.append(".getUserInfoByInnerForeach"); //select标签的id属性值
    //3.定义查询条件
    JSONObject jsonObject = new JSONObject();
    List idList = new ArrayList<>();
    idList.add(1);
    idList.add(11);
    jsonObject.put("idList", idList);
    //4.执行查询返回一个唯一user对象的sql
    List myUser = session.selectList(statement.toString(), jsonObject);
    mybatisUtils.closeSqlSession(session);
    //5.输出结果
    System.out.println(myUser);
    }
    5.1.测试4
    
  /**
  
  • getUserInfoByInnerForeachRetJsonTest
    */
    private static void getUserInfoByInnerForeachRetJsonTest() {
    //1.构建sqlSession
    SqlSession session = mybatisUtils.getSqlSession(ExecutorType.SIMPLE, false);
    //2.映射sql的标识字符串
    StringBuffer statement = new StringBuffer();
    statement.append("com.tech.ability.mybatis.Mapper.MyUserMapper"); //mapper标签的namespace属性的值
    statement.append(".getUserInfoByInnerForeachRetJson"); //select标签的id属性值
    //3.定义查询条件
    JSONObject jsonObject = new JSONObject();
    List idList = new ArrayList<>();
    idList.add(1);
    idList.add(92);
    jsonObject.put("idList", idList);
    //4.执行查询返回一个唯一user对象的sql
    List myUser = session.selectList(statement.toString(), jsonObject);
    mybatisUtils.closeSqlSession(session);
    //5.输出结果
    System.out.println(myUser);
    }
    

6.调用
public static void main(String[] args) throws Exception {
//getUserInfoByIDTest();
//getUserInfoByInTest();
//getUserInfoByInnerForeachTest();
//batchUpdateUserInfoListManualTest();
//batchUpdateUserInfoListAutoTest();
//batchInsertUserInfoListByUnionAllTest();
//batchInsertUserInfoListByExecutorBachTest2();
//insertUserXmlTest();
batchInsertUserInfoListByUnionAllTest();
}
}
总结
1.数据库连接时,设置运行多行查询。
2.多条语句,用“；”隔开即可。

推荐阅读

• 

  如何下载bt磁力种子
• 

  亚索在永恩出来后新台词 mysql的特征及性能
• 

  三星W2019手机屏幕失灵维修价格
• 

  解压包子使用感怎么样 网红解压包子里面是什么
• 

  经常莫名其妙的就来一下胸口痛，想知道怎么了
• 

  非法吸收公众存款罪怎么处罚 非法吸收公众存款罪怎么处罚的
• 

  方太烤箱烧烤用哪个模式 方太烤箱烤红薯用哪个模式
• 

  大金空调制冷可以制热没反应 大金空调为什么加热不制冷解决步骤
• 

  湖山入映—西湖游记
• 

  石斛粉一天吃多少克为好
• 

  《LOL》IG经理透露,战队被官方针对,选手在韩服无法正常游戏,这事你怎么看？
• 

  莲子煮粥一次放几个
• 

  数据分析行业的薪酬,游戏公司数据分析工程师薪酬
• 

  原神神鹤是谁 原神神鹤雨海阵容厉害吗
• 

  ?V怎么读 汜怎么读
• 

  有没有专门抓小三的机构 专业捉小三团队多少钱
• 

  公司不证明个人可以申请工伤鉴定吗
• 

  大众辉昂的发动机是进口的吗 大众辉昂的发动机是进口的吗多少钱
• 

  八下期中语文考卷
• 

  二零小麦粉和三零面粉的区别 二零小麦粉和三零面粉的区别是什么

• 关于QueryWrapper|关于QueryWrapper,实现MybatisPlus多表关联查询方式
• mybatisplus如何在xml的连表查询中使用queryWrapper
• mybatisplus|mybatisplus where QueryWrapper加括号嵌套查询方式
• MybatisPlus|MybatisPlus LambdaQueryWrapper使用int默认值的坑及解决
• MybatisPlus使用queryWrapper如何实现复杂查询
• 四首关于旅行记忆的外文歌曲
• 醒不来的梦
• 关于自我为中心的一点感想
• 「按键精灵安卓版」关于全分辨率脚本的一些理解（非游戏app）
• 关于Ruby的杂想