[大数据]2021-10-05

JDBC程序(数据库查询）

步骤：

1. 加载驱动

2. 连接数据库DriverManager

3. 获得执行sql的对象 Statement

4. 获得返回的结果集 ResultSet

5. 释放连接

DriverManager

//DriverManager.registerDriver(new com.mysql.jdbc.Driver());
Class.forName("com.mysql.cj.jdbc.Driver");

URL

String url="jdbc:mysql://localhost:3306/bjpowernode?

useUnicode=true&characterEncoding=utf8&useSSL=true";

//mysql --3306

//协议://主机地址:端口号/数据库名?参数1&参数2&参数3

//Oralce --1521

//jdbc:Orcal:thin:@locasthost:1521:sid;

Statement 执行SQL的对象 PrepareStatement执行SQL的对象

Statement statement=connection.createStatement();//使用Statement声明一个SQL语句对象，用createStatement创建这个语句对象  向数据库发送SQL查询语句
String sql="SELECT * from dept";//编写SQL

statement.executeQuery();//查询操作返回ResultSet
statement.execute();//执行任何SQL
statement.executeLargeUpdate();//更新，插入，删除都是这个，返回一个受影响的行数

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

获得指定的数据类型

reultSet.getObject();//在不知道类型的情况下使用
//知道的情况下使用指定类型
resultSet.getString();
resultSet.getInt();
resultSet.getFloat();

遍历，指针

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

释放资源

resultSet.close();
statement.close();
connection.close();

整体代码

package com.pp.lesson01;

import java.net.ConnectException;
import java.sql.*;

//我的第一个JDBC程序
public class jdbcfirstDemo {
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
        //1.加载驱动
        Class.forName("com.mysql.cj.jdbc.Driver");

        //2.用户信息和url
        String url="jdbc:mysql://localhost:3306/bjpowernode?useUnicode=true&characterEncoding=utf8&usrSSL=true";
        String name="root";
        String password="111111";

        //3.连接成功，数据库对象
        Connection connection= DriverManager.getConnection(url,name,password);
        //4.执行SQL语句
        Statement statement=connection.createStatement();

        //5.执行SQL的对象去执行SQL，可能存在结果，查看返回结果
        String sql="SELECT * from dept";
        ResultSet resultSet = statement.executeQuery(sql);

        while(resultSet.next()){
            System.out.println("DEPTNO="+resultSet.getObject("DEPTNO"));
            System.out.println("DNAME="+resultSet.getObject("DNAME"));
            System.out.println("LOC="+resultSet.getObject("LOC"));
        }
        //6.释放连接
        resultSet.close();
        statement.close();
        connection.close();
	}
}