MyBatis的CURD

Dear 丶 2022-04-25 02:12 161阅读 0赞

Mybatis 数据库增删改查操作：

## 数据准备 ##

![Amx8Z4.png][]

![AmxZIs.png][]

## 项目结构 ##

![Amxyod.png][]

### Department ###

### Employee ###

### EmployeeMapper ###

### EmployeeMapper.xml ###

### TestMybatisMapper ###

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 </pre></td> 
 <td><pre>package com.hph.mybatis.test; import com.hph.mybatis.beans.Employee; import com.hph.mybatis.dao.EmployeeMapper; import org.apache.ibatis.io.Resources; import org.apache.ibatis.session.SqlSession; import org.apache.ibatis.session.SqlSessionFactory; import org.apache.ibatis.session.SqlSessionFactoryBuilder; import org.junit.Test; import java.io.IOException; import java.io.InputStream; import java.sql.SQLException; import java.util.HashMap; import java.util.Map; public class TestMybatisMapper {
 @Test public void testSqlsessionFactory() throws IOException {
 String resource = "mybatis-config.xml"; InputStream inputStream = Resources.getResourceAsStream(resource); SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream); System.out.println(sqlSessionFactory); SqlSession session = sqlSessionFactory.openSession(); System.out.println(session); try {
 Employee employee = session.selectOne("selectEmployee", 5); System.out.println(employee); } finally {
 session.close(); } } @Test public void testHelloWorldMapper() throws IOException {
 String resource = "mybatis-config.xml"; InputStream inputStream = Resources.getResourceAsStream(resource); SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream); SqlSession session = sqlSessionFactory.openSession(); try {
 //Mapper接口 dao接口 EmployeeMapper dao = session.getMapper(EmployeeMapper.class); Employee employee = dao.getEmployeeById(1001); System.out.println(employee); } finally {
 session.close(); } } public SqlSessionFactory getsqlSessionFactory() throws IOException {
 String resource = "mybatis-config.xml"; InputStream inputStream = Resources.getResourceAsStream(resource); SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream); return sqlSessionFactory; } @Test public void testCRUD() throws IOException, SQLException {
 SqlSessionFactory ssf = getsqlSessionFactory(); SqlSession session = ssf.openSession(true); try {
 //获取代理实现类对象 mapper接口的代理实现类对象 EmployeeMapper mapper = session.getMapper(EmployeeMapper.class); //添加 Employee employee = new Employee(null, "清风笑_Test", "qfx@qq.com", 1); mapper.addEmployee(employee); System.out.println("返回的键值" + employee.getId()); /** * Connection conn = null; * PreparedStatement ps = conn.prepareStatement("sql", PreparedStatement.RETURN_GENERATED_KEYS); * * ps.executeUpdate(); * ps.getGeneratedKeys(); * jdbc获取新插入的组件的数值 */ //修改 Employee employee1 = new Employee(null,"清风_笑丶", "qfx@gmail.com", 1); mapper.updateEmployee(employee1); //删除 // Integer count = mapper.deleteEmployeeById(1001); // System.out.println(count); } finally {
 session.close(); } } @Test public void testParameter() throws IOException {
 SqlSessionFactory ssf = getsqlSessionFactory(); SqlSession session = ssf.openSession(true); try {
 EmployeeMapper mapper = session.getMapper(EmployeeMapper.class); // Employee employee = mapper.getEmployeeByIdAndLastName(5, "清风_笑丶"); Map&lt;String, Object&gt; map = new HashMap&lt;String, Object&gt;(); map.put("id", "5"); map.put("ln", "清风_笑丶"); map.put("tableName", "tbl_employee"); Employee employee = mapper.getEmployeeByMap(map); System.out.println(employee); } finally {
 session.close(); } } @Test public void tetSelect() throws IOException {
 SqlSessionFactory ssf = getsqlSessionFactory(); SqlSession session = ssf.openSession(true); try {
 EmployeeMapper mapper = session.getMapper(EmployeeMapper.class); //List&lt;Employee&gt; emps = mapper.getEmps(); //System.out.println(emps); //Map&lt;String, Object&gt; map = mapper.getEmployeeByIdReturnMap(5); //System.out.println(map); Map&lt;Integer, Employee&gt; map = mapper.getEmpsRetrunMap(); System.out.println(map); } finally {
 session.close(); } } } </pre></td> 
 </tr> 
 </tbody> 
</table>

## 结果 ##

testHelloWorldMapper

![AmzojK.png][]

addEmployee

添加数据

![AnpOSI.png][]

![AnpbYd.png][]

修改数据

![AnPBOP.png][]

![AnP2Wj.png][]

删除数据

![AnPfln.png][]

![AnPhyq.png][]

testParameter

![AnFHz9.png][]

tetSelect

无参数

![AnkFsI.png][]

有参数

![AnkKzj.png][]

## 主键生成方式、获取主键值 ##

### 主键生成方式 ###

支持主键自增，例如MySQL数据库

不支持主键自增，例如Oracle数据库

### 获取主键值 ###

数据库支持自动生成主键的字段（比如 MySQL 和 SQL Server），则可以设置 useGeneratedKeys=”true”，然后再把 keyProperty设置到目标属性上。

