JDBC_03 实现对数据表的查询操作

梦里梦外; 2023-06-20 06:17 11阅读 0赞

--------------------

***本人是个新手，写下博客用于自我复习、自我总结。  
如有错误之处，请各位大佬指出。  
学习资料来源于：尚硅谷***

--------------------

每个人的数据库的名字以及表可能不相同，可以对以下中出现的数据进行相应的修改

通用操作：

package com.guigu.util;
    
    import java.io.InputStream;
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    import java.util.Properties;
    
    /** * 操作数据库的工具类 * */
    public class JDBCUtils { 
    
    	/** * 获取数据库的连接 * */
    	public static Connection getConnection() throws Exception { 
    		// 1、读取配置文件中的基本信息
    		InputStream is = ClassLoader.getSystemClassLoader()
    				.getResourceAsStream("jdbc.properties");
    		Properties pros = new Properties();
    		pros.load(is);
    		String user = pros.getProperty("user");
    		String url = pros.getProperty("url");
    		String password = pros.getProperty("password");
    		// 2、加载驱动
    		Class.forName("com.mysql.jdbc.Driver");
    		// 3、获取链接
    		Connection conn = DriverManager.getConnection(url, user, password);
    		return conn;
    	}
    
    	// 关闭资源的操作
    	public static void closeResource(Connection conn, Statement ps) { 
    		try { 
    			if (ps != null)
    				ps.close();
    		} catch (SQLException e) { 
    			e.printStackTrace();
    		}
    		try { 
    			if (conn != null)
    				conn.close();
    		} catch (SQLException e) { 
    			e.printStackTrace();
    		}
    	}
    
    	// 关闭资源的操作
    	public static void closeResource(Connection conn, Statement ps, ResultSet rs) { 
    		try { 
    			if (ps != null)
    				ps.close();
    		} catch (SQLException e) { 
    			e.printStackTrace();
    		}
    		try { 
    			if (conn != null)
    				conn.close();
    		} catch (SQLException e) { 
    			e.printStackTrace();
    		}
    		try { 
    			if (rs != null)
    				rs.close();
    		} catch (SQLException e) { 
    			e.printStackTrace();
    		}
    	}
    }

查询操作的类（一个数据表对应一个java类）

package com.guigu.bean;
    
    import java.sql.Date;
    
    /** * ORM编程思想（object relational mapping） 一个数据表对应一个java类 表中的一条记录对应java类的一个对象 * 表中的一个字段对应java类的一个属性 * * java与SQL对应数据类型转换表： boolean <--> BIT byte <--> TINYINT short <--> SMALLINT int * <--> INTEGER long <--> BIGINT String <--> CHAR,VARCHAR,LONGVARCHAR byte array * <--> BINARY, VAR BINARY * * java.sql.Date <--> DATE java.sql.Time <--> TIME java.sql.Timestamp <--> * TIMESTAMP * * */
    public class Student { 
    	private String stuname;
    	private double stuscore;
    	private int stunum;
    	private Date stubirth;
    
    	public Student() { 
    		super();
    	}
    
    	public Student(String stuname, double stuscore, int stunum, Date stubirth) { 
    		super();
    		this.stuname = stuname;
    		this.stuscore = stuscore;
    		this.stunum = stunum;
    		this.stubirth = stubirth;
    	}
    
    	public String getStuname() { 
    		return stuname;
    	}
    
    	public void setStuname(String stuname) { 
    		this.stuname = stuname;
    	}
    
    	public double getStuscore() { 
    		return stuscore;
    	}
    
    	public void setStuscore(double stuscore) { 
    		this.stuscore = stuscore;
    	}
    
    	public int getStunum() { 
    		return stunum;
    	}
    
    	public void setStunum(int stunum) { 
    		this.stunum = stunum;
    	}
    
    	public Date getStubirth() { 
    		return stubirth;
    	}
    
    	public void setStubirth(Date stubirth) { 
    		this.stubirth = stubirth;
    	}
    
    	@Override
    	public String toString() { 
    		return "Student [stuname=" + stuname + ", stuscore=" + stuscore
    				+ ", stunum=" + stunum + ", stubirth=" + stubirth + "]";
    	}
    
    }

