当前位置:   article > 正文

一对一关联查询注解@OneToOne的实例详解(一)_@onetoone属性

@onetoone属性

转载自:
https://www.cnblogs.com/boywwj/p/8092915.html

一对一关联查询注解@OneToOne的实例详解
  表的关联查询比较复杂,应用的场景很多,本文根据自己的经验解释@OneToOne注解中的属性在项目中的应用。本打算一篇博客把增删改查写在一起,但是在改的时候遇到了一些问题,感觉挺有意思,所以写下第二篇专门讲修改。

一、单向@OneToOne实例详解

假设一个场景,一个人只能领养一只宠物,根据人能够找到宠物,并且查看宠物的信息,关系是单向的。

创建人与宠物的数据表结构。下载地址:Person,Pet数据库建表。

创建实体。

Person.java


package com.my.model;
 
import java.io.Serializable;
 
import javax.persistence.CascadeType;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.FetchType;
import javax.persistence.ForeignKey;
import javax.persistence.GeneratedValue;
import javax.persistence.Id;
import javax.persistence.JoinColumn;
import javax.persistence.OneToOne;
import javax.persistence.Table;
 
import org.hibernate.annotations.Cascade;
import org.springframework.beans.factory.annotation.Autowired;
 
@Entity
@Table(name = "person")
public class Person  implements Serializable{
    @Id
    // id自动生成
    @GeneratedValue
    @Column(name = "id")
    private Long id;
    @Column(name = "name")
    private String name;
     
    //cascade:表的级联操作
    @OneToOne(fetch=FetchType.LAZY,cascade = CascadeType.ALL) //JPA注释: 一对一 关系
     
    //referencedColumnName:参考列名,默认的情况下是列表的主键
    //nullable=是否可以为空,
    //insertable:是否可以插入,
    //updatable:是否可以更新
    // columnDefinition=列定义,
    //foreignKey=外键
    @JoinColumn(name="pet_id",referencedColumnName="id",nullable=false)
    private Pet pet;
 
     
 
    @Override
    public String toString() {
        return "Person [id=" + id + ", name=" + name + ", pet=" + pet + "]";
    }
     
}
  • 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

Pet.java

package com.my.model;
 
import java.io.Serializable;
 
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.Id;
import javax.persistence.Table;
 
@Entity
@Table(name = "pet")
public class Pet  implements Serializable{
    @Id
    // id自动生成
    @GeneratedValue
    @Column(name = "id")
    private Long id;
    @Column(name = "pet_name")
    private String petName;
    @Column(name = "pet_class")
    private String petClass;
 
    //省略set,get方法。
 
    @Override
    public String toString() {
        return "Pet [id=" + id + ", petName=" + petName + ", petClass="
                + petClass + "]";
    }
 
}  
  • 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

注解@OneToOne的接口定义如下:

public interface OneToOne extends Annotation {
 
    public abstract Class targetEntity();
 
    public abstract CascadeType[] cascade();
 
    public abstract FetchType fetch();
 
    public abstract boolean optional();
 
    public abstract String mappedBy();
 
    public abstract boolean orphanRemoval();
}
 
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15

注解@OneToOne的属性:

cascade:关联属性,这个属性定义了当前类对象操作了之后,级联对象的操作。本例中定义了:CascadeType.ALL,当前类增删改查改变之后,关联类跟着增删改查。

fetch属性:FetchType类型的属性。可选择项包括:FetchType.EAGER 和FetchType.LAZY。 FetchType.EAGER表示关系类(本例是OrderItem类)在主类加载的时候同时加载,FetchType.LAZY表示关系类在被访问时才加载。默认值是FetchType.LAZY。

mappedBy:拥有关联关系的域,如果关系是单向的就不需要,双向关系表,那么拥有关系的这一方有建立、解除和更新与另一方关系的能力,而另一方没有,只能被动管理,这个属性被定义在关系的被拥有方。双向@OneToOne,双向@OneToMany,双向@ManyToMany。

注解@JoinColumn的接口定义:

public interface JoinColumn extends Annotation {
 
    public abstract String name();
 
    public abstract String referencedColumnName();
 
    public abstract boolean unique();
 
    public abstract boolean nullable();
 
    public abstract boolean insertable();
 
    public abstract boolean updatable();
 
    public abstract String columnDefinition();
 
    public abstract String table();
 
    public abstract ForeignKey foreignKey();
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20

注解@JoinColumn的属性:

name属性:外键列的名称,默认情况下是:引用实体的字段名称 +“_”+ 被引用的主键列的名称。一般也可以自定义,一般见名知意,就可以采用默认值。

referencedColumnName属性:参考列,默认值是关联表的主键。例如你可以定义pet_name为参考列,那么就会将pet的name的值关联到这一列。

创建类:TableRelationController

package com.my.controller;
 
import javax.annotation.Resource;
 
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
 
import com.alibaba.fastjson.JSONObject;
import com.my.model.GoodInfoEntity;
import com.my.service.TableRelationService;
 
/**
 * 用于测试表的七种对应关系
 * @author by_ww
 *
 */
@RestController
@RequestMapping(value = "/tableRelation")
public class TableRelationController {
     
    @Resource
    private TableRelationService tableRelationService;
     
    // 增加
     @RequestMapping(value = "/save")
        public Long save(@RequestBody JSONObject record) throws Exception
        {
            return tableRelationService.save(record);
        }
    // 查询
     @RequestMapping(value = "/query")
        public JSONObject query(@RequestBody JSONObject record) throws Exception
        {
            return tableRelationService.getPet(record);
        }
     // 删除
     @RequestMapping(value = "/delete")
        public Long delete(@RequestBody JSONObject record) throws Exception
        {
            return tableRelationService.delete(record);
        }
      
