AI 助理
备案控制台
开发者社区 数据库 文章 正文

JAVA访问数据库之增删改查(CRUD)

2016-01-08 3265
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：

上一篇博客介绍了如何使用JAVA连接数据库，那么这一篇将继续为大家介绍如何使用JDBC对数据库的增删改查(CRUD)操作。
这一篇博客中的示例将使用上一篇中生成的H2数据库文件。

查询

查询在数据库的操作中是很重要的，我们把数据保存在数据库中，就是为了我们在需要的时候能够快速、高效的查询出来。

/**
    * 查询
    * 
    * @throws Exception
    */
   public void query() throws Exception
   {
      Connection conn = getConnection();
      Statement statement = conn.createStatement();
      ResultSet resultSet = statement
            .executeQuery("SELECT USER_ID, USER_NAME FROM USER_INFO");
      System.out.printf("%20s %50s\n", "USER_ID", "USER_NAME");
      // 遍历结果集
      while (resultSet.next())
      {
         System.out.printf("%20s %50s\n", resultSet.getString("USER_ID"),
               resultSet.getString("USER_NAME"));
      }
      resultSet.close();
      statement.close();
      conn.close();
   }

   /**
    * 通过用户编号查询
    * 
    * @param userId
    * @throws Exception
    */
   public void queryById(String userId) throws Exception
   {
      Connection conn = getConnection();
      // 动态参数使用PreparedStatement，使用Statement存在SQL注入风险
      PreparedStatement statement = conn
            .prepareStatement("SELECT USER_ID, USER_NAME FROM USER_INFO WHERE USER_ID = ?");
      statement.setString(1, userId);
      ResultSet resultSet = statement.executeQuery();
      System.out.printf("%20s %50s\n", "USER_ID", "USER_NAME");
      // 遍历结果集
      while (resultSet.next())
      {
         System.out.printf("%20s %50s\n", resultSet.getString("USER_ID"),
               resultSet.getString("USER_NAME"));
      }
      resultSet.close();
      statement.close();
      conn.close();
   }

修改

在这里，我讲增删改作为一类，同属于对数据库的修改操作，在例子中，也会发现，我们使用的方法完全相同，仅仅是SQL的区别。

/**
    * 修改
    * 
    * @param userId
    * @param userName
    * @throws Exception
    */
   public void update(String userId, String userName) throws Exception
   {
      Connection conn = getConnection();
      // 动态参数使用PreparedStatement，使用Statement存在SQL注入风险
      PreparedStatement statement = conn
            .prepareStatement("UPDATE USER_INFO SET USER_NAME = ? WHERE USER_ID = ?");
      statement.setString(1, userName);
      statement.setString(2, userId);
      System.out.println("受影响的记录条数为：" + statement.executeUpdate());
      statement.close();
      conn.close();
   }

   /**
    * 清空
    */
   public void clear() throws Exception
   {
      Connection conn = getConnection();
      Statement statement = conn.createStatement();
      System.out.println("受影响的记录条数为："
            + statement.executeUpdate("DELETE USER_INFO"));
      statement.close();
      conn.close();
   }

完整示例

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;

public class JDBCCRUDemo
{

   /**
    * 获得数据库连接
    * 
    * @return
    * @throws Exception
    */
   public Connection getConnection() throws Exception
   {
      Class.forName("org.h2.Driver");
      return DriverManager.getConnection("jdbc:h2:h2.db", "test", "123");
   }

   /**
    * 查询
    * 
    * @throws Exception
    */
   public void query() throws Exception
   {
      Connection conn = getConnection();
      Statement statement = conn.createStatement();
      ResultSet resultSet = statement
            .executeQuery("SELECT USER_ID, USER_NAME FROM USER_INFO");
      System.out.printf("%20s %50s\n", "USER_ID", "USER_NAME");
      // 遍历结果集
      while (resultSet.next())
      {
         System.out.printf("%20s %50s\n", resultSet.getString("USER_ID"),
               resultSet.getString("USER_NAME"));
      }
      resultSet.close();
      statement.close();
      conn.close();
   }

   /**
    * 通过用户编号查询
    * 
    * @param userId
    * @throws Exception
    */
   public void queryById(String userId) throws Exception
   {
      Connection conn = getConnection();
      // 动态参数使用PreparedStatement，使用Statement存在SQL注入风险
      PreparedStatement statement = conn
            .prepareStatement("SELECT USER_ID, USER_NAME FROM USER_INFO WHERE USER_ID = ?");
      statement.setString(1, userId);
      ResultSet resultSet = statement.executeQuery();
      System.out.printf("%20s %50s\n", "USER_ID", "USER_NAME");
      // 遍历结果集
      while (resultSet.next())
      {
         System.out.printf("%20s %50s\n", resultSet.getString("USER_ID"),
               resultSet.getString("USER_NAME"));
      }
      resultSet.close();
      statement.close();
      conn.close();
   }

