JDBC（重点）

2024-03-01 09:51:52

JDBC（重点）

数据库驱动
- 驱动 : 声卡、显卡、数据库

JDBC

SUN公司为了简化开发人员的（对数据库的统一）操作，提高了一个（java操作数据库的）规范，俗称 JDBC

这些规范的具体实现由具体的厂商去做。

对于开发人员来说，只需要掌握JDBC接口的操作即可

java.sql

javax.sql

还需要导入一个数据库驱动包 mysql-connector-java-5.1.47.jar :

https://mvnrepository.com/artifact/mysql/mysql-connector-java/5.1.47

第一个JDBC程序

创建一个普通项目

创建测试数据库

CREATE DATABASE jdbcStudy CHARACTER SET utf8 COLLATE utf8_general_ci;
USE jdbcStudy;
CREATE TABLE users(
    id INT PRIMARY KEY,
    NAME VARCHAR(40),
    PASSWORD VARCHAR(40),
    email VARCHAR(60),
    birthday DATE
);
INSERT INTO users(id,NAME,PASSWORD,email,birthday)
VALUES(1,'zhangsan','123456','zs@sina.com','1980-12-04'),
(2,'lisi','123456','lisi@sina.com','1981-12-04'),
(3,'wangwu','123456','wangwu@sina.com','1979-12-04');

导入包 : mysql-connector-java-5.1.47.jar
编写测试代码
- 步骤总结：
  
  1.加载驱动
  
  2.连接数据库 DriverManager
  
  3.获得执行sql的对象 Statement
  
  4.获得返回的结果集
  
  5.释放连接

public class jdbcTest01 {
    public static void main(String[] args) throws Exception {
        // 1、加载驱动
        Class.forName("com.mysql.jdbc.Driver");   // 固定写方，加载驱动
        // 2、用户信息和 url
        //        useUnicode=true               支持中文编码
        //        characterEncoding=utf8        设置中文集为utf8
        //        useSSL=true                   设置安全的连接
        String url="jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&useSSL=true";    //由于我的mysql版本较高，不能安全连接
        String username="root";
        String password="123456";
        // 3、连接 数据库对象 Connection 代表数据库
        Connection conn = DriverManager.getConnection(url,username,password);
        // 4、执行SQL对象Statement 执行SQL的对象
        Statement stmt = conn.createStatement();
        //5、执行SQL的对象 去 执行SQL 可能存在的结果 查看返回结果
        String sql = "SELECT * FROM users";
        ResultSet rs = stmt.executeQuery(sql);   // 返回结果集合
        while (rs.next())
        {
            System.out.println("id="+rs.getObject("id"));
            System.out.println("name="+rs.getObject("NAME"));
            System.out.println("pwd="+rs.getObject("PASSWORD"));
            System.out.println("email="+rs.getObject("email"));
            System.out.println("birth="+rs.getObject("birthday"));
        }
        // 6、释放资源
        rs.close();
        stmt.close();
        conn.close();

    }
}

DriverManager

// DriverManager.registerDriver(new com.mysql.jdbc.Driver());
Class.forName("com.mysql.jdbc.Driver");   // 固定写方，加载驱动
Connection conn = DriverManager.getConnection(url,username,password);
// conn 代表数据库
// 数据库设置自动提交
// 事务提交
// 事务回滚
conn.rollback();
conn.commit();
conn.setAutoCommit();

URL

String url="jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&useSSL=false";
//MySQL  端口号：3306
//jdbc:mysql://主机地址:端口号/数据库名?参数1&参数2&参数3
//oralce 端口号：1521
// jdbc:oracle:thin:@主机地址：1521:sid

Statement 执行sql的对象

String sql = "SELECT *FROM users"; //编写SQL
Statement stmt = conn.createStatement();// 执行SQL对象Statement 执行SQL的对象
stmt.executeQuery(); //查询操作返回 ResultSet
stmt.execute();      // 执行任何SQL
stmt.executeUpdate(); // 更新、插入、删除   返回一个受影响的行数

ResultSet 查询的结果集：封装了所有的查询结果

获得指定的数据类型

rs.getObject();  // 在不知道列类型的情况下使用
// 如果知道列的类型就使用指定的类型
rs.getString();
rs.getInt();
rs.getFloat();
rs.getDate();
......

遍历、指针

