【JavaWeb】JDBC实战

深藏阁楼爱情的钟 2024-04-26 03:26 179阅读 0赞

? 本文由 程序喵正在路上 原创，CSDN首发！
? 系列专栏：?JavaWeb从入门到实战
? 首发时间：2022年9月3日
? 欢迎关注?点赞?收藏?留言?
? 一以贯之的努力 不得懈怠的人生

阅读指南

  • 一、需求
  • 二、准备环境
  • 三、查询所有数据
  • 四、添加数据
  • 五、修改数据
  • 六、删除数据

一、需求

完成商品品牌数据的增删改查操作，具体如下

  • 添加：添加品牌
  • 删除：根据 id 删除
  • 修改：根据 id 修改
  • 查询：查询所有数据

二、准备环境

① 准备数据库表 tb_brand：

  1. -- 删除tb_brand表
  2. drop table if exists tb_brand;
  4. -- 创建tb_brand表
  5. create table tb_brand (
  6.     -- id 主键
  7.     id int primary key auto_increment,
  8.     -- 品牌名称
  9.     brand_name varchar(20),
  10.     -- 企业名称
  11.     company_name varchar(20),
  12.     -- 排序字段
  13.     ordered int,
  14.     -- 描述信息
  15.     description varchar(100),
  16.     -- 状态：0：禁用  1：启用
  17.     status int
  18. );
  19. -- 添加数据
  20. insert into tb_brand (brand_name, company_name, ordered, description, status)
  21. values ('三只松鼠', '三只松鼠股份有限公司', 5, '好吃不上火', 0),
  22.        ('华为', '华为技术有限公司', 100, '华为致力于把数字世界带入每个人、每个家庭、每个组织，构建万物互联的智能世界', 1),
  23.        ('小米', '小米科技有限公司', 50, 'are you ok', 1);
  25. SELECT * FROM tb_brand;

在这里插入图片描述

② 在 pojo 包下创建实体类 Brand

在品牌类里面我们首先肯定要做的是定义相关的变量，也就是前一步创建表的那些变量；然后生成相关 get 和 set 方法，还有 toString 方法，建议使用 IDEA 快捷键 Alt + Insert，再按住 Ctrl 键选中所有来生成

在实体类中，基本数据类型建议使用其对应的包装类型

  1. /*
  2.     品牌
  3.  */
  4. public class Brand {
  6.     // id 主键
  7.     private Integer id;
  8.     // 品牌名称
  9.     private String brandName;
  10.     // 企业名称
  11.     private String companyName;
  12.     // 排序字段
  13.     private Integer ordered;
  14.     // 描述信息
  15.     private String description;
  16.     // 状态：0：禁用  1：启用
  17.     //在这种情况下，建议不要用基本数据类型int，因为有默认值0
  18.     private Integer status;
  20.     //get和set方法
  21.     public Integer getId() {
  23.         return id;
  24.     }
  26.     public void setId(Integer id) {
  28.         this.id = id;
  29.     }
  31.     public String getBrandName() {
  33.         return brandName;
  34.     }
  36.     public void setBrandName(String brandName) {
  38.         this.brandName = brandName;
  39.     }
  41.     public String getCompanyName() {
  43.         return companyName;
  44.     }
  46.     public void setCompanyName(String companyName) {
  48.         this.companyName = companyName;
  49.     }
  51.     public Integer getOrdered() {
  53.         return ordered;
  54.     }
  56.     public void setOrdered(Integer ordered) {
  58.         this.ordered = ordered;
  59.     }
  61.     public String getDescription() {
  63.         return description;
  64.     }
  66.     public void setDescription(String description) {
  68.         this.description = description;
  69.     }
  71.     public Integer getStatus() {
  73.         return status;
  74.     }
  76.     public void setStatus(Integer status) {
  78.         this.status = status;
  79.     }
  81.     @Override
  82.     public String toString() {
  84.         return "Brand{" +
  85.                 "id=" + id +
  86.                 ", brandName='" + brandName + '\'' +
  87.                 ", companyName='" + companyName + '\'' +
  88.                 ", ordered=" + ordered +
  89.                 ", description='" + description + '\'' +
  90.                 ", status=" + status +
  91.                 '}';
  92.     }
  93. }

③ 测试用例

在 src 下新建一个 example 包来放置测试的文件，创建一个 BrandTest 类方便我们后面写测试增删改查的操作

在这里插入图片描述

三、查询所有数据

