JDBC基础:JDBC快速入门,JDBC工具类,SQL注入攻击,JDBC管理事务

JDBC基础

重难点梳理

JDBC基础:JDBC快速入门,JDBC工具类,SQL注入攻击,JDBC管理事务

一、JDBC快速入门

1.jdbc的概念

  • JDBC(Java DataBase Connectivity:java数据库连接)是一种用于执行SQL语句的Java API,可以为多种关系型数据库提供统一访问,它是由一组用Java语言编写的类和接口组成的。

  • JDBC的作用:可以通过java代码操作数据库

2.jdbc的本质

  • 其实就是java官方提供的一套规范(接口)。用于帮助开发人员快速实现不同关系型数据库的连接!

  • 图示:

    JDBC基础:JDBC快速入门,JDBC工具类,SQL注入攻击,JDBC管理事务

     

     

  • 上图解释:

    • 如果没有jdbc,程序员想操作mysql,就需要学习mysql的一套操作规范

    • 程序员想操作oracle,就需要学习oracle的一套操作规范,db2也是

    • 这样做太麻烦了,这时候java就出了一套规范jdbc,用来操作所有的关系型数据库,然后各个数据库厂商支持这个规范就可以了

    • 那这样的话,程序员就只需要学习jdbc这一套规范即可

3.jdbc的快速入门程序

  1. 导入jar包

    资料中有一个压缩包:mysql-connector-java-5.1.37.zip
    解压出来,找到mysql-connector-java-5.1.37-bin.jar
  2. 注册驱动

    Class.forName("com.mysql.jdbc.Driver");
  3. 获取连接

    Connection con = DriverManager.getConnection("jdbc:mysql://localhost:3306/db2", "root", "root");
  4. 获取执行者对象

    Statement stat = con.createStatement();
  5. 执行sql语句,并接收返回结果

    String sql = "SELECT * FROM user";
    ResultSet rs = stat.executeQuery(sql);
  6. 处理结果

    while(rs.next()) {
       System.out.println(rs.getInt("id") + "\t" + rs.getString("name"));
    }
  7. 释放资源

    rs.close();
    stat.close();
    con.close();
  8. 创建一个java项目:JDBC基础

  9. 将jar包导入,并添加到引用类库

  10. 新建com.itheima01.JDBCDemo01

   package com.itheima01;
 
  import java.sql.Connection;
  import java.sql.DriverManager;
  import java.sql.ResultSet;
  import java.sql.Statement;
 
  public class JDBCDemo01 {
      public static void main(String[] args) throws Exception{
          //1.导入jar包
          //2.注册驱动
          Class.forName("com.mysql.jdbc.Driver");
 
          //3.获取连接 (连接的数据库名是db2,第二个第三个参数是连接数据库的用户名密码)
          Connection con = DriverManager.getConnection("jdbc:mysql://192.168.59.129:3306/db2","root","itheima");
 
          //4.获取执行者对象 (statement:表现,声明,跟程序意思不匹配)
          Statement stat = con.createStatement();
 
          //5.执行sql语句,并且接收结果
          String sql = "SELECT * FROM user";
          ResultSet rs = stat.executeQuery(sql); //execute执行,query:查询,resultset:结果集
 
          //6.处理结果
          while(rs.next()) {
              System.out.println(rs.getInt("id") + "\t" + rs.getString("name"));
          }
 
          //7.释放资源
          rs.close();
          stat.close();
          con.close();
      }
  }
 

二、JDBC各个功能类详解 ***

1.DriverManager

  • DriverManager:驱动管理对象

    • 注册驱动(告诉程序该使用哪一个数据库驱动)

      • 注册给定的驱动程序:static void registerDriver(Driver driver) (DriverManager的方法)

        • 我们在刚刚的入门案例中并没有注册驱动,也成功了,咋回事呢

      • 这是因为我们使用了Class.forName:Class.forName("com.mysql.jdbc.Driver")

        • 我们通过了给forName指定了是mysql的驱动

        • Class.forName()会加载,初始化指定的类

        • Driver类内部会帮助我们注册驱动,如下:

      • 在com.mysql.jdbc.Driver类中存在静态代码块(通过查看源码发现)

      //这是com.mysql.jdbc.Driver的静态代码块,只要使用这个类,就会执行这段代码
      //而Class.forName("com.mysql.jdbc.Driver")就正好使用到了这个类
      static {
      try {
      java.sql.DriverManager.registerDriver(new Driver());
      } catch (SQLException E) {
      throw new RuntimeException("Can‘t register driver!");
      }
      }
      • 注意:我们不需要通过DriverManager调用静态方法registerDriver(),因为只要Driver类被使用,则会执行其静态代码块完成注册驱动

      • mysql5之后可以省略注册驱动的步骤。在jar包中,存在一个java.sql.Driver配置文件,文件中指定了com.mysql.jdbc.Driver

        JDBC基础:JDBC快速入门,JDBC工具类,SQL注入攻击,JDBC管理事务

         

         

      • 所以后边我们其实可以省略注册驱动的步骤(可以注释掉上个案例的注册驱动的步骤,也可以查询到数据)

  • 获取数据库连接(获取到数据库的连接并返回连接对象)

    • static Connection getConnection(String url, String user, String password);

      • 返回值:Connection数据库连接对象

      • 参数

        • url:指定连接的路径。语法:jdbc:mysql://ip地址(域名):端口号/数据库名称

        • user:用户名

        • password:密码

