Hibernate Annotation 基于连接表的单向一对多关联



Hibernate Annotation 基于连接表的单向一对多关联。一对多的关联形式我就不说了,这个例子是基于连接表jointable的,不懂的参数可以看下 Hibernate Annotation Reference 。

 

sql脚本(附件)

Sql代码 复制代码 收藏代码
  1. – MySQL dump 10.13  Distrib 5.1.55, for Win32 (ia32)
  2. – Host: localhost    Database: hibernate_demo
  3. – ——————————————————
  4. – Server version   5.1.55-community
  5. /*!40101 SET @OLD_CHARACTER_SET_CLIENT=@@CHARACTER_SET_CLIENT */;
  6. /*!40101 SET @OLD_CHARACTER_SET_RESULTS=@@CHARACTER_SET_RESULTS */;
  7. /*!40101 SET @OLD_COLLATION_CONNECTION=@@COLLATION_CONNECTION */;
  8. /*!40101 SET NAMES utf8 */;
  9. /*!40103 SET @OLD_TIME_ZONE=@@TIME_ZONE */;
  10. /*!40103 SET TIME_ZONE=’+00:00′ */;
  11. /*!40014 SET @OLD_UNIQUE_CHECKS=@@UNIQUE_CHECKS, UNIQUE_CHECKS=0 */;
  12. /*!40014 SET @OLD_FOREIGN_KEY_CHECKS=@@FOREIGN_KEY_CHECKS, FOREIGN_KEY_CHECKS=0 */;
  13. /*!40101 SET @OLD_SQL_MODE=@@SQL_MODE, SQL_MODE=’NO_AUTO_VALUE_ON_ZERO’ */;
  14. /*!40111 SET @OLD_SQL_NOTES=@@SQL_NOTES, SQL_NOTES=0 */;
  15. – Table structure for table `address`
  16. DROP TABLE IF EXISTS `address`;
  17. /*!40101 SET @saved_cs_client     = @@character_set_client */;
  18. /*!40101 SET character_set_client = utf8 */;
  19. CREATE TABLE `address` (
  20.   `addressId` int(11) NOT NULL AUTO_INCREMENT,
  21.   `item` varchar(30) NOT NULL,
  22.   PRIMARY KEY (`addressId`)
  23. ) ENGINE=MyISAM AUTO_INCREMENT=3 DEFAULT CHARSET=latin1;
  24. /*!40101 SET character_set_client = @saved_cs_client */;
  25. – Dumping data for table `address`
  26. LOCK TABLES `address` WRITE;
  27. /*!40000 ALTER TABLE `address` DISABLE KEYS */;
  28. INSERT INTO `address` VALUES (1,’item1′),(2,’item2′);
  29. /*!40000 ALTER TABLE `address` ENABLE KEYS */;
  30. UNLOCK TABLES;
  31. – Table structure for table `jointable`
  32. DROP TABLE IF EXISTS `jointable`;
  33. /*!40101 SET @saved_cs_client     = @@character_set_client */;
  34. /*!40101 SET character_set_client = utf8 */;
  35. CREATE TABLE `jointable` (
  36.   `pid` int(11) DEFAULT NULL,
  37.   `aid` int(11) DEFAULT NULL,
  38.   KEY `join_person_fk` (`pid`),
  39.   KEY `join_address_fk` (`aid`)
  40. ) ENGINE=MyISAM DEFAULT CHARSET=latin1;
  41. /*!40101 SET character_set_client = @saved_cs_client */;
  42. – Dumping data for table `jointable`
  43. LOCK TABLES `jointable` WRITE;
  44. /*!40000 ALTER TABLE `jointable` DISABLE KEYS */;
  45. INSERT INTO `jointable` VALUES (1,1),(1,2);
  46. /*!40000 ALTER TABLE `jointable` ENABLE KEYS */;
  47. UNLOCK TABLES;
  48. – Table structure for table `person`
  49. DROP TABLE IF EXISTS `person`;
  50. /*!40101 SET @saved_cs_client     = @@character_set_client */;
  51. /*!40101 SET character_set_client = utf8 */;
  52. CREATE TABLE `person` (
  53.   `id` int(11) NOT NULL AUTO_INCREMENT,
  54.   `name` varchar(30) NOT NULL,
  55.   `age` int(11) NOT NULL,
  56.   PRIMARY KEY (`id`)
  57. ) ENGINE=MyISAM AUTO_INCREMENT=4 DEFAULT CHARSET=latin1;
  58. /*!40101 SET character_set_client = @saved_cs_client */;
  59. – Dumping data for table `person`
  60. LOCK TABLES `person` WRITE;
  61. /*!40000 ALTER TABLE `person` DISABLE KEYS */;
  62. INSERT INTO `person` VALUES (1,’zhaoyunpeng’,10);
  63. /*!40000 ALTER TABLE `person` ENABLE KEYS */;
  64. UNLOCK TABLES;
  65. /*!40103 SET TIME_ZONE=@OLD_TIME_ZONE */;
  66. /*!40101 SET SQL_MODE=@OLD_SQL_MODE */;
  67. /*!40014 SET FOREIGN_KEY_CHECKS=@OLD_FOREIGN_KEY_CHECKS */;
  68. /*!40014 SET UNIQUE_CHECKS=@OLD_UNIQUE_CHECKS */;
  69. /*!40101 SET CHARACTER_SET_CLIENT=@OLD_CHARACTER_SET_CLIENT */;
  70. /*!40101 SET CHARACTER_SET_RESULTS=@OLD_CHARACTER_SET_RESULTS */;
  71. /*!40101 SET COLLATION_CONNECTION=@OLD_COLLATION_CONNECTION */;
  72. /*!40111 SET SQL_NOTES=@OLD_SQL_NOTES */;
  73. – Dump completed on 2012-08-17  0:17:14