rs.beforeFirst();      // 移动到最前面
rs.afterLast();       // 移动到最后面
rs.next();           // 移动到下一个数据
rs.previous();      // 移动到前一行
rs.absolute(row);  // 移动到指定行

释放资源

rs.close();
stmt.close();
conn.close();  // 耗资源，用完关掉！

statement对象

Jdbc中的statement对象用于向数据库发送SQL语句，想完成对数据库的增删改查，只需要通过这个对象向数据库发送增删改查语句即可。
Statement对象的executeUpdate方法，用于向数据库发送增、删、改的sqli语句，executeUpdate执行完后，将会返回一个整数（即增删改语句导致了数据库几行数据发生了变化)。
Statement.executeQuery方法用于向数据库发送查询语句，executeQuery方法返回代表查询结果的ResultSet对象。

CRUD操作-create

使用executeUpdate（String sql）方法完成数据添加操作，实例操作：

Statement st = conn.createstatement();
String sq1 = "insert into user(.... ) values(.....) ";
int num = st.executeUpdate(sql);
if(num>0){
    system.out.println("插入成功!! ! ");
}

CRUD操作-delete

使用executeUpdate（String sql）方法完成数据删除操作，实例操作：

Statement st = conn.createstatement();
string sq1 = "delete from user where id=1";
int num = st.executeUpdate(sql);
if(num>0){
    system.out.println("删除成功!! ! ");
}

CRUD操作-update

使用executeUpdate（String sql）方法完成数据修改操作，实例操作：

Statement st = conn.createstatement();
string sq1 = "update user set name='' where name=''";
int num = st.executeUpdate(sql);
if(num>0){
    system.out.println("修改成功!! ! ");
}

CRUD操作-read

使用executeQuery（String sql）方法完成数据修改操作，实例操作：

Statement st = conn.createstatement();
string sq1 = "select * from user where id=1";
ResultSet rs = st.executeQuery(sql);
while(rs.next(){
    //根据获取列的数据类型，分别调用rs的响应方法映射到java对象中
}

编写工具类

创建资源文件 db.properties

url=jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&useSSL=true
username = root
password = 123456
driver = com.mysql.jdbc.Driver

新建工具类，写有连接数据库使用的代码，方便其他类调用 jdbcUtils.java

public class jdbcUtils {
    private static String driver = null;
    private static String url = null;
    private static String username = null;
    private static String password = null;

    static {
        try {
            InputStream in = jdbcUtils.class.getResourceAsStream("db.properties");
            Properties properties = new Properties();
            properties.load(in);
            driver = properties.getProperty("driver");
            url = properties.getProperty("url");
            username = properties.getProperty("username");
            password = properties.getProperty("password");
            //驱动只需要加载一次
            Class.forName(driver);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    //获取连接
    public static Connection getConnection() throws Exception{
        return DriverManager.getConnection(url,username,password);
    }
    //释放连接资源
    public static void release(Connection conn, Statement st, ResultSet rs){
        if(rs!=null){
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if(st!=null){
            try {
                st.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if(conn!=null){
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

进行增删改测试

public static void main(String[] args) {
        Connection conn = null;
        Statement st = null;
        ResultSet rs = null;
        try {
            conn = jdbcUtils.getConnection();
            st = conn.createStatement();  //创建Statement对象
            /* //新增
            String sql = "INSERT INTO users (id,`NAME`,`PASSWORD`,`email`,`birthday`)" +
                    "VALUES(4,'小李','123456','12344555@qq.com','2020-1-1')";*/
            /*//删除
            String sql = "delete from users where id = '4'";*/
            String sql = "update users set name = 'saxon' where id = '1'";
            int i =  st.executeUpdate(sql);
            if(i>0){ //如果数据大于0
                System.out.println("插入成功！");
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            jdbcUtils.release(conn,st,rs);
        }
    }

进行查询测试

public static void main(String[] args) {
        Connection conn = null;
        Statement st = null;
        ResultSet rs = null;
        try {
            conn = jdbcUtils.getConnection();
            st = conn.createStatement();  //创建Statement对象
            String sql = "select * from users";
            rs = st.executeQuery(sql);
            while (rs.next()){
                System.out.println("name="+rs.getString("NAME"));
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            jdbcUtils.release(conn,st,rs);
        }
    }

码农公寓

JDBC（重点）

数据库驱动

JDBC

第一个JDBC程序

statement对象

CRUD操作-create

CRUD操作-delete

CRUD操作-update

CRUD操作-read

编写工具类

相关文章