从JDBC到mybatis

2021-05-16  本文已影响0人  刘荣杰

一.什么是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>
上一篇下一篇

猜你喜欢

热点阅读