-- MySQL dump 10.13  Distrib 5.1.55, for Win32 (ia32)
--
-- Host: localhost    Database: hibernate_demo
-- ------------------------------------------------------
-- Server version	5.1.55-community

/*!40101 SET @OLD_CHARACTER_SET_CLIENT=@@CHARACTER_SET_CLIENT */;
/*!40101 SET @OLD_CHARACTER_SET_RESULTS=@@CHARACTER_SET_RESULTS */;
/*!40101 SET @OLD_COLLATION_CONNECTION=@@COLLATION_CONNECTION */;
/*!40101 SET NAMES utf8 */;
/*!40103 SET @OLD_TIME_ZONE=@@TIME_ZONE */;
/*!40103 SET TIME_ZONE='+00:00' */;
/*!40014 SET @OLD_UNIQUE_CHECKS=@@UNIQUE_CHECKS, UNIQUE_CHECKS=0 */;
/*!40014 SET @OLD_FOREIGN_KEY_CHECKS=@@FOREIGN_KEY_CHECKS, FOREIGN_KEY_CHECKS=0 */;
/*!40101 SET @OLD_SQL_MODE=@@SQL_MODE, SQL_MODE='NO_AUTO_VALUE_ON_ZERO' */;
/*!40111 SET @OLD_SQL_NOTES=@@SQL_NOTES, SQL_NOTES=0 */;

--
-- Table structure for table `address`
--

DROP TABLE IF EXISTS `address`;
/*!40101 SET @saved_cs_client     = @@character_set_client */;
/*!40101 SET character_set_client = utf8 */;
CREATE TABLE `address` (
  `addressId` int(11) NOT NULL AUTO_INCREMENT,
  `item` varchar(30) NOT NULL,
  PRIMARY KEY (`addressId`)
) ENGINE=MyISAM AUTO_INCREMENT=3 DEFAULT CHARSET=latin1;
/*!40101 SET character_set_client = @saved_cs_client */;

--
-- Dumping data for table `address`
--

LOCK TABLES `address` WRITE;
/*!40000 ALTER TABLE `address` DISABLE KEYS */;
INSERT INTO `address` VALUES (1,'item1'),(2,'item2');
/*!40000 ALTER TABLE `address` ENABLE KEYS */;
UNLOCK TABLES;

--
-- Table structure for table `jointable`
--

