Java入门系列-26-JDBC

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS PostgreSQL,高可用系列 2核4GB
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介:

认识 JDBC

JDBC (Java DataBase Connectivity) 是 Java 数据库连接技术的简称,用于连接常用数据库。

Sun 公司提供了 JDBC API ,供程序员调用接口和类,集成在 java.sqljavax.sql 包中。

Sun 公司还提供了 DriverManager 类用来管理各种不同的JDBC驱动。

不同数据库厂商提供各自的JDBC驱动,所以我们想要连接数据库除了要了解 JDBC API 还需要下载各数据库厂商的驱动 jar 包。

JDBC API

JDBC API主要用于与数据库建立连接、执行SQL语句、处理结果,其中核心类和接口如下:

  • DriverManager:依据数据库的不同,管理JDBC驱动
  • Connection:负责连接数据库并担任传送数据的任务
  • Statement:由 Connection 产生、负责执行SQL语句
  • ResultSet:负责保存 Statement 执行后所产生的查询结果

JDBC 编码模板

1、与数据库建立连接并获取连接

Connection connection=DriverManager.getConnection(URL,数据库用户名,密码);

2、发送SQL语句,得到执行结果

Statement stmt=connection.createStatement();
ResultSet rs=stmt.executeQuery(SQL语句);

3、处理返回结果

while(rs.next()){
    int a=rs.getInt("a");
    String b=rs.getString("b");
    Date d=rs.getDate("d");
    ……
}

4、释放资源

rs.close();
stmt.close();
connection.close();

使用 JDBC 连接到 MySQL 数据库

本例适合已经会使用 MySQL 数据库的同学,首先我们下载 JDBC 的驱动 jar 包。这个网址提供了 MySQL 各种语言连接数据库的驱动 https://www.mysql.com/products/connector/,MySQL Connector / J 8.0与从MySQL 5.5开始的所有MySQL版本兼容。
8.0下载地址
下载完成后解压,后将jar添加依赖到项目中。

连接到MySQL数据库

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

