当前位置：网站首页>JDBC技术（一）——一个简单的JDBC测试

JDBC技术（一）——一个简单的JDBC测试

2022-08-09 01:30:00 【--流星。】

什么是JDBC

JDBC 指 Java 数据库连接，是一种标准Java应用编程接口（ JAVA API），用来连接 Java 编程语言和广泛的数据库。

从根本上来说，JDBC 是一种规范，它提供了一套完整的接口，允许便携式访问到底层数据库，因此可以用 Java 编写不同类型的可执行文件

JDBC架构

JDBC 的 API 支持两层和三层处理模式进行数据库访问，但一般的 JDBC 架构由两层处理模式组成：

  • JDBC API: 使用驱动程序管理器和数据库特定的驱动程序来提供异构（heterogeneous）数据库的透明连接。
  • JDBC Driver API: JDBC 驱动程序管理器可确保正确的驱动程序来访问每个数据源。该驱动程序管理器能够支持连接到多个异构数据库的多个并发的驱动程序。
    在这里插入图片描述

常用的JDBC组件

  • DriverManager ：这个类管理一系列数据库驱动程序。匹配连接使用通信子协议从 JAVA 应用程序中请求合适的数据库驱动程序。识别 JDBC 下某个子协议的第一驱动程序将被用于建立数据库连接。
  • Driver : 这个接口处理与数据库服务器的通信。你将很少直接与驱动程序互动。相反，你使用 DriverManager 中的对象，它管理此类型的对象。它也抽象与驱动程序对象工作相关的详细信息。
  • Connection : 此接口具有接触数据库的所有方法。该连接对象表示通信上下文，即，所有与数据库的通信仅通过这个连接对象进行。
  • Statement : 使用创建于这个接口的对象将 SQL 语句提交到数据库。除了执行存储过程以外，一些派生的接口也接受参数。
  • ResultSet : 在你使用语句对象执行 SQL 查询后，这些对象保存从数据获得的数据。它作为一个迭代器，让您可以通过它的数据来移动。
  • SQLException : 这个类处理发生在数据库应用程序的任何错误。

前期准备

新建java项目，创建lib目录并导入mysql驱动
在这里插入图片描述

项目结构

在这里插入图片描述

jdbc的编写流程

  • 导入mysql驱动，注册驱动
  • 创建与数据库之间的连接（tcp）
  • 封装sql并传输给mysql
  • 数据库响应并处理
  • 释放资源关闭连接

jdbc的代码编写

实体类

public class Emp1 {
    
    private Integer empno;
    private String ename;
    private String job;
    private Integer mgr;
    private String hiredate;
    private BigDecimal sal;
    private BigDecimal comm;
    private Integer deptno;

    public Emp1() {
    
    }

    public Emp1(Integer empno, String ename, String job, Integer mgr, String hiredate, BigDecimal sal, BigDecimal comm, Integer deptno) {
    
        this.empno = empno;
        this.ename = ename;
        this.job = job;
        this.mgr = mgr;
        this.hiredate = hiredate;
        this.sal = sal;
        this.comm = comm;
        this.deptno = deptno;
    }

    @Override
    public String toString() {
    
        return "Emp{" +
                "empno=" + empno +
                ", ename='" + ename + '\'' +
                ", job='" + job + '\'' +
                ", mgr=" + mgr +
                ", hiredate=" + hiredate +
                ", sal=" + sal +
                ", comm=" + comm +
                ", deptno=" + deptno +
                '}';
    }

    public Integer getDeptno() {
    
        return deptno;
    }

    public void setDeptno(Integer deptno) {
    
        this.deptno = deptno;
    }

    public Integer getEmpno() {
    
        return empno;
    }

    public void setEmpno(Integer empno) {
    
        this.empno = empno;
    }

    public String getEname() {
    
        return ename;
    }

    public void setEname(String ename) {
    
        this.ename = ename;
    }

    public String getJob() {
    
        return job;
    }

    public void setJob(String job) {
    
        this.job = job;
    }

    public Integer getMgr() {
    
        return mgr;
    }

    public void setMgr(Integer mgr) {
    
        this.mgr = mgr;
    }

    public String getHiredate() {
    
        return hiredate;
    }

    public void setHiredate(String hiredate) {
    
        this.hiredate = hiredate;
    }

    public BigDecimal getSal() {
    
        return sal;
    }

    public void setSal(BigDecimal sal) {
    
        this.sal = sal;
    }

    public BigDecimal getComm() {
    
        return comm;
    }

    public void setComm(BigDecimal comm) {
    
        this.comm = comm;
    }
}

工具类

package com.lx.jdbc01.util;

import com.lx.jdbc01.entity.Emp1;

import java.sql.*;

/** * description TODO * * @author 流星 * @date 2022/8/4 9:49 */
public class JDBCUtil1 {
    

