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

搞懂JDBC这一篇就够了！！！（一）

2022-05-14 251
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
云数据库 RDS MySQL，集群系列 2核4GB
推荐场景：
搭建个人博客
RDS MySQL Serverless 基础系列，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
云数据库 RDS MySQL，高可用系列 2核4GB
简介： 搞懂JDBC这一篇就够了！！！（一）

一、概念


JDBC全程：


Java Database Connectivity java数据库连接


JDBC本质：其实是官方（SUN公司）定义的一套操作所有关系型数据库的规则，即接口。各个数据库厂商去实现这套接口，提供数据库驱动jar包。我们可以使用这套接口（JDBC）编程，真正执行的代码是驱动jar包中的实现类


为什么要用JDBC连接池？


对数据库进行频繁连接、开启和关闭操作，会造成数据库资源的浪费，十分影像数据库的性能。


**一般我们在项目中都会抽取出一些公共设置数据库连接的配置。项目在修改的时就可以很方便的去修改而不需要在无尽的代码中，去修改所有的代码。提高了软件的可重用性**


二、快速入门


步骤：


导入驱动jar包 mysql-connector-java-5.1.37-bin.jar


右键 --> Add As Library

注册驱动


获取数据库连接对象


定义sql


5.获取执行sql语句的对象statement


6.执行sql，接收返回的结果


7.处理结果


8.释放资源


jar包资源


https://cdn.mysql.com/archives/mysql-connector-java-5.1/mysql-connector-java-5.1.37.zip)


2.1 实例


package cn.caq.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
public class JdbcDemo01 {
    public static void main(String[] args) throws Exception {
        //1.导入驱动jar包
        //2.注册驱动
        Class.forName("com.mysql.jdbc.Driver");
        //3.获取数据库连接对象
        Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/db2", "root", "root");
        //4.定义sql语句
        String sql = "update account set balance = 1000 where id = 1";
        //5.获取执行sql语句的对象 Statement
        Statement statement = connection.createStatement();
        //6.执行sql
        int i = statement.executeUpdate(sql);
        //7.处理结果
        System.out.println(i);
        //8.释放资源
        statement.close();
        connection.close();
    }
}


2.2 详解各个对象


1.DriverManager :驱动管理对象


功能:


1．注册驱动:告诉程序该使用哪一个数据库驱动jar


static void registerDriver(Driver driver) :注册与给定的驱动程序 DriverManager


写代码使用:class.forName( “com.mysql.jdbc.Driver” );


通过查看源码发现:在com.mysql.jdbc.Driver类中存在静态代码块


