Java数据库编程

news2024/11/25 15:55:37

引言

在现代应用开发中，与数据库交互是不可或缺的一部分。Java提供了JDBC（Java Database Connectivity） API，允许开发者方便地连接到数据库并执行SQL操作。本文将详细介绍Java数据库编程的基础知识，包括JDBC的基本概念、数据库连接与操作、事务处理、以及使用ORM框架如Hibernate，并通过表格进行总结和示范。

JDBC基础

什么是JDBC？

JDBC是Java数据库连接的标准API，允许Java应用与数据库进行交互。JDBC API提供了与数据库连接、执行SQL查询、更新数据库和处理结果集的方法。

JDBC体系结构

组件描述
DriverManager管理一组JDBC驱动程序，实现数据库连接
Driver用于与数据库通信的JDBC驱动程序
Connection表示与特定数据库的连接，用于执行SQL语句
Statement用于执行SQL查询和更新
ResultSet表示SQL查询的结果，允许迭代和处理结果集
SQLException指示数据库访问错误的异常类

JDBC四大步骤

  1. 加载并注册数据库驱动
  2. 建立数据库连接
  3. 创建并执行SQL语句
  4. 处理结果与关闭资源

数据库连接与操作

连接数据库

使用DriverManager获取数据库连接。

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

public class DatabaseConnection {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/mydatabase";
        String username = "root";
        String password = "password";

