文档章节

JDBC上关于数据库中多表操作一对多关系和多对多关系的实现方法

凌枫yong
 凌枫yong
发布于 2016/07/17 13:43
字数 1529
阅读 25
收藏 0
点赞 0
评论 0
我们知道,在设计一个JAVA bean的时候,要把这些BEAN 的数据存放在数据库中的表结构,然而这些数据库中的表直接又有些特殊的关系,例如员工与部门直接有一对多的关系,学生与老师直接又多对多的关系,那么这些表的关系如何表示呢?
首先在建立数据库的时候就应该建立这样的对应关系。
一对多 ,只要建立两个表就能建立这样的关系,因为你可以把多方的那个表设置一个Foreign Key 属性 ,下面是一个部门和员工的表结构关系
在mysql 数据库上应该这样建立表结构:
create table department(
id int primary key,
name varchar(100)
);
create table employee(
id int primary key,
name varchar(100),
salary float(8,2),
dept_id int,
constraint dept_id_fk foreign key (dept_id) references department(id)//这个其实是约束条件,不是表格的属性值。
);

在java 程序的javabean中应该如何做呢 
public class Department {
private Integer id;
private String name;
private Set<Employee> emps = new HashSet<Employee>();//查看部门,就能查看得到部门下面有哪些员工,所以存放在一个Set集合中。
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Set<Employee> getEmps() {
return emps;
}
public void setEmps(Set<Employee> emps) {
this.emps = emps;
}
@Override
public String toString() {
return "Department [emps=" + emps + ", id=" + id + ", name=" + name
+ "]";
}
}
public class Employee {
private Integer id;
private String name;
private Float salary;
// private Department dept = new Department();
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Float getSalary() {
return salary;
}
public void setSalary(Float salary) {
this.salary = salary;
}
@Override
public String toString() {
return "Employee [id=" + id + ", name=" + name + ", salary=" + salary
+ "]";
}
}

在DAO层 如何实现增加 查询数据呢?增加一个部门和查询一个部门的时候要不要显示员工呢?
public class DeparmentDao {
private QueryRunner qr = new QueryRunner(JdbcUtil.getDataSource());
public void addDepartment(Department dept){
try{
//先保存部门的基本信息
String sql = "insert into department values(?,?)";
Object params[] = {dept.getId(),dept.getName()};
qr.update(sql, params);
//得到员工,如果有员工信息,保存员工信息
Set<Employee> emps = dept.getEmps();
if(emps!=null&&emps.size()>0){
for(Employee e:emps){
sql = "insert into employee values(?,?,?,?)";
params = new Object[]{e.getId(),e.getName(),e.getSalary(),dept.getId()};
qr.update(sql, params);
}
}
}catch(Exception e){
throw new RuntimeException(e);
}
}
//每个部门中的员工要不要查出来?看需求
public List<Department> findDepts(boolean lazy){
try{
//部门的基本信息
String sql = "select * from department";
List<Department> depts = qr.query(sql, new BeanListHandler<Department>(Department.class));
if(depts!=null&&depts.size()>0){
for(Department dept:depts){
if(lazy){
//懒的
sql = "select id from employee where dept_id=?";
}else{
//饿的
sql = "select * from employee where dept_id=?";
}
List<Employee> emps = qr.query(sql,  new BeanListHandler<Employee>(Employee.class), dept.getId());
for(Employee e:emps){
dept.getEmps().add(e);
}
}
}
return depts;
}catch(Exception e){
throw new RuntimeException(e);
}
}
//每个部门中的员工要不要查出来?看需求.默认情况下,不查
public List<Department> findDepts(){
return findDepts(true);
}
}
---------------------------------------------------------------------------------------------------------------------------多对多的关系---------------------------------------------------------------------------------
下面以老师和学生的关系来说明这个结构
数据库中:
create table teacher(
id int primary key,
name varchar(100),
salary float(8,2)
);
create table student(
id int primary key,
name varchar(100),
grade varchar(100)
);
create table teacher_student(
t_id int,
s_id int,
primary key(t_id,s_id),
constraint t_id_fk foreign key(t_id) references teacher(id),
constraint s_id_fk foreign key(s_id) references student(id)
);
如何写javabean 和 dao呢 ?
public class Teacher {
private Integer id;
private String name;
private Float salary;
private Set<Student> stus = new HashSet<Student>();
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public Float getSalary() {
return salary;
}
public void setSalary(Float salary) {
this.salary = salary;
}
public Set<Student> getStus() {
return stus;
}
public void setStus(Set<Student> stus) {
this.stus = stus;
}
}


