mybatis 多对多 处理

下面的例子让新手看不错。可以改进的一点是

1、不必建立 关联对象实体，可以用map传递两个id进去

2、文章的resultMap 继承和 查询配置 比较清楚，可以借鉴

mybatis3.0添加了association和collection标签专门用于对多个相关实体类数据进行级联查询，但仍不支持多个相关实体类数据的级联保存和级联删除操作。因此在进行实体类多对多映射表设计时，需要专门建立一个关联对象类对相关实体类的关联关系进行描述。下文将以“User”和“Group"两个实体类之间的多对多关联映射为例进行CRUD操作。

建立user表，对应实体类"User"，建表语句如下：
     <!--StartFragment-->

Sql代码  

  1. CREATE TABLE `user` (
  2. `id` int(11) NOT NULL auto_increment,
  3. `name` varchar(40) collate utf8_unicode_ci default NULL,
  4. `password` varchar(20) collate utf8_unicode_ci default NULL,
  5. `createtime` timestamp NULL default CURRENT_TIMESTAMP,
  6. PRIMARY KEY  (`id`)
  7. )

建立group_info表，对应实体类"Group"，建表语句如下：

Sql代码  

  1. CREATE TABLE `group_info` (
  2. `id` int(11) NOT NULL auto_increment,
  3. `name` varchar(40) collate utf8_unicode_ci default NULL,
  4. `createdate` timestamp NULL default CURRENT_TIMESTAMP,
  5. `state` int(1) default ‘0‘ COMMENT ‘0:可见;1:不可见‘,
  6. PRIMARY KEY  (`id`)
  7. )

建立user_group表，对应实体类"UserGroupLink"(该类为User和Group两个实体类之间的关系描述)，建表语句如下：

Sql代码  

  1. CREATE TABLE `user_group` (
  2. `user_id` int(11) default NULL,
  3. `group_id` int(11) default NULL,
  4. `createdate` timestamp NULL default CURRENT_TIMESTAMP,
  5. KEY `FK_user_group_user_id` (`user_id`),
  6. KEY `FK_user_group_group_id` (`group_id`),
  7. CONSTRAINT `FK_user_group_group_id` FOREIGN KEY (`group_id`) REFERENCES `group_info` (`id`),
  8. CONSTRAINT `FK_user_group_user_id` FOREIGN KEY (`user_id`) REFERENCES `user` (`id`)
  9. )

建立实体类User，代码如下：

Java代码  

  1. package com.xxt.ibatis.dbcp.domain;
  2. import java.util.Date;
  3. import java.util.List;
  4. /**
  5. * @describe: User实体类
  6. * @author:    Nirvana
  7. * @version:   V1.0  2011-3-11下午06:06:49 create
  8. */
  9. public class User {
  10. private long id;
  11. private String name;
  12. private String password;
  13. private Date createTime;
  14. private List<Group> group;
  15. public Date getCreateTime() {
  16. return createTime;
  17. }
  18. public void setCreateTime(Date createTime) {
  19. this.createTime = createTime;
  20. }
  21. public long getId() {
  22. return id;
  23. }
  24. public void setId(long id) {
  25. this.id = id;
  26. }
  27. public String getName() {
  28. return name;
  29. }
  30. public void setName(String name) {
  31. this.name = name;
  32. }
  33. public String getPassword() {
  34. return password;
  35. }
  36. public void setPassword(String password) {
  37. this.password = password;
  38. }
  39. public List<Group> getGroup() {
  40. return group;
  41. }
  42. public void setGroup(List<Group> group) {
  43. this.group = group;
  44. }
  45. }

建立实体类Group,代码如下：

Java代码  

  1. package com.xxt.ibatis.dbcp.domain;
  2. import java.util.Date;
  3. import java.util.List;
  4. /**
  5. * @describe: Group实体类
  6. * @author: Nirvana
  7. * @version: V1.0 2011-3-7下午08:10:29 create
  8. */
  9. public class Group {
  10. private long id;
  11. private String name; // 组名
  12. private Date createTime;
  13. private int state; // 0可见状态 1不可见状态
  14. private List<User> user;
  15. public Date getCreateTime() {
  16. return createTime;
  17. }
  18. public void setCreateTime(Date createTime) {
  19. this.createTime = createTime;
  20. }
  21. public long getId() {
  22. return id;
  23. }
  24. public void setId(long id) {
  25. this.id = id;
  26. }
  27. public String getName() {
  28. return name;
  29. }
  30. public void setName(String name) {
  31. this.name = name;
  32. }
  33. public int getState() {
  34. return state;
  35. }
  36. public void setState(int state) {
  37. this.state = state;
  38. }
  39. public List<User> getUser() {
  40. return user;
  41. }
  42. public void setUser(List<User> user) {
  43. this.user = user;
  44. }
  45. }

