MySQL:JDBC 详细内容

news/2024/5/19 1:46:25 标签: 数据库, mysql, JDBC, DBCP, C3P0

文章目录

  • Day 04:
  • 一、JDBC
  • 二、改进 JDBC 程序
    • 1. 思路
    • 2. 实践注意点
    • 3. 分析
    • 4. 结果
    • 5. 代码
  • 三、SQL 注入问题
  • 四、PreparedStatement 对象
    • 1. 实践注意点
    • 2. 分析(增、删、改、查)
    • 3. SQL 注入问题的解决
    • 4. 代码
  • 五、使用 IDEA 连接数据库
  • 六、JDBC 操作事务
    • 1. 步骤及注意点
    • 2. 代码实现
  • 七、数据库连接池
  • 注意:

Day 04:

JDBC_3">一、JDBC

1. 数据库驱动

驱动:驱动程序即添加到操作系统中的一小块代码,其中包含有关硬件设备的信息。有了此信息,计算机就可以与设备进行通信。驱动程序是硬件厂商根据操作系统编写的配置文件,可以说没有驱动程序,计算机中的硬件就无法工作。

种类:声卡驱动、显卡驱动、数据库驱动等。

注意:我们的程序会通过数据库驱动,来和数据库打交道,不同的数据库驱动由不同的厂商去做。

2. 概述

JDBC:Java数据库连接,Java Database Connectivity

定义:是 Java 语言中用来规范客户端程序如何来访问数据库应用程序接口,提供了诸如查询和更新数据库中数据的方法。

公司JDBC 是 Sun 公司提供的。

对于开发人员来说,我们只需要掌握 JDBC 接口的操作。

JDBC__26">3. 第一个 JDBC 程序

  • 准备工作:在 Navicat 中创建测试数据库 jdbcStudy
CREATE DATABASE `jdbcStudy` CHARACTER SET utf8 COLLATE utf8_general_ci;

USE `jdbcStudy`;

