JDBC

2021-08-12 17:42:27

JDBC基本概念

Java数据库连接，也就是使用Java语言操作数据库。

本质：

其实是官方（SUN公司）定义的一套操作所有关系型数据库的规则，即接口。各个数据库厂商去实现这套接口，提供数据库驱动jar包，我们可以使用这套接口（JDBC）变成，整整执行的代码是驱动jar包中的实现类。

JDBC快速入门

步骤：

  1. 导入驱动jar包
  2. 注册驱动
  3. 获取数据库连接对象 Connection
  4. 定义sql
  5. 获取执行sql语句的对象 Statement
  6. 执行sql，接受返回结果
  7. 处理结果
  8. 释放资源
package day21;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;

public class Demo01 {
    public static void main(String[] args) throws Exception{
        //注册驱动
        Class.forName("com.mysql.jdbc.Driver");
        //获取数据库连接对象
        Connection conn = DriverManager.getConnection("http://localhost/phpMyAdmin4.8.5","root1","password");
        //定义sql语句
        String sql = "select * from USER where id = 1";
        //获取执行sql的对象
        Statement stmt = conn.createStatement();
        //执行sql
        int count = stmt.executeUpdate(sql);
        //释放资源
        stmt.close();
        conn.close();
    }
}

详解各个对象：

  1. DriverManager:驱动管理对象

    1. 功能

      1. 注册驱动:告诉程序该使用哪一个数据库驱动jar
static void registerDriver(Driver driver):注册与给定的驱动程序 DriverManager。
写代码使用：Class.forName("com.mysql.jdbc.Driver");
通过查看源码发现：在com.mysql.jdbc.Driver类中存在静态代码块。
static{
	try{
	java.sql.DriverManager.registerDriver(new Driver());
	} catch (SQLException E){
		throw new RuntimeException("Can‘t register driver!");
	}
}
 注意：mysql5之后的驱动jar爆可以省略注册驱动的步骤

2. 获取数据库连接
	方法：static Connection getConnection(String url,String user,String password)
	参数：
		url:指定连接的路径
			语法：jdbc:mysql://ip地址（域名）：端口号/数据库名称
			细节：如果连接的是本机mysql服务器，并且mysql服务默认端口是3306，则url可以简为jdbc:mysql:///数据库名称
		user:用户名
		password:密码

  2. Connection:数据库连接对象

    功能
	获取执行sql的对象
		Statement createStatement()
		PreparedStatement prepareStatement(String sql)
	管理事务
		开启事务：void setAutoCommit(boolean autoCommit):调用该方法设置参数为false, 即开启事务
		提交事务：commit()
		回滚事务: rollback()

  3. Statement:执行sql的对象

    执行sql
	1.boolean execute(String sql):可以执行任意的sql 了解
	2.int executeUpdate(String sql):执行DML（insert、update、delete）语句、DDL（create、alter、drop）语句
		返回值：影响的行数，可以通过这个影响的行数判断DML语句是否执行成功，返回值>0的则执行成功，反之则失败。
	3.ResultSet executeQuery（String sql）:执行DQL(select)语句

    练习1：添加一条记录

    package jdbc;

/*
添加一条记录
 */

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

public class ResultSet {
    public static void main(String[] args) {
        Statement stem = null;
        Connection conn = null;
        //1.注册驱动
        try {
            Class.forName("com.mysql.jdbc.Driver");
            //定义sql
            String sql = "insert into user values(2,‘xiaoming‘,‘11111‘)";
            //获取Connection对象
            conn = DriverManager.getConnection("jdbc:mysql:///db1","root1","password");
            //获取执行sql的对象
            stem = conn.createStatement();
            //执行sql
            int count = stem.executeUpdate(sql);
            //处理结果
            System.out.println(count);
            if (count >0){
                System.out.println("执行成功");
            } else {
                System.out.println("执行失败");
            }
        } catch (ClassNotFoundException | SQLException e) {
            e.printStackTrace();
        } finally {
           if (stem != null){
               try {
                   stem.close();
               } catch (SQLException throwables) {
                   throwables.printStackTrace();
               }
           }
            if (conn != null){
                try {
                    conn.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }
        }

    }
}

    练习2：修改记录

