ToB企服应用市场:ToB评测及商务社交产业平台

标题: MyBatis查询功能演示 [打印本页]
作者: 铁佛    时间: 2024-4-22 05:07
标题: MyBatis查询功能演示
准备工作

① 创建数据库&数据表
  1. ## 创建数据库
  2. CREATE DATABASE `dbtest1`;
  4. ## 创建数据表
  5. CREATE TABLE `t_user` (
  6.   `id` INT NOT NULL AUTO_INCREMENT,
  7.   `username` VARCHAR(20) DEFAULT NULL,
  8.   `password` VARCHAR(20) DEFAULT NULL,
  9.   `age` INT DEFAULT NULL,
  10.   `gender` CHAR(1) DEFAULT NULL,
  11.   `email` VARCHAR(50) DEFAULT NULL,
  12.   PRIMARY KEY (`id`)
  13. ) ENGINE=INNODB AUTO_INCREMENT=16 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci
复制代码
② 创建实体类
  1. public class User {
  3.     private int id;
  4.     private String username;
  5.     private String password;
  6.     private int age;
  7.     private String gender;
  8.     private String email;
  10.     public User() {
  11.     }
  13.     public User(int id, String username, String password, int age, String gender, String email) {
  14.         this.id = id;
  15.         this.username = username;
  16.         this.password = password;
  17.         this.age = age;
  18.         this.gender = gender;
  19.         this.email = email;
  20.     }
  22.     public int getId() {
  23.         return id;
  24.     }
  26.     public void setId(int id) {
  27.         this.id = id;
  28.     }
  30.     public String getUsername() {
  31.         return username;
  32.     }
  34.     public void setUsername(String username) {
  35.         this.username = username;
  36.     }
  38.     public String getPassword() {
  39.         return password;
  40.     }
  42.     public void setPassword(String password) {
  43.         this.password = password;
  44.     }
  46.     public int getAge() {
  47.         return age;
  48.     }
  50.     public void setAge(int age) {
  51.         this.age = age;
  52.     }
  54.     public String getGender() {
  55.         return gender;
  56.     }
  58.     public void setGender(String gender) {
  59.         this.gender = gender;
  60.     }
  62.     public String getEmail() {
  63.         return email;
  64.     }
  66.     public void setEmail(String email) {
  67.         this.email = email;
  68.     }
  70.     @Override
  71.     public String toString() {
  72.         return "User{" +
  73.                 "id=" + id +
  74.                 ", username='" + username + '\'' +
  75.                 ", password='" + password + '\'' +
  76.                 ", age=" + age +
  77.                 ", gender='" + gender + '\'' +
  78.                 ", email='" + email + '\'' +
  79.                 '}';
  80.     }
  81. }
复制代码
③ 创建mybatis核心配置文件
  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE configuration
  3.         PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
  4.         "http://mybatis.org/dtd/mybatis-3-config.dtd">
  5. <configuration>
  6.    
  7.     <properties resource="jdbc.properties"/>
  8.    
  9.     <typeAliases>
  10.         
  11.         <package name="com.evan.entity"/>
  12.     </typeAliases>
  13.    
  14.     <environments default="development">
  15.         <environment id="development">
  16.             <transactionManager type="JDBC"/>
  17.             <dataSource type="POOLED">
  18.                
  19.                 <property name="driver" value="${jdbc.driver}"/>
  20.                
  21.                 <property name="url" value="${jdbc.url}"/>
  22.                
  23.                 <property name="username" value="${jdbc.username}"/>
  24.                
  25.                 <property name="password" value="${jdbc.password}"/>
  26.             </dataSource>
  27.         </environment>
  28.     </environments>
  29.    
  30.     <mappers>
  31.         
  32.         <package name="com.evan.mapper"/>
  33.     </mappers>
  34. </configuration>
复制代码
④ 创建jdbc.properties
  1. jdbc.driver=com.mysql.cj.jdbc.Driver
  2. jdbc.url=jdbc:mysql://localhost:3306/dbtest1?serverTimezone=UTC
  3. jdbc.username=root
  4. jdbc.password=123456
