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

jdbc框架{ 元数据： 数据库、表、列的定义信息在框架中才涉及到的知识 DataBaseMetaData对象（数据库）{ 获取方法： connection.getMetaData(); 使用： getURL();返回当前连接的数据库的URL信息 getUserName();返回当前连接的数据库的用户名 getDatabaseProd

jdbc框架{

元数据：数据库、表、列的定义信息——在框架中才涉及到的知识

DataBaseMetaData对象（数据库）{

获取方法：connection.getMetaData();

使用：

getURL();——返回当前连接的数据库的URL信息

getUserName();——返回当前连接的数据库的用户名

getDatabaseProductName();——数据库的产品名称

getDatabaseProductVersion();——数据库的版本号

getDriverName();——驱动程序的名称

getDriverVersion();——驱动程序的版本号

isReadOnly();——指示数据库是否只允许读的操作

...

例：

	Connection conn = JdbcUtils.getConnection();
	DatabaseMetaData md = conn.getMetaData();
	System.out.println(md.getURL());//输出：jdbc:mysql://localhost:3306/mydb
	System.out.println(md.getDatabaseProductName());//输出：MySQL
	System.out.println(md.getDriverVersion());//输出：mysql-connector-java-5.1.22 ( Revision: ${bzr.revision-id} )

}

ParameterMetaData（参数）{

获取方法：preparedStatement.getParameterMetaData();——例如一条select * from user where name=？ and password=？；这个对象就是这条sql语句参数（问号）的元数据

使用：

getParameterCount();——获得指定参数的个数

getParameterType(int param);——指定参数的sql类型

...

例：

		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());//输出：2
//		System.out.println(md.getParameterType(1));该方法由于mysql的驱动不支持,会抛异常

}

ResultSetMetaData（结果集）{

获取方法：resultSet.getMetaData();——获得代表结果集ResultSet对象的元数据，告诉用户结果集的一些信息

使用：

getColumnCount();——结果集对象的列数

getColumnName(int column);——指定列的名称

getColumnTypeName(int column);——指定列的类型

...

例：

		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());//输出：一共有多少列
		System.out.println(md.getColumnName(1));//输出：第一列的列名
		System.out.println(md.getColumnType(1));//输出：第一列的类型

}

编写增删改查的框架（方法）{

//增删改的工具方法，只需要将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();
		}
	}

}

开源框架dbutils{

1.commons-dbutils是Apache组织提供的一个开源jdbc工具类库，他是对jdbc的简单封装，使用dbutils能极大简化jdbc编码的工作量同时也不会影响程序性能

2.使用dbutils需要查看api文档，内部主要是两个类QueryRunner（用于增删改查）和ResultSetHandler（用于处理查询的结果集）

例：

	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<User> list = runner.query(sql, new BeanListHandler<User>(User.class));
		} catch (Exception e) {
			throw new RuntimeException(e);
		}
	}

结果集处理器（ResultSetHandler实现类）{

ArrayHandler：把结果集的第一行数据封装到一个数组内，返回数组对象。——new ArrayHandler();

ArrayListHandler：把结果集的每一行数据都封装到一个数组中，再将每个数组存到list集合内，返回list对象。——new ArrayListHandler();

BeanHandler：将结果集的第一行数据封装到一个bean对象中，需要将bean的字节码对象传入，返回bean对象。——new BeanHandler(User.class);

BeanListHandler：将结果集的每一行数据封装到一个bean对象中，再存放在list集合内，同样需要传入bean的字节码对象，返回list对象。——new BeanListHandler(User.class);

ColumnListHandler：将结果集的某一列的数据存放在list中，需要将列名传入，返回list对象。——new ColumnListHandler("id");

KeyedHandler：将结果集的每一行数据都封装到一个map（key为列名，value为该列的值）中，再将这个map存放在另一个map中（key为传入的指定列名的值，value就是map），返回map对象。——new KeyedHandler("id");

MapHandler：将结果集的第一行数据封装到一个map中，key为列名，value为该列的值，返回map对象。——new MapHandler();

MapListHandler：将结果集的每一行数据都封装到一个map中，再存放在list中，返回list对象。——new MapListHandler();

ScalarHandler：将制定的第一行的某一列（可以传入第几列或者列名）的值存放在一个对象内，返回该对象。——new ScalarHandler(1);

例:

			//查询总记录数
			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<Long>(1)).intValue();

}

}

}