WordPress一键开启全站SSL,北京做网站哪家强,百度网站公司信息推广怎么做的,信息网站建设预算学习目标 理解JDBC原理 掌握Connection接口的使用 掌握Statement接口的使用 掌握ResultSet接口的使用 掌握PreparedStatement接口的使用 掌握Properties类与配置文件的使用
JDBC 概念
JDBC (Java DataBase Connectivity) Java数据库连接技术的简称#xff0c;提供连接各种常…学习目标 理解JDBC原理 掌握Connection接口的使用 掌握Statement接口的使用 掌握ResultSet接口的使用 掌握PreparedStatement接口的使用 掌握Properties类与配置文件的使用
JDBC 概念
JDBC (Java DataBase Connectivity) Java数据库连接技术的简称提供连接各种常用数据库的能力 说白了就是java语言连接数据库
有一个程序员,他要写一套程序,但是他不知道公司用什么数据库所以,他就得学java连mysql连Oracle,连DB2,
市面上所有的关系型数据库,他都得学习一遍,对吧!而我们期望使用统一的一套Java代码可以操作所有的关系型数据库
有一个程序员终于忍不住了,写了个JDBC
JDBC:定义了操作所有关系型数据库的规则(接口)这里只是写了接口,但是没有写具体的实现类,那么这个实现类谁写呢sun公司说了,每一个数据库的厂商你们自己写实现类
所以每个数据库厂商都写了不同的实现类,不同版本的实现类我们给这个实现类起了个名字,叫做数据库驱动
JDBC本质:其实就是官方(Sun公司)定义的一套操作所有关系型数据库的规则,及接口. 各个数据库厂商去实现这套接口,提供数据库驱动jar包.我们可以使用这套接口(JDBC)编程,真正执行的代码是驱动jar包中的实现类.
JDBC快速入门
步骤: 导入驱动jar包 官网mysql驱动jar包下载地址:mysql/mysql-connector-java 复制mysql-connector-java-5.1.37.jar右键–Add as library 注册驱动 获取数据库的连接对象 定义sql 获取执行sql语句的对象 statement 执行sql,接收返回结果 处理结果 释放资源
实例代码
别管能不能看懂,直接我就上一堆代码,然后再解释
package cn.itcast.jdbc;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;/*** author victor* site https://victorfengming.github.io/* company XDL* project itcast* package cn.itcast.jdbc* created 2019-11-07 23:43* function */
public class JdbcDemo01 {public static void main(String[] args) throws Exception {// 1. 导入驱动jar包// 2.注册驱动Class.forName(com.mysql.jdbc.Driver);// 3.获取数据库连接对象Connection conn DriverManager.getConnection(jdbc:mysql://localhost:3306/plan,root,);//4. 定义sqlString sql use plan;//5. 获取执行sql语句的对象 statementStatement stmt conn.createStatement();//6. 执行sql,接收返回结果int count stmt.executeUpdate(sql);//7. 处理结果System.out.println(count);//8. 释放资源stmt.clearBatch();conn.close();}
}详解各个对象
DriverManager
驱动管理对象,用于管理JDBC驱动, 功能如下:
1. 注册驱动
注册与给定的驱动程序static void registerDriver(Driver driver)写代码使用: Class.forName(com.mysql.jdbc.Driver);好像这个类中有一个静态代码块,这里面有现成的代码通过查看源码发现:在com.mysql.jdbc.Driver类中存在静态代码块 static {try {DriverManager.registerDriver(new Driver());} catch (SQLException var1) {throw new RuntimeException(Cant register driver!);}}补充: 在mysql-connector-java-5.1.37.jar 的5版本之后有一个文件在mysql-connector-java-5.1.37.jar/META-INF/services/java.sql.Driver里面这个文件可以让你省略注册驱动的步骤,好吧!
2. 获取数据库连接:
方法:static Connection getConnection(String url,String user,String password)
参数: - url:指定连接的路径 - 语法:jdbc:mysql://ip地址(域名):端口号/数据库名称 - 例子:jdbc:mysql://localhost:3306/plan - 细节:如果连接的是本机的mysql服务器,并且mysql服务器默认端口是3306,则url可以简写为:jdbc:mysql///数据库名称 - 例如:Connection conn DriverManager.getConnection(jdbc:mysql:///plan,root,); - user:用户名 - password:密码
Connection 数据库连接对象,用于连接数据库并传送数据
1. 获取执行sql的对象
Statement createStatementPreparedStatement prepareStatement(String sql)
2. 管理事务:
开启事务: setAutoCommit(boolean autoCommit): 调用改方法设置参数为false,就开启事务啦,哈哈提交事务: commit()回滚事务: rollback()
Statement 执行sql的对象,负责执行SQL语句
执行sql
boolean execute(String sql) :可以执行任意的sql,可能会返回多个结果!(了解即可)int executeUpdate(String sql): 执行DML(insert,update,delete)语句,DDL(create,alter,drop)语句这个DDL不经常用,所有在这个地方我们都是用前者的返回值: 执行语句后,所影响的行数,我们可以通过这个影响的行数判断DML语句是否执行成功,要是大于0就成功了呗,反之,则失败. ResultSet executeQuery(String sql): 执行DQL(select)语句
练习:见附录
ResultSet结果集对象,负责保存Statement执行后所产生的查询结果
next():
游标向下移动一行并且判断当前行是否是最后一行的末尾返回boolean,如果有数据返回true,反之亦然!
getXxx(参数):获取数据
Xxx:代表数据类型 如:int getInt(), String getString()参数: int: 代表列的编号, 从1开始 如getString(1)String: 代表列名称. 如: getDouble(balance)
- 注意:
使用步骤:
游标向下移动一行判断是否有数据获取数据
- 练习:
定义一个方法,查询emp表的数据将其封装为对象,然后装载集合,返回.
定义Emp类 用于封装Emp表数据的JavaBean定义方法 public ListEmp findAll(){}实现方法 select * from emp;
PreparedStatement : 执行sql的对象,用于负责执行SQL语句
1. SQL注入问题:在拼接sql时,有一些特殊关键字参与字符串的拼接.会造成安全性的问题.
输入用户名随便,输入密码:a or a asql:select * from user where username victor and password a or a a
2. 解决sql注入问题:使用PreparedStatement对象来解决,他是
3. 预编译sql:参数使用?作为占位符
4. 使用步骤: 导入驱动包 注册驱动 获取数据库对象连接 定义sql
注意:sql的参数使用?作为占位符.如:select * from user where username ? and password ?; 获取执行sql语句的对象PreparedStatement Connection.prepareStatement(String sql) 给? 赋值:
方法: setXxx(参数1,参数2) 参数1:?的位置编号 从1 开始参数2:?的值 执行sql,接受返回结果,不需要传递sql语句 处理结果 释放资源
5. 注意:后期都会使用PreparedStatement来完成增删改查的所有操作
可以防止SQL注入效率更高
抽取JDBC工具类 : JdbcUtils.java
- 目的 : 简化书写
- 分析 :
1. 注册驱动
2. 抽取一个方法获取连接对象
需求 : 不想传递参数(麻烦),还得保证工具类的通用性. 解决 : 配置文件 jdbc.properties
urljdbc:mysql:///plan
userroot
password
drivercom.mysql.jdbc.Driver- 练习:
- 需求 :
通过键盘录入用户名和密码判断用户是否登录成功 select * from user where username and password 如果这个sql有结果,则查询成功,反之失败
- 步骤 :
创建数据库表 user
create table user(id int primary key auto_increment,username varchar(32),password varchar(32)
);插入数据
insert into user
values (null,victor,123);insert into user
values (null,ttkr,1907123);JDBC控制事务:
1. 事务: 一个包含多个步骤的业务操作.如果这个业务操作被事务管理,则这多个步骤要么同事成功,要么同时失败.
2. 操作:
开始事务提交事务回滚事务
3. 使用Connection对象来管理事务
开启事务:setAutoCommit(boolean autoCommit) :调用改方法设置参数为false,即开启事务提交事务: commit()回滚事务: rollback() catch中回滚事务
附录(源代码)
account表 添加一条记录
package cn.itcast.jdbc;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;/*** author victor* site https://victorfengming.github.io/* company XDL* project itcast* package cn.itcast.jdbc* created 2019-11-08 14:41* function 用于插入数据*/
public class JdbcDemo02 {public static void main(String[] args) {Statement stmt null;try {// 1.注册驱动// 这行不写也行// Class.forName(com.mysql.jdbc.Driver);// 2. 定义sql// String sql insert into account values(null,ttk,6299);String sql insert into account values(null,yupeng,5666);// 获取Connection对象Connection conn DriverManager.getConnection(jdbc:mysql:///plan, root, );// 4获取执行sql对象 Statementstmt conn.createStatement();// 5 执行sqlint count stmt.executeUpdate(sql);// count影响的行数// 6.处理结果System.out.println(count);if (count 0) {System.out.println(提交成功);} else {System.out.println(添加失败);}} catch (Exception e) {e.printStackTrace();} finally {// 释放资源// 为了避免空指针异常需要判断if (stmt ! null) {try {stmt.close();} catch (SQLException e) {e.printStackTrace();}}}}
}
account表 删除一条记录
package cn.itcast.jdbc;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;/*** author victor* site https://victorfengming.github.io/* company XDL* project itcast* package cn.itcast.jdbc* created 2019-11-08 15:35* function 从表中删除记录*/
public class JdbcDemo04 {public static void main(String[] args) {Connection conn null;Statement stmt null;try {// 1.注册表// 2.获取连接对象conn DriverManager.getConnection(jdbc:mysql:///plan,root,);// 3. 定义sqlString sql delete from account where id 4;// 4.获取执行sql对象stmt conn.createStatement();// 5.执行sqlint count stmt.executeUpdate(sql);// 6.处理结果if (count 0) {System.out.println(运行成功);} else {System.out.println(失败了!);}} catch (Exception e) {e.printStackTrace();}finally {// 7. 释放资源if (stmt ! null) {try {stmt.close();} catch (SQLException e) {e.printStackTrace();}}}}}
account表 修改一条记录
package cn.itcast.jdbc;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;/*** author victor* site https://victorfengming.github.io/* company XDL* project itcast* package cn.itcast.jdbc* created 2019-11-08 15:16* function account表修改记录*/
public class JdbcDemo03 {public static void main(String[] args) {Connection conn null;Statement stmt null;try {// 1.注册表// 2.获取连接对象conn DriverManager.getConnection(jdbc:mysql:///plan,root,);// 3. 定义sqlString sql update account set balance 6060 where id 2;// 4.获取执行sql对象stmt conn.createStatement();// 5.执行sqlint count stmt.executeUpdate(sql);// 6.处理结果if (count 0) {System.out.println(运行成功);} else {System.out.println(失败了!);}} catch (Exception e) {e.printStackTrace();}finally {// 7. 释放资源if (stmt ! null) {try {stmt.close();} catch (SQLException e) {e.printStackTrace();}}}}
}DDl: 创建一个表
package cn.itcast.jdbc;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;/*** author victor* site https://victorfengming.github.io/* company XDL* project itcast* package cn.itcast.jdbc* created 2019-11-08 15:40* function 用于创建一个新表*/
public class JdbcDemo05 {public static void main(String[] args) {Connection conn null;Statement stmt null;try {// 1.注册表// 2.获取连接对象conn DriverManager.getConnection(jdbc:mysql:///plan,root,);// 3. 定义sqlString sql create table student (id int ,name varchar(20));// 4.获取执行sql对象stmt conn.createStatement();// 5.执行sqlint count stmt.executeUpdate(sql);// 6.处理结果if (count 0) {System.out.println(运行成功);} else {System.out.println(失败了!);}} catch (Exception e) {e.printStackTrace();}finally {// 7. 释放资源if (stmt ! null) {try {stmt.close();} catch (SQLException e) {e.printStackTrace();}}}}
}account表 查询一条记录
package cn.itcast.jdbc;import java.sql.*;/*** author victor* site https://victorfengming.github.io/* company XDL* project itcast* package cn.itcast.jdbc* created 2019-11-08 16:01* function 查询是重中之重*/
public class JdbcDemo06 {public static void main(String[] args) {Connection conn null;Statement stmt null;ResultSet rs null;try {// 1.注册表// 2.获取连接对象conn DriverManager.getConnection(jdbc:mysql:///plan, root, );// 3. 定义sqlString sql select * from account;// 4.获取执行sql对象stmt conn.createStatement();// 5.执行sqlrs stmt.executeQuery(sql);// 6.处理结果// 6.1 让游标向下移动一行// 循环判断游标是否最后一行末尾while (rs.next()) {// 获取数据int id rs.getInt(1);String name rs.getString(name);double balance rs.getDouble(3);System.out.println(id --- name --- balance);}} catch (Exception e) {e.printStackTrace();} finally {// 7. 释放资源if (stmt ! null) {try {stmt.close();} catch (SQLException e) {e.printStackTrace();}}}}
}工具类
package cn.itcast.util;import java.io.FileReader;
import java.io.IOException;
import java.net.URL;
import java.sql.*;
import java.util.Properties;/*** author victor* site https://victorfengming.github.io/* company XDL* project itcast* package cn.itcast.util* created 2019-11-09 10:40* function JDBC工具类*/
public class JdbcUtils {//声明三个成员变量// 因为只有静态变量才能被静态代码块所访问,被静态方法所访问private static String url;private static String user;private static String password;private static String driver;/*** 文件的读取,只需要读取一次即可拿到这些值* 我们可以使用静态代码块* 因为静态代码块是随着类加载进行加载的* 只读取一次*/static {// 读取资源文件,获取值try {// 1. 创建 Properties集合类Properties pro new Properties();// 2.加载文件
// pro.load(new FileReader(D:\\IdeaProjects\\itcast\\day04-JDBC\\src\\jdbc.properties));// 这么写指定不行// 获取src路径下的文件的方式--ClassLoader 类加载器ClassLoader classLoader JdbcUtils.class.getClassLoader();// 这里的相对路径就是srcURL res classLoader.getResource(jdbc.properties);// 这里URL表示统一资源对应符String path res.getPath();
// System.out.println(path);pro.load(new FileReader(path));// 3.获取属性,赋值url pro.getProperty(url);user pro.getProperty(user);password pro.getProperty(password);driver pro.getProperty(driver);// 4. 注册驱动Class.forName(driver);} catch (IOException e) {e.printStackTrace();} catch (ClassNotFoundException e) {e.printStackTrace();}}/*** 获取连接* return 连接对象*/
// public static Connection getConnection(String url,String user,String password,String driver) throws SQLException {
// return DriverManager.getConnection(url, user, password);
// }
// 这个地方,我既不想用传递参数的方式,还想要简化书写,这可咋整,我们这里使用配置文件的方式,所以要这样写public static Connection getConnection() throws SQLException {return DriverManager.getConnection(url, user, password);}/*** 释放资源方法*/public static void close(Statement stmt, Connection conn) {if (stmt ! null) {try {stmt.close();} catch (SQLException e) {e.printStackTrace();}}if (conn ! null) {try {conn.close();} catch (SQLException e) {e.printStackTrace();}}}/*** 释放资源方法重载*/public static void close(ResultSet rs, Statement stmt, Connection conn) {if (rs ! null) {try {rs.close();} catch (SQLException e) {e.printStackTrace();}}if (stmt ! null) {try {stmt.close();} catch (SQLException e) {e.printStackTrace();}}if (conn ! null) {try {conn.close();} catch (SQLException e) {e.printStackTrace();}}}
}
查询emp表的数据将其封装为对象
package cn.itcast.jdbc;import cn.itcast.domain.Emp;
import cn.itcast.util.JdbcUtils;import java.sql.*;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;/*** author victor* site https://victorfengming.github.io/* company XDL* project itcast* package cn.itcast.jdbc* created 2019-11-08 23:38* function 定义一个方法,查询emp表的数据将其封装为对象,然后装载集合,返回*/
public class JdbcDemo08 {public static void main(String[] args) {ListEmp list new JdbcDemo08().findAll2();for (Emp emp : list) {System.out.println(emp);}}/*** 查询所有emp对象** return*/public ListEmp findAll() {//提前声明一些变量,以便于能够在try和catch中来回穿梭Connection conn null;Statement stmt null;ResultSet rs null;ListEmp list null;try {// 1.注册,为了能够兼容mysql5以下的版本,所以写上Class.forName(com.mysql.jdbc.Driver);// 2.获取连接conn DriverManager.getConnection(jdbc:mysql:///plan, root, );// 3.定义sqlString sql select * from emp;// 4. 获取执行sql的对象stmt conn.createStatement();// 5.执行sqlrs stmt.executeQuery(sql);// 先创建一个引用就okEmp emp null;list new ArrayListEmp();// 6.遍历结果集while (rs.next()) {// 7.获取数据int id rs.getInt(id);String ename rs.getString(ename);int job_id rs.getInt(job_id);int mgr rs.getInt(mgr);// 这个sqlDate是Date 的子类,所以是可以直接进行赋值的Date joindate rs.getDate(joindate);double bonus rs.getDouble(bonus);double salary rs.getDouble(salary);int dept_id rs.getInt(dept_id);// 创建emp对象emp new Emp();emp.setId(id);emp.setEname(ename);emp.setJob_id(job_id);emp.setMgr(mgr);emp.setJoindate(joindate);emp.setBonus(bonus);emp.setSalary(salary);emp.setDept_id(dept_id);// 装载集合list.add(emp);}} catch (Exception e) {e.printStackTrace();}finally {// 7. 释放资源if (stmt ! null) {try {stmt.close();} catch (SQLException e) {e.printStackTrace();}}if (rs ! null) {try {rs.close();} catch (SQLException e) {e.printStackTrace();}}if (conn ! null) {try {conn.close();} catch (SQLException e) {e.printStackTrace();}}}return list;} /*** 演示JDBC工具类** return*/public ListEmp findAll2() {//提前声明一些变量,以便于能够在try和catch中来回穿梭Connection conn null;Statement stmt null;ResultSet rs null;ListEmp list null;try {// 1.注册,为了能够兼容mysql5以下的版本,所以写上// 2.获取连接conn JdbcUtils.getConnection();// 3.定义sqlString sql select * from emp;// 4. 获取执行sql的对象stmt conn.createStatement();// 5.执行sqlrs stmt.executeQuery(sql);// 先创建一个引用就okEmp emp null;list new ArrayListEmp();// 6.遍历结果集while (rs.next()) {// 7.获取数据int id rs.getInt(id);String ename rs.getString(ename);int job_id rs.getInt(job_id);int mgr rs.getInt(mgr);// 这个sqlDate是Date 的子类,所以是可以直接进行赋值的Date joindate rs.getDate(joindate);double bonus rs.getDouble(bonus);double salary rs.getDouble(salary);int dept_id rs.getInt(dept_id);// 创建emp对象emp new Emp();emp.setId(id);emp.setEname(ename);emp.setJob_id(job_id);emp.setMgr(mgr);emp.setJoindate(joindate);emp.setBonus(bonus);emp.setSalary(salary);emp.setDept_id(dept_id);// 装载集合list.add(emp);}} catch (Exception e) {e.printStackTrace();}finally {// 7. 释放资源JdbcUtils.close(rs,stmt,conn);}return list;}
}
用户登录案例
package cn.itcast.jdbc;import cn.itcast.util.JdbcUtils;
import cn.itcast.util.python;import java.sql.*;/*** author victor* site https://victorfengming.github.io/* company XDL* project itcast* package cn.itcast.jdbc* created 2019-11-09 11:52* function - 需求 :* - 通过键盘录入用户名和密码* - 判断用户是否登录成功*/
public class JdbcDemo09 {public static void main(String[] args) {// 1.键盘录入,接收用户名和密码String username python.input(请输入用户名:);String password python.input(请输入密码:);// 2.调用用方法//创建对象boolean flag new JdbcDemo09().login(username, password);// 3.判断结果,输出不同语句if (flag) {System.out.println(登录成功);} else {System.out.println(用户名或者密码错误);}}/*** 登录方法*/public boolean login(String username, String password) {Connection conn null;PreparedStatement pstmt null;ResultSet rs null;try {if (username ! null || password ! null) {;}// 连接数据库判断是否登录成功// 1.获取连接conn JdbcUtils.getConnection();// 2.定义sqlString sql select * from user where username ? and password ?;System.out.println(sql);// 3获取执行sql的对象// stmt conn.createStatement();// 升级版本的pstmt conn.prepareStatement(sql);// 4执行查询// rs pstmt.executeQuery(sql);// 这里不需要传递参数了rs pstmt.executeQuery();// 5判断// 要是查到了, 唉, 就直接就返回true// if (rs.next()) {// // 如果有下一行则返回true// return true;// } else {// return false;// }// 上面的代码就是垃圾代码// 如果有下一行则返回truereturn rs.next();} catch (SQLException e) {e.printStackTrace();// 去改配置文件, 数据库要db4// 这里就体现了JdbcUtils类的可扩展性很强了,不用改代码都}finally {// 释放资源JdbcUtils.close(rs,pstmt,conn);}return false;}
}
转账案例
package cn.itcast.jdbc;import cn.itcast.util.JdbcUtils;import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;/*** author victor* site https://victorfengming.github.io/* company XDL* project itcast* package cn.itcast.jdbc* created 2019-11-09 14:07* function 事务操作*/
public class JdbcDemo10 {public static void main(String[] args) {transfer();}/*** 转账函数*/public static void transfer() {Connection conn null;PreparedStatement pstmt1 null;PreparedStatement pstmt2 null;try {// 1.获取来接conn JdbcUtils.getConnection();// 2. 定义sql//2.1 victor500String sql1 update account set balance balance ? where id ?;// 2.2 ttkr -50String sql2 update account set balance balance - ? where id ?;// 3.获取执行sql对象pstmt1 conn.prepareStatement(sql1);pstmt2 conn.prepareStatement(sql2);// 设置参数pstmt1.setDouble(1,500);pstmt1.setDouble(2,1);pstmt2.setDouble(1,500);pstmt2.setDouble(2,2);// 5.执行sqlpstmt1.executeUpdate();// 手动制造异常int i 3/0;pstmt2.executeUpdate();} catch (Exception e) {// 事务回滚try {if (conn ! null) {conn.rollback();}} catch (SQLException ex) {ex.printStackTrace();}e.printStackTrace();}finally {JdbcUtils.close(pstmt1,conn);JdbcUtils.close(pstmt2,null);}}
}
