JDBC中数据库的增删改查操作

我会带着你远行 2023-07-10 14:10 42阅读 0赞

一、数据库编程一般过程

在这里插入图片描述
图为数据库编程的一般过程，其中查询（Read）过程最多需要7个步骤，修改（C插入、U 更新、D删除）过程最多需要5个步骤。这个过程采用了预编译语句对象进行数据操作，所以有可能进 行绑定参数。

在编程之前先交代一下config.properties文件：

  1. driver=com.mysql.cj.jdbc.Driver
  2. url=jdbc:mysql://localhost:3306/JAVA
  3. user=root
  4. password=199911
  5. useSSL=false
  6. verifyServerCertificate=false

准备好的数据库
在这里插入图片描述

二、数据查询操作

（1）有条件查询

代码如下：

  1. import java.io.IOException;
  2. import java.io.InputStream;
  3. import java.sql.*;
  4. import java.util.Properties;
  6. /** * @author : 蔡政洁 * @email :caizhengjie888@icloud.com * @date : 2020/3/2 * @time : 3:48 下午 */
  7. //不使用自动资源管理
  8. public class CRUDSample1 { 
  9. // 连接数据库
  10.     static String url;
  11. // 创建properties对象
  12.     static Properties info = new Properties();
  14. // 1.驱动程序加载，放在静态代码块中，在静态代码块中读取属性文件内容到Properties对象和加载驱动程序，这两个操作只需执行一次
  15.     static { 
  16. // 获得属性文件输入流
  17.         InputStream inputStream = CRUDSample1.class.getClassLoader().getResourceAsStream("config.properties");
  18.         try { 
  19. // 加载属性文件内容到Properties对象
  20.             info.load(inputStream);
  21. // 从属性文件中读取URL
  22.             url = info.getProperty("url");
  23. // 从属性文件中读取driver
  24.             String driverClassname = info.getProperty("driver");
  25. // 驱动程序加载
  26.             Class.forName(driverClassname);
  27.             System.out.println("驱动程序加载成功");
  29.         } catch (IOException e) { 
  30.             System.out.println("加载属性文件失败");
  31.             e.printStackTrace();
  32.         } catch (ClassNotFoundException e) { 
  33.             System.out.println("驱动程序加载失败");
  34.             e.printStackTrace();
  35.         }
  36.     }
  37. //主函数
  38.     public static void main(String[] args) { 
  39. // 查询数据
  40.         read();
  41.     }
  43. // 数据查询操作
  44.     public static void read(){ 
  46.         Connection conn = null;
  47.         PreparedStatement pstmt = null;
  48.         ResultSet rs = null;
  50.         try { 
  51. // 2.创建数据库连接
  52.             conn = DriverManager.getConnection(url,info);
  53.             System.out.println("数据库连接成功");
  54. // 3.创建语句对象,返回PreparedStatement对象
  55. // 这里查询的是数据库中id大于2的人的姓名和年龄
  56.             pstmt = conn.prepareStatement("select name,age from xinxi_tb where id > ? order by id");
  57. // 4.绑定参数
  58.             /** * 绑定参数时需要注意两个问题：绑定参数顺序 和 绑定参数的类型 * 绑定参数索引是 从1开始的，而不是从0开始的。 * 根据绑定参数的类型不同选择对应的set方法。 */
  59.             pstmt.setInt(1,3);
  60. // 5.执行查询
  61.             rs =  pstmt.executeQuery();
  62. // 6.遍历结果集
  63.             while (rs.next()){ 
  64.                 /**注意点：列名对应的数据类型，rs.getX就对应什么，例如（name: %s，rs.getString("name"或者为 1 )） *rs.getX(可以设置为columnindex = （查找的列的索引，从1开始索引），或columnLabel = "列名") */
  65.                 System.out.printf("name: %s,age: %d\n",rs.getString(1),rs.getInt("age"));
  66.             }
  68.         } catch (SQLException e) { 
  69.             e.printStackTrace();
  70. // 7.释放资源，这里也可以选择自动资源管理
  71.         }finally { 
  72.             if (rs != null){ 
  73.                 try { 
  74.                     rs.close();
  75.                 } catch (SQLException e) { 
  76.                     e.printStackTrace();
  77.                 }
  78.             }
  79.             if (pstmt != null){ 
  80.                 try { 
  81.                     pstmt.close();
  82.                 } catch (SQLException e) { 
  83.                     e.printStackTrace();
  84.                 }
  85.             }
  86.             if (conn != null){ 
  87.                 try { 
  88.                     conn.close();
  89.                 }catch (SQLException e) { 
  90.                     e.printStackTrace();
  91.                 }
  92.             }
  93.         }
  94.     }
  95. }