DROP TABLE IF EXISTS `jointable`;
/*!40101 SET @saved_cs_client     = @@character_set_client */;
/*!40101 SET character_set_client = utf8 */;
CREATE TABLE `jointable` (
  `pid` int(11) DEFAULT NULL,
  `aid` int(11) DEFAULT NULL,
  KEY `join_person_fk` (`pid`),
  KEY `join_address_fk` (`aid`)
) ENGINE=MyISAM DEFAULT CHARSET=latin1;
/*!40101 SET character_set_client = @saved_cs_client */;

--
-- Dumping data for table `jointable`
--

LOCK TABLES `jointable` WRITE;
/*!40000 ALTER TABLE `jointable` DISABLE KEYS */;
INSERT INTO `jointable` VALUES (1,1),(1,2);
/*!40000 ALTER TABLE `jointable` ENABLE KEYS */;
UNLOCK TABLES;

--
-- Table structure for table `person`
--

DROP TABLE IF EXISTS `person`;
/*!40101 SET @saved_cs_client     = @@character_set_client */;
/*!40101 SET character_set_client = utf8 */;
CREATE TABLE `person` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(30) NOT NULL,
  `age` int(11) NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=MyISAM AUTO_INCREMENT=4 DEFAULT CHARSET=latin1;
/*!40101 SET character_set_client = @saved_cs_client */;

--
-- Dumping data for table `person`
--

LOCK TABLES `person` WRITE;
/*!40000 ALTER TABLE `person` DISABLE KEYS */;
INSERT INTO `person` VALUES (1,'zhaoyunpeng',10);
/*!40000 ALTER TABLE `person` ENABLE KEYS */;
UNLOCK TABLES;
/*!40103 SET TIME_ZONE=@OLD_TIME_ZONE */;

/*!40101 SET SQL_MODE=@OLD_SQL_MODE */;
/*!40014 SET FOREIGN_KEY_CHECKS=@OLD_FOREIGN_KEY_CHECKS */;
/*!40014 SET UNIQUE_CHECKS=@OLD_UNIQUE_CHECKS */;
/*!40101 SET CHARACTER_SET_CLIENT=@OLD_CHARACTER_SET_CLIENT */;
/*!40101 SET CHARACTER_SET_RESULTS=@OLD_CHARACTER_SET_RESULTS */;
/*!40101 SET COLLATION_CONNECTION=@OLD_COLLATION_CONNECTION */;
/*!40111 SET SQL_NOTES=@OLD_SQL_NOTES */;

-- Dump completed on 2012-08-17  0:17:14

 

 

//Address.java

 

Java代码 复制代码 收藏代码
  1. package com.zyp.examples;
  2. import javax.persistence.Column;
  3. import javax.persistence.Entity;
  4. import javax.persistence.GeneratedValue;
  5. import javax.persistence.GenerationType;
  6. import javax.persistence.Id;
  7. import javax.persistence.Table;
  8. import org.hibernate.annotations.GenericGenerator;
  9. /**
  10. * Address entity. @author MyEclipse Persistence Tools
  11. */
  12. @Entity
  13. @Table(name=”address”)
  14. public class Address implements java.io.Serializable {
  15.     private static final long serialVersionUID = 5136081851186696459L;
  16.     // Fields
  17.     @Id
  18.     @GenericGenerator(name=”incrementGenerator”,strategy=”increment”)
  19.     @GeneratedValue(generator=”incrementGenerator”, strategy=GenerationType.IDENTITY)
  20.     @Column(name=”addressId”)
  21.     private Integer addressId;
  22.     @Column(name=”item”)
  23.     private String item;
  24.     // Constructors
  25.     /** default constructor */
  26.     public Address() {
  27.     }
  28.     /** full constructor */
  29.     public Address(String item) {
  30.         this.item = item;
  31.     }
  32.     // Property accessors
  33.     public Integer getAddressId() {
  34.         return this.addressId;
  35.     }
  36.     public void setAddressId(Integer addressId) {
  37.         this.addressId = addressId;
  38.     }
  39.     public String getItem() {
  40.         return this.item;
  41.     }
  42.     public void setItem(String item) {
  43.         this.item = item;
  44.     }
  45. }
package com.zyp.examples;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import javax.persistence.Table;

import org.hibernate.annotations.GenericGenerator;