   /**
    * 添加
    * 
    * @param userId
    * @param userName
    * @throws Exception
    */
   public void insert(String userId, String userName) throws Exception
   {
      Connection conn = getConnection();
      // 动态参数使用PreparedStatement，使用Statement存在SQL注入风险
      PreparedStatement statement = conn
            .prepareStatement("INSERT INTO USER_INFO(USER_ID, USER_NAME) VALUES(?, ?)");
      statement.setString(1, userId);
      statement.setString(2, userName);
      System.out.println("受影响的记录条数为：" + statement.executeUpdate());
      statement.close();
      conn.close();
   }

   /**
    * 修改
    * 
    * @param userId
    * @param userName
    * @throws Exception
    */
   public void update(String userId, String userName) throws Exception
   {
      Connection conn = getConnection();
      // 动态参数使用PreparedStatement，使用Statement存在SQL注入风险
      PreparedStatement statement = conn
            .prepareStatement("UPDATE USER_INFO SET USER_NAME = ? WHERE USER_ID = ?");
      statement.setString(1, userName);
      statement.setString(2, userId);
      System.out.println("受影响的记录条数为：" + statement.executeUpdate());
      statement.close();
      conn.close();
   }

   /**
    * 清空
    */
   public void clear() throws Exception
   {
      Connection conn = getConnection();
      Statement statement = conn.createStatement();
      System.out.println("受影响的记录条数为："
            + statement.executeUpdate("DELETE USER_INFO"));
      statement.close();
      conn.close();
   }

   public static void main(String[] args) throws Exception
   {
      JDBCCRUDemo demo = new JDBCCRUDemo();
      demo.insert("id111", "name111");
      demo.insert("id222", "name222");
      demo.insert("id333", "name333");
      demo.insert("id444", "name444");
      demo.insert("id555", "name555");
      demo.query();
      demo.queryById("id444");
      demo.update("id222", "name1234");
      demo.query();
      demo.clear();
   }
}

运行结果：
受影响的记录条数为：1
受影响的记录条数为：1
受影响的记录条数为：1
受影响的记录条数为：1
受影响的记录条数为：1
             USER_ID                                          USER_NAME
               id111                                            name111
               id222                                            name222
               id333                                            name333
               id444                                            name444
               id555                                            name555
             USER_ID                                          USER_NAME
               id444                                            name444
受影响的记录条数为：1
             USER_ID                                          USER_NAME
               id111                                            name111
               id333                                            name333
               id444                                            name444
               id555                                            name555
               id222                                           name1234
受影响的记录条数为：5

