一、抛出异常的四种基本形式
JdbcTestT.java中
package com.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
/**
* Created by GXWIsSuperMen on 2020/5/21.
*/
public class JdbcTestT {
public static void main(String[] args) throws Exception {
///1.最基本的，dql操作(pstm.executeQuery())
//JDBC操作
/*//1. 注册驱动
Class.forName("com.mysql.jdbc.Driver");
//2. 获取连接
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/sy", "root", "1234");
//3. Sql语句
String sql = "SELECT * FROM account";
//4. 获取执行sql的预处理对象
PreparedStatement pstm = conn.prepareStatement(sql);
//5. 执行sql得到结果集
ResultSet rs = pstm.executeQuery();
//6. 遍历结果集
while (rs.next()){
System.out.println(rs.getString("name"));
}
//7. 释放资源
rs.close();
pstm.close();
conn.close();*/
///2.提取sql语句的，dql操作
/*//1. 注册驱动
Class.forName("com.mysql.jdbc.Driver");
//2. 获取连接
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/sy", "root", "1234");
//4. 获取执行sql的预处理对象
PreparedStatement pstm = conn.prepareStatement("SELECT * FROM account");
//5. 执行sql得到结果集
ResultSet rs = pstm.executeQuery();
//6. 遍历结果集
while (rs.next()){
System.out.println(rs.getString("name"));
}
//7. 释放资源
rs.close();
pstm.close();
conn.close();*/
///3.防止sql注入，dql操作
/*//1. 注册驱动
Class.forName("com.mysql.jdbc.Driver");
//2. 获取连接
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/sy", "root", "1234");
//4. 获取执行sql的预处理对象
PreparedStatement pstm = conn.prepareStatement("SELECT * FROM username=? AND password=?");
//4.1 给？号赋值（防止sql注入）
pstm.setString(1, "gxw");
pstm.setString(2, "1234");
//5. 执行sql得到结果集
ResultSet rs = pstm.executeQuery();
//6. 遍历结果集
while (rs.next()){
System.out.println(rs.getString("name"));
}
//7. 释放资源
rs.close();
pstm.close();
conn.close();*/
///4.基本的dml操作(pstm.executeUpdate())
/*//1. 注册驱动
Class.forName("com.mysql.jdbc.Driver");
//2. 获取连接
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/sy", "root", "1234");
//3. 获取执行sql的预处理对象
PreparedStatement pstm = conn.prepareStatement("DELETE FROM account WHERE id = ?");
//3.1 给？号赋值
pstm.setString(1, "3");
//4. 执行sql
int i = pstm.executeUpdate();
//5. 处理的结果
if(i > 0){
System.out.println("删除成功");
}else {
System.out.println("删除失败");
}
//6. 释放资源
pstm.close();
conn.close();*/
}
}
二、try…catch基本形式
JdbcTestTC.java类中
package com.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
/**
* Created by GXWIsSuperMen on 2020/5/21.
*/
public class JdbcTestTC {
public static void main(String[] args) {
///5. JdbcTestT异常抛出了，这里写一个try...catch————>dql操作的
Connection conn = null;
PreparedStatement pstm = null;
try {
//1. 注册驱动
Class.forName("com.mysql.jdbc.Driver");
//2. 获取连接
conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/sy", "root", "1234");
//3. 获取执行sql的预处理对象
pstm = conn.prepareStatement("UPDATE account SET balance=1500 WHERE id=?");
//3.1 给？号赋值
pstm.setString(1, "3");
//4. 执行sql
int i = pstm.executeUpdate();
//5. 处理的结果
if(i > 0){
System.out.println("更新成功");
}else {
System.out.println("更新失败");
}
} catch (ClassNotFoundException | SQLException e) {
e.printStackTrace();
}finally {
//6. 释放资源
if(pstm != null){
try {
pstm.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(conn != null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
}
三、自定义的JDBC工具类对Jdbc操作的优化【要使用到四、中自定义的JDBC工具类】
- 由于我创建的使用都放到一个包中，所以不需要导包（JDBCUtils）
package com.jdbc;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Scanner;
/**
* Created by GXWIsSuperMen on 2020/5/21.
*/
public class JdebTestUtils {
///6.JDBC工具类对Jdbc操作的优化——>dml操作
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 login = new JdebTestUtils().login(username, password);//非静态方法
if(login){
System.out.println("登录成功");
}else {
System.out.println("账号或者密码错误");
}
}
/*
* 登录方法,使用PreparedStatement实现
*/
public boolean login(String username, String password){
if(username == null || password == null){
return false;
}
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
try {
//1.获取资源
conn = JDBCUtils.getConnection();
//3.获取执行sql的预处理对象
pstmt = conn.prepareStatement("SELECT * FROM username=? AND password=?");
//4.给？号赋值
pstmt.setString(1, username);
pstmt.setString(2, password);
//5.执行sql,不需要传递参数
rs = pstmt.executeQuery();
//判断
return rs.next(); //有下一行则返回true
} catch (SQLException e) {
e.printStackTrace();
}finally {
JDBCUtils.close(rs, pstmt, conn);
}
return false;
}
}
四、自定义的JDBC工具类(一个连接对象)
package com.jdbc;
import java.io.FileReader;
import java.io.IOException;
import java.net.URL;
import java.sql.*;
import java.util.Properties;
/**
* Created by GXWIsSuperMen on 2020/5/21.
*/
public class JDBCUtils {
//先声明4个静态成员变量
private static String url;
private static String user;
private static String password;
private static String driver;
/**
* 文件的读取，只需要读取一次即可拿到这些值。使用静态代码块
*/
static{
//读取资源文件，获取值。
try {
//1. 创建Properties集合类。
Properties pro = new Properties();
//获取src路径下的文件的方式--->ClassLoader 类加载器
ClassLoader classLoader = JDBCUtils.class.getClassLoader();
URL res = classLoader.getResource("jdbc.properties");
String path = res.getPath(); //System.out.println(path);///D:/IdeaProjects/itcast/out/production/day04_jdbc/jdbc.properties
//2. 加载文件
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() throws SQLException {
return DriverManager.getConnection(url, user, password);
}
/**
* 释放资源【dml时候，增删改时】
* @param stmt
* @param conn
*/
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();
}
}
}
/**
* 释放资源【dql时候，查询时】
* @param rs
* @param stmt
* @param conn
*/
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();
}
}
}
}
五、Druid数据库连接池的JDBC工具类对Jdbc操作的优化
- 概念：其实就是一个容器（集合），存放数据库连接的容器。
- 当系统初始化好后，容器被创建，容器中会申请一些连接对象，当用户来访问数据库时，从容器中获取连接对象，用户访问完之后，会将连接对象归还给容器。
- 数据库连接池的好处：
- 节省时间
- 连接利用率更高，节约资源
/**
* 使用新的工具类
*/
public class DruidDemo2 {
public static void main(String[] args) {
/**
* 完成一个添加的操作：给account添加一条记录
*/
Connection conn = null;
PreparedStatement pstmt = null;
try {
//1. 获取连接：
conn = JDBCUtils.getConnection();
//2. 编写sql
String sql = "INSERT INTO account VALUES (null, ?, ?)"; //预编译sql
//3. 获取执行sql对象
pstmt = conn.prepareStatement(sql);
//4. 给？赋值
pstmt.setString(1, "王五");
pstmt.setInt(2, 3000);
//5.执行sql
int count = pstmt.executeUpdate();
//6. 打印一下
System.out.println(count);
} catch (SQLException e) {
e.printStackTrace();
}finally {
//7. 释放资源
JDBCUtils.close(pstmt, conn);
}
}
}
六、Druid数据库连接池的JDBC工具类-（一些连接对象:++和自定义的区别++）
/*
Druid连接池的工具类
*/
public class JDBCUtils {
//1.定义成员变量
private static DataSource ds;
static {
try {
//1. 加载配置文件
Properties pro = new Properties();
InputStream rs = JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties");
pro.load(rs);
//2. 获取DataSource
ds = DruidDataSourceFactory.createDataSource(pro);
} catch (IOException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}
}
/*
获取连接的方法
*/
public static Connection getConnection() throws SQLException {
return ds.getConnection();
}
/*
释放资源的方法重载（DQL使用）
*/
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();
}
}
}
/*
释放资源的方法（DML使用）
*/
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();
}
}
//也可以写成close(null, stmt, conn); 了解一下
}
//获取连接池的方法
public static DataSource getDataSource(){
return ds;
}
}
JdbcTemplate（Spring JDBC提供的一个对象）
- 技术由来：比如java中的查询，需要先获取到信息，然后Emp实体类赋值，最后添加到集合中，此过程很繁琐！！
- Spring框架对JDBC的简单封装，提供了一个JdbcTemplate对象简化JDBC的开发（内部做了封装）
- 使用JdbcTemplate的好处
- 不需要申请链接
- 也不需要释放资源了
- 创建JdbcTemplate对象。依赖于数据源DataSource
- 由于每次都要先获取JdbcTemplate对象，所以一般将它直接写到成员变量的位置
JdbcTemplate template = new JdbcTemplate(JDBCUtils.getDataSource());
- 用druid工具类获取
- 使用步骤：
- 导入jar包
- 创建JdbcTemplate对象
- 调用相应的方法(只说两个常用的)
- update【重点掌握】()：执行DML语句。–>增删改语句
- query【重点掌握】()：查询结果，将结果集封装为JavaBean对象
- query的参数：RowMapper自己来实现【不用】
- query的参数：BeanPropertyRowMappe【掌握】
- 提供好的实现类：BeanPropertyRowMapper，可以完成数据到JavaBean的自动封装
new BeanPropertyRowMapper<类型>(类型.class);
- update使用案例：添加一条记录
//2. 添加一条记录
@Test
public void test2(){
//1.获取Jdbctemplate对象
JdbcTemplate template = new JdbcTemplate(JDBCUtils.getDataSource());
//2.定义sql,这里可能会出现sql注入问题
String sql = "SELECT INTO emp(id, ename, dept_id) VLAUES(?, ?, ?)";
int count = template.update(sql, 1015, "郭靖", 10);
//3.打印
System.out.println(count);
}
- BeanPropertyRowMappe使用案例：查询所有记录，将其封装为Emp对象的list集合
//6_2. 查询所有记录，将其封装为Emp对象的list集合
@Test
public void test6_2() {
//1.获取Jdbctemplate对象的操作放到了外面
//2. 定义sql
String sql = "SELECT * FROM emp";
//3. 执行sql（提供好的实现类：BeanPropertyRowMapper）
List<Emp> list = template.query(sql, new BeanPropertyRowMapper<Emp>(Emp.class)); //括号里获取到Emp的class对象
//4. 遍历打印
for (Emp emp : list) {
System.out.println(emp);
}
}