复制代码
⑤ 添加依赖
  1. <dependencies>
  3. <dependency>
  4.     <groupId>org.mybatis</groupId>
  5.     <artifactId>mybatis</artifactId>
  6.     <version>3.5.7</version>
  7. </dependency>
  9. <dependency>
  10.     <groupId>junit</groupId>
  11.     <artifactId>junit</artifactId>
  12.     <version>4.13.2</version>
  13.     <scope>test</scope>
  14. </dependency>
  16. <dependency>
  17.     <groupId>mysql</groupId>
  18.     <artifactId>mysql-connector-java</artifactId>
  19.     <version>8.0.32</version>
  20. </dependency>
  22. <dependency>
  23.     <groupId>log4j</groupId>
  24.     <artifactId>log4j</artifactId>
  25.     <version>1.2.17</version>
  26. </dependency>
  28. <dependency>
  29.     <groupId>commons-logging</groupId>
  30.     <artifactId>commons-logging</artifactId>
  31.     <version>1.2</version>
  32. </dependency>
  33. </dependencies>
复制代码
⑥ 创建SqlSessionUtil
  1. public class SqlSessionUtil {
  3.     private static final Log logger = LogFactory.getLog(SqlSessionUtil.class);
  5.     public static SqlSession getSqlSession() {
  6.         SqlSession sqlSession = null;
  7.         try (InputStream is = Resources.getResourceAsStream("mybatis-config.xml");) {
  8.             SqlSessionFactoryBuilder sqlSessionFactoryBuilder = new SqlSessionFactoryBuilder();
  9.             SqlSessionFactory sqlSessionFactory = sqlSessionFactoryBuilder.build(is);
  10.             sqlSession = sqlSessionFactory.openSession(true);
  11.         } catch (IOException e) {
  12.             logger.error(e);
  13.         }
  14.         return sqlSession;
  15.     }
  16. }
复制代码
⑦ 创建log4j.xml
  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE log4j:configuration SYSTEM "log4j.dtd">
  3. <log4j:configuration xmlns:log4j="http://jakarta.apache.org/log4j/">
  4.     <appender name="STDOUT" >
  5.         <param name="Encoding" value="UTF-8" />
  6.         <layout >
  7.             <param name="ConversionPattern" value="%-5p %d{MM-dd HH:mm:ss,SSS}%m (%F:%L) \n" />
  8.         </layout>
  9.     </appender>
  10.     <logger name="java.sql">
  11.         <level value="debug" />
  12.     </logger>
  13.     <logger name="org.apache.ibatis">
  14.         <level value="info" />
  15.     </logger>
  16.     <root>
  17.         <level value="debug" />
  18.         <appender-ref ref="STDOUT" />
  19.     </root>
  20. </log4j:configuration>
复制代码
查询返回实体类对象的用户信息

查询返回一条数据使用实体类接收。
  1. /**
  2.   * 根据id查询用户信息
  3.   * @param id
  4.   * @return
  5.   */
  6. User getUserById(@Param("id") Integer id);
复制代码
  1. <select id="getUserById" resultType="com.evan.entity.User">
  2.         select * from t_user where id = #{id}
  3. </select>
复制代码
  1. @Test
  2. public void test1() {
  3.         SqlSession sqlSession = SqlSessionUtil.getSqlSession();
  4.         SelectMapper mapper = sqlSession.getMapper(SelectMapper.class);
  5.         System.out.println(mapper.getUserById(17));
  6.         sqlSession.close();
  7. }
复制代码
查询返回List集合的所有用户信息

使用List集合接收查询返回的多条数据。
  1.     /**
  2.      * 查询所有用户信息
  3.      * @return
  4.      */
  5.     List<User> getAllUser();
复制代码
  1.     <select id="getAllUser" resultType="com.evan.entity.User">
  2.     <select id="getAllUserMap" resultType="map">
  3. <select id="getAllUserMap" resultType="map">
  4.     select * from t_user
  5. </select>
  6. </select>
  7.     </select>
复制代码
  1. @Test
  2. public void test2() {
  3.         SqlSession sqlSession = SqlSessionUtil.getSqlSession();
  4.         SelectMapper mapper = sqlSession.getMapper(SelectMapper.class);
  5.         List<User> users = mapper.getAllUser();
  6.         users.forEach(System.out::println);
  7.         sqlSession.close();
  8. }
