java自学之路-----jdbc_框架

	Connection conn = JdbcUtils.getConnection();
	DatabaseMetaData md = conn.getMetaData();
	System.out.println(md.getURL());//

	Connection conn = JdbcUtils.getConnection();
	String sql = "insert into user(id,name) values(?,?)";
	PreparedStatement st = conn.prepareStatement(sql);
	ParameterMetaData md = st.getParameterMetaData();
	System.out.println(md.getParameterCount());//

	Connection conn = JdbcUtils.getConnection();
	String sql = "select * from user";
	PreparedStatement st = conn.prepareStatement(sql);
	ResultSet rs = st.executeQuery();
	ResultSetMetaData md = rs.getMetaData();
	System.out.println(md.getColumnCount());//

//增删改的工具方法，只需要将sql语句和sql中的问号对应的参数用数组形式传进方法，就可以执行成功
	public static void update(String sql, Object params[]) throws SQLException {
//	定义基本对象
	Connection conn = null;
	PreparedStatement st = null;
	ResultSet rs = null;
	try {
	conn = JdbcUtils.getConnection();
	st = conn.prepareStatement(sql);
//	根据传进来的参数数组填充sql中的问号
	for (int i = 0; i < params.length; i++) {
	st.setObject(i+1, params[i]);
	}
	st.executeUpdate();
	}finally{
	JdbcUtils.release(conn, st, rs);
	}
	
	} 
	
//	查的工具方法,还要得到一个用户想要处理结果集的类,用户只需要new一个处理类的对象进来即可
	public static Object query(String sql, Object params[], ResultSetHandler handler) throws SQLException{
//	定义基本对象
	Connection conn = null;
	PreparedStatement st = null;
	ResultSet rs = null;
	try {
	conn = JdbcUtils.getConnection();
	st = conn.prepareStatement(sql);
//	根据传进来的参数数组填充sql中的问号
	for (int i = 0; i < params.length; i++) {
	st.setObject(i+1, params[i]);
	}
//	由于这边得到的结果集有些内容都不知，可以向用户暴露一个处理接口的方法，然后直接在该程序中调用这个处理的方法。
//	用户实现了这个接口并做出了想要的处理，传递到本程序中，就能返回用户想用的数据
	rs = st.executeQuery();
	return handler.handler(rs);
	}finally{
	JdbcUtils.release(conn, st, rs);
	}
	}
}
//	定义接口
	interface ResultSetHandler{
	public abstract Object handler(ResultSet rs);
	}

//实现处理单行数据的类，返回封装了结果数据的对象，如果需要处理的是多行的数据，就需要使用集合，把每行数据封装成对象，再存入集合。那么这个方法返回的就是集合对象
class BeanHandler implements ResultSetHandler{
//	通过构造函数获得对象的字节码，以备将结果集存到该对象中
	private Class clazz = null;
	
	public BeanHandler(Class clazz) {
	super();
	this.clazz = clazz;
	}
	@Override
	public Object handler(ResultSet rs) {
	try {
	if(rs.next()){
	return null;
	}
//	创建封装结果集的bean对象
	Object bean = clazz.newInstance();
//	通过元数据的技术得到结果集的内容
	ResultSetMetaData md = rs.getMetaData();
	for (int i = 0; i < md.getColumnCount(); i++) {
//	获取结果集每列的名称
	String columnName = md.getColumnName(i+1);
//	得到该列的值
	Object value = rs.getObject(columnName);
//	为bean对象里的列名对应的属性赋value，使用反射技术;也可以使用beanutils库，这样就必须导入一个库，不方便
	//获取bean里的属性，需要设置为私有可见
	Field f = bean.getClass().getDeclaredField(columnName);
	f.setAccessible(true);
	//进行赋值
	f.set(bean, value);	
	}
	return bean;
	} catch (Exception e) {
	throw new RuntimeException();
	}
	}

	public void add(){
	try {
	//	使用QueryRunner和ResultSetHandler
	//	创建一个Queryrunner对象，将数据库的数据源作为构造函数传入
	QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
	//	定义sql语句和参数对象
	String sql = "insert into user(id,name) values(?,?)";
	Object params[] = {"1", "aaa"};
	//	执行更新操作,将sql和参数传入
	runner.update(sql, params);
	} catch (Exception e) {
	throw new RuntimeException(e);
	}
	}
	public void query(){
	try {
//	使用QueryRunner和ResultSetHandler
//	创建一个Queryrunner对象，将数据库的数据源作为构造函数传入
	QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
//	定义sql语句和参数对象
	String sql = "select * from user";
//	执行更新操作,将sql传入.并且将结果处理到list容器中
	List list = runner.query(sql, new BeanListHandler(User.class));
	} catch (Exception e) {
	throw new RuntimeException(e);
	}
	}

	//查询总记录数
	QueryRunner runner = new QueryRunner(JdbcUtils.getDataSource());
	String sql = "select count(*) from user";
////	1.使用arrayhandler处理器
//	Object result[] = runner.query(sql, new ArrayHandler());
////	取出数据,取出的是Long型的数据，需要进行转型
//	int count = ((Long)result[0]).intValue();
//	2.使用scalarhandler处理器,取出第一列的值,指定了封装到Long对象中，进行转型
	int count = runner.query(sql, new ScalarHandler(1)).intValue();