package com.guigu.preparedstatement.crud;
    
    import java.sql.Connection;
    import java.sql.Date;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    
    import com.guigu.bean.Student;
    import com.guigu.util.JDBCUtils;
    
    import org.junit.Test;
    
    /** * 针对student表的查询 * */
    public class StudentForQuery { 
    
    	@Test
    	public void testQuery1(){ 
    		Connection conn = null;
    		PreparedStatement ps=null;
    		ResultSet resultSet = null;
    		try { 
    			conn = JDBCUtils.getConnection();
    			String sql = "select stuname,stuscore,stunum,stubirth from student where stuid = ?";
    			ps = conn.prepareStatement(sql);
    			ps.setObject(1, 6);
    			// 执行并返回结果集
    			resultSet = ps.executeQuery();
    			// 处理结果集
    			if (resultSet.next()) {  // 判断结果集的下一条是否有数据，如果返回true，指针下移；否则指针不下移
    				// 获取当前数据的各个字段值
    				String stuname = resultSet.getString(1);
    				double stuscore = resultSet.getDouble(2);
    				int stunum = resultSet.getInt(3);
    				Date stubirth = resultSet.getDate(4);
    
    				// 方式一
    				//System.out.println("姓名：" + stuname + "分数：" + stuscore + "学号："
    				// + stunum + "生日：" + stubirth);
    
    				// 方式二
    				//Object[] data = new Object[] { stuname, stuscore, stunum, stubirth };
    
    				// 方式三 ：将数据封装成一个对象（推荐）
    				Student student = new Student(stuname,stuscore,stunum,stubirth);
    				System.out.println(student);
    			}
    		} catch (Exception e) { 
    			e.printStackTrace();
    		}
    		
    		//关闭资源
    		JDBCUtils.closeResource(conn,ps,resultSet);
    	}
    }

之后可以写一个针对student的通用查询操作

package com.guigu.preparedstatement.crud;
    
    import java.lang.reflect.Field;
    import java.sql.Connection;
    import java.sql.Date;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.ResultSetMetaData;
    import java.sql.SQLException;
    
    import com.guigu.bean.Student;
    import com.guigu.util.JDBCUtils;
    
    import org.junit.Test;
    
    /** * 针对student表的查询 * */
    public class StudentForQuery { 
    
    	// 针对于student表的通用的查询操作
    	public Student queryForStudent(String sql, Object... args) { 
    
    		Connection conn = null;
    		PreparedStatement ps = null;
    		ResultSet rs = null;
    		try { 
    			conn = JDBCUtils.getConnection();
    			ps = conn.prepareStatement(sql);
    			for (int i = 0; i < args.length; i++) { 
    				ps.setObject(i + 1, args[i]);
    			}
    
    			rs = ps.executeQuery();
    
    			// 获取结果集的元数据
    			ResultSetMetaData rsmd = rs.getMetaData();
    			// 通过ResultSetMetaData获取结果集中的列数
    			int columnCount = rsmd.getColumnCount();
    
    			if (rs.next()) { 
    				Student st = new Student();
    				// 处理结果集一行数据中的每一个列
    				for (int i = 0; i < columnCount; i++) { 
    					// 获取列值
    					Object columnValue = rs.getObject(i + 1);
    
    					// 获取每个列的列名
    					String columnName = rsmd.getColumnName(i + 1);
    
    					// 给st对象指定的columnName属性，赋值为columnValue，反射完成
    					Field field = Student.class.getDeclaredField(columnName);
    					field.setAccessible(true);
    					field.set(st, columnValue);
    				}
    				return st;
    			}
    		} catch (Exception e) { 
    			e.printStackTrace();
    		} finally { 
    			JDBCUtils.closeResource(conn, ps, rs);
    		}
    		return null;
    	}
    	
    	@Test
    	public void testQueryForStudent(){ 
    		String sql = "select stuname,stuscore,stunum,stubirth from student where stuid = ?";
    		Student st = queryForStudent(sql,6);
    		System.out.println(st);
    	}
    }

最后需要想办法实现的是对不同的表都可以做到的通用查询方式：