运行结果：

  1. 驱动程序加载成功
  2. 数据库连接成功
  3. name: 雷军,age: 43
  4. name: 马云,age: 56
  5. name: 马化腾,age: 49

（2）无条件查询

代码如下：

  1. import java.io.IOException;
  2. import java.io.InputStream;
  3. import java.sql.*;
  4. import java.util.Properties;
  6. /** * @author : 蔡政洁 * @email :caizhengjie888@icloud.com * @date : 2020/3/2 * @time : 6:01 下午 */
  7. //使用自动资源管理系统
  8. public class CRUDSample2 { 
  9.     // 连接数据库
  10.     static String url;
  11.     // 创建properties对象
  12.     static Properties info = new Properties();
  14.     // 1.驱动程序加载，放在静态代码块中，在静态代码块中读取属性文件内容到Properties对象和加载驱动程序，这两个操作只需执行一次
  15.     static { 
  16. // 获得属性文件输入流
  17.         InputStream inputStream = CRUDSample2.class.getClassLoader().getResourceAsStream("config.properties");
  18.         try { 
  19. // 加载属性文件内容到Properties对象
  20.             info.load(inputStream);
  21. // 从属性文件中读取URL
  22.             url = info.getProperty("url");
  23. // 从属性文件中读取driver
  24.             String driverClassname = info.getProperty("driver");
  25. // 驱动程序加载
  26.             Class.forName(driverClassname);
  27.             System.out.println("驱动程序加载成功");
  29.         } catch (IOException e) { 
  30.             System.out.println("加载属性文件失败");
  31.             e.printStackTrace();
  32.         } catch (ClassNotFoundException e) { 
  33.             System.out.println("驱动程序加载失败");
  34.             e.printStackTrace();
  35.         }
  36.     }
  37.     //主函数
  38.     public static void main(String[] args) { 
  39. // 查询最大的用户id
  40.         System.out.println(readMaxUserID());
  41.     }
  43. // 查询最大的用户id
  44.     public  static int readMaxUserID(){ 
  45.         int maxid = 0;
  46.         try (
  47. // 2.创建数据库连接
  48.             Connection conn = DriverManager.getConnection(url,info);
  49. // 3.创建语句对象
  50.             PreparedStatement pstmt = conn.prepareStatement("select max(id) from xinxi_tb");
  51. // 4。执行查询
  52.             ResultSet rs = pstmt.executeQuery()
  53.             ){ 
  54. // 打印数据库连接信息
  55.             System.out.println("数据库连接成功");
  56. // 5.遍历结果集
  57.             if (rs.next()){ 
  58.                 maxid = rs.getInt(1);
  59.             }
  60.         } catch (SQLException e) { 
  61.             e.printStackTrace();
  62.         }
  63.         return maxid;
  64.     }
  65. }

运行结果：

  1. 驱动程序加载成功
  2. 数据库连接成功
  3. 6

三、数据插入

