JDBC系列-详解各个对象

本文涉及的产品
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,高可用系列 2核4GB
简介: JDBC系列-详解各个对象

详解各个对象


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

  1. boolean execute(String sql) : 可以执行任意的sql,了解即可
  2. int executeUpdate(String sql) : 执行DML (insert、 update、 delete) 语句、DDL(create, alter、 drop)语句 返回值:影响的行数,可以通过这个影响的行数判断DML语句是否执行成功返回值>0的则执行成功,反之,则失败。
  3. 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}]



相关实践学习
如何在云端创建MySQL数据库
开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
存储 Java 数据库连接
JDBC中MetaData对象使用与详解
JDBC中MetaData对象使用与详解
160 0
|
SQL 存储 Java
如何模拟MyBatis对象映射赋值的过程,以及如何通过这种方式来简化我们的JDBC开发工作?
如何模拟MyBatis对象映射赋值的过程,以及如何通过这种方式来简化我们的JDBC开发工作?
102 0
|
SQL Oracle Java
Spring JDBC-使用Spring JDBC获取本地连接对象以及操作BLOB/CLOB类型数据
Spring JDBC-使用Spring JDBC获取本地连接对象以及操作BLOB/CLOB类型数据
405 0
|
SQL Oracle Java
|
Java 大数据 数据库连接
【大数据系列之JDBC】(八):使用PreparedStatement获取结果集对象
【大数据系列之JDBC】(八):使用PreparedStatement获取结果集对象
380 0
|
Oracle Java 关系型数据库
JDBC获取数据库列名-关于 ResultSet 对象中列的类型和属性信息
JDBC获取数据库列名-关于 ResultSet 对象中列的类型和属性信息
194 0
|
SQL 存储 Java
JDBC之通过ResultSet对象对结果集进行处理
JDBC之通过ResultSet对象对结果集进行处理
|
SQL Java 数据库连接
JDBC游标的使用----ResultSet对象
了解游标类型     关系数据库中的操作会对整个行集起作用。由 SELECT 语句返回的行集包括满足该语句的 WHERE 子句中条件的所有行。
2356 0
|
18天前
|
Java 关系型数据库 MySQL
mysql5.7 jdbc驱动
遵循上述步骤,即可在Java项目中高效地集成MySQL 5.7 JDBC驱动,实现数据库的访问与管理。
37 1
|
28天前
|
SQL 分布式计算 关系型数据库
Hadoop-24 Sqoop迁移 MySQL到Hive 与 Hive到MySQL SQL生成数据 HDFS集群 Sqoop import jdbc ETL MapReduce
Hadoop-24 Sqoop迁移 MySQL到Hive 与 Hive到MySQL SQL生成数据 HDFS集群 Sqoop import jdbc ETL MapReduce
73 0