1 JDBC概述

image.png

2 JDBC快读入门

image.png

编写步骤：

  1. 注册驱动 - 加载Driver类
  2. 获取连接 - 得到Connection (与数据库的连接)
  3. 执行增删改查 - 发送SQL命令给mysql执行 （执行操作和返回结果）

  4. 释放资源 - 关闭相关连接

    3 课堂练习

    image.png

    1. -- 创建测试演员表
    2. CREATE TABLE actor(
    3.  id INT PRIMARY KEY AUTO_INCREMENT,
    4.  `name` VARCHAR(32) NOT NULL DEFAULT '',
    5.  gender CHAR(1) NOT NULL DEFAULT '女',
    6.  birthday DATETIME,
    7.  cellphone VARCHAR(11));

    4 加载jar包

    image.pngimage.png

    5 程序与mysql建立连接的原理图

    image.png

    步骤

  5. Driver 驱动

    • new
  6. Properties 用户和密码
    • new
    • property(“user”,”root”)
    • property(“password”,”123456”);
  7. Connection 连接
    • driver.connect(url,properties)
  8. Statament 执行Sql
    • createStatement()
    • executeUpdate(sql)

  9. 关闭连接和执行sql

    代码dml

    1. public static void main(String[] args) throws SQLException {
    2.  //1.注册驱动
    3.  Driver driver = new Driver();//创建driver对象
    5.  //2.得到连接
    6.  //1) jdbc:mysql:// 规定标准协议，通过JDBC的方式连接musql
    7.  //2) localhost 本机，或者IP地址
    8.  //3) 3306 表示mysql监听的端口
    9.  //4) hsp_db02 连接msyql的那个数据库
    10.  //5) mysql连接的本质就是socket连接
    12.  String url = "jdbc:mysql://localhost:3306/hsp_db02";
    13.  //将用户名和密码放入properties对象中
    14.  Properties properties = new Properties();
    16.  //说明：user和password是规定好的
    17.  properties.setProperty("user", "root");//用户
    18.  properties.setProperty("password", "crossfire395612");//密码
    20.  //Driver每个驱动必须实现的接口，根据给定的url连接数据库
    21.  //connect就是网络连接
    22.  Connection connect = driver.connect(url, properties);
    24.  //3.执行sql
    25.  String sql = "insert into actor values(1,'刘德华','男','1961-9-27','110')";
    26.  //statement:用于发送执行静态sql语句并返回结果的对象
    27.  Statement statement = connect.createStatement();
    28.  //executeUpdate执行sql语句，返回的结果代表受影响数据库的行数,等于0数据添加失败
    29.  int rows = statement.executeUpdate(sql);
    31.  System.out.println(rows > 0 ? "执行成功" : "执行失败");
    33.  //4.关闭连接资源
    34.  statement.close();
    35.  connect.close();
    36. }

    mysql更改密码

    1. mysqladmin -uroot -pcrossfire395612 password root

    6 连接数据库的五种方式

    image.png ```java public void connect01() throws SQLException { Driver driver = new Driver(); String url = “jdbc:mysql://localhost:3306/hsp_db02”; Properties info = new Properties(); info.setProperty(“user”,”root”); info.setProperty(“password”,”root”); Connection conn = driver.connect(url, info); System.out.println(conn);

}

  1. ![image.png](https://cdn.nlark.com/yuque/0/2021/png/12555714/1621422202387-8474ce93-80ba-4768-84c1-f8add722bc7b.png#clientId=uaa5f3b42-f7d1-4&from=paste&height=590&id=uc33dd62d&name=image.png&originHeight=590&originWidth=1109&originalType=binary&size=484586&status=done&style=none&taskId=ucd6eca71-7e7e-4bd4-9c9c-ec5ed5d7365&width=1109)
  2. ```java
  3.  //方式二：使用反射加载Driver类
  4. public void connect02() throws Exception {
  5.     //使用反射加载Driver类.动态加载，更加灵活，减少依赖性
  6.     Class<?> aClass = Class.forName("com.mysql.jdbc.Driver");
  7.     Driver driver = (Driver)aClass.newInstance();
  9.     String url = "jdbc:mysql://localhost:3306/hsp_db02";
  10.     Properties pro = new Properties();
  11.     pro.setProperty("user","root");
  12.     pro.setProperty("password","root");
  14.     Connection conn = driver.connect(url, pro);
  15.     System.out.println(conn);
  16. }