代码如下：

  1. import java.io.IOException;
  2. import java.io.InputStream;
  3. import java.sql.Connection;
  4. import java.sql.DriverManager;
  5. import java.sql.PreparedStatement;
  6. import java.sql.SQLException;
  7. import java.util.Properties;
  9. /** * @author : 蔡政洁 * @email :caizhengjie888@icloud.com * @date : 2020/3/2 * @time : 6:15 下午 */
  10. //使用自动资源管理系统
  11.         public class CRUDSample3 { 
  12.             // 连接数据库
  13.             static String url;
  14.             // 创建properties对象
  15.             static Properties info = new Properties();
  17.             // 1.驱动程序加载，放在静态代码块中，在静态代码块中读取属性文件内容到Properties对象和加载驱动程序，这两个操作只需执行一次
  18.             static { 
  19. // 获得属性文件输入流
  20.                 InputStream inputStream = CRUDSample2.class.getClassLoader().getResourceAsStream("config.properties");
  21.                 try { 
  22. // 加载属性文件内容到Properties对象
  23.             info.load(inputStream);
  24. // 从属性文件中读取URL
  25.             url = info.getProperty("url");
  26. // 从属性文件中读取driver
  27.             String driverClassname = info.getProperty("driver");
  28. // 驱动程序加载
  29.             Class.forName(driverClassname);
  30.             System.out.println("驱动程序加载成功");
  32.         } catch (IOException e) { 
  33.             System.out.println("加载属性文件失败");
  34.             e.printStackTrace();
  35.         } catch (ClassNotFoundException e) { 
  36.             System.out.println("驱动程序加载失败");
  37.             e.printStackTrace();
  38.         }
  39.     }
  41.     //主函数
  42.     public static void main(String[] args) { 
  43. // 数据插入操作
  44.         create();
  45.     }
  46.     public static void create(){ 
  47.         try (
  48. // 2.创建数据库连接
  49.                 Connection conn = DriverManager.getConnection(url,info);
  51. // 3.创建语句对象
  52.                 PreparedStatement pstmt = conn.prepareStatement("insert into xinxi_tb (id, name, age) values (?,?,?)");
  53.                 ){ 
  54. // 打印数据库连接信息
  55.             System.out.println("数据库连接成功");
  56. // 4.绑定参数
  57.             pstmt.setInt(1,6);
  58.             pstmt.setString(2,"马化腾");
  59.             pstmt.setInt(3,49);
  60. // 5.执行修改
  61. // 行executeUpdate()方法执行SQL语句，该 方法与查询方法executeQuery()不同。executeUpdate()方法返回的是整数，成功影响的记录数， 即成功插入记录数。
  62.             int affectedRows = pstmt.executeUpdate();
  64.             System.out.printf("成功插入%d条数据\n",affectedRows);
  66.         } catch (SQLException e) { 
  67.             e.printStackTrace();
  68.         }
  69.     }
  70. }

这里要根据自己数据库的实际情况来修改代码，才能运行

四、数据更新

代码如下：

  1. import java.io.IOException;
  2. import java.io.InputStream;
  3. import java.sql.Connection;
  4. import java.sql.DriverManager;
  5. import java.sql.PreparedStatement;
  6. import java.sql.SQLException;
  7. import java.util.Properties;
  9. /** * @author : 蔡政洁 * @email :caizhengjie888@icloud.com * @date : 2020/3/2 * @time : 6:40 下午 */
  10. //使用自动资源管理系统
  11. public class CRUDSample4 { 
  12.     // 连接数据库
  13.     static String url;
  14.     // 创建properties对象
  15.     static Properties info = new Properties();
  17.     // 1.驱动程序加载，放在静态代码块中，在静态代码块中读取属性文件内容到Properties对象和加载驱动程序，这两个操作只需执行一次
  18.     static { 
  19. // 获得属性文件输入流
  20.         InputStream inputStream = CRUDSample4.class.getClassLoader().getResourceAsStream("config.properties");
  21.         try { 
  22. // 加载属性文件内容到Properties对象
  23.             info.load(inputStream);
  24. // 从属性文件中读取URL
  25.             url = info.getProperty("url");
  26. // 从属性文件中读取driver
  27.             String driverClassname = info.getProperty("driver");
  28. // 驱动程序加载
  29.             Class.forName(driverClassname);
  30.             System.out.println("驱动程序加载成功");
  32.         } catch (IOException e) { 
  33.             System.out.println("加载属性文件失败");
  34.             e.printStackTrace();
  35.         } catch (ClassNotFoundException e) { 
  36.             System.out.println("驱动程序加载失败");
  37.             e.printStackTrace();
  38.         }
  39.     }
  40.     //主函数
  41.     public static void main(String[] args) { 
  42. // 数据更新操作
  43.         update();
  45.     }
  46.     public static void update(){ 
  47.         try (
  48. // 2.创建数据库连接
  49.                 Connection conn = DriverManager.getConnection(url,info);
  50. // 3.创建语句对象
  51.                 PreparedStatement pstmt = conn.prepareStatement("update xinxi_tb set name = ? where id = ?");
  52.                 ){ 
  53. // 打印数据库连接信息
  54.             System.out.println("数据库连接成功");
  55. // 4.绑定参数
  56.             pstmt.setString(1,"雷军");
  57.             pstmt.setInt(2,4);
  58. // 5.执行修改
  59.             int affectedRows = pstmt.executeUpdate();
  61.             System.out.printf("成功更新%d条数据\n",affectedRows);
  63.         } catch (SQLException e) { 
  64.             e.printStackTrace();
  65.         }
  66.     }
  67. }

