美文网首页
从JDBC到mybatis

从JDBC到mybatis

作者: 刘荣杰 | 来源:发表于2021-05-16 18:11 被阅读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>
    

    相关文章

      网友评论

          本文标题:从JDBC到mybatis

          本文链接:https://www.haomeiwen.com/subject/wifcjltx.html