1. 程式人生 > >MyBatis之Mapper.xml獲取資料庫型別

MyBatis之Mapper.xml獲取資料庫型別

一、使用場景

   不同的資料庫的Sql語法有所不同,為了保證在不同的資料庫中都能執行,我們需要在MyBatis的Mapper.xml檔案中編寫sql語句時對當前連線的資料庫的型別進行判斷,然後編寫適應不同資料庫的sql語句。現在我們就是要解決如何在Mapper.xml中區分連線的資料庫的型別。

二、解決方法

   mybatis提供了databaseIdProvider實現了對資料庫型別的獲取,從而實現了在Mapper.xml檔案中對資料庫型別的判斷。廢話不多說,直接上配置。

spring配置檔案如下:

    <?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"  
        xmlns:aop="http://www.springframework.org/schema/aop"   
        xmlns:tx="http://www.springframework.org/schema/tx"   
        xsi:schemaLocation="  
        http://www.springframework.org/schema/beans  
        classpath:/org/springframework/beans/factory/xml/spring-beans-3.0.xsd  
        http://www.springframework.org/schema/aop   
        classpath:/org/springframework/aop/config/spring-aop-3.0.xsd  
        http://www.springframework.org/schema/context  
        classpath:/org/springframework/context/config/spring-context-3.0.xsd  
        http://www.springframework.org/schema/tx   
        classpath:/org/springframework/transaction/config/spring-tx-3.0.xsd">  
      
    <!-- IoC配置 -->  
    <!-- 掃描類包,將標註Spring註解的類自動轉化Bean,同時完成Bean的注入 -->  
    <context:component-scan base-package="com.shr.dao" />  
    <context:component-scan base-package="com.shr.service" />  
      
    <!-- DAO配置 -->  
    <context:property-placeholder location="classpath:config.properties"/>  
    <bean id="mysql" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">  
        <property name="driverClassName"    value="${mysql_driver}"/>  
        <property name="url"        value="${mysql_url}"/>  
        <property name="username"   value="${mysql_username}"/>  
        <property name="password"   value="${mysql_password}"/>  
    </bean>  
    <bean id="oracle" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">  
        <property name="driverClassName"    value="${ora_driver}"/>  
        <property name="url"        value="${ora_url}"/>  
        <property name="username"   value="${ora_username}"/>  
        <property name="password"   value="${ora_password}"/>  
    </bean>  
      
   <!-- 新增對資料庫型別的判斷 -->
<bean id="vendorProperties" class="org.springframework.beans.factory.config.PropertiesFactoryBean"> <property name="properties"> <props> <prop key="Oracle">oracle</prop> <!-- 取別名,名稱可任意,並不是上面配置的oralce資料來源bean的id --> <prop key="MySQL">mysql</prop> <!-- 取別名,名稱可任意,
並不是上面配置的mysql資料來源的bean的id--> </props> </property> </bean> <bean id="databaseIdProvider" class="org.apache.ibatis.mapping.VendorDatabaseIdProvider"> <property name="properties" ref="vendorProperties" /> </bean>
<!-- //新增對資料庫型別的判斷 -->

  <bean name="myBatisSQLInterceptor" class="com.shr.dao.MyBatisSQLInterceptor"></bean> <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> <property name="dataSource" ref="${dataSource}" /> <property name="typeAliasesPackage" value="com.shr.dao.pojo,com.shr.dao.model" /> <!-- 給MyBatis框架提供查詢資料庫型別的功能,這個千萬不能少 --> <property name="databaseIdProvider" ref="databaseIdProvider" /> <property name="mapperLocations"> <list> <value>classpath:com/shr/dao/resources/mappers/*_mapper.xml</value> </list> </property> <!-- <property name="configLocation" value="/WEB-INF/mybatis-config.xml"/> --> <property name="typeHandlersPackage" value="com.shr.dao" /> <property name="plugins"> <list> <ref bean="myBatisSQLInterceptor"/> </list> </property> </bean> <!-- 配置事務管理器 --> <tx:annotation-driven/> <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="${dataSource}"/> </bean> <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"> <property name="basePackage" value="com.shr.dao.mapper"/> <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/> <!-- <property name="markerInterface" value="com.shr.dao.mapper.ITemplateMapper"/> --> </bean> /beans> 說明:重點看用加粗標記的配置,其他的配置不用管,因為跟此次要在Mapper.mxl檔案中獲取資料庫型別的目的沒有直接關係。
Mapper.xml配置如下:
<resultMap id="userResultMap" type="com.shr.dao.model.userManage.UserInfo">  
        <result property="user_id" column="user_id"/>  
        <result property="user_name" column="user_name"/>  
        <result property="user_password" column="user_password"/>  
        <result property="user_privilege" column="user_privilege"/>  
        <result property="user_alias" column="user_alias"/>  
        <result property="create_date" column="create_date" javaType="java.util.Date" jdbcType="TIMESTAMP"/>  
        <result property="invalid_date" column="invalid_date" javaType="java.util.Date" jdbcType="TIMESTAMP"/>  
    </resultMap>  
    <select id="selectUserInfo" resultMap="userResultMap" databaseId="mysql">  <!--對應在spring配置檔案中的別名
 <prop key="Oracle">oracle</prop> <!-- 取別名,名稱可任意,並不是上面配置的mysql資料來源bean的id -->
--> select user_id, user_name, user_password, user_privilege, user_alias, create_date, invalid_date from user_define order by user_id asc </select> <select id="selectUserInfo" resultMap="userResultMap"databaseId="oracle"> <!--對應在spring配置檔案中的別名
 <prop key="Oracle">oracle</prop> <!-- 取別名,名稱可任意,並不是上面配置的oracle資料來源bean的id -->
--> select user_id, user_name, user_password, user_privilege, user_alias, create_date, invalid_date from user_define order by user_id desc </select>
說明:重點關注Mapper.xml檔案用加粗標識的配置,主要是通過databaseId="xxx" 實現對資料庫型別的判斷,然後針對不同的資料庫型別編寫不同的sql即可。上面在spring配置檔案中做的那些配置就是為了在Mapper.xml中使用databaseId="xxx",如果沒有在spring配置檔案中做上面的配置的話,就會報錯,報錯資訊如下:
org.apache.ibatis.binding.BindingException: Invalid bound statement (not found): com.shr.dao.mapper.IuserManageMapper.selectUserInfo  
at org.apache.ibatis.binding.MapperMethod$SqlCommand.<init>(MapperMethod.java:189)  
at org.apache.ibatis.binding.MapperMethod.<init>(MapperMethod.java:43)  
at org.apache.ibatis.binding.MapperProxy.cachedMapperMethod(MapperProxy.java:58)  
at org.apache.ibatis.binding.MapperProxy.invoke(MapperProxy.java:51)  
at com.sun.proxy.$Proxy29.selectUserInfo(Unknown Source)  
at com.shr.service.userManage.UserManageService.getUserListInfo(UserManageService.java:98)