JDBC 针对数据库表的查询操作(2)

相对于第一种更加完善
1、以oreder表为例

2、首先创建Order类，把要获取的数据字段封装在一个类的对象中（Order）

package com.atguigu3.bean;

import java.sql.Date;

public class Order {
//注意在Java代码中属性名是不允许带有下划线的
	private int orderId;
	private String orderName;
	private Date orderDate;
	//空参构造器
	public Order() {
		super();
	}
	//带参构造器
	public Order(int orderId, String orderName, Date orderDate) {
		super();
		this.orderId = orderId;
		this.orderName = orderName;
		this.orderDate = orderDate;
	}
	//set get方法
	public int getOrderId() {
		return orderId;
	}
	public void setOrderId(int orderId) {
		this.orderId = orderId;
	}
	public String getOrderName() {
		return orderName;
	}
	public void setOrderName(String orderName) {
		this.orderName = orderName;
	}
	public Date getOrderDate() {
		return orderDate;
	}
	public void setOrderDate(Date orderDate) {
		this.orderDate = orderDate;
	}
	//toString方法
	@Override
	public String toString() {
		return "Order [orderId=" + orderId + ", orderName=" + orderName + ", orderDate=" + orderDate + "]";
	}
	
}

3、针对于order表创建一个类（OrderForQuery）进行查询操作
与上一种通用查询方式不同的是在这些地方做了修改：

具体有以下原因：
针对于表的字段名与类的属性名不相同的情况；
* 1、必须声明sql时，使用类的属性名来命名字段的别名
* 2、使用ResultSetMetaDate时，需要使用getColumnLable()来替换getColumName()，
* 获取列的别名
* 补充说明：如果sql中没有给字段别名，getColumLable()获取的就是列名

package com.atguigu3.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 org.junit.Test;

import com.atguigu3.bean.Order;
import com.atguigu3.util.JDBCUtils;

/*
 * 针对于Order通用查询操作
 * 
 * 
 */
public class OrderForQuery {
	/*
	 * 针对于表的字段名与类的属性名不相同的情况；
	 * 1、必须声明sql时，使用类的属性名来命名字段的别名
	 * 2、使用ResultSetMetaDate时，需要使用getColumnLable()来替换getColumName()，
	 * 获取列的别名
	 * 补充说明：如果sql中没有给字段别名，getColumLable()获取的就是列名
	 * 
	 */
	@Test
	public void testorderForQuery() {
		String sql="select order_id orderId,order_name orderName,order_date orderDate from `order` where order_id=?";
		Order order = orderForQuery(sql,1);
		System.out.println(order);
	}
	/**
	 * 通用查询
	 * @return 
	 * @throws Exception 
	 */
	public Order orderForQuery(String sql,Object...args) {
		Connection conn=null;
		PreparedStatement ps=null;
		
		ResultSet rs=null;
		try {
			conn = JDBCUtils.getConnectio();
			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();
			//获取列数
			int columnCount = rsmd.getColumnCount();
			if (rs.next()) {
				Order order=new Order();
				for (int i = 0; i < columnCount; i++) {
					//获取每个列的列值:通过结果集ResultSet
					Object columnValue = rs.getObject(i+1);
					//获取每个列的列名:通过ResultSetMetaData
					//String columnName = rsmd.getColumnName(i+1);(不推荐使用)
					
					//获取列的别名：getColumnLable()
					String columnLable= rsmd.getColumnLabel(i+1);
					//通过反射将对象指定的columnName属性，赋值为columValue,
					Field field = Order.class.getDeclaredField(columnLable);
					field.setAccessible(true);
					field.set(order, columnValue);
					
				}
				return order;
				
			}
		
		} catch (Exception e) {
			e.printStackTrace();
		}finally {
			JDBCUtils.closeResource(conn, ps,rs);		
		}
		return null;
		
	}
	
	
	//----------------------------------------------------------------------------
	
	
	/**
	 * 普通查询
	 */
	@Test
	public void testQuery1()  {
		Connection conn=null;
		PreparedStatement ps=null;
		
		ResultSet rs=null;
		try {
			conn = JDBCUtils.getConnectio();
			
			String sql="select order_id,order_name,order_date from `order` where order_id=?";
			ps = conn.prepareStatement(sql);
			ps.setObject(1,1);
			//执行并返回结果集
			rs = ps.executeQuery();
			//处理结果集
			if (rs.next()) {// next():判断结果集的下一条是否有数据，如果有数据返回true,并指针下移；如果返回false,指针不会下移
				//获取当前数据各个字段值
				int id = (int) rs.getObject(1); 
				String name=(String) rs.getObject(2);
				Date date=(Date) rs.getObject(3);
				
				Order order = new Order(id,name,date);
				System.out.println(order);
			}		
		} catch (Exception e) {
			e.printStackTrace();
		}finally {
			JDBCUtils.closeResource(conn, ps,rs);
		}
		
		
		
	}
}

4、查询结果