MyBatis连接数据库以及操作数据库的实现

Mybatis的SqlSession对象就是用来记录服务器与数据库连接状态的,它的底层封装了JDBC连接,MyBatis的数据库操作,事务创建都是由Sqlsession来实现。连接池采用速度最快的Druid,以此可知

先创建Druid数据源，配置Druid数据源需要的驱动,数据库连接地址等属性，抽取到属性文件jdbc.properties

jdbc.properties

# 属性配置文件 用来配置数据源 这里是配置Druid连接池目前速度最快
# JDBC
# MySQL 5.x: com.mysql.jdbc.Driver
jdbc.driverClass=com.mysql.jdbc.Driver
#jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8&useSSL=false
jdbc.connectionURL=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2B8
jdbc.username=root
jdbc.password=root

# JDBC Pool
jdbc.pool.init=1
jdbc.pool.minIdle=3
jdbc.pool.maxActive=20

# JDBC Test
jdbc.testSql=SELECT 'x' FROM DUAL

配制数据源Druid---spring-context-druid.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

    <!-- 加载配置属性文件 -->
    <context:property-placeholder ignore-unresolvable="true" location="classpath:jdbc.properties"/>

    <!-- 数据源配置, 使用 Druid 数据库连接池 -->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
        <!-- 数据源驱动类可不写，Druid默认会自动根据URL识别DriverClass -->
        <property name="driverClassName" value="${jdbc.driverClass}"/>

        <!-- 基本属性 url、user、password -->
        <property name="url" value="${jdbc.connectionURL}"/>
        <property name="username" value="${jdbc.username}"/>
        <property name="password" value="${jdbc.password}"/>

        <!-- 配置初始化大小、最小、最大 -->
        <property name="initialSize" value="${jdbc.pool.init}"/>
        <property name="minIdle" value="${jdbc.pool.minIdle}"/>
        <property name="maxActive" value="${jdbc.pool.maxActive}"/>

        <!-- 配置获取连接等待超时的时间 -->
        <property name="maxWait" value="60000"/>

        <!-- 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒 -->
        <property name="timeBetweenEvictionRunsMillis" value="60000"/>

        <!-- 配置一个连接在池中最小生存的时间，单位是毫秒 -->
        <property name="minEvictableIdleTimeMillis" value="300000"/>

        <property name="validationQuery" value="${jdbc.testSql}"/>
        <property name="testWhileIdle" value="true"/>
        <property name="testOnBorrow" value="false"/>
        <property name="testOnReturn" value="false"/>

        <!-- 配置监控统计拦截的filters -->
        <property name="filters" value="stat"/>
    </bean>
</beans>

Mybatis的配置----mybatis-config.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
    <!-- 全局参数 -->
    <settings>
        <!-- 打印 SQL 语句 -->
        <setting name="logImpl" value="STDOUT_LOGGING" />

        <!-- 使全局的映射器启用或禁用缓存。 -->
        <setting name="cacheEnabled" value="false"/>

        <!-- 全局启用或禁用延迟加载。当禁用时，所有关联对象都会即时加载。 -->
        <setting name="lazyLoadingEnabled" value="true"/>

        <!-- 当启用时，有延迟加载属性的对象在被调用时将会完全加载任意属性。否则，每种属性将会按需要加载。 -->
        <setting name="aggressiveLazyLoading" value="true"/>

        <!-- 是否允许单条 SQL 返回多个数据集 (取决于驱动的兼容性) default:true -->
        <setting name="multipleResultSetsEnabled" value="true"/>

        <!-- 是否可以使用列的别名 (取决于驱动的兼容性) default:true -->
        <setting name="useColumnLabel" value="true"/>

        <!-- 允许 JDBC 生成主键。需要驱动器支持。如果设为了 true，这个设置将强制使用被生成的主键，有一些驱动器不兼容不过仍然可以执行。 default:false  -->
        <setting name="useGeneratedKeys" value="false"/>

        <!-- 指定 MyBatis 如何自动映射 数据基表的列 NONE：不映射 PARTIAL：部分 FULL:全部  -->
        <setting name="autoMappingBehavior" value="PARTIAL"/>

        <!-- 这是默认的执行类型 （SIMPLE: 简单； REUSE: 执行器可能重复使用prepared statements语句；BATCH: 执行器可以重复执行语句和批量更新） -->
        <setting name="defaultExecutorType" value="SIMPLE"/>

        <!-- 使用驼峰命名法转换字段。 -->
        <setting name="mapUnderscoreToCamelCase" value="true"/>

        <!-- 设置本地缓存范围 session:就会有数据的共享 statement:语句范围 (这样就不会有数据的共享 ) defalut:session -->
        <setting name="localCacheScope" value="SESSION"/>

        <!-- 设置 JDBC 类型为空时,某些驱动程序 要指定值, default:OTHER，插入空值时不需要指定类型 -->
        <setting name="jdbcTypeForNull" value="NULL"/>
    </settings>