image.png

DriverManager优势

DriverManager-用户管理JDBC驱动的基本服务
getConnection( ) : 连接数据库
registerDriver() ：注册给定的驱动程序DriverManager

  1.  //方式三：使用DriverManager替换Driver进行统一管理
  2. public void connect03() throws Exception {
  3.     //使用反射加载Driver
  4.     Class<?> aClass = Class.forName("com.mysql.jdbc.Driver");
  5.     Driver driver = (Driver)aClass.newInstance();
  7.     String url = "jdbc:mysql://localhost:3306/hsp_db02";
  8.     String user = "root";
  9.     String password = "root";
  11.     DriverManager.registerDriver(driver);//注册Driver驱动
  12.     Connection conn = DriverManager.getConnection(url, user, password);
  14.     System.out.println(conn);
  15. }

image.png

底层原码分析—注册了Driver：

  1. 静态代码块，在类加载时，会执行一次
  2. 注册Driver的registerDriver在静态代码块已经完成

image.png

Class.forName()省略原因：

在jdk1.5之后，不需要显示调用Class.forName()注册驱动，因为jar(里面写好了)启动的时候自动调用了

  1. //方式四：使用Class.forName自动完成注册驱动，简化代码
  2. public void connect04() throws ClassNotFoundException, SQLException {
  3.     //使用反射加载Driver类
  4.     //在加载Driver类时，完成注册
  5.     /*
  6.         底层分析：
  7.         1.静态代码块，在类加载时，会执行一次
  8.         2.注册Driver的registerDriver在静态代码块中
  9.     */
  10.     Class.forName("com.mysql.jdbc.Driver");
  12.     String url = "jdbc:mysql://localhost:3306/hsp_db02";
  13.     String user = "root";
  14.     String password = "root";
  16.     Connection conn = DriverManager.getConnection(url, user, password);
  17.     System.out.println(conn);
  18. }

image.png

配置文件

  1. #properties配置文件
  2. user=root
  3. password=root
  4. url=jdbc:mysql://localhost:3306/hsp_db02
  5. driver=com.mysql.jdbc.Driver
  1.  //方式五：在方式4的基础上改进，增加配置文件，让连接mysql更加灵活
  2. public void connect05() throws IOException, ClassNotFoundException, SQLException {
  3.     //通过Properties对象获取配置文件信息
  4.     Properties properties = new Properties();
  5.     properties.load(new FileInputStream("src\\mysql.properties"));
  6.     //获取相关值
  7.     String user = properties.getProperty("user");
  8.     String password = properties.getProperty("password");
  9.     String driver = properties.getProperty("driver");
  10.     String url = properties.getProperty("url");
  12.     Class.forName(driver);//建议写上，驱动加载
  13.     Connection connection = DriverManager.getConnection(url, user, password);
  14.     System.out.println(connection);
  15. }

7 课堂练习

image.png

  1. CREATE TABLE news(
  2.     id INT PRIMARY KEY AUTO_INCREMENT,
  3.     title VARCHAR(255) NOT NULL DEFAULT '',
  4.     publish_time DATETIME,
  5.     content TEXT);
  1. public class JdbcTest {
  2.     public void connect05() throws Exception {
  3.         Properties pro = new Properties();
  4.         pro.load(new FileInputStream("src\\mysql.properties"));
  5.         String driver = pro.getProperty("driver");
  6.         String url = pro.getProperty("url");
  7.         String user = pro.getProperty("user");
  8.         String password = pro.getProperty("password");
  10.         //1.加载驱动
  11.         Class.forName(driver);
  13.         //2.获取连接
  14.         Connection conn = DriverManager.getConnection(url, user, password);
  16.         //3.执行SQL
  17. //        String sql = "insert into news(title,publish_time,content) values('特朗普集团遭刑事调查','2021-05-16 16:50:20','据美国媒体报道，纽约总检察长办公室正与曼哈顿检察院合作，积极调查特朗普集团的刑事犯罪问题，但目前尚未对调查的具体细节透露更多信息。')";
  18. //        String sql = "update news set title='谷歌正式发布Android' where id=1";
  19.         String sql = "delete from news where id=3";
  20.         Statement state = conn.createStatement();
  22.         int rows = state.executeUpdate(sql);
  23.         System.out.println(rows > 0 ? "执行成功了" : "执行失败了");
  25.         //4.关闭连接资源
  26.         conn.close();
  27.         state.close();
  28.     }
  29. }