    package jdbc;

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

public class Demo02 {
    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        //注册驱动
        try {
            Class.forName("com.mysql.jdbc.Driver");
            //获取连接对象
            conn = DriverManager.getConnection("jdbc:mysql:///db1","root1","password");
            //定义sql
            String sql = "UPDATE user SET passwd = ‘30000‘ WHERE id = 2";
            //获取执行sql对象
            stmt = conn.createStatement();
            //执行sql
            int count = stmt.executeUpdate(sql);
            //处理结果
            System.out.println(count);
            if (count >0){
                System.out.println("执行成功");
            }else {
                System.out.println("执行失败");
            }
        } catch (ClassNotFoundException | SQLException e) {
            e.printStackTrace();
        } finally {
            if (stmt != null){
                try {
                    stmt.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }
            if (conn != null){
                try {
                    conn.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }
        }
    }
}

    练习3：删除一条记录

    package jdbc;

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

public class Demo02 {
    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        //注册驱动
        try {
            Class.forName("com.mysql.jdbc.Driver");
            //获取连接对象
            conn = DriverManager.getConnection("jdbc:mysql:///db1","root1","password");
            //定义sql
            String sql = "delete from USER where id=1";
            //获取执行sql对象
            stmt = conn.createStatement();
            //执行sql
            int count = stmt.executeUpdate(sql);
            //处理结果
            System.out.println(count);
            if (count >0){
                System.out.println("执行成功");
            }else {
                System.out.println("执行失败");
            }
        } catch (ClassNotFoundException | SQLException e) {
            e.printStackTrace();
        } finally {
            if (stmt != null){
                try {
                    stmt.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }
            if (conn != null){
                try {
                    conn.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }
        }
    }
}

  4. ResultSet:结果集对象，封装查询结果

    next():游标向下移动一行
getxxx(参数):获取数据
	xxx代表数据类型，比如获取int类型的数据，xxx就是int。
	参数：可以接受两种类型的值
		int:代表列的参数，从1开始。
		String:代表列名称

    代码演示：