2.Connection

  • Connection:数据库连接对象

    • 获取执行者对象

      • 获取普通执行者对象:Statement createStatement();

      • 获取预编译执行者对象:PreparedStatement prepareStatement(String sql);

    • 管理事务

      • 开启事务:setAutoCommit(boolean autoCommit); 参数为false,则开启事务。

      • 提交事务:commit();

      • 回滚事务:rollback();

    • 释放资源

      • 立即将数据库连接对象释放:void close();

3.Statement

  • Statement:执行sql语句的对象

    • 执行DML语句:int executeUpdate(String sql);

      • 返回值int:返回影响的行数

      • 参数sql:可以执行insert、update、delete语句。

    • 执行DQL语句:ResultSet executeQuery(String sql);

      • 返回值ResultSet:封装查询的结果

      • 参数sql:可以执行select语句。

    • 释放资源

      • 立即将执行者对象释放:void close();

4.ResultSet

  • ResultSet:结果集对象

    • 判断结果集中是否还有数据:boolean next();

      • 有数据返回true,并将索引向下移动一行

      • 没有数据返回false

    • 获取结果集中的数据:XXX getXxx("列名");

      • XXX代表数据类型(要获取某列数据,这一列的数据类型)

      • 例如:String getString("name"); int getInt("age");

    • 释放资源

      • 立即将结果集对象释放:void close();

    • 游标,相当于是箭头

三、JDBC案例student学生表的CRUD ***

1. 数据准备

  • 数据库和数据表

-- 创建db14数据库
CREATE DATABASE db14;
?
-- 使用db14数据库
USE db14;
?
-- 创建student表
CREATE TABLE student(
sid INT PRIMARY KEY AUTO_INCREMENT, -- 学生id
NAME VARCHAR(20), -- 学生姓名
age INT, -- 学生年龄
birthday DATE -- 学生生日
);
?
-- 添加数据
INSERT INTO student VALUES (NULL,‘张三‘,23,‘1999-09-23‘),(NULL,‘李四‘,24,‘1998-08-10‘),(NULL,‘王五‘,25,‘1996-06-06‘),(NULL,‘赵六‘,26,‘1994-10-20‘);
  • 实体类

    • Student类,成员变量对应表中的列

    • 注意:所有的基本数据类型需要使用包装类,以防null值无法赋值

      • 数据库的查询结果可能是 null,因为自动拆箱,用基本数据类型接收有 空指针 风险

    • 新建com.itheima02.domain.Student (保存实体类的包名,可以用bean,也可以用domain)

package com.itheima02.domain;
?
import java.util.Date;
?
public class Student {
   private Integer sid;
   private String name;
   private Integer age;
   private Date birthday;
?
   public Student() {
  }
?
   public Student(Integer sid, String name, Integer age, Date birthday) {
       this.sid = sid;
       this.name = name;
       this.age = age;
       this.birthday = birthday;
  }
?
   public Integer getSid() {
       return sid;
  }
?
   public void setSid(Integer sid) {
       this.sid = sid;
  }
?
   public String getName() {
       return name;
  }
?
   public void setName(String name) {
       this.name = name;
  }
?
   public Integer getAge() {
       return age;
  }
?
   public void setAge(Integer age) {
       this.age = age;
  }
?
   public Date getBirthday() {
       return birthday;
  }
?
   public void setBirthday(Date birthday) {
       this.birthday = birthday;
  }
?
   @Override
   public String toString() {
       return "Student{" +
               "sid=" + sid +
               ", name=‘" + name + ‘\‘‘ +
               ", age=" + age +
               ", birthday=" + birthday +
               ‘}‘;
  }
}
  • 本案例会使用分层思想,所以需要新建几个包

  • dao:数据持久层:操作数据库

    //定义dao接口:StudentDao
    //本案例要处理五个功能,所以dao接口中定义五个抽象方法
    package com.itheima02.dao;
    ?
    import com.itheima02.domain.Student;
    ?
    import java.util.ArrayList;
    ?
    /*
       Dao层接口
    */
    public interface StudentDao {
       //查询所有学生信息
       public abstract ArrayList<Student> findAll();
    ?
       //条件查询,根据id获取学生信息
       public abstract Student findById(Integer id);
    ?
       //新增学生信息
       public abstract int insert(Student stu);
    ?
       //修改学生信息
       public abstract int update(Student stu);
    ?
       //删除学生信息
       public abstract int delete(Integer id);
    }
    ?
  • service:业务层:处理业务逻辑,调用dao

    //定义service接口:StudentService
    package com.itheima02.service;
    ?
    import com.itheima02.domain.Student;
    ?
    import java.util.ArrayList;
    ?
    /*
       Service层接口
    */
    public interface StudentService {
       //查询所有学生信息
       public abstract ArrayList<Student> findAll();
    ?
       //条件查询,根据id获取学生信息
       public abstract Student findById(Integer id);
    ?
       //新增学生信息
       public abstract int insert(Student stu);
    ?
       //修改学生信息
       public abstract int update(Student stu);
    ?
       //删除学生信息
       public abstract int delete(Integer id);
    }
    ?
  • controller:控制层,调用业务层方法,将数据返回给前端界面(不过目前我们这个案例没有与界面结合)

    //定义控制层类:StudentController,提前准备好对应的测试方法
    package com.itheima02.controller;
    ?
    import org.junit.Test;
    ?
    public class StudentController {
       /*
           查询所有学生信息
        */
       @Test
       public void findAll() {
      }
    ?
       /*
           条件查询,根据id查询学生信息
        */
       @Test
       public void findById() {
      }
    ?
       /*
           添加学生信息
        */
       @Test
       public void insert() {
      }
    ?
       /*
           修改学生信息
        */
       @Test
       public void update() {
      }
    ?
       /*
           删除学生信息
        */
       @Test
       public void delete() {
           
      }
    }
    ?

     

