本课目标
理解JDBC的概念和工作原理
掌握JDBC的开发步骤
掌握 Connection 接口的使用
掌握Statement 接口的使用
掌握 ResultSet 接口的使用
JDBC(Java DataBase Connectivity)是Java数据库连接技术的简称,提供连接各种常用数据库的能力
JDBC API 的主要功能:与数据库建立连接、执行SQL语句、处理结果和释放资源
?API名称 | API作用 |
DriverManager | 注册驱动,获取Connection连接对象。 |
Connection | 负责连接数据库并担任传送数据的任务,最为重要的就是用来产生Statement对象。 |
Statement | 负责向数据库发送SQL语句,这样数据库就会执行发送过来的SQL语句。 |
ResultSet | ResultSet对象表示查询结果集,只有在执行查询操作后才会有结果集的产生。结果集是一个二维的表格。 |
第一步:选择myschool数据库,创建users表(id,username,userpass,role)并插入测试数据。第二步:新建一个Java工程,并导入MySQL程序驱动包
USE MYSCHOOL;
CREATE TABLE `USER`(
ID INT PRIMARY KEY AUTO_INCREMENT,
USERNAME VARCHAR(16) NOT NULL,
USERPASS VARCHAR(18) NOT NULL,
ROLE INT NOT NULL DEFAULT 4
)
INSERT INTO `USER` VALUES
(DEFAULT,'刘备','123456',2),
(DEFAULT,'秦始皇','123456',1),
(DEFAULT,'汉武帝','123456',3),
(DEFAULT,'步兵甲','123456',DEFAULT),
(DEFAULT, '骑兵乙', 'abcdef', 2),
(DEFAULT, '李白', 'qwerty', 1),
(DEFAULT, '王者露娜', '654321', 3),
(DEFAULT, '赵子龙', 'zhaoyun', DEFAULT),
(DEFAULT, '关羽', 'guanyu123', 2),
(DEFAULT, '貂蝉', 'diaochan456', 1),
(DEFAULT, '诸葛亮', 'zhugeliang789', 3),
(DEFAULT, '张良', 'zhangliang', DEFAULT);
在Java中先新建一个目录 lib ,然后“文件”、“项目结构”、“库” ,点“+” 选择包,应用
DriverManager用于加载驱动,并创建与数据库的连接,这个API的常用方法
在实际开发中并不推荐采用registerDriver方法注册驱动原因:
DriverManager.getConnection(url,username,password)
其中 username 和 password 是登录数据库的用户名和密码
url 用来找到要连接数据库的“网址”。mysql的url:jdbc:mysql://localhost:3306/myschool
JDBC规定url的格式是由三部分组成,每个部分中间使用冒号分隔
方法名 | 方法的作用 |
createStatement() | 创建向数据库发送sql的statement对象。 |
prepareStatement(sql) | 创建向数据库发送预编译sql的PrepareSatement对象。 |
prepareCall(sql) | 创建执行存储过程的callableStatement对象。 |
setAutoCommit(boolean autoCommit) | 设置事务是否自动提交。 |
commit() | 在此连接上提交事务。 |
rollback() | 在此连接上回滚事务。 |
close() | 关闭数据库连接。 |
Statement stmt = con.createStatement();//创建Statement对象
String sql = “select username from users”;//发送给服务器的SQL语句
ResultSet rs = stmt.executeQuery(sql);//执行SQL语句,并返回结果集
方法名 | 方法的作用 |
ResultSet executeQuery(String sql) | 用于向数据发送查询语句(select)。 |
int executeUpdate(String sql) | 用于向数据库发送insert、update或delete语句。 |
boolean execute(String sql) | 用于向数据库发送任意sql语句。 |
void addBatch(String sql) | 把多条sql语句放到一个批处理中。 |
int[] executeBatch() | 向数据库发送一批sql语句执行。 |
void close() | 释放资源。 |
String sql = “select username from users”;
ResultSet rs = stmt.executeQuery(sql);//执行SQL语句,并返回结果集
//读取结果
while(rs.next()){
????????? String userName=rs.getString(“username”);
????????? System.out.println(userName);
}
方法名 | 方法的作用 |
Object getObject(int index) | 根据列的索引获取任意的数据类型 |
Object getObject(string columnName) | 根据列的名称获取任意的数据类型 |
String getString(int index) | 根据列的索引获取字符串 |
String getString(String columnName) | 根据列的名称获取字符串 |
int? getInt(int index) | 根据列的索引获取整数 |
int getInt(String columnName) | 根据列的名称获取整数 |
boolean next() | 将游标从当前位置向下移动一行 |
close() | 释放资源。 |
Jdbc程序运行完后,切记要释放程序在运行过程中,创建的那些与数据库进行交互的对象,这些对象通常是ResultSet, Statement和Connection对象,特别是Connection对象,它是非常稀有的资源,用完后必须马上释放,如果Connection不能及时、正确的关闭,极易导致系统宕机。Connection的使用原则是尽量晚创建,尽量早的释放。
为确保资源释放代码能运行,资源释放代码也一定要放在finally语句中。
try {
if(rs != null) rs.close();
if(stmt != null) stmt.close();
if(con != null) con.close();
} catch(SQLException e) {
????? e.printStackTrace();
}
代码:
public class UserJdbc {
private static String url = "jdbc:mysql://127.0.0.1:3306/myschool?useSSL=false";
private static String userName = "root";
private static String passWord = "123456";
public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
try {
//1.加载驱动
Class.forName("com.mysql.jdbc.Driver");
//2.获取连接
conn = DriverManager.getConnection(url,userName,passWord);
//3.创建statement对象,并执行SQL
stmt = conn.createStatement();
String sql = "SELECT COUNT(1) FROM USER";
rs = stmt.executeQuery(sql);
//4.处理结果
int userCount = 0;
while (rs.next()) {
userCount = rs.getInt(1);
}
System.out.println("该表中一共有" + userCount + "条记录") ;
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}finally {
//5.释放资源
try {
if (rs != null) {
rs.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
try {
if (stmt != null) {
stmt.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
try {
if (conn != null) {
conn.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}