Home > Database > Mysql Tutorial > java自学之路-----jdbc_框架

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

WBOY
Release: 2016-06-07 16:10:04
Original
997 people have browsed it

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} )
Copy after login

}

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的驱动不支持,会抛异常
Copy after login

}

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));//输出:第一列的类型
Copy after login

}

编写增删改查的框架(方法){

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

}

开源框架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);
		}
	}
Copy after login
结果集处理器(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();
Copy after login

}

}

}

Related labels:
source:php.cn
Statement of this Website
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn
Popular Tutorials
More>
Latest Downloads
More>
Web Effects
Website Source Code
Website Materials
Front End Template