public class DemoConnectMySQL {
    public static void main(String[] args) {
        //连接MySQL的URL
        String url="jdbc:mysql://localhost:3306/mysql?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC&useSSL=false";
        //MySQL数据库用户名
        String user="root";
        //MySQL数据库的密码
        String password="1234";
        Connection connection=null;
        try {
            connection=DriverManager.getConnection(url, user, password);
            System.out.println("连接成功");
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            try {
                connection.close();
                System.out.println("连接关闭");
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

url指定数据库的连接字符串,格式为:

jdbc:数据库://ip或域名:端口号?参数&参数……
这里的参数 useUnicode=true 使用Unicode字符,characterEncoding=utf8 设置编码防止中文乱码,serverTimezone=UTC 设置时区,useSSL=false 不使用SSL

jdbc4.0不需要加载驱动

PreparedStatement 增删改

PreparedStatement 继承了 Statement 接口,表示预编译的 SQL 语句对象,SQL 语句被预编译并存储在 PreparedStatement 对象中,可以使用此对象多次高效地执行该语句。(还避免了 SQL 注入的隐患)

先准备好数据库 books

表 book

字段 类型 属性
id 整数 主键,自增
bName 字符串 非空
price 小数 非空

脚本也准备好了

#创建数据库
CREATE DATABASE books;
USE books;
#创建表
CREATE TABLE book ( 
    id INT primary key    auto_increment, 
    bName VARCHAR ( 255 ) NOT NULL, 
    price FLOAT NOT NULL 
);

PreparedStatement添加数据

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

public class TestInsert {

    public static void main(String[] args) {
        Connection connection=null;
        PreparedStatement pstmt=null;
        String url="jdbc:mysql://localhost:3306/books?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC&useSSL=false";
        String user="root";
        String password="1234";
        try {
            connection=DriverManager.getConnection(url,user,password);
            //sql语句
            String sql="insert into book(bName,price) values (?,?)";
            pstmt=connection.prepareStatement(sql);
            //传入参数
            pstmt.setString(1, "《java入门到改行》");
            pstmt.setFloat(2, 11.11f);
            int result=pstmt.executeUpdate();
            System.out.println("受影响行数:"+result);
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            if (pstmt!=null) {
                try {
                    pstmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (connection!=null) {
                try {
                    connection.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

说明:

1、连接字符串要修改数据库名字为 books

String url="jdbc:mysql://localhost:3306/books?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC&useSSL=false";

2、插入数据库的数据不能拼接而是要用 ? 代替

String sql="insert into book(bName,price) values (?,?)";

3、? 代替的参数要通过 set类型(位置,值) 传入

pstmt.setString(1, "《java入门到改行》");
pstmt.setFloat(2, 11.11f);

pstmt.setXxx()的位置从 1 开始!

4、增删改的SQL语句都使用这个方法,返回受影响行数

int result=pstmt.executeUpdate();

删除数据

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

public class TestDelete {

    public static void main(String[] args) {
        Connection connection=null;
        PreparedStatement pstmt=null;
        String url="jdbc:mysql://localhost:3306/books?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC&useSSL=false";
        String user="root";
        String password="1234";
        try {
            connection=DriverManager.getConnection(url,user,password);
            //sql语句
            String sql="delete from book where id=?";
            pstmt=connection.prepareStatement(sql);
            //传入参数 要删除id
            pstmt.setInt(1, 1);
            int result=pstmt.executeUpdate();
            System.out.println("受影响行数:"+result);
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            if (pstmt!=null) {
                try {
                    pstmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (connection!=null) {
                try {
                    connection.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

修改数据

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

public class TestUpdate {

    public static void main(String[] args) {
        Connection connection=null;
        PreparedStatement pstmt=null;
        String url="jdbc:mysql://localhost:3306/books?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC&useSSL=false";
        String user="root";
        String password="1234";
        try {
            connection=DriverManager.getConnection(url,user,password);
            //sql语句
            String sql="update book set bName=?,price=? where id=?";
            pstmt=connection.prepareStatement(sql);
            //传入参数 要删除id
            pstmt.setString(1, "《MySQL从删库到跑路》");
            pstmt.setFloat(2, 16.66f);
            pstmt.setInt(3, 2);
            int result=pstmt.executeUpdate();
            System.out.println("受影响行数:"+result);
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            if (pstmt!=null) {
                try {
                    pstmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (connection!=null) {
                try {
                    connection.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

增、删、改操作的写法都一样,都调用 executeUpdate() 方法返回一个受影响行数,唯一不同的 SQL语句。

PreparedStatement 查询数据

查询数据需要用到 ResultSet 类保存返回的结果集,我们获取数据要操作 ResultSet 获取。

ResultSet 常用方法

方法名 说明
boolean next() 将游标从当前位置向下移动一行
void close() 关闭 ResultSet 对象
int getInt(int colIndex) 以int形式获取结果集当前行指定列号值
int getInt(String colLabel) 以int形式获取结果集当前行指定列名值
float getFloat(String colLabel) 以float形式获取结果集当前行指定列名值
String getString(String colLabel) 以 String 形式获取结果集当前行指定列名值
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class TestSelect {

    public static void main(String[] args) {
        Connection connection=null;
        PreparedStatement pstmt=null;
        ResultSet rs=null;
        String url="jdbc:mysql://localhost:3306/books?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC&useSSL=false";
        String user="root";
        String password="1234";
        try {
            connection=DriverManager.getConnection(url,user,password);
            //sql语句
            String sql="select bName,price,id from book where id=?";
            pstmt=connection.prepareStatement(sql);
            //传入查询条件
            pstmt.setInt(1, 2);
            rs=pstmt.executeQuery();
            while(rs.next()) {
                //通过列名获取列的值
                int id=rs.getInt("id");
                //通过位置获取列的值
                String bName=rs.getString(1);
                float price=rs.getFloat("price");
                System.out.println(id+" "+bName+" "+price);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            if(rs!=null) {
                try {
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (pstmt!=null) {
                try {
                    pstmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (connection!=null) {
                try {
                    connection.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

关闭对象时注意关闭的顺序,后使用的先关闭:rs.close()->pstmt.close()->connection.close()

ResultSet 对象存在一个光标,光标所指行为当前行。想要获取列的数据需要先指向一行,所以要先指定 next() 方法用于指向一行,如果没有数据next()方法返回false,有数据返回true。

使用 getXxx() 方法获取列的数据时建议写列名,这样好识别

相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发,帮助IT从业者们通过“阿里云Web应用上云解决方案”,了解一个企业级Web应用上云的常见架构,了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。   相关的阿里云产品:云数据库RDS MySQL 版 阿里云关系型数据库RDS(Relational Database Service)是一种稳定可靠、可弹性伸缩的在线数据库服务,提供容灾、备份、恢复、迁移等方面的全套解决方案,彻底解决数据库运维的烦恼。 了解产品详情: https://www.aliyun.com/product/rds/mysql 
相关文章
|
1月前
|
安全 Java 数据库连接
2025 年最新 Java 学习路线图含实操指南助你高效入门 Java 编程掌握核心技能
2025年最新Java学习路线图,涵盖基础环境搭建、核心特性(如密封类、虚拟线程)、模块化开发、响应式编程、主流框架(Spring Boot 3、Spring Security 6)、数据库操作(JPA + Hibernate 6)及微服务实战,助你掌握企业级开发技能。
251 3
|
21天前
|
前端开发 Java 数据库连接
帮助新手快速上手的 JAVA 学习路线最详细版涵盖从入门到进阶的 JAVA 学习路线
本Java学习路线涵盖从基础语法、面向对象、异常处理到高级框架、微服务、JVM调优等内容,适合新手入门到进阶,助力掌握企业级开发技能,快速成为合格Java开发者。
266 3
|
1月前
|
NoSQL Java 关系型数据库
Java 从入门到进阶完整学习路线图规划与实战开发最佳实践指南
本文为Java开发者提供从入门到进阶的完整学习路线图,涵盖基础语法、面向对象、数据结构与算法、并发编程、JVM调优、主流框架(如Spring Boot)、数据库操作(MySQL、Redis)、微服务架构及云原生开发等内容,并结合实战案例与最佳实践,助力高效掌握Java核心技术。
218 1
|
1月前
|
Java 测试技术 API
Java IO流(二):文件操作与NIO入门
本文详解Java NIO与传统IO的区别与优势,涵盖Path、Files类、Channel、Buffer、Selector等核心概念,深入讲解文件操作、目录遍历、NIO实战及性能优化技巧,适合处理大文件与高并发场景,助力高效IO编程与面试准备。
|
1月前
|
Java 编译器 API
Java Lambda表达式与函数式编程入门
Lambda表达式是Java 8引入的重要特性,简化了函数式编程的实现方式。它通过简洁的语法替代传统的匿名内部类,使代码更清晰、易读。本文深入讲解Lambda表达式的基本语法、函数式接口、方法引用等核心概念,并结合集合操作、线程处理、事件回调等实战案例,帮助开发者掌握现代Java编程技巧。同时,还解析了面试中高频出现的相关问题,助你深入理解其原理与应用场景。
|
12天前
|
Java API 数据库
2025 年最新 Java 实操学习路线,从入门到高级应用详细指南
2025年Java最新实操学习路线,涵盖从环境搭建到微服务、容器化部署的全流程实战内容,助你掌握Java 21核心特性、Spring Boot 3.2开发、云原生与微服务架构,提升企业级项目开发能力,适合从入门到高级应用的学习需求。
235 0
|
22天前
|
监控 Java API
2025 年全新出炉的 Java 学习路线:从入门起步到实操精通的详细指南
2025年Java学习路线与实操指南,涵盖Java 21核心特性、虚拟线程、Spring Boot 3、微服务、Spring Security、容器化部署等前沿技术,助你从入门到企业级开发进阶。
187 0
|
1月前
|
前端开发 Java 数据库
Java 项目实战从入门到精通 :Java Web 在线商城项目开发指南
本文介绍了一个基于Java Web的在线商城项目,涵盖技术方案与应用实例。项目采用Spring、Spring MVC和MyBatis框架,结合MySQL数据库,实现商品展示、购物车、用户注册登录等核心功能。通过Spring Boot快速搭建项目结构,使用JPA进行数据持久化,并通过Thymeleaf模板展示页面。项目结构清晰,适合Java Web初学者学习与拓展。
181 1
|
1月前
|
算法 Java 测试技术
零基础学 Java: 从语法入门到企业级项目实战的详细学习路线解析
本文为零基础学习者提供完整的Java学习路线,涵盖语法基础、面向对象编程、数据结构与算法、多线程、JVM原理、Spring框架、Spring Boot及项目实战,助你从入门到进阶,系统掌握Java编程技能,提升实战开发能力。
110 0
|
2月前
|
存储 缓存 NoSQL
java 集合入门基础理论的核心概念与实用长尾知识
本文介绍了Java集合框架的基础理论知识,包括单列集合(List、Set、Queue)和双列集合(Map)的特点及常用实现类(如ArrayList、HashSet、HashMap等)。详细讲解了集合的遍历方式(迭代器、增强for循环、Lambda表达式)和典型应用场景(如数据去重、键值存储等)。通过具体代码示例,帮助初学者理解集合框架的核心概念和实际应用,为Java编程中的数据存储与管理提供基础指导。
92 0