2. 需求一:查询全部(查询所有学生信息)

  • 持久层:新建StudentDaoImpl实现StudentDao,并重写所有方法,我们先来处理第一个逻辑:

/*
    查询所有学生信息
*/
@Override
public ArrayList<Student> findAll() {
   ArrayList<Student> list = new ArrayList<>();
   Connection con = null;
   Statement stat = null;
   ResultSet rs = null;
   try{
       //1.注册驱动
       Class.forName("com.mysql.jdbc.Driver");
?
       //2.获取数据库连接
       con = DriverManager.getConnection("jdbc:mysql://192.168.59.129:3306/db14", "root", "itheima");
?
       //3.获取执行者对象
       stat = con.createStatement();
?
       //4.执行sql语句,并且接收返回的结果集
       String sql = "SELECT * FROM student";
       rs = stat.executeQuery(sql);
?
       //5.处理结果集
       while(rs.next()) {
           Integer sid = rs.getInt("sid");
           String name = rs.getString("name");
           Integer age = rs.getInt("age");
           Date birthday = rs.getDate("birthday");
?
           //封装Student对象
           Student stu = new Student(sid,name,age,birthday);
?
           //将student对象保存到集合中
           list.add(stu);
      }
?
  } catch(Exception e) {
       e.printStackTrace();
  } finally {
       //6.释放资源
       if(con != null) {
           try {
               con.close();
          } catch (SQLException e) {
               e.printStackTrace();
          }
      }
?
       if(stat != null) {
           try {
               stat.close();
          } catch (SQLException e) {
               e.printStackTrace();
          }
      }
?
       if(rs != null) {
           try {
               rs.close();
          } catch (SQLException e) {
               e.printStackTrace();
          }
      }
  }
   //将集合对象返回
   return list;
}
  • 业务层:新建StudentServiceImpl,实现StudentService,重写所有方法,然后先处理第一个逻辑:

private StudentDao dao = new StudentDaoImpl();
/*
   查询所有学生信息
*/
@Override
public ArrayList<Student> findAll() {
   return dao.findAll();
}
  • 控制层

private StudentService service = new StudentServiceImpl();
/*
    查询所有学生信息
*/
@Test
public void findAll() {
    ArrayList<Student> list = service.findAll();
    for(Student stu : list) {
        System.out.println(stu);
    }
}

3. 需求二:条件查询(根据id查询学生信息)

  • 持久层