package com.guigu.preparedstatement.crud;
    
    import java.lang.reflect.Field;
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.ResultSetMetaData;
    import java.util.ArrayList;
    import java.util.List;
    
    import org.junit.Test;
    
    import com.guigu.bean.Student;
    import com.guigu.util.JDBCUtils;
    
    //使用PreparedStatement实现对于不同表的通用的查询操作
    public class PreparedStatementQueryTest { 
    
    	@Test
    	public void testGetInstance() { 
    		String sql = "select stuname,stuscore,stunum,stubirth from student where stuid = ?";
    		Student st = getInstance(Student.class, sql, 6);
    		System.out.println(st);
    	}
    
    	// 针对于不同的表的通用的查询操作，返回表中的一条记录
    	public <T> T getInstance(Class<T> clazz, String sql, Object... args) { 
    
    		Connection conn = null;
    		PreparedStatement ps = null;
    		ResultSet rs = null;
    		try { 
    			conn = JDBCUtils.getConnection();
    			ps = conn.prepareStatement(sql);
    			for (int i = 0; i < args.length; i++) { 
    				ps.setObject(i + 1, args[i]);
    			}
    
    			rs = ps.executeQuery();
    
    			// 获取结果集的元数据
    			ResultSetMetaData rsmd = rs.getMetaData();
    			// 通过ResultSetMetaData获取结果集中的列数
    			int columnCount = rsmd.getColumnCount();
    
    			if (rs.next()) { 
    				T t = clazz.newInstance();
    				// 处理结果集一行数据中的每一个列
    				for (int i = 0; i < columnCount; i++) { 
    					// 获取列值
    					Object columnValue = rs.getObject(i + 1);
    
    					// 获取每个列的列名
    					String columnName = rsmd.getColumnName(i + 1);
    
    					// 给st对象指定的columnName属性，赋值为columnValue，反射完成
    					Field field = Student.class.getDeclaredField(columnName);
    					field.setAccessible(true);
    					field.set(t, columnValue);
    				}
    				return t;
    			}
    		} catch (Exception e) { 
    			e.printStackTrace();
    		} finally { 
    			JDBCUtils.closeResource(conn, ps, rs);
    		}
    		return null;
    	}
    	
    	@Test
    	public void testGetForList() { 
    		String sql = "select stuname,stuscore,stunum,stubirth from student where stuid < ?";
    		List<Student> list = getForList(Student.class, sql, 3);
    		int size = list.size();
            for (int i = 0; i < size; i++) { 
            	System.out.println(list.get(i));
            }
    	}
    
    	// 针对于不同的表的通用的查询操作，返回表中的多条记录
    	public <T> List<T> getForList(Class<T> clazz, String sql, Object... args) { 
    		Connection conn = null;
    		PreparedStatement ps = null;
    		ResultSet rs = null;
    		try { 
    			conn = JDBCUtils.getConnection();
    			ps = conn.prepareStatement(sql);
    			for (int i = 0; i < args.length; i++) { 
    				ps.setObject(i + 1, args[i]);
    			}
    
    			rs = ps.executeQuery();
    
    			// 获取结果集的元数据
    			ResultSetMetaData rsmd = rs.getMetaData();
    			// 通过ResultSetMetaData获取结果集中的列数
    			int columnCount = rsmd.getColumnCount();
    			// 创建集合对象
    			ArrayList<T> list = new ArrayList<T>();
    			while (rs.next()) { 
    				T t = clazz.newInstance();
    				// 处理结果集一行数据中的每一个列：给t对象指定的属性赋值
    				for (int i = 0; i < columnCount; i++) { 
    					// 获取列值
    					Object columnValue = rs.getObject(i + 1);
    
    					// 获取每个列的列名
    					String columnName = rsmd.getColumnName(i + 1);
    
    					// 给st对象指定的columnName属性，赋值为columnValue，反射完成
    					Field field = Student.class.getDeclaredField(columnName);
    					field.setAccessible(true);
    					field.set(t, columnValue);
    				}
    				list.add(t);
    			}
    			return list;
    		} catch (Exception e) { 
    			e.printStackTrace();
    		} finally { 
    			JDBCUtils.closeResource(conn, ps, rs);
    		}
    		return null;
    	}
    
    }

PreparedStatement可以解决sql注入问题  
(需要在数据库中建立User表，把有登录权限的人的信息写上，  
再在java中写一个User类（像之前那样）  
判断输入的用户名和密码能否匹配上，如果匹配上就允许登录，否则不允许)