CREATE TABLE IF NOT EXISTS `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,'张三','123456','zs@sina.com','1980-12-04'),
(2,'李四','123456','lisi@sina.com','1981-12-04'),
(3,'王五','123456','wangwu@sina.com','1979-12-04');
  • 在 IDEA 中创建一个 Maven 项目(方便下一步导入依赖),删除 src 文件夹,建立子模块,在子项目的 main 中建立 java 以及 resources 文件夹,并标记功能。

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.16</version>
</dependency>

  • 创建 JdbcDemo01 类,编写 JDBC 程序
package com.Sun3285.jdbc;

import java.sql.*;

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

        // 2. url 和用户信息,用 ? 连接参数
        // useUnicode=true&characterEncoding=uft8&useSSL=true&serverTimezone=Asia/Shanghai  编码、字符集、使用安全的连接、时区
        String url = "jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&useSSL=true&serverTimezone=Asia/Shanghai";
        String username = "root";
        String password = "1142553864qq";

        // 3. 连接数据库,connection 代表数据库
        Connection connection = DriverManager.getConnection(url, username, password);

        // 4. 得到执行 SQL 的对象,即:statement 可以执行 SQL
        Statement statement = connection.createStatement();

        // 5. 编写要执行的 SQL
        String sql = "SELECT * FROM `users`;";

        // 6. 执行 SQL,得到的 resultSet 为结果集,封装了全部的查询出来的结果,链表的形式
        ResultSet resultSet = statement.executeQuery(sql);

        while (resultSet.next()) {
            System.out.println("id = " + resultSet.getObject("id"));
            System.out.println("name = " + resultSet.getObject("name"));
            System.out.println("password = " + resultSet.getObject("password"));
            System.out.println("email = " + resultSet.getObject("email"));
            System.out.println("birthday = " + resultSet.getObject("birthday"));
            System.out.println("=========================");
        }

        // 7. 释放连接
        resultSet.close();
        statement.close();
        connection.close();
    }
}

步骤总结(具体看代码中注释):

  1. 加载驱动;
  2. url 和用户信息;
  3. 连接数据库
  4. 得到执行 SQL 的对象;
  5. 编写要执行的 SQL;
  6. 执行 SQL;
  7. 释放连接。

JDBC__127">4. JDBC 中对象的解释

  • 第 2 步:在 url 中
String url = "协议://主机地址:端口号/数据库名?参数1&参数2&参数3&参数x";

String url = "jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&useSSL=true&serverTimezone=Asia/Shanghai";
// 协议:jdbc:mysql
// 主机地址:localhost
// 端口号:mysql 默认为 3306
// 数据库名:jdbcstudy
// 若干参数:useUnicode=true&characterEncoding=utf8&useSSL=true&serverTimezone=Asia/Shanghai 编码、字符集、使用安全的连接、时区
  • 第 3 步connection 对象代表数据库,可以设置数据库自动提交(setAutoCommit),事务提交(commit)、回滚(rollback)等;
  • 第 4 步statement 对象是执行类,可以执行 SQL;
  • 第 6 步statement 对象可以执行的方法,例如
statement.execute();        // 执行任何 SQL
statement.executeQuery();   // 执行查询操作,得到的 resultSet 为结果集,封装了全部的查询出来的结果,链表的形式
statement.executeUpdate();  // 执行更新、插入、删除操作,返回一个受影响的行数(int 类型)
  • 第 6 步查询操作得到resultSet结果集,封装了全部的查询出来的结果
    • 可以获得指定的数据类型:调用 getObjectgetStringgetInt 等方法;
    • 可以遍历:调用 next 方法,指针移动到下一个数据(先移动,再判断);
  • 第 7 步:释放资源必须做,先开后关。

JDBC__159">二、改进 JDBC 程序

通过提取工具类,来改进 JDBC 程序,之后只写 SQL 语句和输出即可。

1. 思路

  1. driverurlusername 以及 password 信息放到一个属性 properties 文件中存放
  2. 编写一个工具类 JdbcUtils 完成重复代码的封装
  3. 自定义的类只需调用工具类,以及写 SQL 语句即可。

2. 实践注意点

  1. 属性 properties 文件存放信息时,没有引号没有分号,如:driver=com.mysql.cj.jdbc.Driver
  2. 工具类完成重复代码的封装,可以把第 1、2、3、7 步放入这里;
  3. 工具类中,可以把读取属性文件和加载驱动,放入静态代码块中,当第一次用到本类时,执行唯一的一次;
  4. 工具类中,第 3 步(连接数据库)和第 7 步(释放连接)可以封装为静态方法;
  5. 总体步骤与之前步骤一样,只是提取了工具类,简化了代码

3. 分析

  • 工具类 JdbcUtils.java

  • 插入数据类 TestDemo01.java

4. 结果

5. 代码

  • 属性文件 db.properties
driver=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&useSSL=true&serverTimezone=Asia/Shanghai
username=root
password=1142553864qq
  • 工具类 JdbcUtils.java
package com.Sun3285.utils;

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

public class JdbcUtils {

    private static String driver = null;
    private static String url = null;
    private static String username = null;
    private static String password = null;

    static {
        try {
            // 通过反射获取类加载器,再转变为流
            InputStream is = JdbcUtils.class.getClassLoader().getResourceAsStream("db.properties");

            Properties properties = new Properties();
            properties.load(is);

            driver = (String) properties.get("driver");
            url = (String) properties.get("url");
            username = (String) properties.get("username");
            password = (String) properties.get("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 connection, Statement statement, ResultSet resultSet) {
        if (resultSet != null) {
            try {
                resultSet.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (statement != null) {
            try {
                statement.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (connection != null) {
            try {
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}
  • 插入/修改/删除/查询数据类 TestDemo.java
package com.Sun3285.jdbc;

import com.Sun3285.utils.JdbcUtils;

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

public class TestDemo {

    public static void main(String[] args) {

        Connection connection = null;
        Statement statement = null;
        ResultSet resultSet = null;
        try {
            connection = JdbcUtils.getConnection();
            statement = connection.createStatement();

            // 插入
            String sql1 = "INSERT INTO `users` (`id`, `name`, `password`, `email`, `birthday`) VALUES" +
                    "(4, '健康', '1375380', '1375380@qq.com', '1999-11-01'), " +
                    "(5, '快乐', '7894561', '7894561@qq.com', '1998-2-3');";
            int column1 = statement.executeUpdate(sql1);
            if (column1 > 0) {
                System.out.println("插入数据成功!");
            }
            
            // 修改
            String sql2 = "UPDATE `users` SET `password` = '753159' WHERE `id` = 2 OR `birthday` = '1979-12-4';";
            String sql3 = "UPDATE `users` SET `name` = '天天', `email` = '123abc@qq.com' WHERE `id` = 1;";
            int column2 = statement.executeUpdate(sql2);
            int column3 = statement.executeUpdate(sql3);
            if (column2 > 0 || column3 > 0) {
                System.out.println("修改数据成功!被修改的数据有 " + (column2 + column3) + " 条。");
            }
            
            // 删除
            String sql4 = "DELETE FROM `users` WHERE `name` = '李四';";
            int column4 = statement.executeUpdate(sql4);
            if (column4 > 0) {
                System.out.println("删除数据成功!被删除的数据有 " + column4 + " 条。");
            } else {
                System.out.println("没有删除数据。");
            }
            
            // 查询
            String sql5 = "SELECT `name` AS '姓名', `password` AS '密码', `birthday` AS '生日' FROM `users`;";
            resultSet = statement.executeQuery(sql5);
            System.out.println("查询到的信息如下:");
            while (resultSet.next()) {
                System.out.println("姓名:" + resultSet.getString("姓名"));
                System.out.println("密码:" + resultSet.getString("密码"));
                System.out.println("生日:" + resultSet.getString("生日"));
                System.out.println("================");
            }
            
            
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JdbcUtils.release(connection, statement, resultSet);
        }
    }
}

三、SQL 注入问题

百度百科

SQL 是操作数据库数据的结构化查询语言,网页的应用数据和后台数据库中的数据进行交互时会采用 SQL 。而 SQL 注入是将 Web 页面的原 URL、表单域或数据包输入的参数,修改拼接成 SQL 语句,传递给 Web 服务器,进而传给数据库服务器以执行数据库命令。

如果 Web 应用程序的开发人员对用户所输入的数据或 cookie 等内容不进行过滤或验证(即存在注入点)就直接传输给数据库,就可能导致拼接的 SQL 被执行,获取对数据库的信息以及提权,发生 SQL 注入攻击

举例:模拟用户的登录:输入用户名和密码,来进行登录。

注意

  • SQL 中 AND优先级高于 OR
  • 登录也可以写为:login("", "' OR '1=1");

运行结果

代码

package com.Sun3285.jdbc;

import com.Sun3285.utils.JdbcUtils;

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

public class SQLInjection {

    public static void main(String[] args) {

        // login("健康", "1375380");
        login("' OR '1=1", "' OR '1=1");
    }

    // 登录方法
    public static void login(String username, String password) {

        Connection connection = null;
        Statement statement = null;
        ResultSet resultSet = null;

        try {
            connection = JdbcUtils.getConnection();
            statement = connection.createStatement();

            String sql = "SELECT * FROM `users` WHERE `name` = '" + username + "' AND `password` = '" + password + "';";

            resultSet = statement.executeQuery(sql);
            if (resultSet.next()) {
                resultSet.previous();
                while (resultSet.next()) {
                    System.out.println("登录成功!");
                    System.out.println("姓名:" + resultSet.getString("name"));
                    System.out.println("密码:" + resultSet.getString("password"));
                    System.out.println("邮箱:" + resultSet.getString("email"));
                    System.out.println("生日:" + resultSet.getString("birthday"));
                    System.out.println("=========================");
                }
            } else {
                System.out.println("登录失败,用户名或密码错误!");
            }

        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JdbcUtils.release(connection, statement, resultSet);
        }
    }
}

四、PreparedStatement 对象

PreparedStatement 继承Statement 可以防止 SQL 注入,并且效率更好。防止 SQL 注入的本质:把传递进来的参数当作字符,假设其中存在转义字符,会直接忽略。例如,单引号 ' 会被直接转义,然后被直接忽略。

1. 实践注意点

  1. 与之前 JDBC 程序的步骤有所区别:在创建了数据库对象 connection 后,进行编写 SQL预编译传递参数执行
  2. 注意 PreparedStatementsetDate 方法,第二个参数java.sql.Date
  3. 在编写 SQL 时,使用 ? 占位符代替参数;
  4. 在传递参数时,不能重复给相同位置的参数赋值后执行,因为会覆盖上一次的值,可以先执行,再再次赋值;
  5. 在传递参数时,方法的第一个参数是占位符 ? 的位置(从 1 开始),第二个参数是要传入的值;
  6. 与之前 JDBC 程序不同,在调用 executeUpdateexecuteQuery 方法执行时,不传入 SQL,在预编译时已经传入了 SQL;
  7. 整体学习过程:一个简单的 JDBC 程序 --> 通过提取工具类进行改进,实现简化 --> 发现 SQL 注入问题,使用 PreparedStatement 对象防止 SQL 注入 --> 节省资源,使用数据库连接池。

2. 分析(增、删、改、查)

插入数据查询数据为例:

  • 插入数据

  • 查询数据

3. SQL 注入问题的解决

在原先基础上,将 Statement 对象替换PreparedStatement 对象。

运行结果

4. 代码

  • 插入/修改/删除/查询数据类 PreparedDemo.java
package com.Sun3285.jdbc;

import com.Sun3285.utils.JdbcUtils;

import java.sql.*;

public class PreparedDemo {

    public static void main(String[] args) {

        Connection con = null;
        PreparedStatement pst = null;
        ResultSet rs = null;

        try {
            con = JdbcUtils.getConnection();

            // 插入
            String sql1 = "INSERT INTO `users` (`id`, `name`, `password`, `email`, `birthday`) VALUES (?,?,?,?,?);";
            pst = con.prepareStatement(sql1);
            pst.setInt(1, 6);
            pst.setString(2, "李龙");
            pst.setString(3, "147258");
            pst.setString(4, "147258@qq.com");
            pst.setDate(5, Date.valueOf("1989-2-3"));
            int column1 = pst.executeUpdate();
            if (column1 > 0) {
                System.out.println("插入数据成功!共插入 " + column1 + " 条数据。");
            } else {
                System.out.println("没有插入数据!");
            }
            
            // 修改
            String sql2 = "UPDATE `users` SET `birthday` = ? WHERE `name` = ? OR `id` = ?;";
            pst = con.prepareStatement(sql2);
            pst.setDate(1, Date.valueOf("2007-9-1"));
            pst.setString(2, "天天");
            pst.setInt(3, 6);
            int column2 = pst.executeUpdate();
            if (column2 > 0) {
                System.out.println("修改数据成功!共修改 " + column2 + " 条数据。");
            } else {
                System.out.println("没有修改数据!");
            }

            // 删除
            String sql3 = "DELETE FROM `users` WHERE `email` = ?;";
            pst = con.prepareStatement(sql3);
            pst.setString(1, "147258@qq.com");
            int column3 = pst.executeUpdate();
            if (column3 > 0) {
                System.out.println("删除数据成功!共删除 " + column3 + " 条数据。");
            } else {
                System.out.println("没有删除数据!");
            }
            
            // 查询
            String sql4 = "SELECT `name` AS '姓名', `birthday` AS '生日' FROM `users` WHERE `id` > ? AND `password` = ?; ";
            pst = con.prepareStatement(sql4);
            pst.setInt(1, 3);
            pst.setString(2, "222222");
            rs = pst.executeQuery();
            if (rs.next()) {
                System.out.println("查询成功!结果为:");
                rs.previous();
                while (rs.next()) {
                    System.out.println("姓名:" + rs.getString("姓名"));
                    System.out.println("生日:" + rs.getString("生日"));
                    System.out.println("========================");
                }
            } else {
                System.out.println("没有查询到数据!");
            }

            
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JdbcUtils.release(con, pst, rs);
        }
    }
}
  • SQL 注入问题的解决
package com.Sun3285.jdbc;

import com.Sun3285.utils.JdbcUtils;

import java.sql.*;

public class SQLInjection2 {

    public static void main(String[] args) {

        // login("健康", "1375380");
        login("", "' OR '1=1");
    }

    // 登录方法
    public static void login(String username, String password) {

        Connection con = null;
        PreparedStatement pst = null;
        ResultSet rs = null;

        try {
            con = JdbcUtils.getConnection();

            String sql = "SELECT * FROM `users` WHERE `name` = ? AND `password` = ?;";

            pst = con.prepareStatement(sql);

            pst.setString(1, username);
            pst.setString(2, password);

            rs = pst.executeQuery();

            if (rs.next()) {
                rs.previous();
                while (rs.next()) {
                    System.out.println("登录成功!");
                    System.out.println("姓名:" + rs.getString("name"));
                    System.out.println("密码:" + rs.getString("password"));
                    System.out.println("邮箱:" + rs.getString("email"));
                    System.out.println("生日:" + rs.getString("birthday"));
                    System.out.println("=========================");
                }
            } else {
                System.out.println("登录失败,用户名或密码错误!");
            }

        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JdbcUtils.release(con, pst, rs);
        }
    }
}

五、使用 IDEA 连接数据库

Navicat 一样,IDEA 也可以连接数据库,来管理数据库

注意

  • 在这一步中,进行参数设置以及连接数据库
  • 在此之前需要加载数据库驱动,即在 pom.xml 配置文件中导入依赖(mysql 数据库驱动包)见 一、3;
  • 这里的 URL 需要和之前一致,可以不写数据库
  • 测试连接,成功后,选择 OK

注意:如果由于 MySQL 的版本或驱动不对,而出现错误,可以在这个地方修改(一般不要改)。


JDBC__663">六、JDBC 操作事务

之前已经学过用 SQL 语言实现一个事务(如下图),现在用 Java 来实现一个事务。

1. 步骤及注意点

JDBC 操作事务的步骤

  1. 关闭数据库自动提交(开启事务):con.setAutoCommit(false);
  2. 执行一组业务;
  3. 提交事务:con.commit()
  4. 可选择)可以在 catch 语句中显示地定义回滚语句:con.rollback();

注意点

  1. 每次在使用 JDBC 时,需要先检查属性文件 db.properties 中的各个参数,例如 url 中的数据库是否是要操作的数据库
  2. JDBC 操作事务时,关闭数据库自动提交的时候,会自动开启事务;
  3. 事务的回滚 con.rollback() 可以不写,因为如果事务执行失败,会默认回滚;

2. 代码实现

举例:实现转账业务。

package com.Sun3285.jdbc;

import com.Sun3285.utils.JdbcUtils;

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

public class TransactionDemo01 {

    public static void main(String[] args) {

        Connection con = null;
        PreparedStatement pst = null;
        ResultSet rs = null;

        try {
            con = JdbcUtils.getConnection();

            // 关闭数据库自动提交,自动会开启事务
            con.setAutoCommit(false);

            String sql1 = "update `account` set `money` = `money` - 2000 where `name` = ?;";
            pst = con.prepareStatement(sql1);
            pst.setString(1, "Sun3285");
            pst.executeUpdate();

            String sql2 = "update `account` set `money` = `money` + 2000 where `name` = ?;";
            pst = con.prepareStatement(sql2);
            pst.setString(1, "Sun1478");
            pst.executeUpdate();

            // 提交事务
            con.commit();
            System.out.println("转账成功!");

        } catch (SQLException e) {
            try {
                // 出现异常,回滚事务
                con.rollback();
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
            e.printStackTrace();
        } finally {
            JdbcUtils.release(con, pst, rs);
        }
    }
}

七、数据库连接池

1. 概述

背景:每次连接数据库和释放连接资源都十分浪费系统资源

解决方法:编写一个数据库连接池需要实现 DataSource 接口(如下图)。

比较知名的 DataSource 接口的实现类(开源的数据源实现,会用就好)有:DBCPC3P0Druid 等。

注意

  • 当使用了数据库连接池之后,我们在项目开发中就不需要编写连接数据库的代码了;
  • 无论使用什么数据源,本质都是一样的DataSource 接口不会变,方法就不会变。

所用到的池化技术:准备一些预先的资源,过来就连接预先准备好的。例如:常用连接数为 10 个,可以设置最小连接数为 10,最大连接数为 15(业务最高承载上限)。若 15 个业务都在进行,其他的业务将会排队等待,还可以设置等待超时为 5 秒,若业务的排队等待时间超过 5 秒,则不会继续等待。

DBCP_770">2. DBCP

注意

  1. 使用数据库连接池 BasicDataSource 实现了 DataSource 接口,代替了之前连接数据库的步骤;
  2. 创建数据源 dataSource 时使用了工厂模式,用来创建 BasicDataSource 类的对象,可以理解为将属性文件中的各个参数传给 BasicDataSource 类,然后来创建数据源。

步骤

  • 准备工作:在 pom.xml 中导入依赖:commons-dbcp 以及 commons-pool
<dependency>
    <groupId>commons-dbcp</groupId>
    <artifactId>commons-dbcp</artifactId>
    <version>1.4</version>
</dependency>

<dependency>
    <groupId>commons-pool</groupId>
    <artifactId>commons-pool</artifactId>
    <version>1.6</version>
</dependency>
  • 编写配置文件,是 properties 类型的文件,存放参数(参数由自己设置,注意 driverClassName 的名字不能改变,固定的
#连接设置
driverClassName=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&useSSL=true
username=root
password=1142553864qq

#<!-- 初始化连接 -->
initialSize=10

#最大连接数量
maxActive=50

#<!-- 最大空闲连接 -->
maxIdle=20

#<!-- 最小空闲连接 -->
minIdle=5

#<!-- 超时等待时间以毫秒为单位 6000毫秒/1000等于60秒 -->
maxWait=60000
#JDBC驱动建立连接时附带的连接属性属性的格式必须为这样:【属性名=property;】
#注意:"user" 与 "password" 两个属性会被明确地传递,因此这里不需要包含他们。
connectionProperties=useUnicode=true;characterEncoding=UTF8;useSSL=true;serverTimezone=Asia/Shanghai

#指定由连接池所创建的连接的自动提交(auto-commit)状态。
defaultAutoCommit=true

#driver default 指定由连接池所创建的连接的只读(read-only)状态。
#如果没有设置该值,则“setReadOnly”方法将不被调用。(某些驱动并不支持只读模式,如:Informix)
defaultReadOnly=

#driver default 指定由连接池所创建的连接的事务级别(TransactionIsolation)。
#可用值为下列之一:(详情可见javadoc。)NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE
defaultTransactionIsolation=READ_UNCOMMITTED

  • 其他步骤不变,编写测试类

C3P0_847">3. C3P0

注意

  1. 使用数据库连接池 ComboPooledDataSource 实现了 DataSource 接口,代替了之前连接数据库的步骤;

  2. 在编写 xml 配置文件时,可以指定多个数据源,还需要注意 &amp; 表示与的意思;

  3. 在获取数据源 dataSource 时,不写参数代表获取默认的数据源,有参数代表指定的数据源。

步骤

  • 准备工作:在 pom.xml 中导入依赖:c3p0 以及 mchange-commons-java
<dependency>
    <groupId>c3p0</groupId>
    <artifactId>c3p0</artifactId>
    <version>0.9.1.2</version>
</dependency>

<dependency>
    <groupId>com.mchange</groupId>
    <artifactId>mchange-commons-java</artifactId>
    <version>0.2.15</version>
</dependency>
  • 编写配置文件,是 xml 类型的文件,设置参数
<?xml version="1.0" encoding="UTF-8"?>

<c3p0-config>
    <!--
    c3p0的缺省(默认)配置
    如果在代码中"ComboPooledDataSource ds=new ComboPooledDataSource();"这样写就表示使用的是c3p0的缺省(默认)
    -->
    <default-config>
        <property name="driverClass">com.mysql.cj.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&amp;characterEncoding=utf8&amp;useSSL=true&amp;serverTimezone=Asia/Shanghai</property>
        <property name="user">root</property>
        <property name="password">1142553864qq</property>

        <property name="acquireIncrement">5</property>
        <property name="initialPoolSize">10</property>
        <property name="minPoolSize">5</property>
        <property name="maxPoolSize">20</property>
    </default-config>

    <!-- 指定的数据源 -->
    <named-config name="MySQL">
        <property name="driverClass">com.mysql.cj.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&amp;characterEncoding=utf8&amp;useSSL=true&amp;serverTimezone=Asia/Shanghai</property>
        <property name="user">root</property>
        <property name="password">1142553864qq</property>

        <property name="acquireIncrement">5</property>
        <property name="initialPoolSize">10</property>
        <property name="minPoolSize">5</property>
        <property name="maxPoolSize">20</property>
    </named-config>
</c3p0-config>

  • 其他步骤不变,编写测试类


注意:

  1. 将一个普通项目(模块)转换为 Maven 项目(模块)的方法:选中项目(模块)右键,选择 Add Framework Support... ,打开后选择 Maven 项目。

  1. 程序执行时,会先找到 main 函数(相当于入口),从 main 函数开始执行,当 main 函数执行完毕退出后,整个程序就结束。

  2. 代码块分为静态代码块(类加载时调用,一个类的静态代码块会执行一次)和普通初始化代码块(在每次创建对象时会调用一次),执行静态代码块,执行普通初始化代码块。可以用静态代码块来一次性对静态成员变量进行赋值。

  3. 当使用 JDBC 进行查询 executeQuery 操作时,若没有查询到数据,得到的 resultSet 结果集不为 null因为此时结果集中还包括了字段名。因此,要判断是否查询到数据,不能if (resultSet != null)而应该if (resultSet.next()) ,如果结果为 false ,则说明没有查询到数据。

  4. 理解结果集 resultSetnext 方法:最初指针被置于第一行之前(即 beforeFirst),当执行 next 方法时,指针会移动到下一行,此时若有下一行,结果为 true ,再执行 getString 等方法时,得到指针所指的这一行数据;若没有下一行,结果为 false 。与 next 相反的另一个方法为 previous

  5. SQL 中 AND优先级高于 OR

  6. java.sql.Datejava.util.Date不一样的包,前者是数据库用的,后者是 Java 用的,前者继承了后者

  1. properties 类型和 xml 类型的配置文件可以放在资源目录 resources 下。

http://www.niftyadmin.cn/n/231669.html

相关文章

现在跑来学习Java,还有前景吗

Java是一门经典的编程语言&#xff0c;自1995年面世以来&#xff0c;Java已经成为了世界上应用最广泛和使用最广泛的编程语言之一。在过去的几十年里&#xff0c;Java一直是企业级开发的首选语言&#xff0c;因为它具有跨平台性、可扩展性和安全性等优点。但是&#xff0c;随着…

C++【深入理解多态】

文章目录一、多态概念与实现&#xff08;1&#xff09;多态的概念&#xff08;2&#xff09;怎么构成多态&#xff08;3&#xff09;虚函数重写的2个例外&#xff08;4&#xff09;经典剖析巩固知识点&#xff08;5&#xff09; override 和 final&#xff08;6&#xff09;小总…

大学生蓝桥杯

蓝桥杯简介比赛科目简介 全国普通高校学科竞赛排行榜&#xff0c;是由中国高等教育学会“高校竞赛评估与管理体系研究”专家工作组研究发布的竞赛评估体系&#xff0c;已经连续六年发布&#xff0c;是高校提高人才培养质量的服务性参考信息&#xff0c;是检验高校创新人才培养…

音视频开发十九:SDL线程和事件

SDL事件相关API DL_Event 是SDL库中使用的一个数据结构&#xff0c;用于表示系统中发生的事件。一个事件可以是键盘按键、鼠标移动、游戏手柄移动、窗口事件等。SDL_Event 结构包含有关事件类型、事件发生时间和事件参数的详细信息。 SDL_Event 结构具有以下成员&#xff1a;…

网络中的阻塞与非阻塞以及reactor模型

文章目录一、网络IO的职责操作IOIO的操作方式**阻塞与非阻塞IO的具体差别&#xff1a;**阻塞IO在系统调用中的流程非阻塞IO在系统调用中的流程网络编程系统调用具备检测和操作的功能accept&#xff1a;read&#xff1a;write&#xff1a;二、系统调用在调用非阻塞IO的具体处理c…

迈入Java,一文告诉你学习Java的原因

前言 Java是一种流行的编程语言&#xff0c;由Sun Microsystems于1995年首次发布。自那时以来&#xff0c;Java已成为全球最广泛使用的编程语言之一。Java具有许多优点&#xff0c;包括跨平台、面向对象和安全性等&#xff0c;使其成为开发企业软件、Web应用程序和移动应用程序…

VS Code 插件开发概览

VS Code 插件开发概览 前言 VS Code作为开发者的代码开发利器&#xff0c;越来越受开发者的喜爱。像我身边的前端&#xff0c;每天80%的开发工作都是在VS Code上完成的。随着人们对它的使用&#xff0c;不再满足简单的优雅&#xff0c;舒服写代码这一基本需求。有些人利用它进…

【ConfluxNews】2023.4.17 我们将在香港扎根

1.【网络状态】当前版本V2.2.3&#xff0c;全网算力≈8T&#xff0c;昨日交易次数43K&#xff0c;昨日新增账户0.32K&#xff0c;昨日新增合约1个&#xff1b; 2.【POS参数】总锁仓257M&#xff08;1&#xff09;&#xff0c;节点总数268&#xff0c;年利率14.2%&#xff08;理…