/*
    条件查询,根据id查询学生信息
*/
@Override
public Student findById(Integer id) {
    Student stu = new Student();
    Connection con = null;
    Statement stat = null;
    ResultSet rs = null;
    try{
        //1.注册驱动
        Class.forName("com.mysql.jdbc.Driver");

        //2.获取数据库连接
        con = DriverManager.getConnection("jdbc:mysql://192.168.59.129:3306/db14", "root", "itheima");

        //3.获取执行者对象
        stat = con.createStatement();

        //4.执行sql语句,并且接收返回的结果集
        String sql = "SELECT * FROM student WHERE sid=‘"+id+"‘";
        // 引引加加
         String sql = "SELECT * FROM student WHERE sid=‘"+id+"‘";
        // SELECT * FROM student WHERE sid=‘1‘
        String sql = "SELECT * FROM student WHERE sid=‘"+id+"‘";
        
         String sql = "SELECT * FROM student WHERE sid=" +id;
        rs = stat.executeQuery(sql);

        //5.处理结果集
        while(rs.next()) {
            Integer sid = rs.getInt("sid");
            String name = rs.getString("name");
            Integer age = rs.getInt("age");
            Date birthday = rs.getDate("birthday");

            //封装Student对象
            stu.setSid(sid);
            stu.setName(name);
            stu.setAge(age);
            stu.setBirthday(birthday);
        }

    } catch(Exception e) {
        e.printStackTrace();
    } finally {
        //6.释放资源
        if(con != null) {
            try {
                con.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if(stat != null) {
            try {
                stat.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if(rs != null) {
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
    //将对象返回
    return stu;
}
  • 业务层

/*
    条件查询,根据id查询学生信息
*/
@Override
public Student findById(Integer id) {
    return dao.findById(id);
}
  • 控制层

/*
    条件查询,根据id查询学生信息
*/
@Test
public void findById() {
    Student stu = service.findById(3);
    System.out.println(stu);
}

4. 需求三:新增数据 (添加学生)

  • 持久层

/*
      添加学生信息
*/
@Override
public int insert(Student stu) {
    Connection con = null;
    Statement stat = null;
    int result = 0;
    try{
        //1.注册驱动
        Class.forName("com.mysql.jdbc.Driver");

        //2.获取数据库连接
        con = DriverManager.getConnection("jdbc:mysql://192.168.59.129:3306/db14", "root", "itheima");

        //3.获取执行者对象
        stat = con.createStatement();

        //4.执行sql语句,并且接收返回的结果集
        Date d = stu.getBirthday();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
        String birthday = sdf.format(d);
        // 字符串与多个变量进行拼接,将写死的内容 替换为  "+变量+"
        String sql = "INSERT INTO student VALUES (‘"+stu.getSid()+"‘,‘"+stu.getName()+"‘,‘"+stu.getAge()+"‘,‘"+birthday+"‘)";
        result = stat.executeUpdate(sql);

    } catch(Exception e) {
        e.printStackTrace();
    } finally {
        //6.释放资源
        if(con != null) {
            try {
                con.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if(stat != null) {
            try {
                stat.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
    //将结果返回
    return result;
}
  • 业务层

/*
    新增学生信息
*/
@Override
public int insert(Student stu) {
    return dao.insert(stu);
}
  • 控制层

/*
  	新增学生信息
*/
@Test
public void insert() {
    Student stu = new Student(5,"周七",27,new Date());
    int result = service.insert(stu);
    if(result != 0) {
        System.out.println("新增成功");
    }else {
        System.out.println("新增失败");
    }
}

5. 需求四:修改数据(修改学生信息)

  • 持久层

/*
    修改学生信息
*/
@Override
public int update(Student stu) {
    Connection con = null;
    Statement stat = null;
    int result = 0;
    try{
        //1.注册驱动
        Class.forName("com.mysql.jdbc.Driver");

        //2.获取数据库连接
        con = DriverManager.getConnection("jdbc:mysql://192.168.59.129:3306/db14", "root", "itheima");

        //3.获取执行者对象
        stat = con.createStatement();

        //4.执行sql语句,并且接收返回的结果集
        Date d = stu.getBirthday();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
        String birthday = sdf.format(d);
        String sql = "UPDATE student SET sid=‘"+stu.getSid()+"‘,name=‘"+stu.getName()+"‘,age=‘"+stu.getAge()+"‘,birthday=‘"+birthday+"‘ WHERE sid=‘"+stu.getSid()+"‘";
        result = stat.executeUpdate(sql);

    } catch(Exception e) {
        e.printStackTrace();
    } finally {
        //6.释放资源
        if(con != null) {
            try {
                con.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if(stat != null) {
            try {
                stat.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
    //将结果返回
    return result;
}
  • 业务层

/*
    修改学生信息
*/
@Override
public int update(Student stu) {
    return dao.update(stu);
}
  • 控制层

/*
    修改学生信息
*/
@Test
public void update() {
    Student stu = service.findById(5);
    stu.setName("周七七");

    int result = service.update(stu);
    if(result != 0) {
        System.out.println("修改成功");
    }else {
        System.out.println("修改失败");
    }
}

6. 需求五:删除数据(删除学生)

  • 持久层

/*
    删除学生信息
*/
@Override
public int delete(Integer id) {
    Connection con = null;
    Statement stat = null;
    int result = 0;
    try{
        //1.注册驱动
        Class.forName("com.mysql.jdbc.Driver");

        //2.获取数据库连接
        con = DriverManager.getConnection("jdbc:mysql://192.168.59.129:3306/db14", "root", "itheima");

        //3.获取执行者对象
        stat = con.createStatement();

        //4.执行sql语句,并且接收返回的结果集
        String sql = "DELETE FROM student WHERE sid=‘"+id+"‘";
        result = stat.executeUpdate(sql);

    } catch(Exception e) {
        e.printStackTrace();
    } finally {
        //6.释放资源
        if(con != null) {
            try {
                con.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if(stat != null) {
            try {
                stat.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
    //将结果返回
    return result;
}
  • 业务层

/*
    删除学生信息
*/
@Override
public int delete(Integer id) {
    return dao.delete(id);
}
  • 控制层

/*
    删除学生信息
*/
@Test
public void delete() {
    int result = service.delete(5);

    if(result != 0) {
        System.out.println("删除成功");
    }else {
        System.out.println("删除失败");
    }
}

四、JDBC工具类

  • 为啥需要工具类呢?

  • 因为在上个案例中的dao层的代码,很多都是重复的

  • 程序员一但碰到重复代码,就要想办法解决

1.工具类的抽取 ***

  • 配置文件(在src下创建config.properties)

driverClass=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/db14
username=root
password=itheima
  • 工具类:com.itheima02.utils.JDBCUtils

package com.itheima02.utils;

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

/*
    JDBC工具类
 */
public class JDBCUtils {
    //1.私有构造方法
    private JDBCUtils(){};

    //2.声明配置信息变量
    private static String driverClass;
    private static String url;
    private static String username;
    private static String password;
    private static Connection con;

    //3.静态代码块中实现加载配置文件和注册驱动
    static{
        try{
            //通过类加载器返回配置文件的字节流
            InputStream is = JDBCUtils.class.getClassLoader().getResourceAsStream("config.properties");

            //创建Properties集合,加载流对象的信息
            Properties prop = new Properties();
            prop.load(is);

            //获取信息为变量赋值
            driverClass = prop.getProperty("driverClass");
            url = prop.getProperty("url");
            username = prop.getProperty("username");
            password = prop.getProperty("password");

            //注册驱动
            Class.forName(driverClass);

        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    //4.获取数据库连接的方法
    public static Connection getConnection() {
        try {
            con = DriverManager.getConnection(url,username,password);
        } catch (SQLException e) {
            e.printStackTrace();
        }

        return con;
    }

    //5.释放资源的方法
    public static void close(Connection con, Statement stat, ResultSet rs) {
        if(con != null) {
            try {
                con.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if(stat != null) {
            try {
                stat.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        if(rs != null) {
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    public static void close(Connection con, Statement stat) {
        close(con,stat,null);
    }
}

2.使用工具类优化student表的CRUD

  • 查询全部:修改StudentDaoImpl 中的方法

/*
    查询所有学生信息
*/
@Override
public ArrayList<Student> findAll() {
    ArrayList<Student> list = new ArrayList<>();
    Connection con = null;
    Statement stat = null;
    ResultSet rs = null;
    try{

        con = JDBCUtils.getConnection();

        //3.获取执行者对象
        stat = con.createStatement();

        //4.执行sql语句,并且接收返回的结果集
        String sql = "SELECT * FROM student";
        rs = stat.executeQuery(sql);

        //5.处理结果集
        while(rs.next()) {
            Integer sid = rs.getInt("sid");
            String name = rs.getString("name");
            Integer age = rs.getInt("age");
            Date birthday = rs.getDate("birthday");

            //封装Student对象
            Student stu = new Student(sid,name,age,birthday);

            //将student对象保存到集合中
            list.add(stu);
        }

    } catch(Exception e) {
        e.printStackTrace();
    } finally {
        //6.释放资源
        JDBCUtils.close(con,stat,rs);
    }
    //将集合对象返回
    return list;
}
  • 条件查询

/*
    条件查询,根据id查询学生信息
*/
@Override
public Student findById(Integer id) {
    Student stu = new Student();
    Connection con = null;
    Statement stat = null;
    ResultSet rs = null;
    try{

        con = JDBCUtils.getConnection();

        //3.获取执行者对象
        stat = con.createStatement();

        //4.执行sql语句,并且接收返回的结果集
        String sql = "SELECT * FROM student WHERE sid=‘"+id+"‘";
        rs = stat.executeQuery(sql);

        //5.处理结果集
        while(rs.next()) {
            Integer sid = rs.getInt("sid");
            String name = rs.getString("name");
            Integer age = rs.getInt("age");
            Date birthday = rs.getDate("birthday");

            //封装Student对象
            stu.setSid(sid);
            stu.setName(name);
            stu.setAge(age);
            stu.setBirthday(birthday);
        }

    } catch(Exception e) {
        e.printStackTrace();
    } finally {
        //6.释放资源
        JDBCUtils.close(con,stat,rs);
    }
    //将对象返回
    return stu;
}
  • 新增数据

/*
     添加学生信息
*/
@Override
public int insert(Student stu) {
    Connection con = null;
    Statement stat = null;
    int result = 0;
    try{
        con = JDBCUtils.getConnection();

        //3.获取执行者对象
        stat = con.createStatement();

        //4.执行sql语句,并且接收返回的结果集
        Date d = stu.getBirthday();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
        String birthday = sdf.format(d);
        String sql = "INSERT INTO student VALUES (‘"+stu.getSid()+"‘,‘"+stu.getName()+"‘,‘"+stu.getAge()+"‘,‘"+birthday+"‘)";
        result = stat.executeUpdate(sql);

    } catch(Exception e) {
        e.printStackTrace();
    } finally {
        //6.释放资源
        JDBCUtils.close(con,stat);
    }
    //将结果返回
    return result;
}
  • 修改数据

/*
     修改学生信息
*/
@Override
public int update(Student stu) {
    Connection con = null;
    Statement stat = null;
    int result = 0;
    try{
        con = JDBCUtils.getConnection();

        //3.获取执行者对象
        stat = con.createStatement();

        //4.执行sql语句,并且接收返回的结果集
        Date d = stu.getBirthday();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
        String birthday = sdf.format(d);
        String sql = "UPDATE student SET sid=‘"+stu.getSid()+"‘,name=‘"+stu.getName()+"‘,age=‘"+stu.getAge()+"‘,birthday=‘"+birthday+"‘ WHERE sid=‘"+stu.getSid()+"‘";
        result = stat.executeUpdate(sql);

    } catch(Exception e) {
        e.printStackTrace();
    } finally {
        //6.释放资源
        JDBCUtils.close(con,stat);
    }
    //将结果返回
    return result;
}
  • 删除数据

/*
   删除学生信息
*/
@Override
public int delete(Integer id) {
    Connection con = null;
    Statement stat = null;
    int result = 0;
    try{
        con = JDBCUtils.getConnection();

        //3.获取执行者对象
        stat = con.createStatement();

        //4.执行sql语句,并且接收返回的结果集
        String sql = "DELETE FROM student WHERE sid=‘"+id+"‘";
        result = stat.executeUpdate(sql);

    } catch(Exception e) {
        e.printStackTrace();
    } finally {
        //6.释放资源
        JDBCUtils.close(con,stat);
    }
    //将结果返回
    return result;
}

3.student表的CRUD整合页面

  • 接下来我们将程序与界面结合起来

  • 用户表的数据准备

-- 创建用户表
CREATE TABLE USER(
	uid VARCHAR(50) PRIMARY KEY,	-- 用户id
	ucode VARCHAR(50),				-- 用户标识
	loginname VARCHAR(100),			-- 登录用户名
	PASSWORD VARCHAR(100),			-- 登录密码
	username VARCHAR(100),			-- 用户名
	gender VARCHAR(10),				-- 用户性别
	birthday DATE,					-- 出生日期
	dutydate DATE                   -- 入职日期
);

-- 添加一条测试数据
INSERT INTO `user` VALUES (‘11111111‘, ‘zhangsan001‘, ‘zhangsan‘, ‘1234‘, ‘张三‘, ‘男‘, ‘2008-10-28‘, ‘2018-10-28‘);
  • 今天资料中有一个准备好的项目:JDBC基础网页版

  • 将上个案例的StudentDaoImpl复制到这个案例中,需要修改insert方法中的id为null,因为id是自增的

  • 或者直接复制如下代码:

public class StudentDaoImpl implements StudentDao {

    /*
        查询所有学生信息
     */
    @Override
    public ArrayList<Student> findAll() {
        Connection con = null;
        Statement stat = null;
        ResultSet rs = null;
        ArrayList<Student> list = new ArrayList<>();
        try {
            //1.获取连接
            con = JDBCUtils.getConnection();

            //2.获取执行者对象
            stat = con.createStatement();

            //3.执行sql语句,并接收结果
            String sql = "SELECT * FROM student";
            rs = stat.executeQuery(sql);

            //4.处理结果,将每条记录封装成一个Student对象。将多个Student对象保存到集合中
            while(rs.next()) {
                Integer sid = rs.getInt("sid");
                String name = rs.getString("name");
                Integer age = rs.getInt("age");
                Date birthday = rs.getDate("birthday");

                Student stu = new Student(sid,name,age,birthday);

                list.add(stu);
            }

        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            //5.释放资源
            JDBCUtils.close(con,stat,rs);
        }

        return list;
    }

    /*
        条件查询,根据id查询学生信息
     */
    @Override
    public Student findById(Integer id) {
        Connection con = null;
        Statement stat = null;
        ResultSet rs = null;
        Student stu = new Student();
        try {
            //1.获取连接
            con = JDBCUtils.getConnection();

            //2.获取执行者对象
            stat = con.createStatement();

            //3.执行sql语句,并接收结果
            String sql = "SELECT * FROM student WHERE sid=‘"+id+"‘";
            rs = stat.executeQuery(sql);

            //4.处理结果,将记录封装成一个Student对象。
            if(rs.next()) {
                Integer sid = rs.getInt("sid");
                String name = rs.getString("name");
                Integer age = rs.getInt("age");
                Date birthday = rs.getDate("birthday");

                stu.setSid(sid);
                stu.setName(name);
                stu.setAge(age);
                stu.setBirthday(birthday);
            }

        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            //5.释放资源
            JDBCUtils.close(con,stat,rs);
        }

        return stu;
    }

    /*
        新增学生信息
     */
    @Override
    public int insert(Student stu) {
        Connection con = null;
        Statement stat = null;
        int result = 0;
        try{
            //1.获取连接
            con = JDBCUtils.getConnection();

            //2.获取执行者对象
            stat = con.createStatement();

            //3.执行sql语句,并接收结果
            Date date = stu.getBirthday();
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
            String birthday = sdf.format(date);
            String sql = "INSERT INTO student VALUES (null,‘"+stu.getName()+"‘,‘"+stu.getAge()+"‘,‘"+birthday+"‘)";
            result = stat.executeUpdate(sql);

        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            //4.释放资源
            JDBCUtils.close(con,stat);
        }

        return result;
    }

    /*
        修改学生信息
     */
    @Override
    public int update(Student stu) {
        Connection con = null;
        Statement stat = null;
        int result = 0;
        try{
            //1.获取连接
            con = JDBCUtils.getConnection();

            //2.获取执行者对象
            stat = con.createStatement();

            //3.执行sql语句,并接收结果
            Date date = stu.getBirthday();
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
            String birthday = sdf.format(date);
            String sql = "UPDATE student SET sid=‘"+stu.getSid()+"‘,name=‘"+stu.getName()+"‘,age=‘"+stu.getAge()+"‘,birthday=‘"+birthday+"‘ WHERE sid=‘"+stu.getSid()+"‘";
            result = stat.executeUpdate(sql);

        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            //4.释放资源
            JDBCUtils.close(con,stat);
        }

        return result;
    }

    /*
        删除学生信息
     */
    @Override
    public int delete(Integer id) {
        Connection con = null;
        Statement stat = null;
        int result = 0;
        try{
            //1.获取连接
            con = JDBCUtils.getConnection();

            //2.获取执行者对象
            stat = con.createStatement();

            //3.执行sql语句,并接收结果
            String sql = "DELETE FROM student WHERE sid=‘"+id+"‘";
            result = stat.executeUpdate(sql);

        } catch (SQLException e) {
            e.printStackTrace();
        }  finally {
            //4.释放资源
            JDBCUtils.close(con,stat);
        }

        return result;
    }
}
  • 测试:用户名zhangsan,密码1234

    JDBC基础:JDBC快速入门,JDBC工具类,SQL注入攻击,JDBC管理事务

     

     

  • 找到学生管理

    JDBC基础:JDBC快速入门,JDBC工具类,SQL注入攻击,JDBC管理事务

     

     

  • 然后可以添加,修改,删除

  • 那至于,界面和相关Servlet代码,咱们先不用管,后边会有类似的案例

五、SQL注入攻击

1.sql注入攻击的演示 ***

  • sql注入攻击:就是利用sql语句的漏洞来对系统进行攻击

  • 演示:

    • 在登录界面,输入一个错误的用户名或密码,也可以登录成功

JDBC基础:JDBC快速入门,JDBC工具类,SQL注入攻击,JDBC管理事务

 

 

  • 分析:为啥能够登陆成功?

    • 登陆的时候,会调用UserDaoImpl .findByLoginNameAndPassword 方法

    • 此方法中的sql语句如下

    //2.定义SQL语句
    String sql = "SELECT * FROM user WHERE loginname=‘"+loginName+"‘ AND password=‘"+password+"‘";
    System.out.println(sql);
    //3.获取操作对象,执行sql语句,获取结果集
    st = conn.createStatement();
    rs = st.executeQuery(sql);
    //4.获取结果集
    if (rs.next()) {
        //5.封装
        user = new User();
        user.setUid(rs.getString("uid"));
        ....
    }
    //6.返回
    return user;
    • 输入aaa和aaa‘ or ‘1‘=‘1 (注意引号)最终sql拼接完变为:

      SELECT * FROM user WHERE loginname=‘aaa‘ AND password=‘aaa‘ or ‘1‘=‘1‘
    • 这样的sql语句,会将user表中所有数据都查询出来(当然我们目前user中只有zhangsan一条数据)

    • 所以最终查询到用户了,就登陆进去了

2.sql注入攻击的原理

  • 按照正常道理来说,我们在密码处输入的所有内容,都应该认为是密码的组成

  • 但是现在Statement对象在执行sql语句时,将一部分内容当做查询条件来执行了

3.PreparedStatement的介绍

  • 预编译sql语句的执行者对象。在执行sql语句之前,将sql语句进行提前编译

  • 明确sql语句的格式后,就不会改变了。剩余的内容都会认为是参数

  • 参数使用?作为占位符

  • 为参数赋值的方法:setXxx(参数1,参数2);

    • 参数1:?的位置编号(编号从1开始)

    • 参数2:?的实际参数

  • 执行sql语句的方法

    • 执行insert、update、delete语句:int executeUpdate();

    • 执行select语句:ResultSet executeQuery();

4.PreparedStatement的使用 ***

/*
	 使用PreparedStatement的登录方法,解决注入攻击
*/
@Override
public User findByLoginNameAndPassword(String loginName, String password) {
    //定义必要信息
    Connection conn = null;
    PreparedStatement pstm = null;
    ResultSet rs = null;
    User user = null;
    try {
        //1.获取连接
        conn = JDBCUtils.getConnection();
        //2.创建操作SQL对象
        String sql = "SELECT * FROM user WHERE loginname=? AND password=?";
        SELECT * FROM user WHERE loginname=‘aaa‘ AND password= "aaa‘ or ‘1‘ = ‘1"
        pstm = conn.prepareStatement(sql);
        //3.设置参数
        pstm.setString(1,loginName);//设置第一个?参数
        pstm.setString(2,password);//设置第二个?参数
        System.out.println(sql);
        //4.执行sql语句,获取结果集
        rs = pstm.executeQuery();
        //5.获取结果集
        if (rs.next()) {
            //6.封装
            user = new User();
            user.setUid(rs.getString("uid"));
            user.setUcode(rs.getString("ucode"));
            user.setUsername(rs.getString("username"));
            user.setPassword(rs.getString("password"));
            user.setGender(rs.getString("gender"));
            user.setDutydate(rs.getDate("dutydate"));
            user.setBirthday(rs.getDate("birthday"));
            user.setLoginname(rs.getString("loginname"));
        }
        //7.返回
        return user;
    }catch (Exception e){
        throw new RuntimeException(e);
    }finally {
        JDBCUtils.close(conn,pstm,rs);
    }
}

5.使用PreparedStatement优化student表的CRUD(作业)

public class StudentDaoImpl implements StudentDao {

    @Override
    public ArrayList<Student> findAll() {
        //定义必要信息
        Connection conn = null;
        PreparedStatement pstm = null;
        ResultSet rs = null;
        ArrayList<Student> students = null;
        try {
            //1.获取连接
            conn = JDBCUtils.getConnection();
            //2.获取操作对象
            pstm = conn.prepareStatement("select * from student");
            //3.执行sql语句,获取结果集
            rs = pstm.executeQuery();
            //4.遍历结果集
            students = new ArrayList<Student>();
            while (rs.next()) {
                //5.封装
                Student student = new Student();
                student.setSid(rs.getInt("sid"));
                student.setName(rs.getString("name"));
                student.setAge(rs.getInt("age"));
                student.setBirthday(rs.getDate("birthday"));
                //加入到集合中
                students.add(student);
            }
            //6.返回
            return students;
        }catch (Exception e){
            throw new RuntimeException(e);
        }finally {
            JDBCUtils.close(conn,pstm,rs);
        }
    }

    @Override
    public Student findById(Integer sid) {
        //定义必要信息
        Connection conn = null;
        PreparedStatement pstm = null;
        ResultSet rs = null;
        Student student = null;
        try {
            //1.获取连接
            conn = JDBCUtils.getConnection();
            //2.获取操作对象
            pstm = conn.prepareStatement("select * from student where sid = ? ");
            pstm.setInt(1,sid);
            //3.执行sql语句,获取结果集
            rs = pstm.executeQuery();
            //4.遍历结果集
            if (rs.next()) {
                //5.封装
                student = new Student();
                student.setSid(rs.getInt("sid"));
                student.setName(rs.getString("name"));
                student.setAge(rs.getInt("age"));
                student.setBirthday(rs.getDate("birthday"));
            }
            //6.返回
            return student;
        }catch (Exception e){
            throw new RuntimeException(e);
        }finally {
            JDBCUtils.close(conn,pstm,rs);
        }
    }

    @Override
    public int insert(Student student) {
        //定义必要信息
        Connection conn = null;
        PreparedStatement pstm = null;
        int result = 0;
        try {
            //1.获取连接
            conn = JDBCUtils.getConnection();
            //2.获取操作对象
            pstm = conn.prepareStatement("insert into student(sid,name,age,birthday)values(null,?,?,?)");
            //3.设置参数
            //pstm.setInt(1,null);
            pstm.setString(1,student.getName());
            pstm.setInt(2,student.getAge());
            pstm.setDate(3,new Date(student.getBirthday().getTime()));
            //4.执行sql语句
            result = pstm.executeUpdate();
        }catch (Exception e){
            throw new RuntimeException(e);
        }finally {
            JDBCUtils.close(conn,pstm);
        }
        return result;
    }

    @Override
    public int update(Student student) {
        //定义必要信息
        Connection conn = null;
        PreparedStatement pstm = null;
        int result = 0;
        try {
            //1.获取连接
            conn = JDBCUtils.getConnection();
            //2.获取操作对象
            pstm = conn.prepareStatement("update student set name=?,age=?,birthday=? where sid=? ");
            //3.设置参数
            pstm.setString(1,student.getName());
            pstm.setInt(2,student.getAge());
            pstm.setDate(3,new Date(student.getBirthday().getTime()));
            pstm.setInt(4,student.getSid());
            //4.执行sql语句
            result = pstm.executeUpdate();
        }catch (Exception e){
            throw new RuntimeException(e);
        }finally {
            JDBCUtils.close(conn,pstm);
        }
        return result;
    }

    @Override
    public int delete(Integer sid) {
        //定义必要信息
        Connection conn = null;
        PreparedStatement pstm = null;
        int result = 0;
        try {
            //1.获取连接
            conn = JDBCUtils.getConnection();
            //2.获取操作对象
            pstm = conn.prepareStatement("delete from student where sid=? ");
            //3.设置参数
            pstm.setInt(1,sid);
            //4.执行sql语句
            result = pstm.executeUpdate();
        }catch (Exception e){
            throw new RuntimeException(e);
        }finally {
            JDBCUtils.close(conn,pstm);
        }
        return result;
    }
}

六、JDBC管理事务 ***

1. 介绍

  1. JDBC如何管理事务

  • 管理事务的功能类:Connection

  • 开启事务:setAutoCommit(boolean autoCommit); 参数为false,则开启手动提交事务。

    • 自动提交

    • true:自动提交

    • false:不是自动提交(手动提交,程序员可以控制事务提交或回滚)

  • 提交事务:commit();

  • 回滚事务:rollback();

  • JDBC基础:JDBC快速入门,JDBC工具类,SQL注入攻击,JDBC管理事务

     

     

2. 演示

  • 演示批量添加数据并在业务层管理事务

  • 注意:事务的管理需要在业务层实现,因为dao层的功能要给很多模块提供功能的支撑,而有些模块是不需要事务的。

  • 批量添加用户

    JDBC基础:JDBC快速入门,JDBC工具类,SQL注入攻击,JDBC管理事务

     

     

    JDBC基础:JDBC快速入门,JDBC工具类,SQL注入攻击,JDBC管理事务

     

     

  • 我们在这里可以批量添加三个用户

3. 具体操作

  • UserService 接口

/*
	 批量添加 : batch:一批,成批处理
*/
void batchAdd(List<User> users);
  • UserServiceImpl 实现类:事务需要在service添加

/*
      事务要控制在此处
*/
@Override
public void batchAdd(List<User> users) {
    //获取数据库连接
    Connection connection = JDBCUtils.getConnection();
    try {
        //开启事务
        connection.setAutoCommit(false);
        for (User user : users) {
            //1.创建ID,并把UUID中的-替换
            String uid = UUID.randomUUID().toString().replace("-", "").toUpperCase();
            //2.给user的uid赋值
            user.setUid(uid);
            //3.生成员工编号
            user.setUcode(uid);

            //模拟异常
            //int n = 1 / 0;

            //4.保存
            userDao.save(connection,user);
        }
        //提交事务
        connection.commit();
    }catch (Exception e){
        try {
            //回滚事务
            connection.rollback();
        }catch (Exception ex){
            ex.printStackTrace();
        }
        e.printStackTrace();
    }finally {
        JDBCUtils.close(connection,null,null);
    }
}
  • UserDao 接口

/**
	支持事务的添加
*/
void save(Connection connection,User user);
  • UserDaoImpl 实现类

/*
       支持事务的添加
*/
@Override
public void save(Connection connection, User user) {
    //定义必要信息
    PreparedStatement pstm = null;
    try {
        //1.获取连接
        connection = JDBCUtils.getConnection();
        //2.获取操作对象
        pstm = connection.prepareStatement("insert into user(uid,ucode,loginname,password,username,gender,birthday,dutydate)values(?,?,?,?,?,?,?,?)");
        //3.设置参数
        pstm.setString(1,user.getUid());
        pstm.setString(2,user.getUcode());
        pstm.setString(3,user.getLoginname());
        pstm.setString(4,user.getPassword());
        pstm.setString(5,user.getUsername());
        pstm.setString(6,user.getGender());
        pstm.setDate(7,new Date(user.getBirthday().getTime()));
        pstm.setDate(8,new Date(user.getDutydate().getTime()));
        //4.执行sql语句,获取结果集
        pstm.executeUpdate();
    }catch (Exception e){
        throw new RuntimeException(e);
    }finally {
        JDBCUtils.close(null,pstm,null);
    }
}

 

JDBC基础:JDBC快速入门,JDBC工具类,SQL注入攻击,JDBC管理事务

上一篇:Mysql-9 视图


下一篇:MySQL 多个表的 连接