</configuration>

将数据源,Mybatis的配置,实体类所在的包,对象关系映射注入Mybatis创建SqlSession，同时还需要对持久层所在的包扫描---spring-context-mybatis.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">
    <!--SqlSession对象包含以数据库为背景的所有执行SQL操作的方法,
    它的底层封装了JDBC连接,可以用SqlSession实例来直接执行被映射的SQL语句.
    sqlSession是线程不安全的,面向程序员的接口,当放在多线程容易造成数据冲突,适合在方法体内作为局部变量.-->
    <!-- 配置SqlSession 使客户端与数据库的连接有状态需要注入数据源-->
    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="dataSource" ref="dataSource"/>
        <!-- 用于配置对应实体类所在的包，多个 package 之间可以用 ',' 号分割
        映射实体类用于给对象关系映射的SQL语句参数传值-->
        <property name="typeAliasesPackage" value="com.test.my.admin.entity"/>
        <!-- 用于配置对象关系映射配置文件所在目录 -->
        <!-- 自动扫描mapper目录下.xml文件 mybatis加载sql映射语句-->
        <property name="mapperLocations" value="classpath:/mapper/**/*.xml"/>
        <!-- 文件映射器,指定类文件 -->
        <property name="configLocation" value="classpath:/mybatis-config.xml"></property>
    </bean>
    <!-- 配置扫描器扫描Mapper 告诉mybatis 数据访问接口的位置 通过这个接口和mapper映射文件做匹配
    从映射文件拿到所需要的东西
    创建mapper代理对象 用来操作mapper的业务-->
    <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
        <property name="basePackage" value="com.test.my.admin.mapper" />
    </bean>
</beans>

关系对象映射---mapper/xx类Mapper.xml-----将实体类,mapper接口,数据库3者关联

<?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">
<!--对象关系映射文件——将原生java对象(POJO)与数据库表相关联
对持久层的sql语句进行映射
namespace等于mapper接口类路径，这样实现通过映射文件找到对应的mapper接口是哪个-->
<mapper namespace="com.test.my.admin.mapper.UserMapper">
    <select id="login" resultType="User">
        select
          id,
          username,
          email,
          phone,
          password,
          createDate
          from
          user
          where
          <!--通过对象传值(MyBatis的xml文件中映射的实体类) #{对象的属性名}自动将对象的属性值传递过来-->
          username=#{username}
          OR
          phone=#{phone}
          OR
          email=#{email}
    </select>
  <update id="updateInfo">
      update
      user
      set
      /*用来判断设置完以后的值是否为空 不为空就才执行*/
      <if test="password!=null and password!=''">
          password=#{password},
      </if>
      username=#{username},
      email=#{email},
      phone=#{phone}
      where
      id=#{id}
  </update>
</mapper>

UserMapper接口类 持久层操作,不需要实现类

@Repository
public interface UserMapper {
    /**
     * 根据登录id获取用户实例
     * @param user
     * @return
     */
    public User login(User user);
    /**
     * 修改信息
     * @param user
     */
    public void updateInfo(User user);
}

Userserviceimpl实现层操作

@Service
public class UserServiceImpl implements UserService {
    @Autowired
    private UserMapper userMapper;

    /**
     * 登录验证
     * @param loginId
     * @param password
     * @return
     */
    @Override
    public User login(String loginId,String password) {
        User params=new User();
        //用户名 邮箱 电话 都可当成账号
        params.setUsername(loginId);
        params.setEmail(loginId);
        params.setPhone(loginId);
        User user = userMapper.login(params);
        /*密码加密
        String password = DigestUtils.md5DigestAsHex(loginPwd.getBytes());*/
        //先通过账号获取用户 再验证密码 一般加密验证 安全
        if(user!=null){
            if(password.equals(user.getPassword())){
                return user;
            }
        }
        return null;
    }
    /**
     * 修改信息先判断各项数据是否为空
     * @param user
     */
    @Override
    public String updateInfo(User user) {
        String check = check(user);
        //不为空 说明信息有空的不修改 返回客户端提示不能为空
        if(StringUtils.isNoneBlank(check)){
            return check;
        }
        //信息没有空的 可以修改 返回客户端提示修改成功
        // 不在service层直接返回修改成功 不然控制层尴尬 不好判断有没有进行修改操作 用null来表示进行了修改 跟check方法操作类似
        else{
            userMapper.updateInfo(user);
            return null;
        }
    }

    public String check(User user){
       if(user==null){
           return "信息不能为空";
       }
       else{
           if (StringUtils.isBlank(user.getUsername())){
               return "用户不能为空";
           }
           if (StringUtils.isBlank(user.getEmail())){
               return "邮箱不能为空";
           }
           if (StringUtils.isBlank(user.getPhone())){
               return "手机号不能为空";
           }
           return null;
       }
    }
}