8 Result结果集

image.png
resultset数据库返回的结果集，通过SQL查询语句生成
resultset对象保持光标指向当前行，最开始光标位于第一行之前，next()将光标移动到下一行
如果resultset没有更多行时返回false,可以通过while循环来遍历结果集

课堂练习

image.png

  1. public static void main(String[] args) throws ClassNotFoundException, SQLException, IOException {
  3.     //通过Properties对象获取配置文件的信息
  5.     //1.加载驱动
  6.     Class.forName(driver);
  8.     //2.得到连接
  9.     Connection conn = DriverManager.getConnection(url, user, password);
  11.     //3.得到Statement
  12.     Statement state = conn.createStatement();
  14.     //4.组织sql
  15.     String sql = "select id,name,gender,birthday from actor";
  16.     //执行给定的SQL语句，改语句返回单个ResulSet对象
  17.     ResultSet resultSet = state.executeQuery(sql);
  19.     //5.循环取出数据
  20.     while(resultSet.next()){//让光标向后移动，如果没有更多行，返回false
  21.         int id = resultSet.getInt(1);//获取该行第一列数据
  22.         String name = resultSet.getString(2);
  23.         String gender = resultSet.getString(3);
  24.         Date birthday = resultSet.getDate(4);
  25.         System.out.println(id + "\t" + name + "\t" + gender + "\t" + birthday);
  26.     }
  28.     //6.关闭连接
  29.     resultSet.close();
  30.     state.close();
  31.     conn.close();
  32. }

Result结果集执行原理

image.png

9 SQL注入

image.png
image.png

  1. -- SQL注入 
  2. -- 输入用户名为 1' or
  3. -- 输入密码为 or '1'='1
  4. SELECT * FROM ADMIN 
  5.     WHERE NAME = '1' OR' AND pwd = 'OR '1'='1';
  7. -- NAME = '1'
  8. -- ' AND pwd = '
  9. -- '1'='1'  永远成立
  1. public static void main(String[] args) throws Exception {
  2.     Scanner scanner = new Scanner(System.in);
  4.     //让用户输入管理员名和密码
  5.     System.out.print("请输入管理员的名字:");
  6.     //next()：当接收空格或'就是表示结束
  8.     String admin_name = scanner.nextLine();
  9.     //nextLine():如果希望看到SQL注入，需要用nextLine,回车表示结束
  10.     System.out.print("请输入管理员的密码:");
  11.     String admin_pwd = scanner.nextLine();
  13.     //配置Propare省略
  15.     Class.forName(driver);
  16.     Connection conn = DriverManager.getConnection(url, user, password);
  17.     String sql = "select * from admin where name = '" + admin_name + "'and pwd='" + admin_pwd + "'";
  18.     Statement state = conn.createStatement();
  19.     ResultSet resultSet = state.executeQuery(sql);
  20.     if (resultSet.next()) {//如果查询到一条记录，则说明该管理员存在
  21.         System.out.println("恭喜登录成功");
  22.     }else {
  23.         System.out.println("恭喜登录失败");
  24.     }
  26.     state.close();
  27.     conn.close();
  28.     resultSet.close();
  29. }

10 预处理PrparedStatement

image.png

预处理好处

