AI 助理
备案控制台
开发者社区 数据库 文章 正文

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

2017-06-16 1175
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 黑马程序员我们知道，在设计一个Java bean的时候，要把这些BEAN 的数据存放在数据库中的表结构，然而这些数据库中的表直接又有些特殊的关系，例如员工与部门直接有一对多的关系，学生与老师直接又多对多的关系，那么这些表的关系如何表示呢？首先在建立数据库的时候就应该建立这样的对应关系。

黑马程序员

我们知道，在设计一个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
 
文章标签：
SQL
数据库
Java
数据库连接
关键词：
jdbc操作
jdbc方法
数据库一对多
数据库多对多
炉火纯青
目录
相关文章
光明顶阳顶天
|
10天前
|
存储 监控 安全
数据库多实例的部署与配置方法
【10月更文挑战第23天】数据库多实例的部署和配置需要综合考虑多个因素，包括硬件资源、软件设置、性能优化、安全保障等。通过合理的部署和配置，可以充分发挥多实例的优势，提高数据库系统的运行效率和可靠性。在实际操作中，要不断总结经验，根据实际情况进行调整和优化，以适应不断变化的业务需求。
光明顶阳顶天
35 1
东方睿赢
|
3月前
|
Java 关系型数据库 数据库连接
JDBC：Java与数据库的“黄金搭档”，为何它如此重要？
JDBC：Java与数据库的“黄金搭档”，为何它如此重要？
东方睿赢
45 8
龙大吉
|
3月前
|
Java 数据库连接 API
JDBC：Java数据库连接的“黑科技”大揭秘
JDBC：Java数据库连接的“黑科技”大揭秘
龙大吉
36 7
sunrr
|
9天前
|
SQL Oracle 关系型数据库
Oracle数据库优化方法
【10月更文挑战第25天】Oracle数据库优化方法
sunrr
20 7
1100237741946300
|
28天前
|
SQL 关系型数据库 MySQL
Go语言项目高效对接SQL数据库：实践技巧与方法
在Go语言项目中，与SQL数据库进行对接是一项基础且重要的任务
1100237741946300
48 11
1100237741946300
|
27天前
|
SQL 数据库 数据库管理
数据库SQL函数应用技巧与方法
在数据库管理中，SQL函数是处理和分析数据的强大工具
1100237741946300
34 5
nanshaws
|
1月前
|
SQL Java 数据库
Springboot+spring-boot-starter-data-jdbc实现数据库的操作
本文介绍了如何使用Spring Boot的spring-boot-starter-data-jdbc依赖来操作数据库，包括添加依赖、配置数据库信息和编写基于JdbcTemplate的数据访问代码。
nanshaws
33 2
蓝易云
|
2月前
|
消息中间件 关系型数据库 数据库
Python实时监测数据库表数据变化的方法
在实现时，需要考虑到应用的实时性需求、数据库性能影响以及网络延迟等因素，选择最适合的方法。每种方法都有其适用场景和限制，理解这些方法的原理和应用，将帮助开发者在实际项目中做出最合适的技术选择。
蓝易云
113 17
蓝易云
|
2月前
|
SQL 关系型数据库 MySQL
创建包含MySQL和SQLServer数据库所有字段类型的表的方法
创建一个既包含MySQL又包含SQL Server所有字段类型的表是一个复杂的任务，需要仔细地比较和转换数据类型。通过上述方法，可以在两个数据库系统之间建立起相互兼容的数据结构，为数据迁移和同步提供便利。这一过程不仅要考虑数据类型的直接对应，还要注意特定数据类型在不同系统中的表现差异，确保数据的一致性和完整性。
蓝易云
31 4
杀死一只知更鸟debug
|
2月前
|
SQL 关系型数据库 MySQL
ThinkPHP6 连接使用数据库，增删改查，find，select，save，insert，insertAll，insertGetId，delete，update方法的用法
本文介绍了在ThinkPHP6框架中如何连接和使用数据库进行增删改查操作。内容包括配置数据库连接信息、使用Db类进行原生MySQL查询、find方法查询单个数据、select方法查询数据集、save方法添加数据、insertAll方法批量添加数据、insertGetId方法添加数据并返回自增主键、delete方法删除数据和update方法更新数据。此外，还说明了如何通过数据库配置文件进行数据库连接信息的配置，并强调了在使用Db类时需要先将其引入。
杀死一只知更鸟debug
84 0
ThinkPHP6 连接使用数据库，增删改查，find，select，save，insert，insertAll，insertGetId，delete，update方法的用法

热门文章

最新文章

  • 1
    RDS入门——Excel文件转存到RDS数据库实践
  • 2
    数据库厂商提供的 Providers for ASP.NET
  • 3
    mysql数据库主从不同步的解决方法
  • 4
    重启数据库的一场闹剧
  • 5
    NSPredicate用法总结(Cocoa框架中的NSPredicate用于查询，原理和用法都类似于SQL中的where，作用相当于数据库的过滤取)
  • 6
    数据库只读时无法更新的解决方法
  • 7
    数据与程序的物理独立性、数据与程序的逻辑独立性、为什么数据库系统具有数据与程序的独立性？
  • 8
    数据库改名系列（数据库名，逻辑名，物理文件名）
  • 9
    云数据库（国产）测试结果总结
  • 10
    Myeclipse 操作数据库
  • 1
    JDBC编程
    48
  • 2
    JDBC Java标准库提供的一些api(类+方法) 统一各种数据库提供的api
    48
  • 3
    Scala应用 —— JDBC的创建
    69
  • 4
    Springboot框架整合Spring JDBC操作数据
    67
  • 5
    启动项目出现com.mysql.jdbc.exceptions.jdbc4.MySQLNonTransientConnectionException异常解决方法
    66
  • 6
    JDBC实现往MySQL插入百万级数据
    59
  • 7
    JDBC批量插入mysql数据
    53
  • 8
    Sharding-JDBC如何实现读写分离
    97
  • 9
    Sharding-JDBC 如何实现分片
    86
  • 10
    【JDBC编程】基于MySql的Java应用程序中访问数据库与交互数据的技术
    55

    • 相关课程

    更多
  • 数据库的前世今生
  • 数据库核心概念
  • JDBC数据库开发入门
  • 数据库及SQL/MySQL基础
  • JDBC数据库开发进阶
  • 高校精品课-西安交通大学 -数据库理论与技术

    • 相关电子书

    更多
  • DTCC 2022大会集锦《云原生一站式数据库技术与实践》
  • 阿里云瑶池数据库精要2022版
  • 2022 DTCC-阿里云一站式数据库上云最佳实践

    • 相关实验场景

    更多
  • 数据库实验室挑战任务-高级任务
  • 数据库实验室挑战任务-中级任务
  • 数据库实验室挑战任务-初级任务
  • 阿里云数据库产品实验室
  • MongoDB数据库入门
  • 使用DAS实现数据库自动扩容和回缩
    • 下一篇
    DataWorks智能数据建模全面公测开始啦！