这里要根据自己数据库的实际情况来修改代码，才能运行

五、数据删除

代码如下：

  1. import java.io.IOException;
  2. import java.io.InputStream;
  3. import java.sql.Connection;
  4. import java.sql.DriverManager;
  5. import java.sql.PreparedStatement;
  6. import java.sql.SQLException;
  7. import java.util.Properties;
  9. /** * @author : 蔡政洁 * @email :caizhengjie888@icloud.com * @date : 2020/3/2 * @time : 6:49 下午 */
  10. //使用自动资源管理系统
  11. public class CRUDSample5 { 
  12.     // 连接数据库
  13.     static String url;
  14.     // 创建properties对象
  15.     static Properties info = new Properties();
  17.     // 1.驱动程序加载，放在静态代码块中，在静态代码块中读取属性文件内容到Properties对象和加载驱动程序，这两个操作只需执行一次
  18.     static { 
  19. // 获得属性文件输入流
  20.         InputStream inputStream = CRUDSample2.class.getClassLoader().getResourceAsStream("config.properties");
  21.         try { 
  22. // 加载属性文件内容到Properties对象
  23.             info.load(inputStream);
  24. // 从属性文件中读取URL
  25.             url = info.getProperty("url");
  26. // 从属性文件中读取driver
  27.             String driverClassname = info.getProperty("driver");
  28. // 驱动程序加载
  29.             Class.forName(driverClassname);
  30.             System.out.println("驱动程序加载成功");
  32.         } catch (IOException e) { 
  33.             System.out.println("加载属性文件失败");
  34.             e.printStackTrace();
  35.         } catch (ClassNotFoundException e) { 
  36.             System.out.println("驱动程序加载失败");
  37.             e.printStackTrace();
  38.         }
  39.     }
  40.     //主函数
  41.     public static void main(String[] args) { 
  42. // 数据删除操作
  43.         delete();
  44.     }
  45.     public static void delete(){ 
  46.         try (
  47. // 2.创建数据库连接
  48.                 Connection conn = DriverManager.getConnection(url,info);
  49. // 3.创建语句对象
  50.                 PreparedStatement pstmt = conn.prepareStatement("delete from xinxi_tb where id = ?");
  51.                 ){ 
  52. // 打印数据库连接信息
  53.             System.out.println("数据库连接成功");
  54. // 4.绑定参数
  55.             pstmt.setInt(1, 3);
  56. // 5.执行修改
  57.             int affectedRows = pstmt.executeUpdate();
  59.             System.out.printf("成功删除%d条数据\n",affectedRows);
  61.         } catch (SQLException e) { 
  62.             e.printStackTrace();
  63.         }
  64.     }
  65. }

这里要根据自己数据库的实际情况来修改代码，才能运行

总结：学好数据库编程还是需要掌握一些MySQL的基本语句，如果您想更多的了解MySQL常用命令，可以详见连接https://blog.csdn.net/weixin_45366499/article/details/104585167
相信它一定对您有帮助！

以上内容仅供参考学习，如有侵权请联系我删除！
如果这篇文章对您有帮助，左下角的大拇指就是对博主最大的鼓励。
您的鼓励就是博主最大的动力！

发表评论

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

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

相关阅读