• 欢迎访问搞代码网站,推荐使用最新版火狐浏览器和Chrome浏览器访问本网站!
  • 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏搞代码吧

java自学之路—–jdbc_框架

mysql 搞代码 4年前 (2022-01-09) 32次浏览 已收录 0个评论
文章目录[隐藏]

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);		}fi<strong style="color:transparent">本文来源gaodai#ma#com搞@@代~&码网^</strong>nally{			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 list = runner.query(sql, new BeanListHandler(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(1)).intValue();

}

}

}


搞代码网(gaodaima.com)提供的所有资源部分来自互联网,如果有侵犯您的版权或其他权益,请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected],我们会在看到邮件的第一时间内为您处理,或直接联系QQ:872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接:java自学之路—–jdbc_框架

喜欢 (0)
[搞代码]
分享 (0)
发表我的评论
取消评论

表情 贴图 加粗 删除线 居中 斜体 签到

Hi,您需要填写昵称和邮箱!

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址