JDBC程序(数据库查询)
步骤:
-
加载驱动
-
连接数据库DriverManager
-
获得执行sql的对象 Statement
-
获得返回的结果集 ResultSet
-
释放连接
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();
}
}