JDBC开发之四大核心API:DriverManager Connection Statement ResultSet-阿里云开发者社区

JDBC开发之四大核心API:DriverManager Connection Statement ResultSet

2024-06-24 36

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

本文涉及的产品

RDS MySQL Serverless 基础系列，0.5-2RCU 50GB

云数据库 RDS MySQL，集群系列 2核4GB

RDS MySQL Serverless 高可用系列，价值2615元额度，1个月

简介： JDBC开发之四大核心API:DriverManager Connection Statement ResultSet

DriverManager

方法都是静态的

注册驱动

在Mysql5之后我们就不用注册驱动了

在jar包里已经写好了

读取文件

第二个方法

如果连接的是主机mysql并且端口是默认的3306

则可以简化书写

代码书写

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
 
 
public class Main {
 
    //JDBC的快速入门
    public static void main(String[] args) throws Exception {
        //注册驱动
//        Class.forName("com.mysql.cj.jdbc.Driver");
 
        //获取连接
        String url = "jdbc:mysql:///mybatis?serverTimezone=UTC&useSSL=false";
        String username = "root";
        String password = "123456";
        Connection conn = DriverManager.getConnection(url, username, password);
 
        //定义SQL语句
        String sql = "update tbl_user set age = 21 where id=1";
 
        //获取执行SQL的对象
        Statement stmt = conn.createStatement();
 
        //执行SQL
        int count1 = stmt.executeUpdate(sql);
 
        //处理结果
        System.out.println(count1);
 
        //释放资源
        stmt.close();
        conn.close();
    }
 
}

Connection

数据库连接对象

非常重要的功能

事物管理

sql语句设置被事物管理

要不同时成功要不同时失败

这样用异常包围

在加上修饰的代码

try {
    //开启事物
    conn.setAutoCommit(false);
 
    //执行SQL
    int count1 = stmt.executeUpdate(sql1);
    int count2 = stmt.executeUpdate(sql2);
 
    //处理结果
    System.out.println(count1);
    System.out.println(count2);
 
    //提交事务
    conn.commit();
} catch (Exception e) {
 
    //回滚事务
    conn.rollback();
 
    e.printStackTrace();
}

整体代码

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
 
 
public class Main {
 
    //JDBC的快速入门
    public static void main(String[] args) throws Exception {
        //注册驱动
//        Class.forName("com.mysql.cj.jdbc.Driver");
 
        //获取连接
        String url = "jdbc:mysql:///mybatis?serverTimezone=UTC&useSSL=false";
        String username = "root";
        String password = "123456";
        Connection conn = DriverManager.getConnection(url, username, password);
 
        //定义SQL语句
        String sql1 = "update tbl_user set age = 21 where id=1";
        String sql2 = "update tbl_user set age = 21 where id=2";
 
        //获取执行SQL的对象
        Statement stmt = conn.createStatement();
 
        try {
            //开启事物
            conn.setAutoCommit(false);
 
            //执行SQL
            int count1 = stmt.executeUpdate(sql1);
            int count2 = stmt.executeUpdate(sql2);
 
            //处理结果
            System.out.println(count1);
            System.out.println(count2);
 
            //提交事务
            conn.commit();
        } catch (Exception e) {
 
            //回滚事务
            conn.rollback();
 
            e.printStackTrace();
        }
 
        //释放资源
        stmt.close();
        conn.close();
    }
 
}

Statement

执行SQL语句

处理结果

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
 
 
public class Main {
 
    //JDBC的快速入门
    public static void main(String[] args) throws Exception {
        //注册驱动
        Class.forName("com.mysql.cj.jdbc.Driver");
 
        //获取连接
        String url = "jdbc:mysql:///mybatis?serverTimezone=UTC&useSSL=false";
        String username = "root";
        String password = "123456";
        Connection conn = DriverManager.getConnection(url, username, password);
 
        //定义SQL语句
        String sql = "update tbl_user set age = 21 where id=1";
 
        //获取执行SQL的对象
        Statement stmt = conn.createStatement();
 
        //执行SQL
        int count = stmt.executeUpdate(sql);//执行完DML语句 受影响的行数
 
        //处理结果
        System.out.println(count>0?"修改成功":"修改失败");
 
        //释放资源
        stmt.close();
        conn.close();
    }
 
}

创建新的数据库

删除数据库

ResultSet

查询相关的API

将来我们的查询代码使用频率最高

查询相关的API

将来我们的查询代码使用频率最高

书写代码

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
 
 
public class Main {
 
    //JDBC的快速入门
    public static void main(String[] args) throws Exception {
        //注册驱动
        Class.forName("com.mysql.cj.jdbc.Driver");
 
        //获取连接
        String url = "jdbc:mysql:///mybatis?serverTimezone=UTC&useSSL=false";
        String username = "root";
        String password = "123456";
        Connection conn = DriverManager.getConnection(url, username, password);
 
        //定义SQL语句
        String sql = "select * from tbl_user";
 
        //获取statement对象
        Statement stmt=conn.createStatement();
 
        //执行SQL
        ResultSet rs=stmt.executeQuery(sql);
 
        //遍历集合
        while(rs.next()){
            //获取数据
            int id=rs.getInt(1);
            String name=rs.getString(2);
            String age=rs.getString(3);
            String gender=rs.getString(4);
            System.out.println(id+" "+name+" "+age+" "+gender);
        }
 
        //释放资源
        rs.close();
        conn.close();
    }
 
}