7.1. JDBC简介

这篇具有很好参考价值的文章主要介绍了7.1. JDBC简介。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

1. 什么是JDBC?

JDBC(Java Database Connectivity)是一个Java API,用于连接和执行SQL语句与关系型数据库进行交互。JDBC提供了一组接口和类,使Java程序能够与各种数据库通信,如MySQL、Oracle、PostgreSQL等。

2. JDBC的主要组件

JDBC主要由以下几个组件组成:

  • DriverManager:负责加载数据库驱动,并建立与数据库的连接。
  • Connection:表示与数据库的连接。
  • Statement:用于执行SQL语句。
  • PreparedStatement:用于执行预编译的SQL语句。
  • ResultSet:表示查询结果集。

3. 连接数据库

在连接数据库之前,需要确保已经安装了相应的数据库驱动并将其添加到项目中。以下是一个简单示例,演示如何使用JDBC连接到MySQL数据库:

java

Copy

import java.sql.Connection;
import java.sql.DriverManager;

public class JdbcConnectExample {
    public static void main(String[] args) {
        try {
            // 加载数据库驱动
            Class.forName("com.mysql.cj.jdbc.Driver");

            // 连接到数据库
            String url = "jdbc:mysql://localhost:3306/mydb?useUnicode=true&characterEncoding=utf-8&useSSL=false&allowPublicKeyRetrieval=true";
            String username = "root";
            String password = "mypassword";
            Connection connection = DriverManager.getConnection(url, username, password);

            System.out.println("Connected to database!");

            // 关闭连接
            connection.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

4. 执行SQL查询

要使用JDBC执行SQL查询,可以创建一个Statement对象,然后调用其executeQuery()方法。以下是一个简单示例,演示如何查询数据库中的数据:

java

Copy

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

public class JdbcQueryExample {
    public static void main(String[] args) {
        try {
            // 加载数据库驱动并连接到数据库
            Class.forName("com.mysql.cj.jdbc.Driver");
            String url = "jdbc:mysql://localhost:3306/mydb?useUnicode=true&characterEncoding=utf-8&useSSL=false&allowPublicKeyRetrieval=true";
            String username = "root";
            String password = "mypassword";
            Connection connection = DriverManager.getConnection(url, username, password);

            // 创建Statement对象并执行SQL查询
            Statement statement = connection.createStatement();
            String sql = "SELECT id, name FROM users";
            ResultSet resultSet = statement.executeQuery(sql);

            // 处理结果集
            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("name");
                System.out.println("ID: " + id + ", Name: " + name);
            }

            // 关闭资源
            resultSet.close();
            statement.close();
            connection.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

5. 执行SQL更新

要使用JDBC执行SQL更新(如插入、更新或删除),可以创建一个Statement对象,然后调用其executeUpdate()方法。以下是一个简单示例,演示如何向数据库中插入数据:

java

Copy

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

public class JdbcUpdateExample {
    public static void main(String[] args) {
        try {
            // 加载数据库驱动并连接到数据库
            Class.forName("com.mysql.cj.jdbc.Driver");
            String url = "jdbc:mysql://localhost:3306/mydb?useUnicode=true&characterEncoding=utf-8&useSSL=false&allowPublicKeyRetrieval=true";
            String username = "root";
            String password = "mypassword";
            Connection connection = DriverManager.getConnection(url, username, password);

            // 创建Statement对象并执行SQL更新
            Statement statement = connection.createStatement();
            String sql = "INSERT INTO users (name, age) VALUES ('John Doe', 30)";
            int rowsAffected = statement.executeUpdate(sql);

            System.out.println("Rows affected: " + rowsAffected);

            // 关闭资源
            statement.close();
            connection.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

**6. 使用PreparedStatement**

`PreparedStatement`是一个预编译的`Statement`对象,可以提高SQL语句的执行效率。它还可以防止SQL注入攻击。以下是一个简单示例,演示如何使用`PreparedStatement`插入数据:

```java
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;

public class JdbcPreparedStatementExample {
    public static void main(String[] args) {
        try {
            // 加载数据库驱动并连接到数据库
            Class.forName("com.mysql.cj.jdbc.Driver");
            String url = "jdbc:mysql://localhost:3306/mydb?useUnicode=true&characterEncoding=utf-8&useSSL=false&allowPublicKeyRetrieval=true";
            String username = "root";
            String password = "mypassword";
            Connection connection = DriverManager.getConnection(url, username, password);

            // 创建PreparedStatement对象并执行SQL更新
            String sql = "INSERT INTO users (name, age) VALUES (?, ?)";
            PreparedStatement preparedStatement = connection.prepareStatement(sql);
            preparedStatement.setString(1, "Jane Doe");
            preparedStatement.setInt(2, 28);
            int rowsAffected = preparedStatement.executeUpdate();

            System.out.println("Rows affected: " + rowsAffected);

            // 关闭资源
            preparedStatement.close();
            connection.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

7. 事务处理

事务是一组逻辑操作单元,执行这些操作要么全部成功,要么全部失败。在JDBC中,可以使用Connection对象的commit()rollback()方法进行事务处理。以下是一个简单示例,演示如何使用事务处理:

java

Copy

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

public class JdbcTransactionExample {
    public static void main(String[] args) {
        Connection connection = null;
        PreparedStatement preparedStatement = null;

        try {
            // 加载数据库驱动并连接到数据库
            Class.forName("com.mysql.cj.jdbc.Driver");
            String url = "jdbc:mysql://localhost:3306/mydb?useUnicode=true&characterEncoding=utf-8&useSSL=false&allowPublicKeyRetrieval=true";
            String username = "root";
            String password = "mypassword";
            connection = DriverManager.getConnection(url, username, password);

            // 关闭自动提交(开启事务)
            connection.setAutoCommit(false);

            // 执行SQL更新
            String sql = "UPDATE users SET age = age + 1 WHERE id = ?";
            preparedStatement = connection.prepareStatement(sql);
            preparedStatement.setInt(1, 1);
            preparedStatement.executeUpdate();

            // 提交事务
            connection.commit();
            System.out.println("Transaction committed.");
        } catch (Exception e) {
            // 回滚事务
            try {
                if (connection != null) {
                    connection.rollback();
                    System.out.println("Transaction rolled back.");
                }
            } catch (Exception ex) {
                ex.printStackTrace();
            }
            e.printStackTrace();
        } finally {
            // 关闭资源
            try {
                if (preparedStatement != null) {
                    preparedStatement.close();
                }
                if (connection != null) {
                    connection.close();
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

8. 关闭资源

在JDBC中,需要确保及时关闭资源,如ConnectionStatementResultSet等。可以使用close()方法或者Java 7中引入的try-with-resources语句进行资源关闭。以下是一个简单示例,演示如何使用try-with-resources关闭资源:

java

Copy

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

public class JdbcCloseResourceExample {
    public static void main(String[] args) {
        try {
            // 加载数据库驱动
            Class.forName("com.mysql.cj.jdbc.Driver");

            // 连接到数据库
            String url = "jdbc:mysql://localhost:3306/mydb?useUnicode=true&characterEncoding=utf-8&useSSL=false&allowPublicKeyRetrieval=true";
            String username = "root";
            String password = "mypassword";

            try (Connection connection = DriverManager.getConnection(url, username, password);
                 Statement statement = connection.createStatement()) {

                // 执行SQL查询并处理结果集

推荐阅读:

https://mp.weixin.qq.com/s/dV2JzXfgjDdCmWRmE0glDA

https://mp.weixin.qq.com/s/an83QZOWXHqll3SGPYTL5g

7.1. JDBC简介文章来源地址https://www.toymoban.com/news/detail-469990.html

到了这里,关于7.1. JDBC简介的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

原文地址:https://www.cnblogs.com/yaoqian/p/17454763.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 7.1. JDBC简介

    1. 什么是JDBC? JDBC(Java Database Connectivity)是一个Java API,用于连接和执行SQL语句与关系型数据库进行交互。JDBC提供了一组接口和类,使Java程序能够与各种数据库通信,如MySQL、Oracle、PostgreSQL等。 2. JDBC的主要组件 JDBC主要由以下几个组件组成: DriverManager :负责加载数据库驱

    2024年02月07日
    浏览(8)
  • 【云原生技术】云计算中,时序数据库(Time-Series Database,TSDB)简介

    时序数据库(Time-Series Database,TSDB)是专门为处理时间序列数据(即随时间变化的数据序列)设计的数据库类型。在云计算环境中,时序数据库的应用日益增多,特别是在物联网(IoT)、监控、日志数据管理、金融市场和其他需要快速、高效处理大量时间序列数据的领域。

    2024年01月22日
    浏览(10)
  • 【云原生技术】云计算中的数据库管理服务(Database as a Service, DBaaS)简介

    云计算中的数据库管理服务(Database as a Service, DBaaS)是一种托管式服务,它允许用户在云环境中创建、使用和管理数据库,而无需关心底层的硬件、软件或日常维护任务。这些服务通常由云服务提供商提供,如 Amazon Web Services (AWS)、Microsoft Azure 和 Google Cloud Platform (GCP)。 主要

    2024年01月23日
    浏览(14)
  • 从零实现一个数据库(DataBase) Go语言实现版 0.介绍

    英文源地址 我们为什么需要数据库?为什么不是直接把数据dump进文件中. 第一个话题就是持久化. 我们将讨论如果写入文件的过程中程序崩溃了, 或者电源断电了, 文件的状态会是什么样的呢? 文件是否只是丢失了最后一次写操作? 或者以写了一半的文件结束 或者是以更差的状态

    2024年02月06日
    浏览(10)
  • 什么是向量数据库 ?| What is a Vector Database?

    目录 What’s the difference between a vector index and a vector database?矢量索引和矢量数据库有什么区别? How does a vector database work?矢量数据库如何工作? Algorithms Random Projection Product Quantization 产品量化

    2024年02月07日
    浏览(14)
  • 已解决TimeoutError: [WinError 10060] 由于连接方在一段时间后没有正确答复或连接的主机没有反应,连接尝试失败。

    已解决Python爬虫报错:TimeoutError: [WinError 10060] 由于连接方在一段时间后没有正确答复或连接的主机没有反应,连接尝试失败。 粉丝群里面的一个小伙伴遇到问题跑来私信我,想用想用Python爬虫,但是发生了报错(当时他心里瞬间凉了一大截,跑来找我求助,然后顺利帮助他

    2024年01月16日
    浏览(16)
  • 什么是 MySQL JDBC 连接池中最高效的连接检测语句?

    在回答这个问题之前,首先我们看看 MySQL 中有哪些常用的 JDBC 连接池: c3p0 DBCP Druid Tomcat JDBC Pool HikariCP 这些连接池中,c3p0 是一个老牌的连接池,很多流行框架,在其老版本中,都将 c3p0 作为默认的连接池。 DBCP 和 Tomcat JDBC Pool(Tomcat 的默认连接池)是 Apache 开源的。 Druid

    2024年02月04日
    浏览(15)
  • sock.connect(sa) TimeoutError: [WinError 10060] 由于连接方在一段时间后没有正确答复或连接的主机没有反应,连接尝试失败

    在利用邮箱下载附件的时候,附件数量一多就会出现sock.connect(sa) TimeoutError: [WinError 10060] 由于连接方在一段时间后没有正确答复或连接的主机没有反应,连接尝试失败的问题,下面主要分享一下自己解决这个问题的经验。 首先可以确定的是这是由于timeout超时带来的问题,和

    2024年02月16日
    浏览(6)
  • Qlik Sense Websocket Connectivity Tester

      QlikSenseWebsocketConnectivityTester-master.zip   Qlik Sense use HTTP,  HTTPS and Web Socket to transfer the information in/out from Qlik Sense. The provided tool can be used to test protocol compliance, indicating if a network policy, firewall, or other perimeter device is blocking any of the required connections. If any of the tests return as unsucces

    2024年02月05日
    浏览(12)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包