建立实体类UserGroupLink，用于描述User和Group之间的对应关系，代码如下：

Java代码  

  1. package com.xxt.ibatis.dbcp.domain;
  2. import java.util.Date;
  3. /**
  4. * @describe: 描述User和Group之间的映射关系
  5. * @author: Nirvana
  6. * @version: V1.0 2011-3-11下午02:57:52 create
  7. */
  8. public class UserGroupLink {
  9. private User user;
  10. private Group group;
  11. private Date createTime;
  12. public Date getCreateTime() {
  13. return createTime;
  14. }
  15. public void setCreateTime(Date createTime) {
  16. this.createTime = createTime;
  17. }
  18. public Group getGroup() {
  19. return group;
  20. }
  21. public void setGroup(Group group) {
  22. this.group = group;
  23. }
  24. public User getUser() {
  25. return user;
  26. }
  27. public void setUser(User user) {
  28. this.user = user;
  29. }
  30. }

建立user实体类的映射文件user.map.xml，代码如下：

Xml代码  

  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE mapper
  3. PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
  4. "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  5. <mapper namespace="com.xxt.ibatis.dbcp.domain.User">
  6. <resultMap type="User" id="userMap">
  7. <id property="id" column="id" />
  8. <result property="name" column="name" />
  9. <result property="password" column="password" />
  10. <result property="createTime" column="createtime" />
  11. </resultMap>
  12. <resultMap type="User" id="userGroupMap" extends="userMap">
  13. <collection property="groups" ofType="Group">
  14. <id property="id" column="goupId" />
  15. <result property="name" column="groupName" />
  16. <result property="state" column="state" />
  17. <result property="createTime" column="groupCreateTime" />
  18. </collection>
  19. </resultMap>
  20. <!-- 根据user表中的id查询用户信息 -->
  21. <select id="selectUser" parameterType="long" resultMap="userMap">
  22. select * from user where id = #{id}
  23. </select>
  24. <!-- 根据user表中的id查询用户和组信息 -->
  25. <select id="selectUserGroup" parameterType="long"
  26. resultMap="userGroupMap">
  27. select u.id,u.name,u.password,u.createtime, gi.id as
  28. goupId,gi.name as groupName, gi.createdate as groupCreateTime,
  29. gi.state from user u left join user_group ug on u.id=ug.user_id
  30. left join group_info gi on ug.group_id=gi.id where u.id = #{id}
  31. </select>
  32. <!-- 插入用户信息 -->
  33. <insert id="saveUser" parameterType="User" keyProperty="id"
  34. useGeneratedKeys="true">
  35. insert into user(name,password) values(#{name},#{password})
  36. </insert>
  37. <!-- 保存用户和组之间的关系信息 -->
  38. <insert id="saveRelativity" parameterType="UserGroupLink">
  39. insert into user_group(user_id,group_id)
  40. values(#{user.id},#{group.id})
  41. </insert>
  42. <select id="selectAllUser" resultMap="userMap">
  43. select * from user
  44. </select>
  45. </mapper>

建立group实体类的映射文件group.map.xml，代码如下:

Xml代码  

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE mapper
  3. PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
  4. "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  5. <mapper namespace="com.xxt.ibatis.dbcp.domain.Group">
  6. <resultMap type="Group" id="groupMap">
  7. <id property="id" column="id" />
  8. <result property="name" column="name" />
  9. <result property="createTime" column="createdate" />
  10. </resultMap>
  11. <resultMap type="Group" id="groupUserMap" extends="groupMap">
  12. <collection property="users" ofType="User">
  13. <id property="id" column="userId" />
  14. <result property="name" column="userName" />
  15. <result property="password" column="password" />
  16. <result property="createTime" column="userCreateTime" />
  17. </collection>
  18. </resultMap>
  19. <!-- 根据Group表中的id或name查询组信息和组内用户信息 -->
  20. <select id="selectGroupUser" parameterType="Group"
  21. resultMap="groupUserMap">
  22. select u.id as userId,u.name as userName,
  23. u.password,u.createtime as userCreateTime,
  24. gi.id,gi.name,gi.createdate,gi.state from group_info gi left
  25. join user_group ug on gi.id=ug.group_id left join user u on
  26. uug.user_id=u.id
  27. <where>
  28. <!--当id为初始值0，不再使用id作为查询条件 -->
  29. <if test="id != 0  ">gi.id=#{id}</if>
  30. <!-- 当name为空或为空串时，不再使用name作为查询条件 -->
  31. <if test="name != null and name != ‘‘">
  32. or gi.name = #{name}
  33. </if>
  34. </where>
  35. </select>
  36. <!-- 根据id查询group组信息 -->
  37. <select id="selectGroup" parameterType="Date"
  38. resultMap="groupMap">
  39. select * from group_info where id=#{group_id}
  40. </select>
  41. <!--根据name查询group组信息  -->
  42. <select id="getGroupByName" parameterType="String"
  43. resultMap="groupMap">
  44. select * from group_info where name=#{name}
  45. </select>
  46. <!-- 插入组信息 -->
  47. <insert id="saveGroup" parameterType="Group" keyProperty="id"
  48. useGeneratedKeys="true">
  49. insert into group_info(name) values(#{name})
  50. </insert>
  51. <!-- 删除组与组内成员之间的对应关系 -->
  52. <delete id="deleteGroupUser" parameterType="UserGroupLink">
  53. delete from user_group
  54. <where>
  55. <if test="user.id != 0">user_id = #{user.id}</if>
  56. <if test="group.id != 0">and group_id = #{group.id}</if>
  57. </where>
  58. </delete>
  59. <!--根据组id或者组name删除组信息 -->
  60. <delete id="deleteGroup" parameterType="Group">
  61. delete from group_info
  62. <where>
  63. <if test="id!=0">id=#{id}</if>
  64. <if test="name!=null || name!=‘‘">and name=#{name}</if>
  65. </where>
  66. </delete>
  67. <!-- 更新根据组id或者组name更新组状态 -->
  68. <update id="updateGroupState" parameterType="Group">
  69. update group_info set state=#{state}
  70. <where>
  71. <if test="id!=0">id=#{id}</if>
  72. <if test="name!=null || name!=‘‘">and name=#{name}</if>
  73. </where>
  74. </update>
  75. </mapper>

建立ibatis总配置文件salMapConfig.xml,代码如下：

Xml代码  

  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. <properties resource="jdbc.properties" />
  7. <typeAliases>
  8. <typeAlias type="com.xxt.ibatis.dbcp.domain.User" alias="User" />
  9. <typeAlias type="com.xxt.ibatis.dbcp.domain.Group"
  10. alias="Group" />
  11. <typeAlias type="com.xxt.ibatis.dbcp.domain.UserGroupLink"
  12. alias="UserGroupLink" />
  13. </typeAliases>
  14. <environments default="development">
  15. <environment id="development">
  16. <transactionManager type="JDBC" />
  17. <dataSource type="UNPOOLED">
  18. <property name="driver" value="${driver}" />
  19. <property name="url" value="${url}" />
  20. <property name="username" value="${username}" />
  21. <property name="password" value="${password}" />
  22. </dataSource>
  23. </environment>
  24. </environments>
  25. <mappers>
  26. <mapper resource="com/xxt/ibatis/dbcp/domain/user.map.xml" />
  27. <mapper resource="com/xxt/ibatis/dbcp/domain/group.map.xml" />
  28. </mappers>
  29. </configuration>

测试用例，代码如下：

Java代码  

  1. package com.xxt.ibatis.dbcp.test;
  2. import java.io.Reader;
  3. import java.text.SimpleDateFormat;
  4. import java.util.List;
  5. import org.junit.AfterClass;
  6. import org.junit.BeforeClass;
  7. import org.junit.Test;
  8. import org.apache.ibatis.io.Resources;
  9. import org.apache.ibatis.session.SqlSession;
  10. import org.apache.ibatis.session.SqlSessionFactory;
  11. import org.apache.ibatis.session.SqlSessionFactoryBuilder;
  12. import com.xxt.ibatis.dbcp.domain.Group;
  13. import com.xxt.ibatis.dbcp.domain.User;
  14. import com.xxt.ibatis.dbcp.domain.UserGroupLink;
  15. /**
  16. * @describe: 测试用例
  17. * @author:    Nirvana
  18. * @version:   V1.0  2011-3-4下午03:21:17 create
  19. */
  20. public class IbatisUserTest {
  21. private final static String IBATIS_CONFIG_XML  = "sqlMapConfig.xml";
  22. private static SqlSession session;
  23. private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd k:mm:ss");
  24. @BeforeClass
  25. public static void setUpBeforeClass() throws Exception {
  26. Reader reader = Resources.getResourceAsReader(IBATIS_CONFIG_XML);  //读取ibatis配置文件
  27. SqlSessionFactory sqlMapper = new SqlSessionFactoryBuilder().build(reader);
  28. session = sqlMapper.openSession(true);
  29. session.commit(false); //将默认提交事务属性设置为否
  30. }
  31. //保存用户信息
  32. @Test
  33. public void saveUserTest(){
  34. User user = new User();
  35. user.setName("张三");
  36. user.setPassword("123456");
  37. session.insert("com.xxt.ibatis.dbcp.domain.User.saveUser", user);
  38. }
  39. //获取用户信息
  40. @Test
  41. public void getUserTest(){
  42. User user = (User) session.selectOne("com.xxt.ibatis.dbcp.domain.User.selectUser", 1L);
  43. System.out.println("用户名： "+user.getName());
  44. System.out.println("用户密码:  "+user.getPassword());
  45. System.out.println("用户创建日期："+sdf.format(user.getCreateTime()));
  46. }
  47. //获取用户和用户所在组信息
  48. @Test
  49. public void getUserAndGroupTest(){
  50. User  user =  (User)session.selectOne("com.xxt.ibatis.dbcp.domain.User.selectUserGroup", 4L);
  51. System.out.println(user.getName() +"所属组信息:");
  52. for(Group group : user.getGroups() ){
  53. System.out.println("    组名:"+group.getName()+"，组创建时间:"+sdf.format(group.getCreateTime()));
  54. }
  55. }
  56. //保存用户和用户所在组信息
  57. //当用户所在组不存在时，创建该组，并生成映射关系
  58. @Test
  59. public void saveUserAndGroupTest(){
  60. User user = new User();
  61. user.setName("无常鬼");
  62. user.setPassword("wuchang");
  63. session.insert("com.xxt.ibatis.dbcp.domain.User.saveUser", user);
  64. Group groupImpl = (Group)session.selectOne("com.xxt.ibatis.dbcp.domain.Group.getGroupByName","用户组4");//获取组实例
  65. UserGroupLink ugl = new UserGroupLink();//声明User和Group实体间映射关系实例
  66. //查询到的组实例为空时的逻辑处理
  67. if(groupImpl == null){
  68. Group group = new Group();
  69. group.setName("用户组4");
  70. session.insert("com.xxt.ibatis.dbcp.domain.Group.saveGroup", group);//持久化创建好的组实例
  71. //设置映射关系实例相关的属性
  72. ugl.setUser(user);
  73. ugl.setGroup(group);
  74. session.insert("com.xxt.ibatis.dbcp.domain.User.saveRelativity",ugl);//持久化映射关系实力
  75. }else{
  76. ugl.setGroup(groupImpl);
  77. ugl.setUser(user);
  78. session.insert("com.xxt.ibatis.dbcp.domain.User.saveRelativity",ugl);
  79. }
  80. }
  81. //删除组信息的同时，取消组内所有的成员与该组的关联关系
  82. @Test
  83. public void deleteGroupTest(){
  84. Group group = new Group();
  85. //group.setId(1L);  //以组id作为查询条件
  86. group.setName("用户组1"); //以组name作为查询条件
  87. Group groupImpl = (Group)session.selectOne("com.xxt.ibatis.dbcp.domain.Group.selectGroupUser",group);//获取组实例
  88. //组实例存在时
  89. if(groupImpl != null){
  90. List<User> users = groupImpl.getUsers();
  91. //查看用户组1中是否存在用户
  92. if(users != null && users.size() > 0){
  93. //存在用户时，先删除组与用户的对应关系
  94. UserGroupLink ugl = new UserGroupLink();
  95. for(User user : users){
  96. ugl.setUser(user);
  97. ugl.setGroup(groupImpl);
  98. session.delete("com.xxt.ibatis.dbcp.domain.Group.deleteGroupUser",ugl );
  99. }
  100. }
  101. //删除组信息
  102. session.delete("com.xxt.ibatis.dbcp.domain.Group.deleteGroup", groupImpl);
  103. }else{
  104. throw new RuntimeException("查询的组不存在!!");
  105. }
  106. }
  107. //更新组状态，当组状态由可见状态变成不可见时，取消该组下的用户与该组的映射关系
  108. @Test
  109. public void updateGroupStateTest(){
  110. Group group = new Group();
  111. group.setName("用户组2");
  112. Group groupImpl = (Group) session.selectOne("com.xxt.ibatis.dbcp.domain.Group.selectGroupUser",group);
  113. if(groupImpl != null){
  114. int state = groupImpl.getState() == 1 ? 0 : 1;
  115. //组状态由0变成1时，即由可见变为不可见
  116. if(state == 1){
  117. List<User> users = groupImpl.getUsers();
  118. //查看用户组2中是否存在用户
  119. if(users != null && users.size() > 0){
  120. //存在用户时，删除组与用户的对应关系
  121. UserGroupLink ugl = new UserGroupLink();
  122. for(User user : users){
  123. ugl.setUser(user);
  124. ugl.setGroup(groupImpl);
  125. session.delete("com.xxt.ibatis.dbcp.domain.Group.deleteGroupUser",ugl );
  126. }
  127. }
  128. }
  129. //更新组状态
  130. groupImpl.setState(state);
  131. }
  132. else{
  133. throw new RuntimeException("查询的组不存在!!");
  134. }
  135. }
  136. @AfterClass
  137. public static void tearDownAfterClass() throws Exception {
  138. if(session != null){
  139. session.commit(); //提交事务
  140. session.close(); //关闭连接
  141. }
  142. }
  143. }

源码来源：minglisoft.cn/technology

时间： 2024-10-29 00:30:56

mybatis 多对多 处理的相关文章

mybatis多对一关联

mybatis多对一关联查询实现 1.定义实体 定义实体的时候需要注意,若是双向关联,就是说双方的属性中都含有对方对象作为域属性出现, 那么在写toString()方法时需要注意,只让某一方输出即可,不要让双方的toString()都输出对方, 这样会形成递归调用,程序会出错,报堆栈溢出. Country实体类 Minsiter 实体类 2.数据库设计 a) country数据库 b) minsiter数据库 3.DAO层设计 4.service层设计 5.impl实现类 6.Controlle

mybatis多对多关联查询——（十）

1.需求 查询用户及用户购买商品信息. 2     sql语句 查询主表是:用户表 关联表:由于用户和商品没有直接关联,通过订单和订单明细进行关联,所以关联表: orders.orderdetail.items SELECT orders.*, USER.username, USER.sex, USER.address, orderdetail.id orderdetail_id, orderdetail.items_id, orderdetail.items_num, orderdetail.

Mybatis 多对多（易百教程）

mybatis3.0 添加了association和collection标签专门用于对多个相关实体类数据进行级联查询,但仍不支持多个相关实体类数据的级联保存和级联删除操作.因此在进行实体类多对多映射表设计时,需要专门建立一个关联对象类对相关实体类的关联关系进行描述.下文将以"User"和"Group"两个实体类之间的多对多关联映射为例进行CRUD操作. 1.应用场景 假设项目中存在用户和用户组,从一个用户读取出它所在的用户组,从一个用户组也知道这个组内的所有用户信息

mybatis多对一

产品和分类的多对一关系 多个产品属于一个分类 public class Product { private int id; private String name; private float price; private Category category; public Category getCategory() { return category; } public void setCategory(Category category) { this.category = categor

Mybatis—多对一和一对多

1.多对一处理 多对一: 多个学生,对应一个老师 对于学生这边而言, 关联 .. 多个学生,关联一个老师 [多对一] 对于老师而言, 集合 , 一个老师,有很多学生 [一对多] 搭建环境 创建Teacher,Student表并插入 Teacher表 CREATE TABLE `teacher` ( `id` INT(10) NOT NULL, `name` VARCHAR(30) DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=INNODB DEFAULT C

mybatis 多对多映射关系

xml映射文件:一个用户对应多个订单,一个订单对应多个订单明细,一个订单明细对应一个商品 可以推断出用户和商品是多对多的关系用户和商品的关系分析 可以发现一层套一层... <!-- #######################################多对多的关系映射####################################################### --> <resultMap type="cn.itcast.domain.User"

myBatis 多对多

先说明一下需求: 在页面上显示数据库中的所有图书,显示图书的同时,显示出该图书所属的类别(这里一本书可能同时属于多个类别) 测试环境:MySQL.MyEclipse 创建表: 笔者这里使用 中间表 连接 图书表 和 图书类别表,图书表中 没有使用外键关联 图书类别表 而是在中间表中引用了 图书主键 和 类别主键 通过中间表来 表示 图书 和 图书类别 的关系 建立图书表(图书编号,图书名字) create table book ( bid int primary key auto_increme

mybatis多对多级联查询

1.实体 package com.govmade.govdata.modules.sys.pojo; import java.util.List; import javax.persistence.Table; import javax.persistence.Transient; import com.google.common.collect.Lists; import com.govmade.govdata.common.persistence.BasePo; @Table(name =

mybatis多对多映射

数据库里面有角色实体类app_cms_role 权限实体类app_cms_right 以及一张中间表app_cms_role_right 建立对应的实体类AppCmsRole package com.qianlong.cms.entity; import java.util.Date; import java.util.Set; public class AppCmsRole { private Integer id; private String name; private Date crea