    package jdbc;

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

public class ResultSet02 {
    public static void main(String[] args) {
        Statement stmt = null;
        Connection conn = null;
        ResultSet rs = null;
        try {
            //注册驱动
            Class.forName("com.mysql.jdbc.Driver");
            //获取连接对象
            conn = DriverManager.getConnection("jdbc:mysql:///db1","root1","password");
            //定义sql
            String sql = "select * from user";
            //获取sql对象
            stmt = conn.createStatement();
            //执行sql
            rs = stmt.executeQuery(sql);
            //让游标向下移动一行
            rs.next();
            //获取数据
            int id = rs.getInt(1);
            String name = rs.getString("name");
            String passwd = rs.getString("passwd");
            rs.next();
            //获取数据
            int id1 = rs.getInt(1);
            String name1 = rs.getString("name");
            String passwd1 = rs.getString("passwd");

            System.out.println(id+"---"+name+"---"+passwd);
            System.out.println(id1+"---"+name1+"---"+passwd1);
        } catch (ClassNotFoundException | SQLException e) {
            e.printStackTrace();
        } finally {
            if (rs != null){
                try {
                    stmt.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }
            if (conn != null){
                try {
                    stmt.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            } if (stmt != null){
                try {
                    stmt.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }
        }
    }
}

    注意：
	使用步骤：
		1.游标向下移动一行
		2.判断是否有数据
		3.获取数据
boolean next():游标向下移动一行，判断当前行是否是最后一行末尾（是否有数据），如果是，则返回false，如果不是则返回true。

    代码演示：
package jdbc;

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

public class ResultSet02 {
    public static void main(String[] args) {
        Statement stmt = null;
        Connection conn = null;
        ResultSet rs = null;
        try {
            //注册驱动
            Class.forName("com.mysql.jdbc.Driver");
            //获取连接对象
            conn = DriverManager.getConnection("jdbc:mysql:///db1","root1","password");
            //定义sql
            String sql = "select * from user";
            //获取sql对象
            stmt = conn.createStatement();
            //执行sql
            rs = stmt.executeQuery(sql);
            //使用循环遍历所有内容
            while(rs.next()){
                int id = rs.getInt(1);
                String name = rs.getString("name");
                String passwd = rs.getString("passwd");
                System.out.println(id+"---"+name+"---"+passwd);
            }
        } catch (ClassNotFoundException | SQLException e) {
            e.printStackTrace();
        } finally {
            if (rs != null){
                try {
                    stmt.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }
            if (conn != null){
                try {
                    stmt.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            } if (stmt != null){
                try {
                    stmt.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }
        }
    }
}

    练习4：查询表中指定数据，将其封装成对象，装载集合，打印

    创建封装对象的类
package jdbc;
/*
封装表内的数据
 */
public class SelectDemo01 {
    private int id;
    private String name;
    private String passwd;

    @Override
    public String toString() {
        return "SelectDemo01{" +
                "id=" + id +
                ", name=‘" + name + ‘\‘‘ +
                ", passwd=‘" + passwd + ‘\‘‘ +
                ‘}‘;
    }

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getPasswd() {
        return passwd;
    }

    public void setPasswd(String passwd) {
        this.passwd = passwd;
    }
}

将表中查询的数据封装到集合中打印
package jdbc;

import java.util.Collections;
import java.util.List;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;

/*
定义一个方法，查询表中的数据将其封装为对象，然后装载集合，返回
 */
public class SelectDemo02 {
    public static void main(String[] args) {
        List<SelectDemo01> list = new SelectDemo02().findAll();
        System.out.println(list);
        System.out.println(list.size());
    }

    /**
     *
     * @return
     */
    public List<SelectDemo01> findAll(){
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        List<SelectDemo01> list = null;
        //注册驱动
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection("jdbc:mysql:///db1", "root1", "password");
            String sql = "select * from user";
            stmt = conn.createStatement();
            rs = stmt.executeQuery(sql);
            list = new ArrayList<>();
            SelectDemo01 users = null;
            while (rs.next()) {
                int id = rs.getInt("id");
                String name = rs.getString("name");
                String passwd = rs.getString("passwd");
                //创建对象
                users = new SelectDemo01();
                users.setId(id);
                users.setName(name);
                users.setPasswd(passwd);

                list.add(users);
            }
        } catch (ClassNotFoundException | SQLException e) {
            e.printStackTrace();
        } finally {
            if (rs != null) {
                try {
                    rs.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }
            if (stmt != null) {
                try {
                    stmt.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }
        }
        return list;
    }
}

  5. PreparedStatement:执行sql的对象

    1. SQL注入问题（万能密码）：在拼接sql时，有一些sql的特殊关键字参与字符串的拼接，会造成安全性问题。

      1. 输入用户名随便输入，输入密码：a‘ or ‘1‘ = ‘1

        sql:select * from user where username = ‘asdaweq‘ and password = ‘a‘ or ‘1‘ = ‘1‘

    2. 解决sql注入问题：使用PreparedStatment对象来解决。

    3. 预编译sql：参数使用占位符替代，在执行sql语句的时候，将占位符替换。

    4. 步骤：

      1. 导入驱动jar包
      2. 注册驱动
      3. 获取数据库连接对象
      4. 定义sql
        • 注意：sql的参数使用？作为占位符。如：select * from user where username = ? and password = ?
      5. 获取执行的sql语句的对象
      6. 给?赋值
        • 方法： setxxx（参数1，参数2）
          • 参数1：?的位置编号，从1开始
          • 参数2：？的值
      7. 执行sql，接受返回的结果，不需要传递sql语句
      8. 处理结果
      9. 释放资源

    5. 注意：后期都会使用PreparedStatement来完成增删改查的所有操作：

      1. 可以防止sql注入
      2. 效率更高

    代码演示：

    //暂无，有坑未排

JDBC的工具类：JDBCUtils

目的：简化代码的书写

分析：

  1. 注册驱动也抽取

  2. 抽取一个方法获取连接对象

    1. 需求：不想传递参数（麻烦），还得保证工具类的通用性。

    2. 解决：配置文件

      ? jdbc.properties

      ? url=

      ? user=

      ? password=

      简单来说，就是在写工具类的时候，并不把连接对象写死，这样修改起来会比较麻烦，我们可以在一个文件里面写明连接对象的数据，这个在代码执行的时候，只需要修改配置文件就可以获取数据。

  3. 抽取一个方法释放资源

JDBC控制事务

事务：一个包含多个步骤的业务操作，如果这个业务操作被事务管理，则这多个步骤要么同时成功，要么同时失败。

操作：

  1. 开启事务
  2. 提交事务
  3. 回滚事务

使用Connection对象来管理事务

  • 开启事务：setAutoCommit(boolean autoCommit):调用该方法设置参数为false，即开启事务。
  • 提交事务：commit()
  • 回滚事务：rollback()

JDBC

上一篇：一个mysql表最多可以有几列? 一个mysql表最多可以创建多少个索引? 单个索引最多可以包含多少个列? 一个索引最多可以有多长?这个几个问题你都不一定知道正确答案


下一篇：【c++基础】static修饰的函数作用与意义