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

2024-06-21 11:48
文章标签 实现 方法 操作 关系 jdbc 数据库 一对 中多表

本文主要是介绍JDBC上关于数据库中多表操作一对多关系和多对多关系的实现方法，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

我们知道，在设计一个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

这篇关于JDBC上关于数据库中多表操作一对多关系和多对多关系的实现方法的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1081139。

相关文章

Python调用Orator ORM进行数据库操作

Python调用Orator ORM进行数据库操作

《Python调用OratorORM进行数据库操作》OratorORM是一个功能丰富且灵活的PythonORM库,旨在简化数据库操作,它支持多种数据库并提供了简洁且直观的API,下面我们就... 目录Orator ORM 主要特点安装使用示例总结Orator ORM 是一个功能丰富且灵活的 python O
阅读更多...
Java实现检查多个时间段是否有重合

Java实现检查多个时间段是否有重合

《Java实现检查多个时间段是否有重合》这篇文章主要为大家详细介绍了如何使用Java实现检查多个时间段是否有重合,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录流程概述步骤详解China编程步骤1：定义时间段类步骤2：添加时间段步骤3：检查时间段是否有重合步骤4：输出结果示例代码结语作
阅读更多...
Nginx设置连接超时并进行测试的方法步骤

Nginx设置连接超时并进行测试的方法步骤

《Nginx设置连接超时并进行测试的方法步骤》在高并发场景下,如果客户端与服务器的连接长时间未响应,会占用大量的系统资源,影响其他正常请求的处理效率,为了解决这个问题,可以通过设置Nginx的连接... 目录设置连接超时目的操作步骤测试连接超时测试方法：总结：设置连接超时目的设置客户端与服务器之间的连接
阅读更多...
Java判断多个时间段是否重合的方法小结

Java判断多个时间段是否重合的方法小结

《Java判断多个时间段是否重合的方法小结》这篇文章主要为大家详细介绍了Java中判断多个时间段是否重合的方法,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录判断多个时间段是否有间隔判断时间段集合是否与某时间段重合判断多个时间段是否有间隔实体类内容public class D
阅读更多...
Python使用国内镜像加速pip安装的方法讲解

Python使用国内镜像加速pip安装的方法讲解

《Python使用国内镜像加速pip安装的方法讲解》在Python开发中,pip是一个非常重要的工具,用于安装和管理Python的第三方库,然而,在国内使用pip安装依赖时,往往会因为网络问题而导致速... 目录一、pip 工具简介1. 什么是 pip？2. 什么是 -i 参数？二、国内镜像源的选择三、如何
阅读更多...
使用C++实现链表元素的反转

使用C++实现链表元素的反转

《使用C++实现链表元素的反转》反转链表是链表操作中一个经典的问题,也是面试中常见的考题,本文将从思路到实现一步步地讲解如何实现链表的反转,帮助初学者理解这一操作,我们将使用C++代码演示具体实现,同... 目录问题定义思路分析代码实现带头节点的链表代码讲解其他实现方式时间和空间复杂度分析总结问题定义给定
阅读更多...
IDEA编译报错“java: 常量字符串过长”的原因及解决方法

IDEA编译报错“java: 常量字符串过长”的原因及解决方法

《IDEA编译报错“java:常量字符串过长”的原因及解决方法》今天在开发过程中,由于尝试将一个文件的Base64字符串设置为常量,结果导致IDEA编译的时候出现了如下报错java:常量字符串过长,... 目录一、问题描述二、问题原因2.1 理论角度2.2 源码角度三、解决方案解决方案①：StringBui
阅读更多...
Linux使用nload监控网络流量的方法

Linux使用nload监控网络流量的方法

《Linux使用nload监控网络流量的方法》Linux中的nload命令是一个用于实时监控网络流量的工具,它提供了传入和传出流量的可视化表示,帮助用户一目了然地了解网络活动,本文给大家介绍了Linu... 目录简介安装示例用法基础用法指定网络接口限制显示特定流量类型指定刷新率设置流量速率的显示单位监控多个
阅读更多...
Java覆盖第三方jar包中的某一个类的实现方法

Java覆盖第三方jar包中的某一个类的实现方法

《Java覆盖第三方jar包中的某一个类的实现方法》在我们日常的开发中,经常需要使用第三方的jar包,有时候我们会发现第三方的jar包中的某一个类有问题,或者我们需要定制化修改其中的逻辑,那么应该如何... 目录一、需求描述二、示例描述三、操作步骤四、验证结果五、实现原理一、需求描述需求描述如下：需要在
阅读更多...
JavaScript中的reduce方法执行过程、使用场景及进阶用法

JavaScript中的reduce方法执行过程、使用场景及进阶用法

《JavaScript中的reduce方法执行过程、使用场景及进阶用法》：本文主要介绍JavaScript中的reduce方法执行过程、使用场景及进阶用法的相关资料,reduce是JavaScri... 目录1. 什么是reduce2. reduce语法2.1 语法2.2 参数说明3. reduce执行过程
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2