/**
 * Address entity. @author MyEclipse Persistence Tools
 */
@Entity
@Table(name="address")
public class Address implements java.io.Serializable {

	private static final long serialVersionUID = 5136081851186696459L;

	// Fields
	@Id
	@GenericGenerator(name="incrementGenerator",strategy="increment")
	@GeneratedValue(generator="incrementGenerator", strategy=GenerationType.IDENTITY)
	@Column(name="addressId")
	private Integer addressId;

	@Column(name="item")
	private String item;

	// Constructors

	/** default constructor */
	public Address() {
	}

	/** full constructor */
	public Address(String item) {
		this.item = item;
	}

	// Property accessors

	public Integer getAddressId() {
		return this.addressId;
	}

	public void setAddressId(Integer addressId) {
		this.addressId = addressId;
	}

	public String getItem() {
		return this.item;
	}

	public void setItem(String item) {
		this.item = item;
	}

}

 

//Person.java

 

Java代码 复制代码 收藏代码
  1. package com.zyp.examples;
  2. import java.util.HashSet;
  3. import java.util.Set;
  4. import javax.persistence.CascadeType;
  5. import javax.persistence.Column;
  6. import javax.persistence.Entity;
  7. import javax.persistence.FetchType;
  8. import javax.persistence.GeneratedValue;
  9. import javax.persistence.GenerationType;
  10. import javax.persistence.Id;
  11. import javax.persistence.JoinColumn;
  12. import javax.persistence.JoinTable;
  13. import javax.persistence.OneToMany;
  14. import javax.persistence.Table;
  15. import org.hibernate.annotations.Fetch;
  16. import org.hibernate.annotations.FetchMode;
  17. import org.hibernate.annotations.GenericGenerator;
  18. /**
  19. * Person entity. @author MyEclipse Persistence Tools
  20. */
  21. @Entity
  22. @Table(name=”person”)
  23. public class Person implements java.io.Serializable {
  24.     // Fields
  25.     private static final long serialVersionUID = -5910642968209679728L;
  26.     @Id
  27.     @GenericGenerator(name=”incrementGenerator”,strategy=”increment”)
  28.     @GeneratedValue(generator=”incrementGenerator”, strategy=GenerationType.IDENTITY)
  29.     @Column(name=”id”)
  30.     private Integer id;
  31.     @Column(name=”name”, nullable=false)
  32.     private String name;
  33.     @Column(name=”age”, nullable=false)
  34.     private Integer age;
  35.     @OneToMany(targetEntity=Address.class, fetch=FetchType.EAGER, cascade=CascadeType.ALL)
  36.     @Fetch(FetchMode.SELECT)
  37.     @JoinTable(joinColumns=@JoinColumn(name=”pid”, nullable=true),
  38.             name=”jointable”, inverseJoinColumns=@JoinColumn(name=”aid”))
  39.     private Set<Address> address = new HashSet<Address>();
  40.     // Constructors
  41.     /** default constructor */
  42.     public Person() {
  43.     }
  44.     // Property accessors
  45.     public Integer getId() {
  46.         return this.id;
  47.     }
  48.     public void setId(Integer id) {
  49.         this.id = id;
  50.     }
  51.     public String getName() {
  52.         return this.name;
  53.     }
  54.     public void setName(String name) {
  55.         this.name = name;
  56.     }
  57.     public Integer getAge() {
  58.         return this.age;
  59.     }
  60.     public void setAge(Integer age) {
  61.         this.age = age;
  62.     }
  63.     public Set<Address> getAddress() {
  64.         return address;
  65.     }
  66.     public void setAddress(Set<Address> address) {
  67.         this.address = address;
  68.     }
  69. }
package com.zyp.examples;

import java.util.HashSet;
import java.util.Set;

import javax.persistence.CascadeType;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.FetchType;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import javax.persistence.JoinColumn;
import javax.persistence.JoinTable;
import javax.persistence.OneToMany;
import javax.persistence.Table;

import org.hibernate.annotations.Fetch;
import org.hibernate.annotations.FetchMode;
import org.hibernate.annotations.GenericGenerator;

/**
 * Person entity. @author MyEclipse Persistence Tools
 */

