• 使用 jdbc 技术升级水果库存系统（优化版本）

    • 抽取执行更新方法
    • 抽取查询方法 —— ResultSetMetaData   
      ResultSetMetaData rsmd = rs.getMetaData();//元数据,结果集的结构数据
    • 抽取查询方法 —— 解析结果集封装成实体对象
    • 提取 获取连接 和 释放资源 的方法
    • 将数据库配置信息转移到配置文件
    1.     <dependencies>
    2.         <dependency>
    3.             <groupId>org.projectlombokgroupId>
    4.             <artifactId>lombokartifactId>
    5.             <version>1.18.10version>
    6.         dependency>
    7.         <dependency>
    8.             <groupId>junitgroupId>
    9.             <artifactId>junitartifactId>
    10.             <version>4.12version>
    11.             <scope>testscope>
    12.         dependency>
    13.         <dependency>
    14.             <groupId>mysqlgroupId>
    15.             <artifactId>mysql-connector-javaartifactId>
    16.             <version>8.0.28version>
    17.         dependency>
    18.     dependencies>
    1. package com.csdn.fruit.pojo;
    2. import lombok.AllArgsConstructor;
    3. import lombok.Data;
    4. import lombok.NoArgsConstructor;
    5. import java.io.Serializable;
    6. @Data
    7. @NoArgsConstructor
    8. @AllArgsConstructor
    9. public class Fruit implements Serializable {
    10.     private Integer fid;
    11.     private String fname;
    12.     private Integer price;
    13.     private Integer fcount;
    14.     private String remark;
    15.  
    16.     public Fruit(String fname, Integer price, Integer fcount, String remark) {
    17.         this.fname = fname;
    18.         this.price = price;
    19.         this.fcount = fcount;
    20.         this.remark = remark;
    21.     }
    22.     @Override
    23.     public String toString() {
    24.         return fname + "\t\t" + price + "\t\t" + fcount + "\t\t" + remark;
    25.     }
    26. }
    •  
    1. jdbc.driver=com.mysql.cj.jdbc.Driver
    2. jdbc.url=jdbc:mysql:///fruitdb
    3. jdbc.user=root
    4. jdbc.pwd=123456
    1. package com.csdn.mymvc.dao;
    2. import com.csdn.mymvc.util.ClassUtil;
    3. import java.io.IOException;
    4. import java.io.InputStream;
    5. import java.lang.reflect.ParameterizedType;
    6. import java.lang.reflect.Type;
    7. import java.sql.*;
    8. import java.util.ArrayList;
    9. import java.util.List;
    10. import java.util.Properties;
    11. public abstract class BaseDao {
    12.  
    13.     private String DRIVER;
    14.     private String URL;
    15.     private String USER;
    16.     private String PWD;
    17.  
    18.     private String entityClassName;
    19.  
    20.     public BaseDao() {
    21.         // this 是谁？ this代表的是 FruitDaoImpl 的实例对象，因为 BaseDao是抽象类，不能直接创建对象，所以 new 的是它的子类对象 FruitDaoImpl
    22.         // this.getClass() 获取的是 FruitDaoImpl 的Class对象
    23.         // getGenericSuperclass() 获取到的是：BaseDao
    24.         // Type 是顶层接口，表示所有的类型。它有一个子接口：ParameterizedType
    25.         ParameterizedType genericSuperclass = (ParameterizedType) this.getClass().getGenericSuperclass();
    26.         // Actual:实际的
    27.         // getActualTypeArguments() 获取实际的类型参数
    28.         Type[] actualTypeArguments = genericSuperclass.getActualTypeArguments();
    29.         Type actualTypeArgument = actualTypeArguments[0];
    30.  
    31.         // System.out.println(actualTypeArgument.getTypeName());//com.csdn.fruit.pojo.Fruit
    32.  
    33.         entityClassName = actualTypeArgument.getTypeName();
    34.  
    35.         loadJdbcProperties();
    36.     }
    37.  
    38.     //加载jdbc.properties文件
    39.     private void loadJdbcProperties() {
    40.         try {
    41.             InputStream inputStream = getClass().getClassLoader().getResourceAsStream("jdbc.properties");
    42.             Properties properties = new Properties();
    43.             properties.load(inputStream);
    44.  
    45.             DRIVER = properties.getProperty("jdbc.driver", "com.mysql.cj.jdbc.Driver");
    46.             URL = properties.getProperty("jdbc.url", "jdbc:mysql:///fruitdb");
    47.             USER = properties.getProperty("jdbc.user", "root");
    48.             PWD = properties.getProperty("jdbc.pwd", "123456");
    49.         } catch (IOException e) {
    50.             throw new RuntimeException(e);
    51.         }
    52.  
    53.     }
    54.  
    55.     private Connection getConn() {
    56.         try {
    57.             Class.forName(DRIVER);
    58.             return DriverManager.getConnection(URL, USER, PWD);
    59.         } catch (ClassNotFoundException | SQLException e) {
    60.             throw new RuntimeException(e);
    61.         }
    62.     }
    63.  
    64.     private void close(Connection conn, PreparedStatement psmt, ResultSet rs) {
    65.         try {
    66.             if (rs != null) {
    67.                 rs.close();
    68.             }
    69.             if (psmt != null) {
    70.                 psmt.close();
    71.             }
    72.             if (conn != null && !conn.isClosed()) {
    73.                 conn.close();
    74.             }
    75.         } catch (SQLException e) {
    76.             throw new RuntimeException(e);
    77.         }
    78.     }
    79.  
    80.     //抽取执行更新方法
    81.     //执行更新，返回影响行数
    82.     protected int executeUpdate(String sql, Object... params) {
    83.         PreparedStatement psmt = null;
    84.         Connection conn = null;
    85.         try {
    86.             conn = getConn();
    87.             psmt = conn.prepareStatement(sql);
    88.  
    89.             setParams(psmt, params);
    90.  
    91.             return psmt.executeUpdate();
    92.  
    93.         } catch (SQLException e) {
    94.             throw new RuntimeException(e);
    95.         } finally {
    96.             close(conn, psmt, null);
    97.         }
    98.     }
    99.  
    100.     //设置参数
    101.     private void setParams(PreparedStatement psmt, Object... params) throws SQLException {
    102.         if (params != null && params.length > 0) {
    103.             for (int i = 0; i < params.length; i++) {
    104.                 psmt.setObject(i + 1, params[i]);
    105.             }
    106.         }
    107.     }
    108.  
    109.     //执行查询，返回集合
    110.     protected List executeQuery(String sql, Object... params) {
    111.         List list = new ArrayList<>();
    112.         Connection conn = null;
    113.         PreparedStatement psmt = null;
    114.         ResultSet rs = null;
    115.  
    116.         try {
    117.             conn = getConn();
    118.             psmt = conn.prepareStatement(sql);
    119.             setParams(psmt, params);
    120.             rs = psmt.executeQuery();
    121.             ResultSetMetaData rsmd = rs.getMetaData();//元数据,结果集的结构数据
    122.             while (rs.next()) {
    123.                 //T t = new T();  T仅仅是一个符号，所以不能 new
    124.                 T t = (T) ClassUtil.createInstance(entityClassName);
    125.                 int columnCount = rsmd.getColumnCount();//获取结果集的列的数据
    126.                 //jdbc中都是从 1 开始，所以要把 i 改成 从 1 开始
    127.                 for (int i = 1; i <= columnCount; i++) {
    128.                     //假设循环 5 次，得到 5 个值，应该对应的是一个对象的 5 个属性的值
    129.                     String columnName = rsmd.getColumnLabel(i);
    130.                     Object columnValue = rs.getObject(i);
    131.                     //给 t 这个对象的 columnName 属性赋 columnValue 值
    132.                     ClassUtil.setProperty(t, columnName, columnValue);
    133.                 }
    134.                 list.add(t);
    135.             }
    136.             return list;
    137.         } catch (SQLException e) {
    138.             throw new RuntimeException(e);
    139.         } finally {
    140.             close(conn, psmt, rs);
    141.         }
    142.     }
    143.  
    144.     protected T load(String sql, Object... params) {
    145.  
    146.         Connection conn = null;
    147.         PreparedStatement psmt = null;
    148.         ResultSet rs = null;
    149.  
    150.         try {
    151.             conn = getConn();
    152.             psmt = conn.prepareStatement(sql);
    153.             setParams(psmt, params);
    154.             rs = psmt.executeQuery();
    155.             ResultSetMetaData rsmd = rs.getMetaData();//元数据,结果集的结构数据
    156.             if (rs.next()) {
    157.                 //T t = new T();  T仅仅是一个符号，所以不能 new
    158.                 T t = (T) ClassUtil.createInstance(entityClassName);
    159.                 int columnCount = rsmd.getColumnCount();//获取结果集的列的数据
    160.                 //jdbc中都是从 1 开始，所以要把 i 改成 从 1 开始
    161.                 for (int i = 1; i <= columnCount; i++) {
    162.                     //假设循环 5 次，得到 5 个值，应该对应的是一个对象的 5 个属性的值
    163.                     String columnName = rsmd.getColumnLabel(i);
    164.                     Object columnValue = rs.getObject(i);
    165.                     //给 t 这个对象的 columnName 属性赋 columnValue 值
    166.                     ClassUtil.setProperty(t, columnName, columnValue);
    167.                 }
    168.                 return t;
    169.             }
    170.         } catch (SQLException e) {
    171.             throw new RuntimeException(e);
    172.         } finally {
    173.             close(conn, psmt, rs);
    174.         }
    175.         return null;
    176.     }
    177. }
    1. package com.csdn.mymvc.util;
    2. import java.lang.reflect.Field;
    3. import java.lang.reflect.InvocationTargetException;
    4. public class ClassUtil {
    5.  
    6.     public static Object createInstance(String entityClassName) {
    7.         try {
    8.             return Class.forName(entityClassName).getDeclaredConstructor().newInstance();
    9.         } catch (InstantiationException | IllegalAccessException | InvocationTargetException | NoSuchMethodException |
    10.                  ClassNotFoundException e) {
    11.             throw new RuntimeException(e);
    12.         }
    13.     }
    14.  
    15.     public static void setProperty(Object instance, String propertyName, Object propertyValue) {
    16.         Class aClass = instance.getClass();
    17.         try {
    18.             Field field = aClass.getDeclaredField(propertyName);
    19.             field.setAccessible(true);
    20.             field.set(instance, propertyValue);
    21.         } catch (NoSuchFieldException | IllegalAccessException e) {
    22.             throw new RuntimeException(e);
    23.         }
    24.     }
    25. }

    1. package com.csdn.fruit.dao;
    2. import com.csdn.fruit.pojo.Fruit;
    3. import java.util.List;
    4. //dao ：Data Access Object 数据访问对象
    5. //接口设计
    6. public interface FruitDao {
    7.  
    8.     void addFruit(Fruit fruit);
    9.  
    10.     void delFruit(String fname);
    11.  
    12.     void updateFruit(Fruit fruit);
    13.  
    14.     List getFruitList();
    15.  
    16.     Fruit getFruitByFname(String fname);
    17. }
    1. package com.csdn.fruit.dao.impl;
    2. import com.csdn.fruit.dao.FruitDao;
    3. import com.csdn.fruit.pojo.Fruit;
    4. import com.csdn.mymvc.dao.BaseDao;
    5. import java.util.List;
    6. public class FruitDaoImpl extends BaseDao implements FruitDao {
    7.     @Override
    8.     public void addFruit(Fruit fruit) {
    9.         String sql = "insert into t_fruit values (0,?,?,?,?)";
    10.         super.executeUpdate(sql, fruit.getFname(), fruit.getPrice(), fruit.getFcount(), fruit.getRemark());
    11.     }
    12.  
    13.     @Override
    14.     public void delFruit(String fname) {
    15.         String sql = "delete from t_fruit where fname=?";
    16.         super.executeUpdate(sql, fname);
    17.     }
    18.  
    19.     @Override
    20.     public void updateFruit(Fruit fruit) {
    21.         String sql = "update  t_fruit set fcount=? where fname = ?";
    22.         super.executeUpdate(sql, fruit.getFcount(), fruit.getFname());
    23.  
    24.     }
    25.  
    26.     @Override
    27.     public List getFruitList() {
    28.         return super.executeQuery("select * from t_fruit");
    29.     }
    30.  
    31.     @Override
    32.     public Fruit getFruitByFname(String fname) {
    33.         return load("select * from t_fruit where fname = ?", fname);
    34.     }
    35. }
    1. package com.csdn.fruit.view;
    2. import com.csdn.fruit.dao.FruitDao;
    3. import com.csdn.fruit.dao.impl.FruitDaoImpl;
    4. import com.csdn.fruit.pojo.Fruit;
    5. import java.util.List;
    6. import java.util.Scanner;
    7. public class Menu {
    8.     Scanner input = new Scanner(System.in);
    9.     private FruitDao fruitDao = new FruitDaoImpl();
    10.     //显示主菜单
    11.     public int showMainMenu() {
    12.         System.out.println("================欢迎使用水果库存系统===================");
    13.         System.out.println("1.显示库存列表");
    14.         System.out.println("2.添加库存记录");
    15.         System.out.println("3.查看特定库存");
    16.         System.out.println("4.水果下架");
    17.         System.out.println("5.退出");
    18.         System.out.println("====================================================");
    19.         System.out.print("请选择：");
    20.  
    21.  
    22.         return input.nextInt();
    23.     }
    24.     //显示库存列表
    25.     public void showFruitList() {
    26.         List fruitList = fruitDao.getFruitList();
    27.         System.out.println("----------------------------------------------------");
    28.         System.out.println("名称\t\t单价\t\t库存\t\t备注");
    29.         if (fruitList == null || fruitList.size() <= 0) {
    30.             System.out.println("对不起，库存为空！");
    31.         } else {
    32.                /* fruitList.forEach(new Consumer() {
    33.                 @Override
    34.                 public void accept(Fruit fruit) {
    35.                     System.out.println(fruit);
    36.                 }
    37.             });*/
    38.  
    39. //            fruitList.forEach(fruit -> System.out.println(fruit));
    40.             fruitList.forEach(System.out::println);
    41.         }
    42.         System.out.println("----------------------------------------------------");
    43.     }
    44.     //添加库存记录
    45.     public void addFruit() {
    46.         System.out.print("请输入水果名称：");
    47.         String fname = input.next();
    48.  
    49.         Fruit fruit = fruitDao.getFruitByFname(fname);
    50.  
    51.         if (fruit == null) {
    52.             System.out.print("请输入水果单价：");
    53.             Integer price = input.nextInt();
    54.             System.out.print("请输入水果库存：");
    55.             Integer fcount = input.nextInt();
    56.             System.out.print("请输入水果备注：");
    57.             String remark = input.next();
    58.  
    59.             fruit = new Fruit(fname, price, fcount, remark);
    60.             fruitDao.addFruit(fruit);
    61.         } else {
    62.             System.out.print("请输入追加的库存量：");
    63.             Integer fcount = input.nextInt();
    64.             fruit.setFcount(fruit.getFcount() + fcount);
    65.             fruitDao.updateFruit(fruit);
    66.         }
    67.         System.out.println("添加成功！");
    68.     }
    69.     //查看特定库存记录
    70.     public void showFruitInfo() {
    71.         System.out.print("请输入水果名称：");
    72.         String fname = input.next();
    73.         Fruit fruit = fruitDao.getFruitByFname(fname);
    74.  
    75.         if (fruit == null) {
    76.             System.out.println("对不起，没有找到对应的库存记录！");
    77.         } else {
    78.             System.out.println("----------------------------------------------------");
    79.             System.out.println("名称\t\t单价\t\t库存\t\t备注");
    80.             System.out.println(fruit);
    81.             System.out.println("----------------------------------------------------");
    82.         }
    83.     }
    84.     //水果下架
    85.     public void delFruit() {
    86.         System.out.print("请输入水果名称：");
    87.         String fname = input.next();
    88.  
    89.         Fruit fruit = fruitDao.getFruitByFname(fname);
    90.         if (fruit == null) {
    91.             System.out.println("对不起，没有找到需要下架的库存记录！");
    92.         } else {
    93.             System.out.print("是否确认下架?（Y/N）");
    94.             String confirm = input.next();
    95.             if ("y".equalsIgnoreCase(confirm)) {
    96.                 fruitDao.delFruit(fname);
    97.             }
    98.  
    99.         }
    100.     }
    101.     //退出
    102.     public boolean exit() {
    103.         System.out.print("是否确认退出？（Y/N）");
    104.         String confirm = input.next();
    105.         boolean flag= !"y".equalsIgnoreCase(confirm);
    106.         return flag;
    107.     }
    108. }
    1. package com.csdn.fruit.view;
    2. public class Client {
    3.     public static void main(String[] args) {
    4.         Menu m = new Menu();
    5.         boolean flag = true;
    6.         while (flag) {
    7.             int slt = m.showMainMenu();
    8.             switch (slt) {
    9.                 case 1:
    10.                     m.showFruitList();
    11.                     break;
    12.                 case 2:
    13.                     m.addFruit();
    14.                     break;
    15.                 case 3:
    16.                     m.showFruitInfo();
    17.                     break;
    18.                 case 4:
    19.                     m.delFruit();
    20.                     break;
    21.                 case 5:
    22.                     //方法设计时是否需要返回值，依据是：是否在调用的地方需要留下一些值用于再运算
    23.                     flag = m.exit();
    24.                     break;
    25.                 default:
    26.                     System.out.println("你不按套路出牌！");
    27.                     break;
    28.             }
    29.         }
    30.         System.out.println("谢谢使用！再见！");
    31.     }
    32. }
    1. package com.csdn.dao.impl;
    2. import com.csdn.fruit.dao.FruitDao;
    3. import com.csdn.fruit.dao.impl.FruitDaoImpl;
    4. import com.csdn.fruit.pojo.Fruit;
    5. import org.junit.Test;
    6. import java.util.List;
    7. public class FruitDaoImplTest {
    8.  
    9.     private FruitDao fruitDao = new FruitDaoImpl();
    10.  
    11.     @Test
    12.     public void testAddFruit() {
    13.         Fruit fruit = new Fruit("香蕉", 7, 77, "波罗蜜是一种神奇的水果！");
    14.         fruitDao.addFruit(fruit);
    15.     }
    16.  
    17.     @Test
    18.     public void testDelFruit() {
    19.         fruitDao.delFruit("哈密瓜");
    20.     }
    21.  
    22.     @Test
    23.     public void testUpdateFruit() {
    24.         Fruit fruit = new Fruit("波罗蜜", 5, 1000, "好吃");
    25.         fruitDao.updateFruit(fruit);
    26.     }
    27.  
    28.     @Test
    29.     public void testGetFruitList() {
    30.         List fruitList = fruitDao.getFruitList();
    31.         fruitList.stream().forEach(System.out::println);
    32.     }
    33.  
    34.     @Test
    35.     public void testGetFruitByFname() {
    36.  
    37.         Fruit fruit = fruitDao.getFruitByFname("波罗蜜");
    38.         System.out.println(fruit);
    39.     }
    40.  
    41. /*
    42.     // this 是谁？ this代表的是 FruitDaoImpl 的实例对象，因为 BaseDao是抽象类，不能直接创建对象，所以 new 的是它的子类对象 FruitDaoImpl
    43.     // this.getClass() 获取的是 FruitDaoImpl 的Class对象
    44.     // getGenericSuperclass() 获取到的是：BaseDao
    45.     // Type 是顶层接口，表示所有的类型。它有一个子接口：ParameterizedType
    46.     ParameterizedType genericSuperclass = (ParameterizedType) this.getClass().getGenericSuperclass();
    47.     // Actual:实际的
    48.     // getActualTypeArguments() 获取实际的类型参数
    49.     Type[] actualTypeArguments = genericSuperclass.getActualTypeArguments();
    50.     Type actualTypeArgument = actualTypeArguments[0];
    52.     // System.out.println(actualTypeArgument.getTypeName());//com.csdn.fruit.pojo.Fruit
    54.     entityClassName = actualTypeArgument.getTypeName();
    56.     loadJdbcProperties();
    57. */
    58.     @Test
    59.     public void testActualTypeArgument() {
    60.             //这个方法是用来测试  actualTypeArgument 实际返回的参数
    61.     }
    62. }
  • 相关阅读:
    CSS常用背景属性
    【MYSQL】在线恢复主从复制方案
    算法的时间复杂度和空间复杂度
    2022年10月29日 20点 程序爱生活 纳指和恒指可能会小破前高，然后有概率继续破新低，但是破完就需要考虑一次较大级别反弹的概率了! 第一次不再完全看空！
    Maven多环境下 active: @profileActive@报错问题解决
    网络文件传输程序设计（上）
    构建自定义ChatGPT，微软推出Copilot Studio
    【网络容灾失败案例】三种HTTP请求重试导致重复提交
    信息系统安全运维和管理指南
    Docker 及 Docker Compose 安装指南
  • 原文地址：https://blog.csdn.net/m0_65152767/article/details/134043216