Java原生操作JDBC连接以及原理详解

package com.bnd.util;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Objects;

/** 

* @author 作者 mbql: 

* @version 创建时间：2021年1月10日 下午5:14:16 

* 类说明 	JDBC操作数据库工具类

*/
public class JdbcUtils {
	
	private static final String driverName = "com.mysql.jdbc.Driver";		// 数据库驱动名称
	
	private static final String url = "jdbc:mysql://39.108.146.20:3307/jsp?useUnicode=true&characterEncoding=utf-8";	// 数据库url
	
	private static final String userName = "root";			// 用户名
	
	private static final String password = "123456";	 // 用户密码
	
	private static Connection conn = null;					// 数据库连接对象
	
	private static PreparedStatement preparedStatement = null;	// 执行操作对象
	
	static {
		
		try {
			Class.forName(driverName);		// 2、注册数据库驱动
			conn = DriverManager.getConnection(url, userName, password);	// 3、获取数据库连接
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
	}
	
	/**
	 * 查询数据
	 * @return	返回查询到结果
	 */
	public static ResultSet queryData() {
		ResultSet result = null;
		String sql = "select id, name, pwd from user";		// 定义预编译SQL
		try {
			preparedStatement = conn.prepareStatement(sql);			// 4、执行预编译SQL操作
			result = preparedStatement.executeQuery();	// 5、执行查询操作
			while (result.next()) {
				int id = result.getInt(1);
				String name = result.getString(2);
				String pwd = result.getString(3);
				System.out.println("id：" + id + "--> name：" + name + "--> pwd：" + pwd);
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
			// 7、释放资源
			close(conn, preparedStatement, result);
		}
		return result;
	}
	
	/**
	 * 添加数据
	 * @return	返回受影响行数
	 */
	public static int addData() {
		String sql = "insert into user(name,pwd) values(?, ?)";
		try {
			preparedStatement = conn.prepareStatement(sql);		// 4、执行预编译SQL操作
			preparedStatement.setString(1, "tom");
			preparedStatement.setString(2, "abc123");
			int count = preparedStatement.executeUpdate();			// 6、执行添加操作
			if (count > 0) {
				return count;
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
			// 7、释放资源
			close(conn, preparedStatement, null);
		}			
		return -1;
	}
	
	/**
	 * 更新数据
	 * @return	返回受影响行数
	 */
	public static int updateData() {
		String sql = "update user set name = ?, pwd = ? where id = ?";
		try {
			preparedStatement = conn.prepareStatement(sql);		// 4、执行预编译SQL操作
			preparedStatement.setString(1, "sueno");
			preparedStatement.setString(2, "qwe123");
			preparedStatement.setInt(3, 10);
			int count = preparedStatement.executeUpdate();			// 6、执行添加操作
			if (count > 0) {
				return count;
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
			// 7、释放资源
			close(conn, preparedStatement, null);
		}			
		return -1;
	}
	
	
	/**
	 * 删除数据
	 * @return	返回受影响行数
	 */
	public static int deleteData() {
		String sql = "delete from user where id = ?";
		try {
			preparedStatement = conn.prepareStatement(sql);		// 4、执行预编译SQL操作
			preparedStatement.setInt(1, 11);
			int count = preparedStatement.executeUpdate();			// 6、执行添加操作
			if (count > 0) {
				return count;
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
			// 7、释放资源
			close(conn, preparedStatement, null);
		}			
		return -1;
	}
	
	/**
	 * 释放资源
	 * @param conn	关闭数据库连接
	 * @param statement	关闭数据库操作对象
	 * @param rs	关闭结果集操作对象
	 */
	public static void close(Connection conn, Statement statement, ResultSet rs) {
		if (Objects.nonNull(rs)) {
			try {
				rs.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		if (Objects.nonNull(statement)) {
			try {
				statement.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		if (Objects.nonNull(conn)) {
			try {
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
}

package com.bnd.util;

import java.sql.ResultSet;

/** 

* @author 作者 mbql: 

* @version 创建时间：2021年1月10日 下午6:00:30 

* 类说明 

*/
public class TestJdbc {
	
	public static void main(String[] args) {
		// 获取用户数据
//		ResultSet rs = JdbcUtils.queryData();
//		System.out.println(rs);
		
		// 添加用户数据
//		int count = JdbcUtils.addData();
//		if (count > 0) {
//			System.out.println("添加成功！");
//		}
		
		// 更新用户数据
//		int count = JdbcUtils.updateData();
//		if (count > 0) {
//			System.out.println("更新成功！");
//		}
		
		// 删除用户数据
//		int count = JdbcUtils.deleteData();
//		if (count > 0) {
//			System.out.println("删除成功！");
//		}
	}
}