public class Student {
private Integer id;
private String name;
private String grade;
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getGrade() {
return grade;
}
public void setGrade(String grade) {
this.grade = grade;
}
@Override
public String toString() {
return "Student [grade=" + grade + ", id=" + id + ", name=" + name+ "]";
}
}
public class TeacherDao {
private  QueryRunner qr = new QueryRunner(JdbcUtil.getDataSource());
public void addTeacher(Teacher t) throws SQLException{
//保存教师基本信息
String sql = "insert into teacher values(?,?,?)";
Object params[] = {t.getId(),t.getName(),t.getSalary()};
qr.update(sql, params);
//保存学生基本信息
//第3方表
Set<Student> stus = t.getStus();
if(stus!=null&&stus.size()>0){
for(Student s:stus){
sql = "insert into student values(?,?,?)";
params = new Object[]{s.getId(),s.getName(),s.getGrade()};
qr.update(sql, params);
sql = "insert into teacher_student values(?,?)";
params = new Object[]{t.getId(),s.getId()};;
qr.update(sql, params);
}
}


}
public List<Teacher> findTeacher(boolean lazy) throws SQLException{
String sql = "select * from teacher";
List<Teacher> ts = qr.query(sql, new BeanListHandler<Teacher>(Teacher.class));
if(ts!=null&&ts.size()>0){
for(Teacher t:ts){
if(lazy){
sql = "select id from student where id in (select s_id from teacher_student where t_id=?)";
}else{
sql = "select * from student where id in (select s_id from teacher_student where t_id=?)";
}
List<Student> stus = qr.query(sql, new BeanListHandler<Student>(Student.class), t.getId());
for(Student s:stus){
t.getStus().add(s);
}
}
}
return ts;
}
}
工具表工具
public class JdbcUtil {
private static DataSource ds;
private static ThreadLocal<Connection> tl = new ThreadLocal<Connection>();
static{
try{
InputStream in = JdbcUtil.class.getClassLoader().getResourceAsStream("dbcpconfig.properties");
Properties props = new Properties();
props.load(in);

BasicDataSourceFactory factory = new BasicDataSourceFactory();
ds = factory.createDataSource(props);

}catch(Exception e){
throw new ExceptionInInitializerError(e);
}
}
public static DataSource getDataSource(){
return ds;
}
public static Connection getConnection() throws SQLException{
Connection conn = tl.get();
if(conn==null){
conn = ds.getConnection();
tl.set(conn);
}
return conn;
}
public static void startTransaction() throws SQLException{
Connection conn = tl.get();
if(conn==null){
conn = ds.getConnection();
tl.set(conn);
}
conn.setAutoCommit(false);
}
public static void rollback()throws SQLException{
Connection conn = tl.get();
if(conn==null){
conn = ds.getConnection();
tl.set(conn);
}
conn.rollback();
}
public static void commit()throws SQLException{
Connection conn = tl.get();
if(conn==null){
conn = ds.getConnection();
tl.set(conn);
}
conn.commit();
tl.remove();
}
public static void release(ResultSet rs,Statement stmt,Connection conn){
if(rs!=null){
try{
rs.close();
}catch(Exception e){
e.printStackTrace();
}
rs = null;
}
if(stmt!=null){
try{
stmt.close();
}catch(Exception e){
e.printStackTrace();
}
stmt = null;
}
if(conn!=null){
try{
conn.close();
}catch(Exception e){
e.printStackTrace();
}
conn = null;
}
}
}

dbcpconfig.properties的文件 中内容
#连接设置
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/day15  #这个是你的数据库地址
username=root #这个是你的用户名
password=sorry # 这个是你 密码


#<!-- 初始化连接 -->
initialSize=10


#最大连接数量
maxActive=20


#<!-- 最大空闲连接 -->
maxIdle=6


