JavaWeb 笔记 8 MySqlHelper 类第 1 版

复习

先来复习一遍要对数据库进行操作的步骤

增删改

注册驱动
连接数据库
准备 PrepareStatement，预处理 SQL 语句
调用 executeUpdate() 得到 int 类型返回值
处理数据
关闭连接

查

注册驱动
连接数据库
准备 PrepareStatement，预处理 SQL 语句
调用 executeQuery() 得到 ResultSet 类型返回值
处理数据
关闭连接

原先代码

如果说看不懂上面我想表达什么，看看这两份代码

增删改

// 注册驱动
String driver = "com.cj.mysql.jdbc.Driver";
try {
	Class.forName(driver);
} catch (ClassNotFoundException e) {
}

// 建立连接
String url = "jdbc:mysql://localhost:3306/数据库名";
try {
	Connection conn = DriverManager.getConnection(url, "root", "123456");
	
	// 创建 PrepareStatement 对象，预处理 SQL 语句
	PreparedStatement pstmt = conn.prepareStatement(sql);
	
	// 执行查询
	int result = pstmt.executeUpdate();
	
	// 处理结果
	if (result >= 1) {
		response.getWriter.append("成功！");
	} else {
		response.getWriter.append("失败");
	}
	
	// 关闭连接释放资源
	pstmt.close();
	conn.close();
} catch (SQLException e) {
}

查

// 注册驱动
String driver = "com.cj.mysql.jdbc.Driver";
try {
	Class.forName(driver);
} catch (ClassNotFoundException e) {
}

// 建立连接
String url = "jdbc:mysql://localhost:3306/数据库名";
try {
	Connection conn = DriverManager.getConnection(url, "root", "123456");
	
	// 创建 PrepareStatement 对象，预处理 SQL 语句
	PreparedStatement pstmt = conn.prepareStatement(sql);
	
	// 执行查询
	ResultSet rs = pstmt.executeQuery();
	
	// 处理结果
	if (rs.next()) {
		response.getWriter.append("成功！");
	} else {
		response.getWriter.append("失败");
	}
	
	// 关闭连接释放资源
	rs.close();
	pstmt.close();
	conn.close();
} catch (SQLException e) {
}

MySqlHelper 类提取

经过观察以上两个文件，我们得知其实除了执行查询和处理结果的语句有不同之外，很大一部分的代码都是重复的。所以我们可以将重复的部分提取出来，然后将他们封装成一个类。另外就是，如果没有这么做，那么每次访问数据库的时候，都需要重复写这些冗余的代码

所以我们需要一个类，负责处理数据库的链接和数据库增删改查。

我们把所有重复的代码提取出来，MySqlHelper.java 内容如下：

package com.tootaio.helper;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class MysqlHelper {

	// 属性
	static String url = "jdbc:mysql://localhost:3306/trading";
	static String username = "root";
	static String password = "123456";
	static Connection conn = null;
	static PreparedStatement pstmt = null;
	static ResultSet rs = null;

	// 3 匿名方法注册驱动
	static {
		// 注册驱动程序
		String driver = "com.mysql.cj.jdbc.Driver";
		try {
			Class.forName(driver);
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}
	}

	// 4 关闭连接
	public static void closeAll() {
		try {
			if (rs != null) {
				rs.close();				
			}
			if (pstmt != null) {
				pstmt.close();				
			}
			if (conn != null) {
				conn.close();				
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}

	// 1 方法：查
	public static ResultSet executeQuery(String sql) {
		ResultSet rs = null;

		// 建立连接
		try {
			conn = DriverManager.getConnection(url, username, password);
			// 创建 PreparedStatement 对象
			pstmt = conn.prepareStatement(sql);
			// 执行查询
			rs = pstmt.executeQuery();
//			closeAll(); // 暂时不关
		} catch (SQLException e) {
			e.printStackTrace();
		}

		return rs;
	}

	// 2 方法：增删改
	public static int executeUpdate(String sql) {
		int result = 0;

		try {
			conn = DriverManager.getConnection(url, "root", "123456");
			// 创建 PreparedStatement 对象
			pstmt = conn.prepareStatement(sql);
			// 执行查询
			result = pstmt.executeUpdate();
			closeAll();
		} catch (SQLException e) {
			e.printStackTrace();
		}

		return result;
	}
}