步骤：

  1. 获取 Connection
  2. 定义 SQL：select * from tb_brand;
  3. 获取 PreparedStatement 对象
  4. 设置参数：不需要
  5. 执行 SQL
  6. 处理结果：List<Brand>
  7. 释放资源

其中 1、3、5、7 四个步骤是不变的

在 BrandTest 类中按照上列步骤写一个测试方法 testSelectAll()

  1. import com.alibaba.druid.pool.DruidDataSourceFactory;
  2. import org.junit.Test;
  3. import pojo.Brand;
  5. import javax.sql.DataSource;
  6. import java.io.FileInputStream;
  7. import java.sql.Connection;
  8. import java.sql.PreparedStatement;
  9. import java.sql.ResultSet;
  10. import java.util.*;
  12. public class BrandTest {
  15.     @Test
  16.     public void testSelectAll() throws Exception {
  18.         //1. 获取Connection
  19.         //加载配置文件
  20.         Properties prop = new Properties();
  21.         prop.load(new FileInputStream("D:\\IdeaProjects\\jdbc_demo\\src\\druid.properties"));
  23.         //获取连接池对象
  24.         DataSource dataSource = DruidDataSourceFactory.createDataSource(prop);
  26.         //获取数据库连接 Connection
  27.         Connection conn = dataSource.getConnection();
  29.         //2. 定义SQL
  30.         String sql = "select * from tb_brand";
  32.         //3. 获取pstmt对象
  33.         PreparedStatement pstmt = conn.prepareStatement(sql);
  35.         //4. 设置参数
  37.         //5. 执行SQL
  38.         ResultSet rs = pstmt.executeQuery();
  40.         //6. 处理结果
  41.         Brand brand = null;
  42.         List<Brand> brands = new ArrayList<>();
  44.         while(rs.next()){
  46.             //获取数据
  47.             int id = rs.getInt("id");
  48.             String brandName = rs.getString("brand_name");
  49.             String companyName = rs.getString("company_name");
  50.             int ordered = rs.getInt("ordered");
  51.             String description = rs.getString("description");
  52.             int status = rs.getInt("status");
  53.             //封装Brand对象
  54.             brand = new Brand();
  55.             brand.setId(id);
  56.             brand.setBrandName(brandName);
  57.             brand.setCompanyName(companyName);
  58.             brand.setOrdered(ordered);
  59.             brand.setDescription(description);
  60.             brand.setStatus(status);
  61.             //装载集合
  62.             brands.add(brand);
  63.         }
  64.         //打印一下
  65.         for(Brand b:brands){
  67.             System.out.println(b);
  68.         }
  70.         //7. 释放资源
  71.         rs.close();
  72.         pstmt.close();
  73.         conn.close();
  74.     }
  75. }

然后，鼠标双击方法名，右击运行这个方法试试看，结果如下：

在这里插入图片描述

查询所有数据功能完成！

四、添加数据

我们需要考虑的有 3 点：

  1. 编写哪种 SQL 语句：insert
  2. SQL 语句是否需要参数？ 需要，除了 id 外的所有数据
  3. 返回的结果如何封装？boolean

注意：添加数据这一步我们是不需要从用户那里获取 id 的，因为数据库会自动生成

  1. //添加数据
  2. @Test
  3. public void testAdd() throws Exception {
  5.     // 模拟接收页面提交的参数
  6.     String brandName = "香飘飘";
  7.     String companyName = "香飘飘";
  8.     int ordered = 1;
  9.     String description = "绕地球一圈";
  10.     int status = 1;
  13.     //1. 获取Connection
  14.     //加载配置文件
  15.     Properties prop = new Properties();
  16.     prop.load(new FileInputStream("D:\\IdeaProjects\\jdbc_demo\\src\\druid.properties"));
  18.     //获取连接池对象
  19.     DataSource dataSource = DruidDataSourceFactory.createDataSource(prop);
  21.     //获取数据库连接 Connection
  22.     Connection conn = dataSource.getConnection();
  24.     //2. 定义SQL
  25.     String sql = "insert into tb_brand(brand_name, company_name, ordered, description, status) values(?,?,?,?,?);";
  27.     //3. 获取pstmt对象
  28.     PreparedStatement pstmt = conn.prepareStatement(sql);
  30.     //4. 设置参数
  31.     pstmt.setString(1, brandName);
  32.     pstmt.setString(2, companyName);
  33.     pstmt.setInt(3, ordered);
  34.     pstmt.setString(4, description);
  35.     pstmt.setInt(5, status);
  37.     //5. 执行SQL
  38.     int count = pstmt.executeUpdate();  //影响的行数
  40.     //6. 处理结果
  41.     System.out.println(count > 0);
  43.     //7. 释放资源
  44.     pstmt.close();
  45.     conn.close();
  46. }

