JDBC(重点)

数据库驱动

我们的程序会通过数据库驱动和数据库打交道

JDBC

Java数据库连接，（Java Database Connectivity，简称JDBC）是Java语言中用来规范客户端程序如何来访问数据库的应用程序接口，提供了诸如查询和更新数据库中数据的方法。JDBC也是Sun Microsystems的商标。我们通常说的JDBC是面向关系型数据库的。

对于开发人员只需要使用jdbc即可

第一个JDBC程序

建立一个数据库

CREATE DATABASE `jdbcStudy` CHARACTER SET utf8 COLLATE utf8_general_ci;

USE `jdbcStudy`;

CREATE TABLE `users`(
 `id` INT PRIMARY KEY,
 `NAME` VARCHAR(40),
 `PASSWORD` VARCHAR(40),
 `email` VARCHAR(60),
 birthday DATE
);

 INSERT INTO `users`(`id`,`NAME`,`PASSWORD`,`email`,`birthday`)
VALUES('1','zhangsan','123456','zs@sina.com','1980-12-04'),
('2','lisi','123456','lisi@sina.com','1981-12-04'),
('3','wangwu','123456','wangwu@sina.com','1979-12-04')

然后创建一个名为JDBC的普通java项目
创建一个lib文件夹
导入MySQL Connector/J » 5.1.47的jar包

https://mvnrepository.com/artifact/mysql/mysql-connector-java/5.1.47

然后右键add as library 点击ok

创建一个class

package com.jdbctest.lesson01;

import java.sql.*;

public class HelloJdbc {
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
        // 加载驱动
        // 固定写法
        Class.forName("com.mysql.jdbc.Driver");

        //用户信息和url
        String url="jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&useSSL=false";
        String username="root";
        String password="123456";
        // 连接成功数据库对象
        Connection connection = DriverManager.getConnection(url, username, password);

        // 执行sql的对象，去执行sql
        Statement statement = connection.createStatement();
        String sql = "SELECT * FROM users";
        // 结果集封装了我们全部的查询结果
        ResultSet resultSet = statement.executeQuery(sql);
        while (resultSet.next()){
            System.out.println(resultSet.getObject("id"));
            System.out.println(resultSet.getObject("NAME"));
            System.out.println(resultSet.getObject("PASSWORD"));
            System.out.println(resultSet.getObject("email"));
            System.out.println(resultSet.getObject("birthday"));
        }
        // 释放连接
        resultSet.close();
        statement.close();
        connection.close();
    }
}

DriverManager

 // 加载驱动
  Class.forName("com.mysql.jdbc.Driver"); //固定写法

URL

//jdbc:mysql://主机名:端口号/数据库名?参数1&参数2
String url="jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8";

statement 执行sql的对象

statement.executeQuery();  // 查询
statement.execute(); //执行任何sql
statement.executeUpdate(); //更新 插入 删除都用这个，返回一个受影响行数

ResultSet 查询结果集,封装了所有的查询结果

 //和数据库中的类型一一匹配
    resultSet.getObject(); // 不知道列类型的情况下使用
    // 如果知道列的类型就使用指定的类型
    resultSet.getString(); 
    resultSet.getDate();
    resultSet.getInt();
    resultSet.getDouble();

遍历指针

resultSet.beforeFirst(); //移动到最前面
resultSet.afterLast();  //移动到最后面
resultSet.next()  // 移动到下一个
resultSet.previous(); // 移动到上一个
resultSet.absolute(); // 移动到指定行

释放资源

 // 释放连接 十分耗费资源
        resultSet.close();
        statement.close();
        connection.close();

statement对象

JDBC中的statement对象用于向数据库发送SQL语句，想完成对数据库的增删改查，只需要通过这个对象向数据库发送增删改查语句即可。

Statement对象的executeUpdate方法，用于向数据库发送增、删、改的sql语句，executeUpdate执行完后，将会返回一个整数（即增删改语句导致了数据库几行数据发生了变化)。