复制代码
说明:
当查询的数据为多条时，不能使用实体类作为返回值，否则会抛出异常TooManyResultsException；
但是若查询的数据只有一条，可以使用实体类或集合作为返回值。
查询返回Map集合的所有用户信息

Map集合返回单条记录
  1.     /**
  2.      * 根据id查询用户信息(Map集合接收)
  3.      * @param id
  4.      * @return
  5.      */
  6.     Map<String,Object> getUserByIdMap(@Param("id") Integer id);
复制代码
  1. <select id="getUserByIdMap" resultType="map">
  2. <select id="getAllUserMap" resultType="map">
  3. <select id="getAllUserMap" resultType="map">
  4.     select * from t_user
  5. </select>
  6. </select> where id = #{id}
  7. </select>
复制代码
  1. @Test
  2. public void test3() {
  3.     SqlSession sqlSession = SqlSessionUtil.getSqlSession();
  4.     SelectMapper mapper = sqlSession.getMapper(SelectMapper.class);
  5.     Map<String, Object> users = mapper.getUserByIdMap(1002);
  6.     System.out.println(users);
  7.     sqlSession.close();
  8. }
复制代码
Map集合返回多条记录

方式1：使用List集合接收Map查询的数据
  1. /**
  2.   * 查询所有用户信息(list集合接收Map集合查询的所有数据)
  3.   * @return
  4.   */
  5. List<Map<String,Object>> getAllUserMap();
复制代码
  1. <select id="getAllUserMap" resultType="map">
  2. <select id="getAllUserMap" resultType="map">
  3.     select * from t_user
  4. </select>
  5. </select>
复制代码
  1. @Test
  2. public void test5() {
  3.     SqlSession sqlSession = SqlSessionUtil.getSqlSession();
  4.     SelectMapper mapper = sqlSession.getMapper(SelectMapper.class);
  5.     List<Map<String, Object> > userList = mapper.getAllUserMap();
  6.     userList.forEach(System.out::println);
  7.     sqlSession.close();
  8. }
复制代码
方式2：@MapKey注解
  1. @MapKey("id")
  2. Map<String,Object> getAllUserMap();
复制代码
  1. <select id="getAllUserMap" resultType="map">
  2. <select id="getAllUserMap" resultType="map">
  3.     select * from t_user
  4. </select>
  5. </select>
复制代码
  1. @Test
  2. public void test5() {
  3.     SqlSession sqlSession = SqlSessionUtil.getSqlSession();
  4.     SelectMapper mapper = sqlSession.getMapper(SelectMapper.class);
  5.     Map<String, Object> userMap = mapper.getAllUserMap();
  6.     System.out.println(userMap);
  7.     sqlSession.close();
  8. }
复制代码
结论:
查询所有的用户信息为map集合时：
若查询的数据有多条时，并且要将每条数据转换为map集合，此时有两种解决方案：
1、将mapper接口方法的返回值设置为泛型是map的list集合
List getAllUserMap();
显示结果的格式(无序结果集)：
{password=123456,gender=男,id=1001,age=18,email=lisi@qq.com,username=李四}
2、可以将每条数据转换的map集合放到一个大的Map集合中，但是必须要通过@MapKey注解将查询的某个字段的值作为大的Map集合的键。
@MapKey("id")
Map getAllUserMap();
相当于：Map
显示结果格式：
{
1001={password=123456, gender=男, id=1001, age=15, email=root@qq.com, username=root},
1002={password=123456, gender=女, id=1002, age=20, email=zh3@sina.cn, username=张三}
}
查询总记录数
  1. /**
  2. * 查询用户总记录数
  3. * @return
  4. */
  5. Integer getCount();
复制代码
  1. <select id="getCount" resultType="integer">
  2.     select count(1) from t_user
  3. </select>
复制代码
  1. @Test
  2. public void test4() {
  3.     SqlSession sqlSession = SqlSessionUtil.getSqlSession();
  4.     SelectMapper mapper = sqlSession.getMapper(SelectMapper.class);
  5.     Integer count = mapper.getCount();
  6.     System.out.println(count);
  7.     sqlSession.close();
  8. }
复制代码
MyBatis对Java常用类型设置的类型别名




免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！



欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4