static {
 try {
 java.sql.DriverManager.registerDriver(new Driver());
 }catch (SQLException E) {
 throw new RuntimeException( “can’t register driver!”);
 }


注意: mysq15之后的驱动jar包可以省略注册驱动的步骤。


2．获取数据库连接


image.png


Connection conn = DriverManager.getConnection(“jdbc:mysql://localhost:3306/db2”, “root”, “root”);


url:指定连接的路径


细节∶如果连接的是本机mysql服务器，并且mysql服务默认端口是3306，则url可以简写为:jdbc:mysql///数据库名


user：用户名


password：密码


2.connection :数据库连接对象


功能:


1．获取执行sql 的对象


statement createstatement()

Preparedstatement preparestatement(string sql)


2．管理事务∶


开启事务: setAutoCommit(boolean autoCommit):调用该方法设置参数为false，即开启事务


提交事务: commit()


回滚事务:rollback()


3.statement :执行sql的对象


1.执行sql


boolean execute(String sql) : 可以执行任意的sql,了解即可


int executeUpdate(String sql) : 执行DML (insert、 update、 delete) 语句、

DDL(create, alter、 drop)语句


返回值:影响的行数,可以通过这个影响的行数判断DML语句是否执行成功返回值>0的则执行成功，反之，则失败。


ResultSet executeQuery(String sql) : 执行DQL (select)语句


2.练习


1.添加一条记录


2.修改记录


3.删除记录


为了代码健壮性，进行捕获异常


String sql = "update account set balance = 40 where id = 1";
String sql = "insert into account values(3,'ws',1002)";
String sql = "delete from account where id = 3";


修改后的代码


package cn.caq.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class JdbcDemo03 {
    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        try {
            //1.注册驱动
            Class.forName("com.mysql.jdbc.Driver");
            //2.获取连接对象
            conn = DriverManager.getConnection("jdbc:mysql:///db2", "root", "root");
            //3.定义sql
            String sql = "insert into account values(3,'ws',1002)";
            //4.获取执行sql对象
            stmt = conn.createStatement();
            //5.执行sql
            int count = stmt.executeUpdate(sql);
            //6.处理结果
            System.out.println(count);
            if (count > 0){
                System.out.println("修改成功");
            }else {
                System.out.println("修改失败");
            }
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        } finally {
            if (stmt != null){
                try {
                    stmt.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }
            if (conn != null){
                try {
                    conn.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }
        }
    }
}


4.Resultset :结果集对象


结果集对象，封装查询结果


1.next（）;游标向下移动一行，判断当前行是否是最后一行末尾


它的返回值是布尔值


2.getXXX：获取数据，XXX代表数据类型int getInt() String getString()


...
    //int :代表列的编号，从1开始  如:getString(1)
    //string: 代表列的名称 如：getString("name")
int id = res.getInt(1);
String name = res.getString("name");
double balance = res.getDouble(3);
System.out.println(id + "---" + name + "---" + balance);
结果为：
1---zs---40.0


使用步骤：


游标向下移动一行

判断是否有数据

获取数据

正确用法


while (res.next()){
    int id = res.getInt(1);
    String name = res.getString("name");
    double balance = res.getDouble(3);
    System.out.println(id + "---" + name + "---" + balance);
}


查询练习：


查询表的数据封装为对象，返回一个列表打印处理


思路：


定义一个方法，查询emp表的数据将其封装为对象，然后装载集合，返回


1.根据表的结构定义一个emp类


2.查询的结果封装为emp类的对象


3.定义方法public list findAll(){}查询表中数据并封装为集合


Emp类


package cn.caq.domain;
import java.util.Date;
/**
 * 封装Emp表数据的Java Bean
 */
public class Emp {
    private int id;
    private String ename;
    private int job_id;
    private int mgr;
    private Date joindate;
    private double salary;
    private double bounds;
    private int dept_id;
    public int getId() {
        return id;
    }
    public String getEname() {
        return ename;
    }
    public void setEname(String ename) {
        this.ename = ename;
    }
    public void setId(int id) {
        this.id = id;
    }
    public int getJob_id() {
        return job_id;
    }
    public void setJob_id(int job_id) {
        this.job_id = job_id;
    }
    public int getMgr() {
        return mgr;
    }
    public void setMgr(int mgr) {
        this.mgr = mgr;
    }
    public Date getJoindate() {
        return joindate;
    }
    public void setJoindate(Date joindate) {
        this.joindate = joindate;
    }
    public double getSalary() {
        return salary;
    }
    public void setSalary(double salary) {
        this.salary = salary;
    }
    public double getBounds() {
        return bounds;
    }
    public void setBounds(double bounds) {
        this.bounds = bounds;
    }
    public int getDept_id() {
        return dept_id;
    }
    public void setDept_id(int dept_id) {
        this.dept_id = dept_id;
    }
    @Override
    public String toString() {
        return "Emp{" +
                "id=" + id +
                ", ename='" + ename + '\'' +
                ", job_id=" + job_id +
                '}';
    }
}


查询方法


package cn.caq.jdbc;
import cn.caq.domain.Emp;
import java.sql.*;
import java.util.ArrayList;
import java.util.List;
/**
 * 定义一个方法，查询emp表的数据将其封装为对象，然后装载集合，返回
 */
public class JdbcDemo06 {
    public static void main(String[]args){
        List<Emp> list = new JdbcDemo06().findall();
        System.out.println(list);
    }
    public List<Emp> findall() {
        Connection conn = null;
        Statement stmt = null;
        ResultSet res = null;
        ArrayList<Emp> list = null;
        try {
            //1.注册驱动
            Class.forName("com.mysql.jdbc.Driver");
            //2.获取连接对象
            conn = DriverManager.getConnection("jdbc:mysql:///db2", "root", "root");
            //3.定义sql
            String sql = "select * from emp";
            //4.获取执行sql对象
            stmt = conn.createStatement();
            //5.执行sql
            res = stmt.executeQuery(sql);
            //6.处理结果
            Emp emp = null;
            list = new ArrayList<>();
            while (res.next()) {
                int id = res.getInt("id");
                String ename = res.getString("ename");
                int job_id = res.getInt("job_id");
                //创建emp对象，并赋值
                emp = new Emp();
                emp.setId(id);
                emp.setEname(ename);
                emp.setJob_id(job_id);
                //装载集合
                list.add(emp);
            }
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        } finally {
            if (stmt != null) {
                try {
                    stmt.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }
            if (res != null) {
                try {
                    res.close();
                } catch (SQLException throwables) {
                    throwables.printStackTrace();
                }
            }
        }
    return list;
    }
}
输出结果为：
    [Emp{id=1001, ename='孙悟空', job_id=4}, Emp{id=1002, ename='卢俊义', job_id=3}, Emp{id=1003, ename='林冲', job_id=3}, Emp{id=1004, ename='唐僧', job_id=2}, Emp{id=1005, ename='李逵', job_id=4}, Emp{id=1006, ename='宋江', job_id=2}, Emp{id=1007, ename='刘备', job_id=2}, Emp{id=1008, ename='猪八戒', job_id=4}, Emp{id=1009, ename='罗贯中', job_id=1}, Emp{id=1010, ename='吴用', job_id=3}, Emp{id=1011, ename='沙僧', job_id=4}, Emp{id=1012, ename='李逵', job_id=4}, Emp{id=1013, ename='小白龙', job_id=4}, Emp{id=1014, ename='关羽', job_id=4}]


5.Preparedstatement :执行sql的对象

1. SQL注入问题

用户随便输入密码：a’ or ‘a’ = 'a


String sql = "select * from user where username = '"+username+"' and password = '"+password+"'";

System.out.println(sql);

1

2

拼接后的sql：select * from user where username = ‘dafsdfda’ and password = ‘a’ or ‘a’ = 'a’


请输入username：

fassag

请输入password

a’ or ‘a’ = 'a

Success!!!


解决方案

通过Preparedstatement :执行sql


它是预编译的SQL（ 一次编译、多次运行，省去了解析优化等过程，此外预编译语句能防止sql注入 。）


参数使用?作为占位符


全部的流程为：


步骠:

1.导入驱动jar包mysql-connector-java-5.1.37-bin.jar


2．注册驱动


3．获取数据库连接对象connection


4．定义sql

注意:sql的参数使用?作为占位符。如: select * from user where username ? and password ?;


5．获取执行sql语句的对象preparedstatement Connection.preparestatement(string sql)

6．给?赋值:

*方法: setXXX(参数1,参数2)

参数1:?的位置编号 从1开始


参数2:?的值


7、执行sql，接受返回结果,不需要传递sql语句


8．处理结果


9．释放资源


三、JDBC工具类

目的

简化书写


分析

1.注册驱动也抽取


2.抽取一个方法获取连接对象


需求：不想传递参数（麻烦），还带保证工具类的通用新


解决：properties配置文件


url=jdbc:mysql:///db2
user=root
password=root
driver=com.mysql.jdbc.Driver


抽取一个方法释放资源


package cn.caq.utils;
import java.io.FileReader;
import java.io.IOException;
import java.net.URL;
import java.sql.*;
import java.util.Properties;
/**
 * JDBC工具类
 */
public class JDBCutils {
    private static String url;
    private static String user;
    private static String password;
    private static String driver;
    /**
     * 文件的读取，只需要读取一次即可拿到这些值。使用静态代码块
     */
    static {
        try {
            //读取资源文件，获取值
            //1.创建Properties集合类
            Properties pro = new Properties();
            //获取src路径下的文件方式--->ClassLoader 类加载器
            ClassLoader classLoader = JDBCutils.class.getClassLoader();
            URL res = classLoader.getResource("jdbc.properties");//得到文件的绝对路径
            String path = res.getPath();//将绝对路径转化为字符串形式
            //FileReader用来读用户本地的文件
            pro.load(new FileReader(path));
            //2.加载文件
    //pro.load(new FileReader("src/jdbc.properties"));
            //3.获取数据，赋值
            url = pro.getProperty("url");
            user = pro.getProperty("user");
            password = pro.getProperty("password");
            driver = pro.getProperty("driver");
            //4.注册驱动
            Class.forName(driver);
        } catch (IOException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
    /**
     * 获取连接的方法
     */
    public static Connection getConnection() throws SQLException {
        return DriverManager.getConnection(url, user, password);
    }
    /**
     * 释放资源的方法
     */
    public static void close(ResultSet rs, Statement stmt, Connection conn) {
        if (rs != null) {
            try {
                rs.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
        if (stmt != null) {
            try {
                stmt.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException throwables) {
                throwables.printStackTrace();
            }
        }
    }
}


使用工具类


package cn.caq.jdbc;
import cn.caq.domain.Emp;
import cn.caq.utils.JDBCutils;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
public class JdbcDemo07 {
    public static void main(String[] args) {
        List<Emp> list = new JdbcDemo07().findall2();
        System.out.println(list);
    }
    /**
     * 演示JDBC工具类
     */
    public List<Emp> findall2() {
        Connection conn = null;
        Statement stmt = null;
        ResultSet res = null;
        ArrayList<Emp> list = null;
        try {
//            //1.注册驱动
//            Class.forName("com.mysql.jdbc.Driver");
//            //2.获取连接对象
//            conn = DriverManager.getConnection("jdbc:mysql:///db2", "root", "root");
            conn = JDBCutils.getConnection();
            //3.定义sql
            String sql = "select * from emp";
            //4.获取执行sql对象
            stmt = conn.createStatement();
            //5.执行sql
            res = stmt.executeQuery(sql);
            //6.处理结果
            Emp emp = null;
            list = new ArrayList<>();
            while (res.next()) {
                int id = res.getInt("id");
                String ename = res.getString("ename");
                int job_id = res.getInt("job_id");
                //创建emp对象，并赋值
                emp = new Emp();
                emp.setId(id);
                emp.setEname(ename);
                emp.setJob_id(job_id);
                //装载集合
                list.add(emp);
            }
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        } finally {
            JDBCutils.close(res,stmt,conn);
        }
        return list;
    }
}


登陆练习


需求：


1.通过键盘录入用户名和密码


2.判断用户是否登录成功


select * from user where username = “” and password = “”;


如果这个sql有查询结果，则成功反之失败

文章标签：
云数据库 RDS MySQL 版
Java
SQL
关系型数据库
数据安全/隐私保护
MySQL
数据库
数据库连接
相关实践学习
如何在云端创建MySQL数据库
开始实验后，系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心，利用清洁计算为万物互联的新世界提供源源不断的能源动力，目前开服的区域包括中国（华北、华东、华南、香港）、新加坡、美国（美东、美西）、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程，来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品：云服务器ECS 云服务器 ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
小蜗牛耶
目录
相关文章
Z_sorrain
|
3月前
|
Java 数据库连接
JDBC连接复习
JDBC连接复习
Z_sorrain
38 1
你都不懂
|
28天前
|
SQL Java 数据库连接
一文搞懂JDBC
一文搞懂JDBC
你都不懂
26 12
kevinchaos
|
SQL Ubuntu Java
一文搞懂JDBC应该怎么用，附代码实例
说到Java的常见框架，JDBC一定是榜上有名。 虽然大多数人会使用Mybatis来做Java应用和MySQL之间的数据交互，但了解JDBC依然是一个Java工程师的基本功。 本篇文章，就来介绍一下JDBC这个框架，最后内会附上代码实例。
kevinchaos
180 1
一文搞懂JDBC应该怎么用，附代码实例
小蚂蚁XMY
|
存储 开发者
彻底搞懂函数，读这篇文章就够了
如果你之前使用过任何一门编程语言，那么对于你来讲想必已经知道什么是函数，以及如何使用函数了，那你大可不必往下读了。这篇文章是写给新手看的，也就是说我假设你对于函数没有任何的概念。 我们就先从什么是函数来说起吧！
小蚂蚁XMY
115 0
4yva5hg3m356w
|
SQL Java 关系型数据库
JDBC面试核心必考知识点
JDBC核心知识点 如有编辑错误联系作者 如果有比较好的文章欢迎分享给我，我会取其精华去其糟粕 王恒杰 男、95后 现居天津 是一名学习java的菜鸟 是万千程序猿中的一只 喜欢编程，喜欢探索新技术，大学生活迷茫过，失落过，还好没有放弃 希望看到这里的你也不要轻易地放弃 这条路上的你并不是孤军奋战，有千千万万的猿在陪你前行
4yva5hg3m356w
148 0
JDBC面试核心必考知识点
君哥聊技术
|
监控 Java uml
lettuce连接池很香，撸撸它的源代码(下）
lettuce连接池很香，撸撸它的源代码
君哥聊技术
431 0
lettuce连接池很香，撸撸它的源代码(下）
君哥聊技术
|
编解码 NoSQL 安全
lettuce连接池很香，撸撸它的源代码(上）
lettuce连接池很香，撸撸它的源代码
君哥聊技术
976 0
lettuce连接池很香，撸撸它的源代码(上）
陈老老老板
|
SQL 存储 安全
《JavaWeb篇》02.JDBC看这一篇就够了（二）
《JavaWeb篇》02.JDBC看这一篇就够了（二）
陈老老老板
142 0
《JavaWeb篇》02.JDBC看这一篇就够了（二）
陈老老老板
|
SQL Oracle Java
《JavaWeb篇》02.JDBC看这一篇就够了（一）
《JavaWeb篇》02.JDBC看这一篇就够了（一）
陈老老老板
179 0
《JavaWeb篇》02.JDBC看这一篇就够了（一）
陈老老老板
|
druid Java 数据库连接
《JavaWeb篇》02.JDBC看这一篇就够了（三）
《JavaWeb篇》02.JDBC看这一篇就够了（三）
陈老老老板
157 0
《JavaWeb篇》02.JDBC看这一篇就够了（三）

热门文章

最新文章

  • 1
    常见浏览器User-Agent大全
  • 2
    未来已来！阿里小蜜AI技术揭秘
  • 3
    Flink: 实时规则引擎助力新零售发展
  • 4
    Apache Flink 进阶（三）：Checkpoint 原理解析与应用实践
  • 5
    weex-html5 组件进阶
  • 6
    群智能算法：灰狼优化算法（GWO）的详细解读
  • 7
    Amazon 的IoT之路
  • 8
    hp M1530一体机无法在OEM系统下安装驱动
  • 9
    NumPy Cookbook 带注释源码 十、Scikit 中的乐趣
  • 10
    潮流设计：15个创意的 3D 字体版式作品欣赏
  • 1
    springboot配置hosts文件
    24
  • 2
    maven项目的pom.xml文件常用标签使用介绍
    23
  • 3
    天气预报-腾讯天气-7天-地址查询版免费API接口
    23
  • 4
    第四届人文，智慧教育与服务管理国际学术会议（HWESM 2025） 2025 4th International Conference on Humanities, Wisdom Education and Service Management
    19
  • 5
    2025电气自动化与电机系统国际学术会议（EAMS 2025） 2025 International Conference on Electrical Automation and Motor System
    19
  • 6
    大厂面试高频：什么是自旋锁？Java 实现自旋锁的原理？
    18
  • 7
    C++ 之 perf+火焰图分析与调试
    16
  • 8
    面试高频：Synchronized 原理，建议收藏备用 ！
    13
  • 9
    SQL 中，通配符
    14
  • 10
    鸿蒙next版开发：相机开发-适配不同折叠状态的摄像头变更(ArkTS)
    20

    • 相关课程

    更多
  • JDBC数据库开发进阶
  • JDBC数据库开发入门
  • PHP进阶教程 - 由浅入深掌握面向对象开发 - 第二阶段

    • 相关电子书

    更多
  • 低代码开发师（初级）实战教程
  • 冬季实战营第三期：MySQL数据库进阶实战
  • 阿里巴巴DevOps 最佳实践手册
    • 下一篇
    无影云桌面