从JDBC到mybatis
一.什么是JDBC
JDBC(Java DataBase Connectivity) Java数据库连接技术,通过Java程序连接并操作数据库。
我们想一想我们没有JDBC我们是如何操作数据库,我们在cmd中输入SQL操作数据库,可以在实际的开发项目中,一个Java项目一定包括后端数据库操作场景,我们需要在Java程序中连接数据库并进行增删查改相应的操作,这时我们需要Java程序连接数据库并进行相应操作,这也是JDBC的由来。
二.JDBC的实现
2.1自我设计
站在设计者的角度,我们会如何设计完成利用Java操作数据库。首先由于具有众多的数据库,我们不可能自己去针对每类数据库都实现相应的操作,我们会定义一套数据库操作接口(接口),里面有各类操作如数据库连接,语句执行,连接断开等,然后让各类数据库厂商去实现接口的内容(实现类,也叫数据库驱动)。
接下来我们只需要探讨需要定义接口里面基本内容:
-进行数据库连接
-构建sql语句
-sql语句传输执行
-返回执行结果
-断开连接
-...
当然在实际接口中会复杂的多,抽象级别更高,耦合更多,还会有相应的错误处理等。
image.png
这是具体JDBC的操作的全流程,通过DriverManager来管理众多驱动。(优势在后面会讲到)
2.2实际应用
2.2.1手动加载驱动并实例化
public static void driverTest(){
try {
//1.加载oracle驱动类,并实例化
Driver driver = (Driver) Class.forName("oracle.jdbc.driver.OracleDriver").newInstance();
//2.判定指定的URL oracle驱动能否接受(符合oracle协议规则)
boolean flag = driver.acceptsURL("jdbc:oracle:thin:@127.0.0.1:1521:xe");
//3.创建真实的数据库连接:
String url = "jdbc:oracle:thin:@127.0.0.1:1521:orcl";
Properties props = new Properties();
props.put("user", "ls");
props.put("password", "123456");
Connection connection = driver.connect(url, props);
//connection 对象用于数据库交互,代码省略。。。。。
} catch (Exception e) {
System.out.println("加载Oracle类失败!");
e.printStackTrace();
} finally{
}
}
这就是手动加载使用oracle驱动的过程。
2.2.2自动管理驱动并实例化
手动加载驱动并实例化太累了,我得自己通过CLASS.forName将驱动字节码文件加载到内存中,然后实例话驱动,其实这时候我们在想每种类别数据库驱动通过数据库url可以可以区分,我们能不能只给定url就自己找到配对的Driver并实例化,这时候DriverManager就产生了。
Driver driver = DriverManager.getDriver(url);
Connection connection = driver.connect(url, props);
上述代码等价于:
Class.forName("oracle.jdbc.driver.OracleDriver");
Connection connection = DriverManager.getConnection(url, props);
DriverManager 作为 Driver 的管理器,它在第一次被使用的过程中(即在代码中第一次用到的时候),它会被加载到内存中,然后执行其定义的static静态代码段,在静态代码段中,有一个 loadInitialDrivers() 静态方法,用于加载配置在jdbc.drivers 系统属性内的驱动Driver,配置在jdbc.drivers 中的驱动driver将会首先被加载。
2.2.3全过程
//数据库连接
Connection conn=null;
String url="http:mysql:///数据库名?characterEncoding=utf-8&serverTimezone=Asia/Shanghai";
conn=DriverManager.getConnection(url,user,password); //获取连接对象
//获取传输器对象
Statement stat=conn.CreateStatement();
//发送sql语句到服务器,并返回结果
String sql="select user,password from user"
Result rs=stat.executeQuery(sql);//执行查询则需要一个结果集来接受查询结果
while(rs.next()){//遍历结果集
......
}
//处理执行结果
//关闭资源(资源关闭需要遵循顺序关闭)
//若有结果集
rs.close();
stat.close();
conn.close();
//若无结果集
stat.close();
conn.close();
到这里就是最原始的JDBC操作了:找到驱动,建立连接(甚至可以合二为一,直接一步到位),获取传输对象,执行sql语句,返回结果,关闭连接。
三.连接池
3.1什么是连接池
连接池:就是将一批连接资源存入到一个容器中。目的是为了实现连接的复用,减少连接创建和关闭的次数,以此来提高程序执行的效率!
3.2为什么使用连接池
传统方式中,每次需要连接都是直接创建一个连接(对象/资源),再基于这个创建的连接去访问数据库,最后用完连接还要关闭!
而每次【创建连接】和【关闭连接】相比使用连接是要消耗大量的时间和资源,导致程序的执行效率非常低下!
为了提高程序执行的效率,我们可以在程序一启动时,就创建一批连接放在一个连接池中,供整个程序共享。
当用户需要连接时,不用再去创建连接,而是直接从连接池中获取一个连接进行使用,在用完连接后,也不需要关闭,而是直接将连接还回到连接池中。这样一来,用来用去都是连接池中的这一批连接,必然可以实现连接的复用,减少连接创建和关闭的次数。提高程序执行的效率!
连接复用的代码体现在close()上,不使用的连接池的close()方法时直接销毁连接对象,而使用了连接池的close()方法是将连接对象放回连接池。
HikariConfig config = new HikariConfig();
config.setJdbcUrl("jdbc:mysql://localhost:3306/test");
config.setUsername("root");
config.setPassword("password");
config.addDataSourceProperty("connectionTimeout", "1000"); // 连接超时:1秒
config.addDataSourceProperty("idleTimeout", "60000"); // 空闲超时:60秒
config.addDataSourceProperty("maximumPoolSize", "10"); // 最大连接数:10
DataSource ds = new HikariDataSource(config);
try (Connection conn = ds.getConnection()) { // 在此获取连接
...
} // 在此“关闭”连接
四.mybatis
到这个时候我们终于要到mybatis了,为什么会有mybatis呢?
4.1为什么会有mybatis?
我们发现没有到这里还是我们手写mysql代码,自己实现连接连接,释放等一系列操作,这时候会出现一系列问题:
1.从对象解析到参数(假设我们自己构建了User对象,里面有name,age等参数)需要我们自己实现,而其实这部分解析是可以抽象出来的。
2.自己手写合并成的mysql语句会有不合规范的地方以及会有mysql注入攻击的可能(比如where id=,后面参数我直接写1or name!="'),这都要自己去完善逻辑,比较麻烦。
3.连接,释放,返回数据构建成对象都要自己完成
其实上述这些东西都是共有操作可以抽象完成的,这时候mybatis就来了,mybatis可以将要执行的SQL语句使用xml文件的方式或者注解方式配置起来,在执行时,将Java对象中携带的参数值和SQL骨架进行映射,生成最终要执行的SQL,将执行的结果处理后再返回。
4.2mybatis优势
1.JDBC连接访问数据库有大量重复的代码,而mybatis可以极大的简化JDBC代码:注册驱动、获取连接、获取传输器、释放资源。
2.JDBC没有自带连接池,而mybatis自带的有连接池。
3.JDBC中是将SQL语句、连接参数写死在程序中,而mybatis是将SQL语句以及连接参数都写在配置文件中。
4.JDBC执行查询后得到的ResultSet我们需要手动处理,而mybatis执行查询后得到的结果会处理完后,将处理后的结果返回。
mybatis最终使我们像操作对象一样操作数据库,实现了两层映射,一是由对象数据向数据库中数据,二是由方法向sql语句。
4.3mybatis使用
mybatis使用这就不讲具体怎么用了。
下面是核心的mapper文件,定义了两类映射方法,一是对象数据和数据库中数据,而是方法和sql语句
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.example.model.mapper.UserMapper">
<!--mysql中数据项和User对象中数据映射-->
<resultMap id="BaseResultMap" type="com.example.model.mapper.User">
<id column="id" jdbcType="BIGINT" property="id" />
<result column="user_name" jdbcType="VARCHAR" property="userName" />
</resultMap>
<sql id="Base_Column_List">
id, user_name
</sql>
<!--方法和sql语句映射-->
<select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap">
select
<include refid="Base_Column_List" />
from user
where id = #{id,jdbcType=BIGINT}
</select>
<delete id="deleteByPrimaryKey" parameterType="java.lang.Long">
delete from user
where id = #{id,jdbcType=BIGINT}
</delete>
<insert id="insert" parameterType="com.example.model.mapper.User">
insert into user (id, user_name)
values (#{id,jdbcType=BIGINT}, #{userName,jdbcType=VARCHAR})
</insert>
<insert id="insertSelective" parameterType="com.example.model.mapper.User">
insert into user
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="id != null">
id,
</if>
<if test="userName != null">
user_name,
</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="id != null">
#{id,jdbcType=BIGINT},
</if>
<if test="userName != null">
#{userName,jdbcType=VARCHAR},
</if>
</trim>
</insert>
<update id="updateByPrimaryKeySelective" parameterType="com.example.model.mapper.User">
update user
<set>
<if test="userName != null">
user_name = #{userName,jdbcType=VARCHAR},
</if>
</set>
where id = #{id,jdbcType=BIGINT}
</update>
<update id="updateByPrimaryKey" parameterType="com.example.model.mapper.User">
update user
set user_name = #{userName,jdbcType=VARCHAR}
where id = #{id,jdbcType=BIGINT}
</update>
<resultMap id="BaseResultMap" type="com.example.model.mapper.User">
<id column="id" jdbcType="BIGINT" property="id" />
<result column="user_name" jdbcType="VARCHAR" property="userName" />
</resultMap>
<sql id="Base_Column_List">
id, user_name
</sql>
<select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap">
select
<include refid="Base_Column_List" />
from user
where id = #{id,jdbcType=BIGINT}
</select>
<delete id="deleteByPrimaryKey" parameterType="java.lang.Long">
delete from user
where id = #{id,jdbcType=BIGINT}
</delete>
<insert id="insert" parameterType="com.example.model.mapper.User">
insert into user (id, user_name)
values (#{id,jdbcType=BIGINT}, #{userName,jdbcType=VARCHAR})
</insert>
<insert id="insertSelective" parameterType="com.example.model.mapper.User">
insert into user
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="id != null">
id,
</if>
<if test="userName != null">
user_name,
</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="id != null">
#{id,jdbcType=BIGINT},
</if>
<if test="userName != null">
#{userName,jdbcType=VARCHAR},
</if>
</trim>
</insert>
<update id="updateByPrimaryKeySelective" parameterType="com.example.model.mapper.User">
update user
<set>
<if test="userName != null">
user_name = #{userName,jdbcType=VARCHAR},
</if>
</set>
where id = #{id,jdbcType=BIGINT}
</update>
<update id="updateByPrimaryKey" parameterType="com.example.model.mapper.User">
update user
set user_name = #{userName,jdbcType=VARCHAR}
where id = #{id,jdbcType=BIGINT}
</update>
<resultMap id="BaseResultMap" type="com.example.model.User">
<id column="id" jdbcType="BIGINT" property="id" />
<result column="user_name" jdbcType="VARCHAR" property="userName" />
</resultMap>
<sql id="Base_Column_List">
id, user_name
</sql>
<select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap">
select
<include refid="Base_Column_List" />
from user
where id = #{id,jdbcType=BIGINT}
</select>
<delete id="deleteByPrimaryKey" parameterType="java.lang.Long">
delete from user
where id = #{id,jdbcType=BIGINT}
</delete>
<insert id="insert" parameterType="com.example.model.User">
insert into user (id, user_name)
values (#{id,jdbcType=BIGINT}, #{userName,jdbcType=VARCHAR})
</insert>
<insert id="insertSelective" parameterType="com.example.model.User">
insert into user
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="id != null">
id,
</if>
<if test="userName != null">
user_name,
</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="id != null">
#{id,jdbcType=BIGINT},
</if>
<if test="userName != null">
#{userName,jdbcType=VARCHAR},
</if>
</trim>
</insert>
<update id="updateByPrimaryKeySelective" parameterType="com.example.model.User">
update user
<set>
<if test="userName != null">
user_name = #{userName,jdbcType=VARCHAR},
</if>
</set>
where id = #{id,jdbcType=BIGINT}
</update>
<update id="updateByPrimaryKey" parameterType="com.example.model.User">
update user
set user_name = #{userName,jdbcType=VARCHAR}
where id = #{id,jdbcType=BIGINT}
</update>
</mapper>