image.png
image.png

  1. public static void main(String[] args) throws Exception{
  3.         //用户输入管理员和密码
  4.         //Poppareties配置文件
  6.         //1.注册驱动
  7.         Class.forName(driver);
  8.         //2.得到连接
  9.         Connection connection = DriverManager.getConnection(url, user, password);
  10.         //3.得到PreparedStatement
  11.         //3.1组织sql，sql的？相当于占位符
  12.         String sql = "select * from admin where name=? and pwd=?";
  13.         //3.2 PreparedStatement对象实现了PreparedStatement接口实现类的对象
  14.         PreparedStatement preparedStatement = connection.prepareStatement(sql);
  15.         //3.3给 ? 赋值
  16.         preparedStatement.setString(1,admin_name);
  17.         preparedStatement.setString(2,admin_pwd);
  19.         //4. 执行SQL语句
  20.         //  如果执行的是dml(update,insert,delete) executeUpdate()
  21.         //  这里执行excuteQuery，不要在写sql
  22.         ResultSet resultSet = preparedStatement.executeQuery();
  23.         if(resultSet.next()){
  24.             System.out.println("恭喜你，登录成功");
  25.         }else {
  26.             System.out.println("很遗憾，登录失败");
  27.         }
  29.         preparedStatement.close();
  30.         resultSet.close();
  31.         connection.close();
  32. }

预处理dml

  1. public static void main(String[] args) throws Exception{
  3.     //用户输入管理员和密码
  4.     //Poppareties配置文件
  5.     //3.得到PreparedStatement
  6.     //3.1组织sql，sql的？相当于占位符
  7.     //添加记录
  8.     //String sql = "insert into admin values(?,?)";
  9.     //String sql = "update admin set pwd=? where name=?";
  10.     String sql = "delete from admin where name=?";
  12.     //3.2 PreparedStatement对象实现了PreparedStatement接口实现类的对象
  13.     PreparedStatement preparedStatement = connection.prepareStatement(sql);
  14.     //3.3给 ? 赋值
  15.     //4. 执行dml语句使用executeUpdate
  16.     int rows = preparedStatement.executeUpdate();
  17.     System.out.println(rows > 0 ? "执行成功" : "执行失败");
  18.     //关闭连接资源
  19. }

练习

image.png

作业

DML

  1. //insert
  2. String sql = "insert into admin values(?,?)";
  3. PreparedStatement pre = conn.prepareStatement(sql);
  4. pre.setString(1,admin_name);
  5. pre.setString(2,admin_pwd);
  6. int rows = pre.executeUpdate();
  8. System.out.println(rows > 0 ? "执行成功" : "执行失败");
  10. //delect
  11. String sql = "delete from admin where name=?";
  12. PreparedStatement pre = conn.prepareStatement(sql);
  13. pre.setString(1,admin_name);
  14. int rows = pre.executeUpdate();
  16. System.out.println(rows > 0 ? "执行成功" : "执行失败");
  18. //update
  19. String sql = "update admin set name=? where name=?";
  20. PreparedStatement pre = conn.prepareStatement(sql);
  21. pre.setString(1,admin_newName);
  22. pre.setString(2,admin_name);
  23. int rows = pre.executeUpdate();
  25. System.out.println(rows > 0 ? "执行成功" : "执行失败");

select

  1. String sql = "select * from admin";
  2. PreparedStatement pre = conn.prepareStatement(sql);
  3. ResultSet resultSet = pre.executeQuery();
  5. while(resultSet.next()){
  6.     String name = resultSet.getString(1);
  7.     String pwd = resultSet.getString(2);
  8.     System.out.println(name + "\t" + pwd);
  9. }

11 总结方式五操作mysql过程

  1. DriverManger 驱动管理类
  • 操作DriverManger的getConnetion(url,user,password)—>得到connection对象
  1. Connection接口
  • 操作connection对象的crateStatement() —>生成statementd对象
  • 操作connection对象的preparedStatement(sql) —>生成preparedstatement对象（预编译对象）

image.png

12 获取配置信息

  1. load()
  • load(new FileInputStream(配置文件路径))

  • 配置文件为properties

    2. getProperties()

  • getProperties(“user”)——>返回对应信息

image.png

13 封装JDBCUtils(获取连接和关闭连接)

说明：

在jdbc操作种，获取连接和释放资源是经常使用到的操作，可以将其封装为工具类
JDBCUtils

JDBC封装工具类原理

image.png
image.png