        try (Connection connection = DriverManager.getConnection(url, username, password)) {
            System.out.println("Database connected!");
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

执行SQL查询

使用Statement执行SQL查询并处理结果集。

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

public class SelectQueryExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/mydatabase";
        String username = "root";
        String password = "password";

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

            String query = "SELECT * FROM users";
            ResultSet resultSet = statement.executeQuery(query);

            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("name");
                String email = resultSet.getString("email");
                System.out.println("ID: " + id + ", Name: " + name + ", Email: " + email);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

更新数据库

使用PreparedStatement执行SQL更新操作。

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

public class UpdateQueryExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/mydatabase";
        String username = "root";
        String password = "password";

        try (Connection connection = DriverManager.getConnection(url, username, password);
             PreparedStatement statement = connection.prepareStatement("UPDATE users SET email = ? WHERE id = ?")) {

            statement.setString(1, "newemail@example.com");
            statement.setInt(2, 1);
            
            int rowsAffected = statement.executeUpdate();
            System.out.println("Rows affected: " + rowsAffected);
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

JDBC常用类与方法表

类/接口方法描述
DriverManagergetConnection(String, String, String)获取数据库连接
ConnectioncreateStatement()创建Statement实例
prepareStatement(String)创建PreparedStatement实例
close()关闭数据库连接
StatementexecuteQuery(String)执行SQL查询并返回ResultSet
executeUpdate(String)执行SQL更新并返回受影响行数
close()关闭Statement
PreparedStatementsetString(int, String)设置SQL参数值
setInt(int, int)设置SQL参数值
executeUpdate()执行SQL更新并返回受影响行数
executeQuery()执行SQL查询并返回ResultSet
close()关闭PreparedStatement
ResultSetnext()移动到下一行数据
getInt(String)获取当前行指定列的整数值
getString(String)获取当前行指定列的字符串值
close()关闭ResultSet
SQLExceptiongetMessage()获取异常消息
printStackTrace()打印异常堆栈轨迹

事务处理

在数据库操作中，事务用于保证一组操作要么全部成功要么全部失败，确保数据一致性。事务具有四个属性（ACID）：原子性、一致性、隔离性和持久性。

使用事务

使用Connection对象的事务控制方法实现数据库事务。

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

public class TransactionExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/mydatabase";
        String username = "root";
        String password = "password";

        try (Connection connection = DriverManager.getConnection(url, username, password)) {
            connection.setAutoCommit(false); // 开始事务

            try (PreparedStatement pst1 = connection.prepareStatement("UPDATE accounts SET balance = balance - ? WHERE id = ?");
                 PreparedStatement pst2 = connection.prepareStatement("UPDATE accounts SET balance = balance + ? WHERE id = ?")) {

                pst1.setDouble(1, 100.0);
                pst1.setInt(2, 1);
                pst1.executeUpdate();

                pst2.setDouble(1, 100.0);
                pst2.setInt(2, 2);
                pst2.executeUpdate();

                connection.commit(); // 提交事务
                System.out.println("Transaction committed successfully.");
            } catch (SQLException e) {
                connection.rollback(); // 回滚事务
                System.out.println("Transaction rolled back.");
                e.printStackTrace();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

事务控制方法表

方法描述示例
setAutoCommit(boolean)设置是否自动提交事务connection.setAutoCommit(false);
commit()提交事务connection.commit();
rollback()回滚事务connection.rollback();

使用ORM框架：Hibernate

Hibernate是Java的一个流行的ORM（对象关系映射）框架，通过将Java对象映射到数据库表，简化了数据库操作并提高了生产力。

Hibernate配置

Hibernate通过hibernate.cfg.xml文件进行配置，包括数据库连接信息和映射文件。

示例：hibernate.cfg.xml

<!DOCTYPE hibernate-configuration PUBLIC
        "-//Hibernate/Hibernate Configuration DTD 3.0//EN"
        "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd">
<hibernate-configuration>
    <session-factory>
        <!-- 数据库连接配置 -->
        <property name="hibernate.connection.driver_class">com.mysql.cj.jdbc.Driver</property>
        <property name="hibernate.connection.url">jdbc:mysql://localhost:3306/mydatabase</property>
        <property name="hibernate.connection.username">root</property>
        <property name="hibernate.connection.password">password</property>
        <property name="hibernate.dialect">org.hibernate.dialect.MySQLDialect</property>

        <!-- 映射类 -->
        <mapping class="com.example.User"/>
    </session-factory>
</hibernate-configuration>

Hibernate实体类

定义一个实体类，并使用Hibernate注解进行配置。

示例：User实体类

import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;

@Entity
@Table(name = "users")
public class User {
    @Id
    private int id;
    private String name;
    private String email;

    // Getters and setters
    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getEmail() {
        return email;
    }

    public void setEmail(String email) {
        this.email = email;
    }
}

使用Hibernate进行数据库操作

使用Hibernate的Session和Transaction进行CRUD（创建、读取、更新、删除）操作。

示例：Hibernate CRUD操作

import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.Transaction;
import org.hibernate.cfg.Configuration;

public class HibernateCRUDExample {
    public static void main(String[] args) {
        // 创建SessionFactory
        SessionFactory sessionFactory = new Configuration().configure().buildSessionFactory();

        // 创建Session
        try (Session session = sessionFactory.openSession()) {
            // 创建Transaction
            Transaction transaction = session.beginTransaction();

            // 创建并保存一个新用户
            User user = new User();
            user.setId(1);
            user.setName("John Doe");
            user.setEmail("john.doe@example.com");
            session.save(user);
            System.out.println("User saved!");

            // 提交事务
            transaction.commit();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 关闭SessionFactory
            sessionFactory.close();
        }
    }
}

Hibernate常用类与方法表

类/接口方法描述
Configurationconfigure()加载Hibernate配置文件
buildSessionFactory()创建SessionFactory实例
SessionFactoryopenSession()打开一个新的Session实例
close()关闭SessionFactory实例
SessionbeginTransaction()开始一个新的事务
save(Object)保存一个对象到数据库
update(Object)更新数据库中的一个对象
delete(Object)从数据库中删除一个对象
get(Class, Serializable)根据标识符从数据库中获取一个对象
Transactioncommit()提交事务
rollback()回滚事务

表格总结

JDBC常用类与方法表

类/接口方法描述
DriverManagergetConnection(String, String, String)获取数据库连接
ConnectioncreateStatement()创建Statement实例
prepareStatement(String)创建PreparedStatement实例
close()关闭数据库连接
StatementexecuteQuery(String)执行SQL查询并返回ResultSet
executeUpdate(String)执行SQL更新并返回受影响行数
close()关闭Statement
PreparedStatementsetString(int, String)设置SQL参数值
setInt(int, int)设置SQL参数值
executeUpdate()执行SQL更新并返回受影响行数
executeQuery()执行SQL查询并返回ResultSet
close()关闭PreparedStatement
ResultSetnext()移动到下一行数据
getInt(String)获取当前行指定列的整数值
getString(String)获取当前行指定列的字符串值
close()关闭ResultSet
SQLExceptiongetMessage()获取异常消息
printStackTrace()打印异常堆栈轨迹

事务控制方法表

方法描述示例
setAutoCommit(boolean)设置是否自动提交事务connection.setAutoCommit(false);
commit()提交事务connection.commit();
rollback()回滚事务connection.rollback();

Hibernate常用类与方法表

类/接口方法描述
Configurationconfigure()加载Hibernate配置文件
buildSessionFactory()创建SessionFactory实例
SessionFactoryopenSession()打开一个新的Session实例
close()关闭SessionFactory实例
SessionbeginTransaction()开始一个新的事务
save(Object)保存一个对象到数据库
update(Object)更新数据库中的一个对象
delete(Object)从数据库中删除一个对象
get(Class, Serializable)根据标识符从数据库中获取一个对象
Transactioncommit()提交事务
rollback()回滚事务

总结

本文详细介绍了Java数据库编程的基础知识，包括JDBC的基本概念、数据库连接与操作、事务处理、以及使用ORM框架如Hibernate。通过示例代码和表格总结，帮助读者更好地理解和应用Java中的数据库编程，提高数据操作的效率和安全性。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1826440.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

为什么 JavaScript 在国外逐渐用于前端+后端开发

为什么 JavaScript 在国外逐渐用于前端+后端开发

这个问题其实没人能给出可证伪的结论&#xff0c;那不如干脆给一个感性的答案: 因为阿里“不争气”。 确切的说&#xff0c;因为阿里的nodejs团队没卷赢&#xff0c;至少暂时还没卷赢&#xff0c;没拿到真正有价值的业务场景&#xff0c;做出真正有说服力的案例项目。刚好我有…
阅读更多...
如何进行LLM大模型推理优化

如何进行LLM大模型推理优化

解密LLM大模型推理优化本质 一、LLM推理的本质以及考量点 LLM推理聚焦Transformer架构的Decoder以生成文本。过程分两步&#xff1a;首先&#xff0c;模型初始化并加载输入文本&#xff1b;接着&#xff0c;进入解码阶段&#xff0c;模型自回归地生成文本&#xff0c;直至满足…
阅读更多...
邮件钓鱼--有无SPF演示--Swaks

邮件钓鱼--有无SPF演示--Swaks

目录 临时邮箱网址: Swaks 简单使用说明&#xff1a;(kali自带) 操作流程: 无SPF:(直接伪造发信人) 演示1 演示2 演示3 ​编辑 有SPF:--演示 临时邮箱网址: http://24mail.chacuo.net/ https://www.linshi-email.com/ Swaks 简单使用说明&#xff1a;(kali自带) -t –t…
阅读更多...
专题六——模拟

专题六——模拟

目录 一替换所有的问号 二提莫攻击 三N字形变换 四外观数列 五数青蛙 一替换所有的问号 oj链接&#xff1a;替换所有的问号 思路&#xff1a;简单模拟&#xff1b;注意i0和in是处理越界问题就行&#xff01;&#xff01; class Solution { public:string modifyString…
阅读更多...
基于scikit-learn的机器学习分类任务实践——集成学习

基于scikit-learn的机器学习分类任务实践——集成学习

一、传统机器学习分类流程与经典思想算法简述 传统机器学习是指&#xff0c;利用线性代数、数理统计与优化算法等数学方式从设计获取的数据集中构建预测学习器&#xff0c;进而对未知数据分类或回归。其主要流程大致可分为七个部分&#xff0c;依次为设计获取数据特征集&#x…
阅读更多...
Reactor 网络模型、Java代码实例

Reactor 网络模型、Java代码实例

文章目录 1. 概述2. Reactor 单线程模型2.1 ByteBufferUtil2.2 服务端代码2.3 客户端2.4 运行截图 3. Reactor多线程模型3.1 服务端代码3.2 运行截图 4. 主从 Reactor多线程模型4.1 服务端代码4.2 运行截图 参考文献 1. 概述 在 I/O 多路复用的场景下&#xff0c;当有数据处于…
阅读更多...
ChatTTS-WebUI测试页面项目

ChatTTS-WebUI测试页面项目

概述 分享可以一个专门为对话场景设计的文本转语音模型ChatTTS&#xff0c;例如LLM助手对话任务。它支持英文和中文两种语言。最大的模型使用了10万小时以上的中英文数据进行训练。在HuggingFace中开源的版本为4万小时训练且未SFT的版本. 该模型能够预测和控制细粒度的韵律特…
阅读更多...
跪求大数据把我推给做投资交易的红薯！

跪求大数据把我推给做投资交易的红薯！

在qq群里认识了君诺金融Juno Markets外汇交易平台的业务经理&#xff0c;平台上大剌剌的打出20%交易返现活动&#xff0c;一时听信了他们的话在该平台有开户入金做交易&#xff0c;做了这家平台的代理&#xff0c;然而君诺金融Juno Markets平台却不给佣金&#xff0c;我都是属于…
阅读更多...
浏览器必备插件：最新Allow copy万能网页复制下载，解锁网页限制！

浏览器必备插件：最新Allow copy万能网页复制下载，解锁网页限制！

今天阿星给大家安利一个超级实用的小工具&#xff0c;专治那些“禁止复制”的网页文字。学生党、资料搜集狂人&#xff0c;你们有福了&#xff01; 想象一下&#xff0c;你在网上冲浪&#xff0c;突然遇到一篇干货满满的文章&#xff0c;正想复制下来慢慢品味&#xff0c;结果…
阅读更多...
值传递和址传递

值传递和址传递

值传递 上面的代码是想要交换x&#xff0c;y的值&#xff0c;把x&#xff0c;y传递给swap函数之后&#xff0c;执行下面的操作&#xff1a; 在swap中a和b交换了&#xff0c;但是和x&#xff0c;y没有关系&#xff0c;所以x&#xff0c;y在main中不会变。 址传递 下面再看把x…
阅读更多...
springcloud gateway转发websocket请求的404问题定位

springcloud gateway转发websocket请求的404问题定位

一、问题 前端小程序通过springcloud gateway接入并访问后端的诸多微服务&#xff0c;几十个微服务相关功能均正常&#xff0c;只有小程序到后端推送服务的websocket连接建立不起来&#xff0c;使用whireshark抓包&#xff0c;发现在小程序通过 GET ws://192.168.6.100:8888/w…
阅读更多...
Apple Intelligence 横空出世！它的独家秘诀在哪里？

Apple Intelligence 横空出世！它的独家秘诀在哪里？

在 WWDC 2024 大会上&#xff0c;苹果公司揭晓了自家的生成式 AI 项目——Apple Intelligence&#xff0c;其策略核心在于采用 ⌈ 更为聚焦的小型模型 ⌋ &#xff0c;而非盲目追求大模型的普遍趋势。横空出世的它究竟有什么过人之处&#xff1f;一文带你探究竟&#xff01;生成…
阅读更多...
[DDR4] DDR1 ~ DDR4 发展史导论

[DDR4] DDR1 ~ DDR4 发展史导论

依公知及经验整理&#xff0c;原创保护&#xff0c;禁止转载。 专栏 《深入理解DDR4》 内存和硬盘是电脑的左膀右臂&#xff0c; 挑起存储的大梁。因为内存的存取速度超凡地快&#xff0c; 但内存上的数据掉电又会丢失&#xff0c;一直其中缓存的作用&#xff0c;就像是我们的工…
阅读更多...
2786. 访问数组中的位置使分数最大

2786. 访问数组中的位置使分数最大

这并不是一个难题,但是我确实在做题中得到了一些启发,所以记录一下 先讲一讲这个题目的做法: 首先不难想到这是一个dp问题,(由 i 可以跳到 j ) 而且应该不难, 要不然就不是medium了,doge 那么,暴力的dp就是: dp[j] max (dp[i] nums OR dp[j] dp[i] nums - x) , i<j, 前…
阅读更多...
mongodb 集群安装

mongodb 集群安装

1. 配置域名 Server1&#xff1a; OS version: CentOS Linux release 8.5.2111 hostnamectl --static set-hostname mongo01 vi /etc/sysconfig/network # Created by anaconda hostnamemong01 echo "192.168.88.20 mong1 mongo01.com mongo02.com" >> /…
阅读更多...
【笔记】【矩阵的二分】668. 乘法表中第k小的数

【笔记】【矩阵的二分】668. 乘法表中第k小的数

力扣链接&#xff1a;题目 参考地址&#xff1a;参考 思路&#xff1a;二分查找 把矩阵想象成一维的已排好序的数组&#xff0c;用二分法找第k小的数字。 假设m行n列&#xff0c;则对应一维下标范围是从1到mn&#xff0c;初始&#xff1a; l1; rmn; mid(lr)/2 设mid在第i行&a…
阅读更多...
【C++11】第一部分(一万六千多字)

【C++11】第一部分(一万六千多字)

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 目录 前言 C11简介 统一的列表初始化 &#xff5b;&#xff5d;初始化 std::initializer_list 声明 auto decltype 右值引用和移动语义 左值引用和右值引用 左值引…
阅读更多...
C#实现WMI获取硬盘参数

C#实现WMI获取硬盘参数

文章目录 背景涉及框架及库WMI查询小工具参数解释U盘移动硬盘本机设备 总结 背景 因为需求需要涉及获取硬盘的SN参数&#xff0c;但是又不想要获取到U盘或移动硬盘设备的SN&#xff0c;所以就浅浅的研究了一下。 以下就是我目前发现的一些参数的作用&#xff0c;够我用了。。。…
阅读更多...
QT QFileDialog文件选择对话框

QT QFileDialog文件选择对话框

QT QFileDialog文件选择对话框 选择txt或者cpp文件&#xff0c;读取内容并显示 参考&#xff1a; QT写入文件与读取文件内容_qt往一个文件写东西-CSDN博客 #include "QtFilePreview.h" #include "qfiledialog.h" #include "qfile.h" #includ…
阅读更多...
【记录】ChatGLM3-6B大模型部署、微调（二）：微调

【记录】ChatGLM3-6B大模型部署、微调（二）：微调

前言 上文记录了ChatGLM3-6B大模型本地化部署过程&#xff0c;本次对模型进行微调&#xff0c;目的是修改模型自我认知。采用官方推荐微调框架&#xff1a;LLaMA-Factory 安装LLaMA-Factory # 克隆项目 git clone https://github.com/hiyouga/LLaMA-Factory.git 安装依赖 # 安装…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023