JDBC流程

Posted 2021-07-11 江西昊仔

JDBC，数据库操作

     * 1.加载驱动
     * 2.连接数据库
     * 3.关闭数据库
     * 4.对数据库操作（增，删，改）模块 

//1.加载驱动
Class.forName("com.mysql.jdbc.Driver");

//2.创建链接，链接数据库
Connection conn = DriverManager.getConnection(url,name,password)
//url = "jdbc:mysql://localhost:端口号/数据库名?useSSL=false&serverTimezone=UTC"
//是否进行SSL连接:useSSL=false
//设置mysql时区：serverTimezone=UTC。UTC--世界统一时间，跟北京时间相比，比北京早8个小时，

//url ="jdbc:mysql://localhost:端口号/数据库名?characterEncoding=utf8&serverTimezone=Asia/Shanghai";
//防止中文乱码:characterEncoding=utf8
//设置mysql时区：serverTimezone=Asia/Shanghai



//3.操作数据库
//3.1准备SQL语句（sql的骨架）
String sql;Object[] params;
PreparedStatement ps = conn.preparedStatement(sql);
//3.2给sql骨架设置参数，params是参数数组。
ps.setObject(i,params)
//3.3执行sql语句,得到结果集
ResultSet rs = ps.executeQuery();
//或3.3执行sql语句，得到影响条数。int count = ps.executeUpdate();

//4.关闭所有链接(先创建，后关闭)
rs.close();
ps.close();
conn.close();

 

包装，需要用可以直接复制，然后更改url，name，password。

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

public class Basedao {
	/**
	 * JDBC，数据库操作
	 * 1.加载驱动
	 * 2.连接数据库
	 * 3.关闭数据库
	 * 4.对数据库操作（增，删，改）模块
	 * 
	 * @return
	 */
	// 1.加载驱动
	static {
		// 加载驱动，需要先下载相应的mysql版本的驱动，然后放在WEB-INF目录下。
		//将驱动加载到java的虚拟机中，加载的时候就会执行驱动的静态初始化，完成初始化的工作
		try {
			Class.forName("com.mysql.cj.jdbc.Driver");
		} catch(ClassNotFoundException e) {
			e.printStackTrace();
		}
	}
	// 2.链接数据库
	public static Connection getconn() {
		// 1.创建一个链接对象
		Connection conn = null;
		
		// 驱动模拟
		try {
			conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/Shop?useSSL=false&serverTimezone=UTC","root","123456");
		} catch(SQLException e) {
			e.printStackTrace();
		}
		
		return conn;
	}
	// 3.关闭数据库
	public static void closeall(ResultSet rs,PreparedStatement ps,Connection conn) {
	
		try {
			if(rs!=null) {
				rs.close();
			}
			if(ps!=null) {
				ps.close();
			}
			if(conn!=null) {
				conn.close();
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	// 4.对数据库操作，需要传入SQL语句， 预处理  ，返回操作影响多少条数据行数
	public static int exectuIUD(String sql,Object[] params) {
		int count=0;
		Connection conn = Basedao.getconn();
		// 准备SQL
		PreparedStatement ps = null;
		try {
			// 准备SQL语句
			ps = conn.prepareStatement(sql);
			// 绑定参数			
			for (int i=0; i<params.length; i++) {
				ps.setObject(i+1, params[i]);
			}
			// 执行SQL语句ps.executeUpdate()，返回操作了几条语句
			count = ps.executeUpdate();
			
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally {
			Basedao.closeall(null, ps, conn);
		}
		
		return count;
	}
}