#<!-- 最小空闲连接 -->
minIdle=3


#<!-- 超时等待时间以毫秒为单位 6000毫秒/1000等于60秒 -->
maxWait=60000




#JDBC驱动建立连接时附带的连接属性属性的格式必须为这样:[属性名=property;] 
#注意:"user" 与 "password" 两个属性会被明确地传递,因此这里不需要包含他们。
connectionProperties=useUnicode=true;characterEncoding=utf8


#指定由连接池所创建的连接的自动提交(auto-commit)状态。
defaultAutoCommit=true


#driver default 指定由连接池所创建的连接的只读(read-only)状态。
#如果没有设置该值,则“setReadOnly”方法将不被调用。(某些驱动并不支持只读模式,如:Informix)
defaultReadOnly=


#driver default 指定由连接池所创建的连接的事务级别(TransactionIsolation)。
#可用值为下列之一:(详情可见javadoc。)NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE
defaultTransactionIsolation=REPEATABLE_READ

© 著作权归作者所有

共有 人打赏支持
凌枫yong
粉丝 1
博文 65
码字总数 0
作品 0
南昌
hibernate七种对应关系映射

首先我们了解一个名词ORM,全称是(Object Relational Mapping),即对象关系映射。ORM的实现思想就是将关系数据库中表的数据映射成对象,以对象的形式展现,这样开发人员就可以把对数据库的...

无敌小学僧 ⋅ 05/17 ⋅ 0

Java面试题之Hibernate

1.简书一下Hibernated的开发流程 第一步:加载Hibernate的配置文件,读取配置文件的参数, 第二步:创建SessionFactory会话工厂(内部有连接池) 第三步:打开Session 连接 第四步:开启事务...

年轻诠释我们的梦想_705b ⋅ 06/05 ⋅ 0

Java面试----2018年MyBatis常见实用面试题整理

Java面试----2018年MyBatis常见实用面试题整理 1、什么是MyBatis? 答:MyBatis是一个可以自定义SQL、存储过程和高级映射的持久层框架。 2、讲下MyBatis的缓存 答:MyBatis的缓存分为一级缓存...

优惠券活动 ⋅ 04/29 ⋅ 0

JAVA程序员面试题整理(较全面)

以下是在面试中可能会遇到的问题,话不多说,往下看 1、面向对象的特征有哪些方面? 2、访问修饰符public,private,protected,以及不写(默认)时的区别? 3、String 是最基本的数据类型吗? ...

编程大侠 ⋅ 04/09 ⋅ 0

MySQL多数据源笔记5-ShardingJDBC实战

Sharding-JDBC集分库分表、读写分离、分布式主键、柔性事务和数据治理与一身,提供一站式的解决分布式关系型数据库的解决方案。 从2.x版本开始,Sharding-JDBC正式将包名、Maven坐标、码云仓...

狂小白 ⋅ 03/19 ⋅ 0

使用 ibatis 处理复杂对象数据关系的实例

ibatis 基本介绍 起源于 2001 年的开放源代码项目 ibatis,是一个基于 Java 的持久层框架。与 Hibernate, Toplink 等持久化框架不同,ibatis 是一个 “半自动化”的 ORM 实现。ibatis 没有对...

红薯 ⋅ 2010/09/05 ⋅ 4

Hibernate实战学习(第一章)

范式不匹配: 1.粒度问题 关系型数据库对UDT(自定义对象) 支持度不高,并且产品间几乎不兼容。 2.子类型问题 SQL数据库目前还缺乏一种表示多态关联的明显方式,一个外键约束会准确的引用一...

无敌小学僧 ⋅ 05/21 ⋅ 0

集成 Proxy 与 DB Mesh,Sharding-JDBC 3 将"Sharding"做到极致

嘉宾:张亮 作者:雨多田光 提起数据库中间件,我们可以很自然地联想到 OneProxy、TDSQL、Sharding-JDBC 与 MyCat 等知名项目。在众多的数据库中间件实现技术中,通常存在两种架构模式,一种...

编辑部的故事 ⋅ 05/23 ⋅ 18

Java面试题全集(上)+JavaSE基础