运行结果为 true，表明添加成功：

在这里插入图片描述

查看了一下表格，发现数据已经添加成功：

在这里插入图片描述
添加数据功能完成！

五、修改数据

我们需要考虑的有 3 点：

  1. 编写哪种 SQL 语句：update
  2. SQL 语句是否需要参数？ 需要所有数据

  3. 返回的结果如何封装？boolean

    //修改数据
    @Test
    public void testUpdate() throws Exception {

    1. // 模拟接收页面提交的参数
    2. String brandName = "香飘飘";
    3. String companyName = "香飘飘";
    4. int ordered = 1000;
    5. String description = "绕地球十圈";
    6. int status = 1;
    7. int id = 4;
    9. //1. 获取Connection
    10. //加载配置文件
    11. Properties prop = new Properties();
    12. prop.load(new FileInputStream("D:\\IdeaProjects\\jdbc_demo\\src\\druid.properties"));
    13. //获取连接池对象
    14. DataSource dataSource = DruidDataSourceFactory.createDataSource(prop);
    15. //获取数据库连接 Connection
    16. Connection conn = dataSource.getConnection();
    18. //2. 定义SQL
    19. String sql = " update tb_brand\n" +
    20.         "         set brand_name  = ?,\n" +
    21.         "         company_name= ?,\n" +
    22.         "         ordered     = ?,\n" +
    23.         "         description = ?,\n" +
    24.         "         status      = ?\n" +
    25.         "     where id = ?";
    27. //3. 获取pstmt对象
    28. PreparedStatement pstmt = conn.prepareStatement(sql);
    30. //4. 设置参数
    31. pstmt.setString(1, brandName);
    32. pstmt.setString(2, companyName);
    33. pstmt.setInt(3, ordered);
    34. pstmt.setString(4, description);
    35. pstmt.setInt(5, status);
    36. pstmt.setInt(6, id);
    38. //5. 执行SQL
    39. int count = pstmt.executeUpdate();  //影响的行数
    41. //6. 处理结果
    42. System.out.println(count > 0);
    44. //7. 释放资源
    45. pstmt.close();
    46. conn.close();

    }

运行结果为 true，表明修改成功：

在这里插入图片描述

查看了一下表格，发现数据已经修改成功：

在这里插入图片描述
修改数据功能完成！

六、删除数据

我们需要考虑的有 3 点：

  1. 编写哪种 SQL 语句：delete
  2. SQL 语句是否需要参数？ 只需要 id

  3. 返回的结果如何封装？boolean

    //删除数据
    @Test
    public void testDeleteById() throws Exception {

    1. // 模拟接收页面提交的参数
    2. int id = 4;
    4. //1. 获取Connection
    5. //加载配置文件
    6. Properties prop = new Properties();
    7. prop.load(new FileInputStream("D:\\IdeaProjects\\jdbc_demo\\src\\druid.properties"));
    8. //获取连接池对象
    9. DataSource dataSource = DruidDataSourceFactory.createDataSource(prop);
    10. //获取数据库连接 Connection
    11. Connection conn = dataSource.getConnection();
    13. //2. 定义SQL
    14. String sql = "delete from tb_brand where id = ?";
    16. //3. 获取pstmt对象
    17. PreparedStatement pstmt = conn.prepareStatement(sql);
    19. //4. 设置参数
    20. pstmt.setInt(1, id);
    22. //5. 执行SQL
    23. int count = pstmt.executeUpdate();  //影响的行数
    25. //6. 处理结果
    26. System.out.println(count > 0);
    28. //7. 释放资源
    29. pstmt.close();
    30. conn.close();

    }

运行结果为 true，表明删除成功：

在这里插入图片描述

查看了一下表格，发现数据已经删除：

在这里插入图片描述
删除数据功能完成！

发表评论

表情：
评论列表 （有 0 条评论，179人围观）

还没有评论，来说两句吧...

相关阅读

    相关 git实战（六）：模拟实战

    之前我们是在本地环境搭建了一个git，然后操作了代码提交，回退等，现在我们需要在一台服务器进行操作，让我们的开发变得更加规范 一）服务器上创建文件夹 我们得有一台服务器，

    缺乏、安全感缺乏、安全感/ 0 赞/ 72 阅读