Statement.executeQuery方法用于向数据库发送查询语句,executeQuery方法返回代表查询结果的ResultSet对象。

CRUD操作-create
使用executeUpdate(String sql)方法完成数据添加操作，示例操作:

Statement st = connection.createStatement();
        String sql = "insert into user(...)value(...)";
        int num = st.executeUpdate(sql);
        if(num>0){
            System.out.println("插入成功！");
        }

CRUD操作-delete
使用executeUpdate(String sql)方法完成数据删除操作，示例操作:

Statement st = connection.createStatement();
        String sql = "delete from user where id=1";
        int num = st.executeUpdate(sql);
        if(num>0){
            System.out.println("删除成功！");
        }

CRUD操作-update
使用executeUpdate(String sql)方法完成数据修改操作，示例操作:

Statement st = connection.createStatement();
        String sql = "update user set name =''where name =''";
        int num = st.executeUpdate(sql);
        if(num>0){
            System.out.println("修改成功！");
        }

CRUD操作-read
使用executeUpdate(String sql)方法完成数据查询操作，示例操作:

Statement st = connection.createStatement();
        String sql = "select * from user where id=1";
        ResultSet rs = st.executeQuery(sql);
        while ( rs.next()){
            //根据获取列的数据类型，分别调用rs的相应方法映射到java对象中
        }

首先在src目录下创建一个db.properties

driver = com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbcstudy?userUnicode=true&characterEncoding=utf8&useSSL=true
username =root
password=123456

在创建一个工具类

package com.jdbctest.lesson02.utils;

import java.io.IOException;
import java.io.InputStream;
import java.sql.*;
import java.util.Properties;

public class JdbcUtils {
    private static String driver;
    private static String url;
    private static String username;
    private static String password;
    static {
        try{
            InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream("db.properties");
            Properties properties = new Properties();
            properties.load(in);

            driver= properties.getProperty("driver");
            url= properties.getProperty("url");
            username= properties.getProperty("username");
            password= properties.getProperty("password");
            Class.forName(driver);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    //获取连接
    public static Connection getConnection()throws SQLException{
        return DriverManager.getConnection(url,username,password);
    }
    //释放连接资源
    public static void release(Connection conn, Statement st, ResultSet rs) throws SQLException {
        if(rs!=null) {
            rs.close();
        }
        if(st!=null){
            st.close();
        }
        if (conn!=null){
            conn.close();
        }
    }

}

再创建测试类

package com.jdbctest.lesson02;

import com.jdbctest.lesson02.utils.JdbcUtils;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class Test {
    public static void main(String[] args) {
        Connection conn=null;
        Statement st =null;
        ResultSet rs=null;
        try{
            conn= JdbcUtils.getConnection();//获取连接
            st=conn.createStatement();//获取sql的执行对象
//            //插入数据
//            String sql="INSERT INTO `users`(`id`,`NAME`,`PASSWORD`,`email`,`birthday`) VALUES ('4','xiaobai','123456','789456158@qq.com','2021-10-22')";
//            int i=st.executeUpdate(sql);
//            if(i>0){
//                System.out.println("插入成功");
//            }
            //删除数据
//            String sql="DELETE FROM users WHERE id=4";
//            int i=st.executeUpdate(sql);
//            if(i>0){
//                System.out.println("删除成功");
//            }
            //更新数据
//            String sql="UPDATE users SET `NAME`='xiaohei' WHERE id=1";
//            int i=st.executeUpdate(sql);
//            if(i>0){
//                System.out.println("修改成功");
//            }
            //查询数据
            String sql="select * from users";
            rs=st.executeQuery(sql);
            while (rs.next()){
                System.out.println(rs.getObject("id"));
                System.out.println(rs.getObject("NAME"));
                System.out.println(rs.getObject("PASSWORD"));
                System.out.println(rs.getObject("email"));
                System.out.println(rs.getObject("birthday"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}