JDBC笔记（1）
jdbc介绍
JDBC 是 Java 访问数据库的标准规范，真正怎么操作数据库还需要具体的实现类，也就是数据库驱动。每个数据库厂商根据自家数据库的通信格式编写好自己数据库的驱动。所以我们只需要会调用JDBC 接口中的方法即可，数据库驱动由数据库厂商提供。
使用 JDBC 的好处：
- 程序员如果要开发访问数据库的程序，只需要会调用 JDBC 接口中的方法即可，不用关注类是如何实现的。
- 使用同一套 Java 代码，进行少量的修改就可以访问其他 JDBC 支持的数据库
jdbc简单入门
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
* 步骤：
1. 导入驱动jar包 mysql-connector-java-5.1.37-bin.jar
1.复制mysql-connector-java-5.1.37-bin.jar到项目的libs目录下
2.右键-->Add As Library
2. 注册驱动
3. 获取数据库连接对象 Connection
4. 定义sql
5. 获取执行sql语句的对象 Statement
6. 执行sql，接受返回结果
7. 处理结果
8. 释放资源
public class JdbcDemo01 {
public static void main(String[] args) throws Exception {
//1.导入jar包 建立lib目录
//2.注册驱动 Class.forName(数据库驱动实现类) 加载和注册数据库驱动，数据库驱动由 mysql 厂商
// "com.mysql.jdbc.Driver" jdk3.0后可以不写
Class.forName("com.mysql.jdbc.Driver");
//3.获取数据库连接对象 协议名:子协议://服务器名或 IP 地址:端口号/数据库名?参数=参数值
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/db4", "root", "root");
//4.定义sql语句
String sql = "update stu2 set age = 50 where id=1";
//5.获取执行sql的对象Statement
Statement stat = conn.createStatement();
//6.执行sql
int i = stat.executeUpdate(sql);
//7.处理结果
System.out.println(i);
//8.释放资源
stat.close();
conn.close();
}
}
jdbc案例：实现登录
工具类：连接方法，释放资源方法
package cn.itcast.util;
import java.io.FileReader;
import java.io.IOException;
import java.net.URL;
import java.sql.*;
import java.util.Properties;
public class JdbsUtils {
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.获取src路径下文件的位置，用ClassLoader类加载器
ClassLoader classLoader = JdbsUtils.class.getClassLoader();
URL res = classLoader.getResource("jdbc.properties");
String path = res.getPath();
//3.加载文件
pro.load(new FileReader(path));
//4.获取数据，赋值
url = pro.getProperty("url");
user = pro.getProperty("user");
password = pro.getProperty("password");
driver = pro.getProperty("driver");
//5.注册驱动
Class.forName(driver);
} catch (IOException | ClassNotFoundException e) {
e.printStackTrace();
}
}
public static Connection getConnection() throws SQLException {
return DriverManager.getConnection(url,user,password);
}
/**
* 释放资源
* @param stat
* @param conn
*/
public static void close(Statement stat, Connection conn){
if(stat != null){
try {
stat.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(conn != null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
public static void close(Statement stat, Connection conn, ResultSet rs){
if(stat != null){
try {
stat.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(conn != null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(rs!= null){
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
配置文件jdbc.properties
url = jdbc:mysql:///db4
user = root
password = root
driver = com.mysql.jdbc.Driver
测试类
login没使用 PreparedStatement 接口，可以sql注入
login2使用了 PreparedStatement 接口
PreparedStatement 是 Statement 接口的子接口，继承于父接口中所有的方法。它是一个预编译的 SQL 语句
PreparedSatement 的好处
- prepareStatement()会先将 SQL 语句发送给数据库预编译。PreparedStatement 会引用着预编译后的结果。
可以多次传入不同的参数给 PreparedStatement 对象并执行。减少 SQL 编译次数，提高效率。 - 安全性更高，没有 SQL 注入的隐患。
- 提高了程序的可读性
使用 PreparedStatement 的步骤：
- 编写 SQL 语句，未知内容使用?占位："SELECT * FROM user WHERE name=? AND password=?";
- 获得 PreparedStatement 对象
- 设置实际参数：setXxx(占位符的位置, 真实的值)
- 执行参数化 SQL 语句
- 关闭资源
package cn.itcast.jdbc;
import cn.itcast.util.JdbsUtils;
import java.sql.*;
import java.util.Scanner;
public class JdbcDemoUserLogin {
public static void main(String[] args) {
Scanner sc = new Scanner(System.in);
System.out.println("请输入用户名");
String username = sc.nextLine();
System.out.println("请输入密码");
String password = sc.nextLine();
boolean flg = new JdbcDemoUserLogin().login2(username, password);
if (flg){
System.out.println("登录成功");
}else {
System.out.println("用户名或密码错误");
}
}
public boolean login(String username,String password){
Connection conn = null;
Statement stat = null;
ResultSet rs = null;
if(username==null || password == null){
return false;
}
try {
conn = JdbsUtils.getConnection();
stat = conn.createStatement();
String sql = "select *from user where username = '"+username+"' and password = '"+password+"'";
rs = stat.executeQuery(sql);
/*if (rs.next()){
return true;
}
else {
return false;
}*/
return rs.next();
} catch (SQLException e) {
e.printStackTrace();
}finally {
JdbsUtils.close(stat,conn,rs);
}
return false;
}
public boolean login2(String username,String password){
Connection conn = null;
PreparedStatement pstat = null;
ResultSet rs = null;
if(username==null || password == null){
return false;
}
try {
conn = JdbsUtils.getConnection();
String sql = "select *from user where username = ? and password = ?";
pstat = conn.prepareStatement(sql);
pstat.setString(1,username);
pstat.setString(2,password);
rs = pstat.executeQuery();
/*if (rs.next()){
return true;
}
else {
return false;
}*/
return rs.next();
} catch (SQLException e) {
e.printStackTrace();
}finally {
JdbsUtils.close(pstat,conn,rs);
}
return false;
}
}
jdbc事务处理
使用了JdbcUtils工具类
Connection 接口中与事务有关的方法
void setAutoCommit(boolean autoCommit) 参数是 true 或 false 如果设置为 false，表示关闭自动提交，相当于开启事务
void commit() 提交事务
void rollback() 回滚事务
开发步骤
1) 获取连接
2) 开启事务
3) 获取到 PreparedStatement
4) 使用 PreparedStatement 执行两次更新操作
5) 正常情况下提交事务
6) 出现异常回滚事务
7) 最后关闭资源
package cn.itcast.jdbc;
import cn.itcast.util.JdbsUtils;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class JdbcDemo06 {
public static void main(String[] args) {
Connection conn = null;
PreparedStatement pstat1 = null;
PreparedStatement pstat2 = null;
try {
conn = JdbsUtils.getConnection();
//开启事务
conn.setAutoCommit(false);
String sql1 = "update shuzhi set num = num-? where id = ?";
String sql2 = "update shuzhi set num = num+? where id = ?";
pstat1 = conn.prepareStatement(sql1);
pstat2 = conn.prepareStatement(sql2);
pstat1.setInt(1,500);//表示sql1第1个问号所代表得数值
pstat1.setInt(2,1);//表示sql2第2个问号所代表得数值
pstat2.setInt(1,500);
pstat2.setInt(2,4);
pstat1.executeUpdate();
pstat2.executeUpdate();
//提交事务
conn.commit();
} catch (Exception e) {
try {
//事务回滚
conn.rollback();
} catch (SQLException ex) {
ex.printStackTrace();
}
e.printStackTrace();
}finally {
JdbsUtils.close(pstat1,conn);
JdbsUtils.close(pstat2,conn);
}
}
}
***详解各个对象：
1. DriverManager：驱动管理对象
* 功能：
1. 注册驱动：告诉程序该使用哪一个数据库驱动jar
static void registerDriver(Driver driver) :注册与给定的驱动程序 DriverManager 。
写代码使用： Class.forName("com.mysql.jdbc.Driver");
通过查看源码发现：在com.mysql.jdbc.Driver类中存在静态代码块
static {
try {
java.sql.DriverManager.registerDriver(new Driver());
} catch (SQLException E) {
throw new RuntimeException("Can't register driver!");
}
}
注意：mysql5之后的驱动jar包可以省略注册驱动的步骤。
2. 获取数据库连接：
* 方法：static Connection getConnection(String url, String user, String password)
* 参数：
* url：指定连接的路径
* 语法：jdbc:mysql://ip地址(域名):端口号/数据库名称
* 例子：jdbc:mysql://localhost:3306/db3
* 细节：如果连接的是本机mysql服务器，并且mysql服务默认端口是3306，则url可以简写为：jdbc:mysql:///数据库名称
* user：用户名
* password：密码
2. Connection：数据库连接对象
1. 功能：
1. 获取执行sql 的对象
* Statement createStatement()
* PreparedStatement prepareStatement(String sql)
2. 管理事务：
* 开启事务：setAutoCommit(boolean autoCommit) ：调用该方法设置参数为false，即开启事务
* 提交事务：commit()
* 回滚事务：rollback()
3. Statement：执行sql的对象
1. 执行sql
1. boolean execute(String sql) ：可以执行任意的sql 了解
2. int executeUpdate(String sql) ：执行DML（insert、update、delete）语句、DDL(create，alter、drop)语句
* 返回值：影响的行数，可以通过这个影响的行数判断DML语句是否执行成功 返回值>0的则执行成功，反之，则失败。
3. ResultSet executeQuery(String sql) ：执行DQL（select)语句