2022-08-18 JDBC

目录

JDBC

JDBC是什么？

数据的持久化：

JDBC编程需要：

1.数据库驱动：

2.url地址：

3.数据库的用户名：

4.数据库的密码：

导入jar包

使用属性配置文件的好处：

正题：执行数据库的DML语言---增删改（没有查哟）

---

JDBC

JDBC是什么？

JDBC指的是Java数据库连接，是一种标准Java应用编程接口,用来连接java编程和广泛的数据库

数据的持久化：

把数据永久的保存起来。主要的方式还是得存到硬盘上。 持久化的实现过程大部分是通过数据库来完成。

JDBC编程需要：

1.数据库驱动：

        所有连接数据库都要实现的最大接口：java.sql.Driver

        如何加载驱动？

        通过反射：class.forName("com.mysql.jdbc.Driver");

        mysql:com.mysql.jdbc.Driver

        oracle:oracle.jdbc.driver.OracleDriver

2.url地址：

        需要链接数据库，其实就是链接一个服务器。

        我们之前链接服务器的时候用的是IP地址+端口号，但是针对于连接数据库的话，有一个专门的协议：jdbc协议：

        jdbc协议：jdbc:mysql://主机名称（主机地址）：端口号/数据库的名字

      (这是我的地址)eg:jdbc:mysql://127.0.0.1:3306/wy?useUnicode=true&characterEncoding=utf8

3.数据库的用户名：

4.数据库的密码：

导入jar包

链接数据库需要导入外部依赖，需要引入mysql的驱动（指的是引入的jar包）

jar包：点击进入官网

我这里用的是5.1.17的，这里不推荐用8.0的，因为8.0变样了，而且非常的私有化，然后还需要解放私有化，非常麻烦，最关键的是，我不会。

我们首先需要导入jar包：在项目下建立一个文件夹：lib

然后把jar包放到文件夹里，之后右键点击add a liabrary

以上的都是准备工作，我们来真正链接数据库：

获取以上的内容

String url="jdbc:mysql://127.0.0.1:3306/wy?useUnicode=true&characterEncoding=utf8";
String username="root";//你自己的用户名字
String password="root";//你自己的用户密码
//驱动的全类名
String driverName="com.mysql.jdbc.Driver";

加载驱动类：

Class clazz = Class.forName(driverName);

实例化Driver对象

Driver driver=(Driver)clazz.getDeclaredConstructor().newInstance();

注册驱动

DriverManager.registerDriver(driver);

获取链接

Connection connection=DriverManager.getConnection(url,username,password);

接下来可以用Objects的nonNull的方法来判断是否连接成功了：

System.out.println(Objects.nonNull(connection)?"数据库连接成功":"数据库连接失败");

这下步骤太麻烦，而且在代码中，不易改变，所以我们用封装+外部文件获取驱动的方式，封装一个方法：

获取JDBC连接的方法 

jdbc.properties文件：注意，是文件，读取外部的properties属性文件，用外部文件获取驱动

mysql.url=jdbc:mysql://127.0.0.1:3306/wy?useUnicode=true&characterEncoding=utf8
mysql.username=root
mysql.password=020323
mysql.driverName=com.mysql.jdbc.Driver

 方法：

public static Connection connection(){
        Properties properties = new Properties();
        Connection connection=null;
        try {
            properties.load(Test01.class.getClassLoader().getResourceAsStream("jdbc.properties"));
            String url = properties.getProperty("mysql.url");
            String driverName = properties.getProperty("mysql.driverName");
            String username = properties.getProperty("mysql.username");
            String password = properties.getProperty("mysql.password");
            Class.forName(driverName);//加载器驱动类（可以省略实例化对象和注册驱动的过程）
            connection = DriverManager.getConnection(url, username, password);
        } catch (SQLException e) {
            throw new RuntimeException(e);
        } catch (IOException e) {
            throw new RuntimeException(e);
        } catch (ClassNotFoundException e) {
            throw new RuntimeException(e);
        }
        return connection;
    }

使用属性配置文件的好处：

1.实现了代码和数据的分离，如果需要修改配置信息,直接在属性文件中修改即可。不需要深入代码

2.如果修改了配置信息，省去了编译的过程

3.符合OCP原则

正题：执行数据库的DML语言---增删改（没有查哟）

在java中有三个接口分别定义了对数据库的调用的不同的方式：

1.Statement：用来执行静态sql语句并返回它所生成的结果对象

2.PreparedStatement：预编译，可以使用此对象多次高效的执行该语句

3.CallableStatement:用来执行sql的存储过程//不学

我们每次开启数据库连接，相对应的也要关闭连接：我们也封装一个工具类：

public static void close(Connection conn, Statement statement){
        if(Objects.nonNull(statement)){
            try {
                statement.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }
        if(Objects.nonNull(conn)){
            try {
                conn.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }
    }

 首先建立连接、创建Statement对象

        Connection conn =null;
        Statement statement=null;
        try {
            conn = JDBCUtil.connection();
            statement = conn.createStatement();
            //增加
            String sql="INSERT INTO teacher (name) VALUES ('法外狂徒')";
//            //返回值是执行sql语句影响的行数
            //修改
//            String sql="UPDATE teacher set name='jay'";
            //删除
//            String sql="DELETE FROM teacher where name='jay'";
            int i = statement.executeUpdate(sql);
            System.out.println(i);
            System.out.println("操作成功！！！");
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }finally {
            JDBCUtil.close(conn,statement);
        }

那么我们要进行查询操作该怎么做呢：

首先获取连接，获取可以执行sql语句的statement对象，定义sql，执行查询的sql，会得到一个ResultSet,ResultSet就是封装了查询结果的一个对象，遍历结果集

    @Test
    public void test01() {
        // 1.获取连接
        Connection conn = JDBCUtil.getConnection();
        Statement stmt = null;
        ResultSet rs = null;
        try {
            // 2.获取可以执行sql语句的stmt对象
            stmt = conn.createStatement();
            // 3.定义sql
            String sql = "select id tid,name tname from teacher where id = 7";
            // 4.执行查询的sql，会得到一个ResultSet
            // ResultSet就是封装了查询结果的一个对象
            rs = stmt.executeQuery(sql);
            // 5.遍历结果集ResultSet
            while(rs.next()) {
                int id = rs.getInt("tid");
                String name = rs.getString("tname");
                System.out.println("id:" + id + ",name:" + name);
            }
        } catch (SQLException e) {
            throw new RuntimeException(e);
        } finally {
            // 6.关闭资源
            JDBCUtil.close(conn,stmt,rs);
        }
    }

 关闭资源的方法:

public static void close(Connection conn, Statement stmt, ResultSet rs) {
 
        if(Objects.nonNull(stmt)) {
            try {
                stmt.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }
        if(Objects.nonNull(conn)){
            try {
                conn.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }
        if(Objects.nonNull(rs)){
            try {
                rs.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }
    }