第一阶段:开发常用 JavaSE基础、Spring、Spring Boot、Spring Cloud、Hibernate、Mybatis、MySQL、Oracle、MariaDB(支持文档数据) 第二阶段:基础提升 JavaSE深入、JVM、数据结构+算法、H...

guod369 ⋅ 2017/12/28 ⋅ 0

2018年Java编程学习面试最全知识点总结

Java是一种可以撰写跨平台应用软件的面向对象的程序设计语言。Java 技术具有卓越的通用性、高效性、平台移植性和安全性,广泛应用于PC、数据中心、游戏控制台、科学超级计算机、移动电话和互...

Java小辰 ⋅ 05/14 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

Centos7重置Mysql 8.0.1 root 密码

问题产生背景: 安装完 最新版的 mysql8.0.1后忘记了密码,向重置root密码;找了网上好多资料都不尽相同,根据自己的问题总结如下: 第一步:修改配置文件免密码登录mysql vim /etc/my.cnf 1...

豆花饭烧土豆 ⋅ 59分钟前 ⋅ 0

熊掌号收录比例对于网站原创数据排名的影响[图]

从去年下半年开始,我在写博客了,因为我觉得业余写写博客也还是很不错的,但是从2017年下半年开始,百度已经推出了原创保护功能和熊掌号平台,为此,我也提交了不少以前的老数据,而这些历史...

原创小博客 ⋅ 今天 ⋅ 0

LVM讲解、磁盘故障小案例

LVM LVM就是动态卷管理,可以将多个硬盘和硬盘分区做成一个逻辑卷,并把这个逻辑卷作为一个整体来统一管理,动态对分区进行扩缩空间大小,安全快捷方便管理。 1.新建分区,更改类型为8e 即L...

蛋黄Yolks ⋅ 今天 ⋅ 0

Hadoop Yarn调度器的选择和使用

一、引言 Yarn在Hadoop的生态系统中担任了资源管理和任务调度的角色。在讨论其构造器之前先简单了解一下Yarn的架构。 上图是Yarn的基本架构,其中ResourceManager是整个架构的核心组件,它负...

p柯西 ⋅ 今天 ⋅ 0

uWSGI + Django @ Ubuntu

创建 Django App Project 创建后, 可以看到路径下有一个wsgi.py的问题 uWSGI运行 直接命令行运行 利用如下命令, 可直接访问 uwsgi --http :8080 --wsgi-file dj/wsgi.py 配置文件 & 运行 [u...

袁祾 ⋅ 今天 ⋅ 0

JVM堆的理解

在JVM中,我们经常提到的就是堆了,堆确实很重要,其实,除了堆之外,还有几个重要的模块,看下图: 大 多数情况下,我们并不需要关心JVM的底层,但是如果了解它的话,对于我们系统调优是非常...

不羁之后 ⋅ 昨天 ⋅ 0

推荐:并发情况下:Java HashMap 形成死循环的原因

在淘宝内网里看到同事发了贴说了一个CPU被100%的线上故障,并且这个事发生了很多次,原因是在Java语言在并发情况下使用HashMap造成Race Condition,从而导致死循环。这个事情我4、5年前也经历...

码代码的小司机 ⋅ 昨天 ⋅ 2

聊聊spring cloud gateway的RetryGatewayFilter

序 本文主要研究一下spring cloud gateway的RetryGatewayFilter GatewayAutoConfiguration spring-cloud-gateway-core-2.0.0.RC2-sources.jar!/org/springframework/cloud/gateway/config/G......

go4it ⋅ 昨天 ⋅ 0

创建新用户和授予MySQL中的权限教程

导读 MySQL是一个开源数据库管理软件,可帮助用户存储,组织和以后检索数据。 它有多种选项来授予特定用户在表和数据库中的细微的权限 - 本教程将简要介绍一些选项。 如何创建新用户 在MySQL...

问题终结者 ⋅ 昨天 ⋅ 0

android -------- 颜色的半透明效果配置

最近有朋友问我 Android 背景颜色的半透明效果配置,我网上看资料,总结了一下, 开发中也是常常遇到的,所以来写篇博客 常用的颜色值格式有: RGB ARGB RRGGBB AARRGGBB 这4种 透明度 透明度...

切切歆语 ⋅ 昨天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部