通过java代码查询数据库必须的步骤
-
注册驱动(regist Driver)
DriverManager.registDrvier(new Driver());
Class.forname("com.mysql.jdbc.Driver");
-
获取连接(getConnection---需要提供url,username,password)
Connection conn=DriverManager.getConnection(url,username,password);
-
创建Statement对象
Statement stat=conn.createStatement();
-
执行sql语句
String sql ="";
stat.excute(sql);
处理结果
关流
我们用QueryRunner查询的时候调用了哪几个代码?(用到了连接池)
//获取c3p0连接池对象
ComboPooledDataSource ds = DBUtil.getDataSource();
//将c3p0连接池对象交给QueryRunner对象管理
QueryRunner runner=new QueryRunner(ds);//我们有个仓库,请了个仓管 给他钥匙 c3p0-config.xml
//将要执行的sql语句已经需要返回对象的对应handler传给QueryRunner对象
//String sql ="select * from user where username = ? and password =?";
User query = runner.query("select * from user", new BeanHandler<>(User.class));
我们在看得到的代码里,并不能看到注册驱动,获取连接,创建Statment对象,执行sql语句,关流这几个步骤,因为这几个步骤被QueryRunneri自己实现了
查看QueryRunner的query方法
我们调用了runner.query(sql,handler)时,runner对象做了什么:
public <T> T query(String sql, ResultSetHandler<T> rsh) throws SQLException {
Connection conn = this.prepareConnection();
//我们调用2个参数的query方法,QueryRunner对象调用了自己的5个参数的query方法
//我们接着看5个参数的query方法
return this.query(conn, true, sql, rsh, (Object[]) null);
}
private <T> T query(Connection conn, boolean closeConn, String sql, ResultSetHandler<T> rsh, Object... params)
throws SQLException {
//...这一段是判断是否为null,删去不看
PreparedStatement stmt = null;
ResultSet rs = null;
T result = null;
try {
//通过自己的prepareStatemnt方法创建stmt对象
stmt = this.prepareStatement(conn, sql);
//通过自己的fillStatement方法将参数传递到stmt对象中
this.fillStatement(stmt, params);
rs = this.wrap(stmt.executeQuery());
//通过我们想用的handler处理ResultSet,result的类型是T,是我们使用ResultSetHandler时指定的泛型对象
result = rsh.handle(rs);
} catch (SQLException e) {
this.rethrow(e, sql, params);
} finally {
//关流
try {
close(rs);
} finally {
close(stmt);
if (closeConn) {
close(conn);
}
}
}
return result;
}
rsh调用handle(resultset)时又做了什么?它为什么可以返回我们想要的返回结果呢?
比如我们调用了BeanHandler
public T handle(ResultSet rs) throws SQLException {
//通过自己的convert对象调用toBean,将resultset和对应的想查询字节码类传过去
return rs.next() ? this.convert.toBean(rs, this.type) : null;
}
this.convert对象是BasicRowProcessor,调用了它的toBean
//toBean方法是BasicRowProcessor对象调用的,我们看它做了什么
public <T> T toBean(ResultSet rs, Class<T> type) throws SQLException {
//将rs和type传给了自己的成员变量BeanProcessor并调用toBean方法
return this.convert.toBean(rs, type);
}
参数传来传去的,给到了BeanProcessor的toBean方法
public <T> T toBean(ResultSet rs, Class<T> type) throws SQLException {
//获取参数的描述
PropertyDescriptor[] props = this.propertyDescriptors(type);
//获取resultSet对象的原数据
ResultSetMetaData rsmd = rs.getMetaData();
//将对应的列所在角标存到int数组中
int[] columnToProperty = this.mapColumnsToProperties(rsmd, props);
//通过createBean方法返回一个我们想要的对象
return this.createBean(rs, type, props, columnToProperty);
}
private <T> T createBean(ResultSet rs, Class<T> type,
PropertyDescriptor[] props, int[] columnToProperty)
throws SQLException {
//新建了一个我们设置的泛型实例对象,newInstance是调用我们所给字节码对象的空参构造,所以空参构造必须为public
T bean = this.newInstance(type);
//通过for循环给该bean设置每个参数
for (int i = 1; i < columnToProperty.length; i++) {
if (columnToProperty[i] == PROPERTY_NOT_FOUND) {
continue;
}
PropertyDescriptor prop = props[columnToProperty[i]];
Class<?> propType = prop.getPropertyType();
Object value = this.processColumn(rs, i, propType);
if (propType != null && value == null && propType.isPrimitive()) {
value = primitiveDefaults.get(propType);
}
//调用所给bean的set方法将value设置进去
this.callSetter(bean, prop, value);
}
//返回我们想要的bean对象
return bean;
}
其实它做的事情内容也不多,就是跳转多了几个类
