拉勾教育Java高薪班学习笔记
平常工作太忙,没有时间来系统学习,所以还是狠狠心报名了高薪班,希望系统的提升自己的技术,为了以后更好的发展.冲鸭!
1.JDBC回顾及问分析
Mybatis的出现是为了解决JDBC中的问题
我们与数据库的交互是通过JDBC,而Mybatis的出现就是为了帮我们解决在JDBC中出现的问题。
那么在原始的JDBC的交互中会出现什么问题呢?
如下所示是我们使用JDBC进行查询的代码
public static void main(String[] args) {
Connection connection = null;
PreparedStatement preparedStatement = null;
ResultSet resultSet = null;
try {
//加载数据库驱动
Class.forName("com.mysql.jdbc.Driver");
//通过驱动管理类获取数据库连接
connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/mybatis?
characterEncoding = utf - 8", " root", " root");
//定义sql语句,?表示占位符
String sql = "select * from user where username = ?";
// 获取预处理statement
preparedStatement = connection.prepareStatement(sql);
// 设置参数
preparedStatement.setString(1, "tom");
// 执行查询
resultSet = preparedStatement.executeQuery();
// 遍历查询结果
while (resultSet.next()) {
int id = resultSet.getInt("id");
String username = resultSet.getString("username");
// 封装数据
user.setId(id);
user.setUsername(username);
}
System.out.println(user);
} catch (
Exception e) {
e.printStackTrace();
} finally {
// 释放资源
if (resultSet != null) {
try {
resultSet.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (preparedStatement != null) {
try {
preparedStatement.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (connection != null) {
try {
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
我们不难看出其中的问题
问题
- 硬编码
数据库的配置,sql语句的配置就直接写死在代码中,给我们后续的维护带来极大的麻烦。
- 资源浪费
每次调用都会创建新的数据库连接,导致资源的极大浪费。
- 手动封装返回结果,太繁琐
每次调用都需要手动将查询结果封装到java bean中。
解决思路
- 配置文件
硬编码的问题一般都使用配置文件,或配置中心来解决,所以对应的我们需要将数据库配置信息和sql信息存放在配置文件中,并且因为sql信息会和不同的业务相关,而数据库信息一般不变,所以两者应该分别存放
- 连接池
使用连接池来管理数据库连接,做到连接多用。
- 使用反射,内省
使用反射,内省技术来映射需要装载的类。
2.自定义持久层框架思路分析
这就是思考mybatis的工作原理
为什么
我们要自定义持久层框架的目的是为了解决上一讲提出的问题。那么我们就应该按照上一讲的思路来思考。
做什么
我们的持久层框架是为了项目使用方能更加便捷的使用数据库,那么就要求可以使用jar的依赖引用来直接达到使用目的。
而上文提到的配置因为框架并不清楚,所以这部分的配置文件应该放在使用项目中维护,再交由框架读取使用。
怎么做
-
由项目创建两个配置文件
- sqlMapConfig:存放数据库配置信息,存放mapper.xml的全路径
- mapper.xml:存放sql信息
创建持久层框架(本质就是对JDBC操作进行了封装)
-
加载配置文件:根据配置文件的路径,将配置文件加载成字节流,存入内存中,等待使用
- 创建Rescources类,方法:getResourcesAsStream(String path)
-
创建两个javaBean:(容器对象):用来存放对加载好的字节流的解析出来的内容
- Configuration:核心配置类:存放sqlMapConfig解析出来的内容。
- MapperStatment:sql配置类:存放mapper解析出来的内容
-
使用dom4f来解析配置文件
- 创建sqlSessionFactoryBuilder类,方法:build(InputStream in)
- 使用dom4f来解析xml文件,并将解析结果存放在容器对象中。
- 创建sqlSessionFactory接口,用于生产sqlSession。(工厂模式)
创建sqlSessionFactory的默认实现类,DefaultSqlSessionFactory类,使用openSqlSession来生产sqlSession
使用上一步创建完成的sqlSession的默认实现类DefaultSqlSession来定义一个crud的操作
创建Executor接口及其实现类SimpleExecutor中的query(Configuration,MapperStatment,Object... param)来具体执行JDBC操作
将返回的数据使用反射和内省来装载。(视频中暂未提及)
补充
其实在使用dom4f来解析对象时应该也要有对应的专门的解析接口类.Resolver,并使用他的XMLResolver来解析
# 3.配置文件的代码实现
- 创建业务项目
使用springboot快速创建即可
- 创建sqlMapConfig文件
- 数据库信息
- mapper文件信息(为了加载时可以直接找到mapper文件的路径)
<configuration>
<!-- 数据库配置信息-->
<dataSource>
<property name="driverClass" value="com.mysql.jdbc.Driver"/>
<property name="jdbcUrl" value="jdbc:mysql:///IPersistence"/>
<property name="username" value="root"/>
<property name="password" value="123456"/>
</dataSource>
<!-- mapper配置信息-->
<mapper resource="UserMapper.xml"></mapper>
</configuration>
- 创建mapper文件
- sql语句
- sql语句对应爹statementId
- mapper文件对应的命名空间(为了区分多个mapper文件)
- 规定返回数据要反射到的数据类型
- 规定查询数据中的参数对应的JAVA类型
- 将sql语句中的?占位符使用特殊标签进行标记
<mapper namespace="user">
<select id="selectList" resultType="com.huixiang.demo.user">
select * from user
</select>
<select id="selectOne" resultType="com.huixiang.demo.user" paramterType="com.huixiang.demo.user">
select * from user where id = #{} and username = #{}
</select>
</mapper>
4.Resource类的定义
下面我们就开始按照我们持久层的步骤来实现.
创建Resource类
Resource类的作用很简单,就是根据路径来获取输入流.实际上可以使用约定的方式来约定配置文件的路径和文件名.但是在我们的项目中先不采用这种方式,而是通过客户端的传入路径来操作
package com.huixiang.io;
import java.io.InputStream;
/**
* 资源类,用于获取输入流
*/
public class Resource {
public static InputStream getInputStream(String path){
return Resource.class.getClassLoader().getResourceAsStream(path);
}
}
打包项目
然后将项目打包,由客户端应用引用即可并调用即可
package com.huixiang.test_app.test;
import com.huixiang.io.Resource;
import java.io.InputStream;
public class Test {
public void test(){
InputStream inputStream = Resource.getInputStream("sqlMapConfig.xml");
}
}
5.容器对象的定义
这次要定义我们的容器对象,也就是要将字节流中解析的数据装载在容器对象中.
MapperStatement
这个是装载mapper文件的.那么对于mapper中的关键信息就都要存储.同时因为我们会有多个mapper,每个mapper中会有多个方法,所以我们对于MapperStatement一一对应了mapper中的每个方法.具体参见代码
package com.huixiang.pojo;
/**
* mapper类
* 重要的就是mapper中的各种信息的存储
*/
public class MapperStatement {
/**
* 对应mapper中的id
*/
private String id;
/**
* 对应mapper中的返回类型
*/
private String resultType;
/**
* 对一你个mapper中的参数类型
*/
private String parameterType;
/**
* 对应sql语句
*/
private String sql;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getResultType() {
return resultType;
}
public void setResultType(String resultType) {
this.resultType = resultType;
}
public String getParameterType() {
return parameterType;
}
public void setParameterType(String parameterType) {
this.parameterType = parameterType;
}
public String getSql() {
return sql;
}
public void setSql(String sql) {
this.sql = sql;
}
}
Configuration
这个是装载数据库配置的,我们也可以直接将配置生成datasource对象来存储.同时因为真正在执行语句时还需要MapperStatement,所以可以直接将MapperStatement类装载在其中.
package com.huixiang.pojo;
import javax.sql.DataSource;
import java.util.HashMap;
import java.util.Map;
/**
* 配置类
* 已将流中的数据装载在配置类中.有数据库信息和mapper信息
*/
public class Configuration {
private DataSource dataSource;
/**
* mapper类
* key是statementId
*/
private Map<String,MapperStatement> mapperStatementMap = new HashMap<>();
public DataSource getDataSource() {
return dataSource;
}
public void setDataSource(DataSource dataSource) {
this.dataSource = dataSource;
}
public Map<String, MapperStatement> getMapperStatementMap() {
return mapperStatementMap;
}
public void setMapperStatementMap(Map<String, MapperStatement> mapperStatementMap) {
this.mapperStatementMap = mapperStatementMap;
}
}