    private static Connection getConnection() {
    
        Connection connection;
        try {
    
            // 1.注册驱动
            Class.forName("com.mysql.cj.jdbc.Driver");
            // 2.建立连接
            connection = DriverManager.getConnection(
                    "jdbc:mysql://localhost:3306/test?useSSL=true&serverTimezone=GMT%2B8",
                    "root",
                    "123456"
            );
        } catch (ClassNotFoundException | SQLException e) {
    
            throw new RuntimeException("创建连接失败！！！");
        }
        return connection;
    }

    public static void query(String ename) throws SQLException {
    
        Connection connection = getConnection();

        /** * 3.封装sql并传给mysql处理 * 用PreparedStatement而不用Statement是为了避免sql注入的问题，PreparedStatement对sql和参数进行了预处理 * sql注入问题：比如传ename的值为 xx or 1 = 1，无论xx是什么都能查出所有的信息 */
        String sql = "select * from emp where ename = ? ";
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        preparedStatement.setString(1, ename);
        ResultSet resultSet = preparedStatement.executeQuery();

        // 4.数据库响应并处理响应
        while (resultSet.next()) {
    
            int empno = resultSet.getInt("empno");
            String ename1 = resultSet.getNString("ename");
            System.out.println(empno + "***" + ename1);
        }

        // 5.关闭连接并释放资源
        close(connection, preparedStatement, resultSet);
    }

    private static void close(Connection connection, PreparedStatement preparedStatement, ResultSet resultSet) {
    
        try {
    
            if (resultSet != null) {
    
                resultSet.close();
            }
            if (preparedStatement != null) {
    
                preparedStatement.close();
            }
            if (connection != null) {
    
                connection.close();
            }
        } catch (SQLException e) {
    
            e.printStackTrace();
        }
    }

    public static void insert(Emp1 emp1) throws SQLException {
    
        Connection connection = getConnection();

        String sql = "insert into emp(empno,ename,job,mgr,hiredate,sal,comm,deptno) values(?,?,?,?,?,?,?,?)";
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        preparedStatement.setInt(1, emp1.getEmpno());
        preparedStatement.setString(2, emp1.getEname());
        preparedStatement.setString(3, emp1.getJob());
        preparedStatement.setInt(4, emp1.getMgr());
        preparedStatement.setString(5, emp1.getHiredate());
        preparedStatement.setBigDecimal(6, emp1.getSal());
        preparedStatement.setBigDecimal(7, emp1.getComm());
        preparedStatement.setInt(8, emp1.getDeptno());
        int count = preparedStatement.executeUpdate();

        if (count == 1) {
    
            System.out.println("插入成功");
        } else {
    
            System.out.println("插入失败");
        }

        close(connection, preparedStatement, null);
    }

    public static void delete(Integer empno) throws SQLException {
    
        Connection connection = getConnection();

        String sql = "delete from emp where empno = ? ";
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        preparedStatement.setInt(1, empno);

        int count = preparedStatement.executeUpdate();

        if (count == 1) {
    
            System.out.println("删除成功");
        } else {
    
            System.out.println("删除失败");
        }

        close(connection, preparedStatement, null);
    }

    public static void update(Integer empno, String ename) throws SQLException {
    
        Connection connection = getConnection();

        String sql = "update emp set ename = ? where empno = ? ";
        PreparedStatement preparedStatement = connection.prepareStatement(sql);
        preparedStatement.setString(1, ename);
        preparedStatement.setInt(2, empno);
        int count = preparedStatement.executeUpdate();

        if (count == 1) {
    
            System.out.println("更新成功");
        } else {
    
            System.out.println("更新失败");
        }

        close(connection, preparedStatement, null);
    }
}

测试类

package com.lx.jdbc01.test;

import com.lx.jdbc01.entity.Emp1;
import com.lx.jdbc01.util.JDBCUtil1;
import org.junit.Test;

import java.math.BigDecimal;
import java.sql.SQLException;
import java.text.SimpleDateFormat;
import java.util.Date;

/** * description TODO * * @author 流星 * @date 2022/8/4 9:50 */
public class MainTest1 {
    

    @Test
    public void query() throws SQLException {
    
        String ename="LI";
        JDBCUtil1.query(ename);
    }

    @Test
    public void insert() throws SQLException {
    
        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        Date createTime = new Date();
        JDBCUtil1.insert(new Emp1(6666,"YUN","CLERK",7698,simpleDateFormat.format(createTime),new BigDecimal(1500),new BigDecimal(200),20));
    }

    @Test
    public void update() throws SQLException {
    
        JDBCUtil1.update(6666,"YING");
    }

    @Test
    public void delete() throws SQLException {
    
        JDBCUtil1.delete(6666);
    }
}

测试结果

在这里插入图片描述

附：参考资料

JDBC介绍

原网站

版权声明
本文为[--流星。]所创，转载请带上原文链接，感谢
https://blog.csdn.net/weixin_45974176/article/details/126221481

边栏推荐

猜你喜欢

随机推荐