代码实现

  1. public class JDBCUtils {
  2.     //定义相关属性（4个）
  3.     private static String user; //用户名
  4.     private static String password; //密码
  5.     private static String url; //连接数据库标准
  6.     private static String driver; //驱动名
  8.     //在static代码块去初始化，随类加载
  9.     static {
  10.         try {
  11.             Properties properties = new Properties();
  12.             properties.load(new FileInputStream("src\\mysql.properties"));
  13.             //读取相关属性值
  14.             user = properties.getProperty("user");
  15.             password = properties.getProperty("password");
  16.             url = properties.getProperty("url");
  17.             driver = properties.getProperty("driver");
  18.         } catch (IOException e) {
  19.             //在实际开发中，这样处理的优点：
  20.             //1.将编译时异常转成运行时异常抛出去
  21.             //2.调用者，可以选择捕获该异常，也可以默认处理该异常，比较方便
  22.             throw new RuntimeException(e);
  23.         }
  24.     }
  26.     //连接数据库，返回Connection
  27.     public static Connection getConnection(){
  28.         try {
  29.             return DriverManager.getConnection(url,user,password);
  30.         } catch (SQLException e) {
  31.             //1.将编译时异常转成运行时异常抛出去
  32.             //2.调用者，可以选择捕获该异常，也可以默认处理该异常，比较方便
  33.             throw new RuntimeException(e);
  34.         }
  35.     }
  37.     //关闭相关资源
  38.     //1.ResultSet 结果集
  39.     //2.Statement或者PreparedStatement
  40.     //3.Connection
  41.     //4.如果需要关闭资源，就传入对象，否则传入null
  42.     public static void close(ResultSet set, Statement statement, Connection connection){
  43.         //Statement是PreparedStatement的父接口，因此可以接收2个实现类
  44.         //判断是否为null
  45.         try {
  46.             if(set != null){
  47.                 set.close();
  48.             }
  49.             if(statement != null){
  50.                 statement.close();
  51.             }
  52.             if(connection != null){
  53.                 connection.close();
  54.             }
  55.         } catch (SQLException e) {
  56.             //1.将编译时异常转成运行时异常抛出去
  57.             //2.调用者，可以选择捕获该异常，也可以默认处理该异常，比较方便
  58.             throw new RuntimeException(e);
  59.         }
  60.     }
  61. }

总结代码：

编译异常变运行时异常的优点：

  1. 将编译时异常转成运行时异常抛出去

  2. 调用者，可以选择捕获该异常，也可以默认处理该异常，比较方便

    1.  throw new RuntimeException(e);

    调用父类就可以调用子类：

    关闭Statement或者PreparedStatement，只用父类Statement
    因为Statement是PreparedStatement的父接口，因此可以接收2个实现类

    工具类属性和方法都是静态

  • 因为是工具类要求方便，节省了创建对象
  • 方法和属性都是静态的，直接调用

  • 如果有些功能是必须项，可以写在静态代码块中，随类加载(调用者无需调用)

    调用工具类代码：

    1. public void testDML(){//insert,update,delete
    2.   //1.得到连接
    3.   Connection connection = null;
    5.   //2.组织一个sql
    6.   String sql = "update actor set name = ? where id = ?";
    7.   //测试delete 测试insert
    8.   PreparedStatement preparedStatement = null;
    10.   //3.创建PreparedStatement对象
    11.   try {
    12.       //因为连接有异常，捕获起来，如果出现异常下面可以看到出错信息
    13.       connection = JDBCUtils.getConnection();
    14.       preparedStatement = connection.prepareStatement(sql);
    15.       //给占位符赋值
    16.       preparedStatement.setString(1,"曹德旺");
    17.       preparedStatement.setInt(2,4);
    18.       //执行
    19.       preparedStatement.executeUpdate();//结果不一定要接收
    20.   } catch (SQLException e) {
    21.       e.printStackTrace();
    22.   } finally {
    23.       //关闭资源
    24.       JDBCUtils.close(null,preparedStatement,connection);
    25.   }
    26. }

    finnaly

  • 无论是否出现异常还是正常执行，finnaly一定会执行 ```java //执行sql,得到结果集 resultSet = preparedStatement.executeQuery(); //遍历该结果集 while(resultSet.next()){ int id = resultSet.getInt(“id”); String name = resultSet.getString(“name”); String gender = resultSet.getString(“gender”); String birthday = resultSet.getString(“birthday”); String cellphone = resultSet.getString(“cellphone”); System.out.println(id + “\t” +name + “\t” +gender + “\t”

    1.                  + birthday + "\t" + cellphone);

    }

```

疑问总结？？？？？？？？？？？

  • import java.sql.Date 只有日期，没有时间