     // 更改
     @RequestMapping(value = "/update")
        public Long update(@RequestBody JSONObject record) throws Exception
        {
            return tableRelationService.update(record);
        }
}
 
  • 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

创建TableRelationService类:

package com.my.service;
 
import javax.annotation.Resource;
import javax.persistence.EntityManagerFactory;
 
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
 
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.my.dao.PersonJPA;
import com.my.dao.PetJPA;
import com.my.model.Person;
import com.my.model.Pet;
 
@Service
public class TableRelationService {
     
    @Resource
    private PersonJPA personJPA;
     
    @Resource
    private PetJPA petJPA;
     
  private SessionFactory sessionFactory;
 
  @Autowired
  public void SomeService(EntityManagerFactory factory) {
    if(factory.unwrap(SessionFactory.class) == null){
      throw new NullPointerException("factory is not a hibernate factory");
    }
    this.sessionFactory = factory.unwrap(SessionFactory.class);
  }
     
      
    public Long save(JSONObject record) {
         
        // 组装person
        Person person = new Person();
        person.setName(record.getString("personName"));
        JSONObject petObj = record.getJSONObject("pet");
        if (null != petObj) {
            Pet pet = new Pet();
            pet.setPetName(petObj.getString("petName"));
            pet.setPetClass(petObj.getString("petClass"));
             
            person.setPet(pet);
        }
        personJPA.save(person);
         
        return 4l;
    }
 
    public JSONObject getPet(JSONObject record) {
         
        Person person = personJPA.findOne(record.getLongValue("id"));
        System.out.println(person.toString());
        return (JSONObject) JSON.toJSON(person);
    }
 
    public Long delete(JSONObject record) {
        personJPA.delete(record.getLongValue("id"));
        return 4l;
    }
      @Transactional
    public Long update(JSONObject record) {
         
         Session session = sessionFactory.getCurrentSession();
//       Session     session = sessionFactory.openSession();
         session.beginTransaction();
          
         Person personRecord = session.get(Person.class, record.getLongValue("id"));
          
        personRecord.setName(record.getString("personName"));
         
        JSONObject petObject = record.getJSONObject("pet");
         
        if (petObject != null) {
             // 如果这里的pet为空
             Pet petRecord = null;
            if (personRecord.getPet() != null) {
                petRecord = session.get(Pet.class, personRecord.getPet().getId());
            }
          
          petRecord.setPetName(petObject.getString("petName"));
          petRecord.setPetClass(petObject.getString("petClass"));
           
        }
        personJPA.save(personRecord);
        return 4l;
    }
 
}
  • 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

注意:这里关联表更改的时候要注意,如果没有配置好会出现异常。

1
org.hibernate.HibernateException: Could not obtain transaction-synchronized Session for current thread
这是在spring的事务实现中需要判断当前线程中的事务是否同步,而没有事务的时候,那个判断是否同步的方法会因为get返回初始的null值而返回false,最终导致throw一个Could not obtain transaction-synchronized Session for current thread的异常,解决方法有两个:

1)加事物控制。

@Transactional
  • 1

2)重新生成session。

Session  session = sessionFactory.openSession();
  • 1

配置文件中:

spring.jpa.properties.hibernate.current_session_context_class=org.springframework.orm.hibernate4.SpringSessionContext
  
  • 1
  • 2

测试:postMan发送请求:

增加:

{
 
"personName":"Steven",
"pet" : {
    "petName":"旺旺",
    "petClass":"dog"
    }
 
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9

查询:

{
"id" : 19
}
  • 1
  • 2
  • 3
 
{
    "id": 19,
    "pet": {
        "id": 19,
        "petClass": "dog",
        "petName": "旺旺"
    },
    "name": "Steven"
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10

删除:

{
"id" : 19
}  
 
  • 1
  • 2
  • 3
  • 4

更改:

这里更改了petName,petClass

{
"id" : 19,
"personName":"Steven",
  "pet" :{
    "petName" : "steven4",
    "petClass" : "cow" 
  }
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8

问题:

在更新的时候存在这样的问题,如果刚开是插入数据的时候,没有插入从表Pet的数据。

{
 
"personName":"King"
 
}
  • 1
  • 2
  • 3
  • 4
  • 5

此时如果想在更新数据,给King添加一个pet数据,那么就会一直插入。

{
"id" : 20,
"personName": "King",
  "pet" :{
    "petName" : "阿旺",
    "petClass" : "cow" 
  }
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8

这是因为程序在执行save操作的时候,默默的执行了下面的语句。

Hibernate: select person0_.id as id1_2_1_, person0_.name as name2_2_1_, person0_.pet_id as pet_id3_2_1_, pet1_.id as id1_3_0_, pet1_.pet_class as pet_clas2_3_0_, pet1_.pet_name as pet_name3_3_0_ from person person0_ inner join pet pet1_ on person0_.pet_id=pet1_.id where person0_.id=?
Hibernate: insert into pet (pet_class, pet_name) values (?, ?)
Hibernate: insert into person (name, pet_id) values (?, ?)
Hibernate: insert into pet (pet_class, pet_name) values (?, ?)
Hibernate: update person set name=?, pet_id=? where id=?
  • 1
  • 2
  • 3
  • 4
  • 5

第一条语句查出来是空,所以会执行插入操作。其实这边也没有完全搞懂,欢迎留言!

这个问题的解决方式,请参考双向一对一映射@OneToOne。

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/羊村懒王/article/detail/530891
推荐阅读
相关标签
  

闽ICP备14008679号