@Entity
@Table(name="person")
public class Person implements java.io.Serializable {

	// Fields
	private static final long serialVersionUID = -5910642968209679728L;

	@Id
	@GenericGenerator(name="incrementGenerator",strategy="increment")
	@GeneratedValue(generator="incrementGenerator", strategy=GenerationType.IDENTITY)
	@Column(name="id")
	private Integer id;

	@Column(name="name", nullable=false)
	private String name;

	@Column(name="age", nullable=false)
	private Integer age;

	@OneToMany(targetEntity=Address.class, fetch=FetchType.EAGER, cascade=CascadeType.ALL)
	@Fetch(FetchMode.SELECT)
	@JoinTable(joinColumns=@JoinColumn(name="pid", nullable=true), 
			name="jointable", inverseJoinColumns=@JoinColumn(name="aid"))
	private Set<Address> address = new HashSet<Address>();

	// Constructors

	/** default constructor */
	public Person() {
	}

	// Property accessors

	public Integer getId() {
		return this.id;
	}

	public void setId(Integer id) {
		this.id = id;
	}

	public String getName() {
		return this.name;
	}

	public void setName(String name) {
		this.name = name;
	}

	public Integer getAge() {
		return this.age;
	}

	public void setAge(Integer age) {
		this.age = age;
	}

	public Set<Address> getAddress() {
		return address;
	}

	public void setAddress(Set<Address> address) {
		this.address = address;
	}

}


 

//HibernateTest.java

 

Java代码 复制代码 收藏代码
  1. package com.zyp.examples;
  2. import java.util.HashSet;
  3. import java.util.Set;
  4. import org.hibernate.Session;
  5. public class HibernateTest {
  6.     public static void main(String[] args) {
  7.         //级联添加
  8. //      addByPerson();
  9.         //级联删除
  10.         deleteByPerson();
  11.     }
  12.     public static void deleteByPerson()
  13.     {
  14.         Session session = HibernateUtil.getSessionFactory().openSession();
  15.         session.beginTransaction();
  16.         session.delete(session.load(Person.class, new Integer(1)));
  17.         session.getTransaction().commit();
  18.     }
  19.     public static void addByPerson()
  20.     {
  21.         Address a1 = new Address();
  22.         a1.setItem(“item1″);
  23.         Address a2 = new Address();
  24.         a2.setItem(“item2″);
  25.         Set<Address> address = new HashSet<Address>();
  26.         address.add(a1);
  27.         address.add(a2);
  28.         Person p = new Person();
  29.         p.setAge(10);
  30.         p.setName(“zhaoyunpeng”);
  31.         p.setAddress(address);
  32.         Session session = HibernateUtil.getSessionFactory().openSession();
  33.         session.beginTransaction();
  34.         session.save(p);
  35.         session.getTransaction().commit();
  36.     }
  37. }
package com.zyp.examples;

import java.util.HashSet;
import java.util.Set;

import org.hibernate.Session;

public class HibernateTest {

	public static void main(String[] args) {

		//级联添加
//		addByPerson();

		//级联删除
		deleteByPerson();
	}

	public static void deleteByPerson()
	{
		Session session = HibernateUtil.getSessionFactory().openSession();
		session.beginTransaction();
		session.delete(session.load(Person.class, new Integer(1)));
		session.getTransaction().commit();
	}

	public static void addByPerson()
	{
		Address a1 = new Address();
		a1.setItem("item1");
		Address a2 = new Address();
		a2.setItem("item2");

		Set<Address> address = new HashSet<Address>();
		address.add(a1);
		address.add(a2);

		Person p = new Person();
		p.setAge(10);
		p.setName("zhaoyunpeng");
		p.setAddress(address);

		Session session = HibernateUtil.getSessionFactory().openSession();
		session.beginTransaction();
		session.save(p);
		session.getTransaction().commit();

	}

}

 

基于连接表的关联查询,最主要的就是 @jointable 注解的参数配置,看名字就知道。

既然是基于jointable的,那么name肯定是连接表的名字,joincolumn肯定是一端的关联列,inverseJoinColumns肯定是多端在连接表中的关联列,就这么简单…

 

 

2012年8月17日0:25:36