使用JDBC操作数据库

03-02 1574阅读

文章目录

    • 1. JDBC简单介绍
      • 1.1 JDBC起源
      • 2. JDBC连接流程
      • 3. 示例代码
        • 3.1 数据源(Getting the DataSource)
        • 3.2 建立数据库连接
        • 3.3 构造SQL语句
        • 3.4 预编译SQL语句并执行
        • 3.5 释放资源
        • 4. 注意事项

          1. JDBC简单介绍

          JDBC,全称是Java Database Connectivity,就是Java数据库连接,它是一个Java API,用于Java程序和数据库之间的通信。简单来说,就像是一个桥梁,让Java应用程序能够执行SQL语句,以查询和操作数据库中的数据。

          1.1 JDBC起源

          那JDBC是怎么来的呢?回到1990年代中期,Java刚刚诞生不久后,就开始被广泛应用于网络和企业环境中。随着Java的普及,需要一个标准的方法让Java应用程序能够与数据库交互,因为那个时候的数据库种类很多,每种数据库都有自己的连接方法,这对于开发者来说太复杂了。

          为了解决这个问题,Sun Microsystems(Java的开发者)在1997年发布了JDBC规范。JDBC通过提供一套统一的API,让Java应用无论背后是什么数据库,都能用同样的方式来访问数据库,极大地简化了数据库编程工作。这样,开发者就不需要针对每一种数据库编写不同的代码了,只需学习JDBC API,就可以实现与数据库的交互,这也促进了Java在企业级应用中的广泛应用。

          使用JDBC操作数据库

          2. JDBC连接流程

          JDBC操作数据库的基本流程通常分为以下几个步骤:
          
          1. 建立数据源
          2. 建立连接
          3. 创建PreparedStatement
          4. 执行SQL语句
          5. 处理结果集
          6. 关闭连接

          3. 示例代码

          下面的示例代码展示了如何使用 JDBC 连接到一个 数据库 ,并执行一个简单的查询操作:
          import com.mysql.cj.jdbc.MysqlDataSource;
          import javax.sql.DataSource;
          import java.sql.Connection;
          import java.sql.PreparedStatement;
          import java.sql.ResultSet;
          import java.sql.SQLException;
          import java.util.Scanner;
          /**
           * Created with IntelliJ IDEA.
           * Description:
           * User: 指向五年
           * Date: 2024-03-01
           * Time: 19:53
           */
          public class JDBCDrop {
              public static void main(String[] args) throws SQLException {
                  Scanner scanner = new Scanner(System.in);
          		//1.获取数据源(解释数据从哪里来)
                  DataSource dataSource = new MysqlDataSource();
                  ((MysqlDataSource)dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/java?characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghai");
                  ((MysqlDataSource)dataSource).setUser("root");
                  ((MysqlDataSource)dataSource).setPassword("******");
          		//2.知道数据库在哪里之后就可以和数据库建立连接.
                  Connection connection = dataSource.getConnection();
          		//3.构造SQL语句
                  System.out.println("输入你要删除学生的id:");
                  int id = scanner.nextInt();
                  String sql = "delete from student1 where id = ?";
                    //为了减轻服务器的压力,在客户端完成预编译
                  PreparedStatement statement = connection.prepareStatement(sql);
                  statement.setInt(1,id);
          		//4.运行SQL语句
                  int ret = statement.executeUpdate();
                  System.out.println("ret = " + ret);
          		//5.释放资源
                  statement.close();
                  connection.close();
              }
          }
          

          3.1 数据源(Getting the DataSource)

          数据源(DataSource)是一个能够建立数据库连接的对象。使用DataSource不仅可以简化数据库连接的代码,还可以通过连接池(如C3P0、HikariCP等)来提高应用性能。在这个示例中,我们将使用MysqlDataSource,它是MySQL Connector/J驱动的一部分,专门用于创建MySQL数据库的连接。

          DataSource dataSource = new MysqlDataSource();
          ((MysqlDataSource)dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/java?characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghai");
          ((MysqlDataSource)dataSource).setUser("root");
          ((MysqlDataSource)dataSource).setPassword("******");
          

          这段代码首先实例化了一个MysqlDataSource对象,并通过向上转型赋值给DataSource类型的变量。然后,我们设置数据库的URL、用户名和密码。这是建立数据库连接的必要信息。

          3.2 建立数据库连接

          一旦配置好DataSource,就可以用它来获取数据库的连接了:

          Connection connection = dataSource.getConnection();
          

          这一步骤通过调用DataSource的getConnection()方法来完成,它会返回一个Connection对象。这个对象代表了Java应用程序和数据库之间的连接。

          3.3 构造SQL语句

          接下来,我们需要构造一个SQL语句来执行。在这个示例中,我们将执行一个插入操作:

          String sql = "insert into student values (11,'张三',22)";
          

          这条SQL语句意图是向student表中插入一条新的记录。

          3.4 预编译SQL语句并执行

          为了减少服务器的压力并提高性能,我们在客户端对SQL语句进行预编译:

          PreparedStatement statement = connection.prepareStatement(sql);
          

          通过Connection对象的prepareStatement方法,我们传入了SQL语句并得到了一个PreparedStatement对象。然后,我们执行这个预编译的SQL语句:

          int ret = statement.executeUpdate();
          System.out.println("ret = " + ret);
          

          executeUpdate方法执行SQL语句(如插入、更新或删除操作),并返回一个整数,表示受影响的行数。这个返回值可以帮助我们确认操作是否成功执行。

          3.5 释放资源

          最后,不要忘记释放资源:

          statement.close();
          connection.close();
          

          关闭PreparedStatement和Connection对象是非常重要的,以释放数据库资源并避免潜在的内存泄漏。

          4. 注意事项

          • 确保在开始之前已经将JDBC驱动添加到项目的依赖中。
          • JDBC URL、用户名和密码需要根据实际的数据库配置进行修改。
          • 处理异常是很重要的,确保在发生异常时能够妥善处理。
VPS购买请点击我

文章版权声明:除非注明,否则均为主机测评原创文章,转载或复制请以超链接形式并注明出处。

目录[+]