### 参数传递 ###

#### 参数传递的方式 ####

*  单个参数: 可以接受基本类型，对象类型。这种情况MyBatis可直接使用这个参数，不需要经过任 何处理。
 *  多个参数: 任意多个参数，都会被MyBatis重新包装成一个Map传入。Map的key是param1，param2，或者0，1…，值就是参数的值
 *  命名参数: 为参数使用@Param起一个名字，MyBatis就会将这些参数封装进map中，key就是我们自己指定的名
 *  POJO: 当这些参数属于我们业务POJO时，直接传递POJO
 *  Map : 我们也可以封装多个参数为map，直接传递
 *  Collection/Array : 会被MyBatis封装成一个map传入, Collection对应的key是collection,Array对应的key是array. 如果确定是List集合，key还可以是list.

#### 参数传递源码 ####

### 参数处理 ###

参数位置支持的属性: javaType、jdbcType、mode、numericScale、resultMap、typeHandler、jdbcTypeName、expression

实际上通常被设置的是：可能为空的列名指定 jdbcType ,例如:

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 </pre></td> 
 <td><pre>insert into orcl_employee(id,last_name,email,gender) values(employee_seq.nextval,#{lastName, ,jdbcType=NULL },#{email},#{gender})可以在全局配置文件指定为null 也可以像上面这面这样单独配置 </pre></td> 
 </tr> 
 </tbody> 
</table>

### 参数获取方式 ###

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 5 6 7 8 9 </pre></td> 
 <td><pre>#{key}：可取普通类型、POJO类型、多个参数、集合类型 获取参数的值，预编译到SQL中。安全。Preparedstatement ${key}：可取单个普通类型、POJO类型、多个参数、集合类型 注意：取单个普通类型的参数，${}中不能随便写 必须用_parameter _parameter是Mybatis的内置参数获取参数的值，拼接到SQL中。有SQL注入问题。Statement ORDER BY ${name} 原则：能用#{}取值就优先使用#{} 解决不了的使用${} 		e.g.原生的JDBC不支持占位符的地方 就可以使用${} 		e.g.Select column1,column2…from 表 where 条件 group by 组表示 having 条件 				order by 排序字段 desc/asc limit X，X； </pre></td> 
 </tr> 
 </tbody> 
</table>

### select查询的几种情况 ###

查询单行数据返回单个对象

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 </pre></td> 
 <td><pre>public Employee getEmployeeById(Integer id ); </pre></td> 
 </tr> 
 </tbody> 
</table>

查询多行数据返回对象的集合

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 </pre></td> 
 <td><pre>public List&lt;Employee&gt; getAllEmps(); </pre></td> 
 </tr> 
 </tbody> 
</table>

查询单行数据返回Map集合

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 </pre></td> 
 <td><pre>public Map&lt;String,Object&gt; getEmployeeByIdReturnMap(Integer id ); </pre></td> 
 </tr> 
 </tbody> 
</table>

查询多行数据返回Map集合

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 </pre></td> 
 <td><pre>@MapKey("id") // 指定使用对象的哪个属性来充当map的key(对象的属性，而不是数据库的列) public Map&lt;Integer,Employee&gt; getAllEmpsReturnMap(); </pre></td> 
 </tr> 
 </tbody> 
</table>

## resultType自动映射 ##

*  autoMappingBehavior默认是PARTIAL，开启自动映射的功能。唯一的要求是列名和javaBean属性名一致
 *  如果autoMappingBehavior设置为null则会取消自动映射
 *  数据库字段命名规范，POJO属性符合驼峰命名法，如A\_COLUMNaColumn，我们可以开启自动驼峰命名规则映射功能，mapUnderscoreToCamelCase=true

缺点：多表查询 完成不了

[Amx8Z4.png]: /images/20220210/c3b8836c179b4cc0b97f0cff486581ac.png
[AmxZIs.png]: /images/20220210/22ecf5a9066448c984ba6e908e6a70a0.png
[Amxyod.png]: /images/20220210/d1da5ad7e2cf484182daa8786e6792d5.png
[AmzojK.png]: /images/20220210/eec2e5e6bbf249159b3c14368e7fc7e8.png
[AnpOSI.png]: /images/20220210/cd33794fc2c845cda3b458fdda18b16e.png
[AnpbYd.png]: /images/20220210/f1876c825835439d80d18e9b5ccb5b26.png
[AnPBOP.png]: /images/20220210/731c2531fee54769992e430d1b0e8cb5.png
[AnP2Wj.png]: /images/20220210/1563eaea87254451ae31d8272a163b92.png
[AnPfln.png]: /images/20220210/4a40d57b09634c51892785630ec4d965.png
[AnPhyq.png]: /images/20220210/a320fc42dd794346bd156bb922e51572.png
[AnFHz9.png]: /images/20220210/343f45cdf9fc41e2b71227494823fe53.png
[AnkFsI.png]: /images/20220210/363b924905b4405994104fb91a210eb4.png
[AnkKzj.png]: /images/20220210/51014ab0ab064c8080c02d50961a1448.png