文章标签：
数据库
Java
SQL
数据库连接
关键词：
Java库
Java访问
Java数据库
数据库java
数据库增删改查
蒋固金
目录
相关文章
最好zzz
|
4天前
|
Java API Apache
Java中Excel导出的高效解决方案：探索JXLS库
【10月更文挑战第29天】
最好zzz
30 2
东方睿赢
|
7天前
|
SQL Java 数据库连接
在Java应用中，数据库访问常成为性能瓶颈。连接池技术通过预建立并复用数据库连接，有效减少连接开销，提升访问效率
在Java应用中，数据库访问常成为性能瓶颈。连接池技术通过预建立并复用数据库连接，有效减少连接开销，提升访问效率。本文介绍了连接池的工作原理、优势及实现方法，并提供了HikariCP的示例代码。
东方睿赢
20 3
东方睿赢
|
7天前
|
存储 Java 关系型数据库
在Java开发中，数据库连接是应用与数据交互的关键环节。本文通过案例分析，深入探讨Java连接池的原理与最佳实践
在Java开发中，数据库连接是应用与数据交互的关键环节。本文通过案例分析，深入探讨Java连接池的原理与最佳实践，包括连接创建、分配、复用和释放等操作，并通过电商应用实例展示了如何选择合适的连接池库（如HikariCP）和配置参数，实现高效、稳定的数据库连接管理。
东方睿赢
20 2
龙大吉
|
7天前
|
Java 数据库连接 数据库
如何构建高效稳定的Java数据库连接池，涵盖连接池配置、并发控制和异常处理等方面
本文介绍了如何构建高效稳定的Java数据库连接池，涵盖连接池配置、并发控制和异常处理等方面。通过合理配置初始连接数、最大连接数和空闲连接超时时间，确保系统性能和稳定性。文章还探讨了同步阻塞、异步回调和信号量等并发控制策略，并提供了异常处理的最佳实践。最后，给出了一个简单的连接池示例代码，并推荐使用成熟的连接池框架（如HikariCP、C3P0）以简化开发。
龙大吉
20 2
众所周知
|
9天前
|
Java 数据库连接 数据库
优化之路：Java连接池技术助力数据库性能飞跃
在Java应用开发中，数据库操作常成为性能瓶颈。频繁的数据库连接建立和断开增加了系统开销，导致性能下降。本文通过问题解答形式，深入探讨Java连接池技术如何通过复用数据库连接，显著减少连接开销，提升系统性能。文章详细介绍了连接池的优势、选择标准、使用方法及优化策略，帮助开发者实现数据库性能的飞跃。
众所周知
18 4
东方睿赢
|
7天前
|
Java 数据库连接 数据库
深入探讨Java连接池技术如何通过复用数据库连接、减少连接建立和断开的开销，从而显著提升系统性能
在Java应用开发中，数据库操作常成为性能瓶颈。本文通过问题解答形式，深入探讨Java连接池技术如何通过复用数据库连接、减少连接建立和断开的开销，从而显著提升系统性能。文章介绍了连接池的优势、选择和使用方法，以及优化配置的技巧。
东方睿赢
11 1
众所周知
|
7天前
|
Java 数据库连接 数据库
Java连接池在数据库性能优化中的重要作用。连接池通过预先创建和管理数据库连接，避免了频繁创建和关闭连接的开销
本文深入探讨了Java连接池在数据库性能优化中的重要作用。连接池通过预先创建和管理数据库连接，避免了频繁创建和关闭连接的开销，显著提升了系统的响应速度和吞吐量。文章介绍了连接池的工作原理，并以HikariCP为例，展示了如何在Java应用中使用连接池。通过合理配置和优化，连接池技术能够有效提升应用性能。
众所周知
22 1
众所周知
|
7天前
|
监控 Java 数据库连接
在Java开发中，数据库连接管理是关键问题之一
在Java开发中，数据库连接管理是关键问题之一。本文介绍了连接池技术如何通过预创建和管理数据库连接，提高数据库操作的性能和稳定性，减少资源消耗，并简化连接管理。通过示例代码展示了HikariCP连接池的实际应用。
众所周知
13 1
龙大吉
|
9天前
|
SQL Java 数据库连接
打破瓶颈：利用Java连接池技术提升数据库访问效率
在Java应用中，数据库访问常成为性能瓶颈。连接池技术通过预建立并复用数据库连接，避免了频繁的连接建立和断开，显著提升了数据库访问效率。常见的连接池库包括HikariCP、C3P0和DBCP，它们提供了丰富的配置选项和强大的功能，帮助优化应用性能。
龙大吉
27 2
java冯坚持
|
26天前
|
Java 数据库
案例一：去掉数据库某列中的所有英文，利用java正则表达式去做，核心：去掉字符串中的英文
这篇文章介绍了如何使用Java正则表达式从数据库某列中去除所有英文字符。
java冯坚持
37 15

热门文章

最新文章

  • 1
    Java本地文件操作(六）文件的简单读写
  • 2
    Java魔法堂：类加载器入了个门
  • 3
    JAVA DES
  • 4
    Java视频流提取与播放技术详解
  • 5
    阿里官方Java代码规范标准解析 - 基本数据类型与包装数据类型的使用标准
  • 6
    16.2. jps - Java Virtual Machine Process Status Tool
  • 7
    Java类库中的一些常用的查找排序
  • 8
    java 适配器模式
  • 9
    JAVA SERVLET 属性范围样例
  • 10
    通过java api提交自定义hadoop 作业
  • 1
    关系型数据库的安装和配置数据库节点
    203
  • 2
    MySQL数据库的约束+进阶版新增与查询-2
    81
  • 3
    AIX数据库启动和停止脚本
    41
  • 4
    数据库性能诊断工具DBdoctor通过阿里云PolarDB产品生态集成认证
    354
  • 5
    修改SAP数据库用户密码的参考
    109
  • 6
    JDBC Java标准库提供的一些api(类+方法) 统一各种数据库提供的api
    47
  • 7
    数据库的约束
    31
  • 8
    SQL主体内容一致,但是对于不同的数据库,对于SQL就可能有一些细节的拓展
    46
  • 9
    关系型数据库选择合适的数据库管理系统
    339
  • 10
    关系型数据库做好备份
    70

    • 相关课程

    更多
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - Java Web开发
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java编程入门
  • Java面向对象编程
  • Java高级编程

    • 相关电子书

    更多
  • Spring Cloud Alibaba - 重新定义 Java Cloud-Native
  • The Reactive Cloud Native Arch
  • JAVA开发手册1.5.0

    • 相关实验场景

    更多
  • 基于ECS搭建Java Web开发环境
  • 数据库实验室挑战任务-高级任务
  • 阿里云数据库产品实验室
  • 使用Aliyun Java Intializr进行项目开发
  • 搭建Java Web开发环境
  • 部署基于Dragonwell的Java运行环境
    • 下一篇
    DataWorks智能数据建模全面公测开始啦！