http://blog.csdn.net/bingjie1217/article/details/21088431?utm_source=tuicool&utm_medium=referral
oracle表結構
create table T_USERS ( ID NUMBER not null, NAME VARCHAR2(30), SEX VARCHAR2(3), BIRS DATE, MESSAGE CLOB ) create sequence SEQ_T_USERS_ID minvalue 1 maxvalue 99999999 start with 1 increment by 1 cache 20;
配置mybatis配置文件UsersMapper.xml
<?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="examples.mapper.UsersMapper" > <!-- Result Map--> <resultMap type="examples.bean.Users" id="BaseResultMap"> <result property="id" column="id" /> <result property="name" column="name" /> <result property="sex" column="sex" /> <result property="birs" column="birs" jdbcType="TIMESTAMP"/> <result property="message" column="message" jdbcType="CLOB" javaType = "java.lang.String" typeHandler ="examples.service.OracleClobTypeHandler"/> </resultMap> <sql id="Tabel_Name"> t_users </sql> <!-- 表中所有列 --> <sql id="Base_Column_List" > id,name,sex,birs,message </sql> <!-- 查詢條件 --> <sql id="Example_Where_Clause"> where 1=1 <trim suffixOverrides=","> <if test="id != null"> and id = #{id} </if> <if test="name != null and name != ''"> and name like concat(concat('%', '${name}'), '%') </if> <if test="sex != null and sex != ''"> and sex like concat(concat('%', '${sex}'), '%') </if> <if test="birs != null"> and birs = #{birs} </if> <if test="message != null"> and message = #{message} </if> </trim> </sql> <!-- 1.新增記錄 --> <insert id="add" parameterType="Object" > <selectKey resultType="int" order="BEFORE" keyProperty="id"> select seq_t_users_id.nextval as id from dual </selectKey> insert into t_users(id,name,sex,birs,message) values(#{id},#{name},#{sex},#{birs},#{message,jdbcType=CLOB}) </insert> <!-- 2.根據id修改記錄--> <update id="update" parameterType="Object" > update t_users set name=#{name},sex=#{sex},birs=#{birs},message=#{message} where id=#{id} </update> <!-- 3.只修改不為空的字段 --> <update id="updateBySelective" parameterType="Object" > update t_users set <trim suffixOverrides="," > <if test="name != null and name != '' "> name=#{name}, </if> <if test="sex != null and sex != '' "> sex=#{sex}, </if> <if test="birs != null "> birs=#{birs}, </if> <if test="message != null and message != '' "> message=#{message}, </if> </trim> where id=#{id} </update> <!-- 4.根據id進行刪除 --> <delete id="delete" parameterType="Object"> delete from t_users where id = #{id} </delete> <!-- 5.根據id查詢 --> <select id="queryById" resultMap="BaseResultMap" parameterType="Object"> select <include refid="Base_Column_List" /> from t_users where id = #{id} </select> <!-- 6.查詢列表,只查詢不為空的字段 --> <select id="queryBySelective" resultMap="BaseResultMap" parameterType="Object"> select <include refid="Base_Column_List" /> from t_users <include refid="Example_Where_Clause" /> </select> <!-- 7.列表總數 --> <select id="queryByCount" resultType="java.lang.Integer" parameterType="Object"> select count(1) from t_users <include refid="Example_Where_Clause" /> </select> <!-- 8.查詢列表 --> <select id="queryByList" resultMap="BaseResultMap" parameterType="Object"> select <include refid="Base_Column_List" /> from t_users <include refid="Example_Where_Clause"/> </select> </mapper>
Mapper類接口
package examples.mapper; import java.util.List; public interface UsersMapper<T> { public void add(T t); public void update(T t); public void updateBySelective(T t); public void delete(Object id); public T queryById(Object id); public List<T> queryBySelective(T t); public int queryByCount(T t); public List<T> queryByList(T t); }
類型轉換工具類
package examples.service; import java.sql.CallableStatement; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import oracle.sql.CLOB; import org.apache.ibatis.type.JdbcType; import org.apache.ibatis.type.TypeHandler; public class OracleClobTypeHandler implements TypeHandler<Object> { public Object valueOf(String param) { return null; } @Override public Object getResult(ResultSet arg0, String arg1) throws SQLException { CLOB clob = (CLOB) arg0.getClob(arg1); return (clob == null || clob.length() == 0) ? null : clob.getSubString((long) 1, (int) clob.length()); } @Override public Object getResult(ResultSet arg0, int arg1) throws SQLException { return null; } @Override public Object getResult(CallableStatement arg0, int arg1) throws SQLException { return null; } @Override public void setParameter(PreparedStatement arg0, int arg1, Object arg2, JdbcType arg3) throws SQLException { CLOB clob = CLOB.empty_lob(); clob.setString(1, (String) arg2); arg0.setClob(arg1, clob); } }
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:mvc="http://www.springframework.org/schema/mvc" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xsi:schemaLocation="http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd" default-autowire="byType"> <!-- 配置數據源 --> <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource"> <property name="driverClassName"><value>oracle.jdbc.driver.OracleDriver</value></property> <property name="url"><value>jdbc:oracle:thin:@127.0.0.1:1521:pms</value></property> <property name="username"><value>pms</value></property> <property name="password"><value>pms</value></property> </bean> <!-- 配完數據源 和 擁有的 sql映射文件 sqlSessionFactory 也可以訪問數據庫 和擁有 sql操作能力了 --> <!-- <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> <property name="dataSource" ref="dataSource" /> <property name="configLocation" value="classpath:mybatis-config.xml"/> </bean> --> <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> <property name="dataSource" ref="dataSource" /> <property name="mapperLocations"> <list> <value>classpath:examples/mybatis/oracle/UsersMapper.xml</value> </list> </property> </bean> <!-- 通過設置 mapperInterface屬性,使接口服務bean 和對應xml文件管理 可以使用其中的sql --> <bean id="dao" class="org.mybatis.spring.mapper.MapperFactoryBean"> <!-- 此處等同於 Mybatis 中 ServerDao serverDao = sqlSession.getMapper(ServerDao.class); 指明映射關系 --> <property name="mapperInterface" value="examples.mapper.UsersMapper" /> <property name="sqlSessionFactory" ref="sqlSessionFactory" /> </bean> </beans>
測試類
package examples.service; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.List; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; import examples.bean.Users; import examples.mapper.UsersMapper; public class TestUsersService { @SuppressWarnings("unchecked") public static void main(String[] args) throws ParseException { ApplicationContext ac = new ClassPathXmlApplicationContext("classpath:/examples/service/spring.xml"); UsersMapper<Users> dao = (UsersMapper<Users>)ac.getBean("dao"); //刪除表中所有信息 Users nullBean = new Users(); List<Users> delList = dao.queryByList(nullBean); if(delList != null) { for(Users user : delList) { dao.delete(user.getId()); } } //新增 Users bean = new Users(); bean.setName("ding"); bean.setSex("男"); bean.setBirs(new SimpleDateFormat("yyyy-MM-dd").parse("1985-01-01")); bean.setMessage("This is Clob!"); dao.add(bean); List<Users> list = dao.queryByList(nullBean); if(list != null) { for(Users user : list) { System.out.println(user); } } //查詢並更新 bean = new Users(); bean.setName("ding"); List<Users> queList = dao.queryByList(bean); if(queList != null) { for(Users user : list) { user.setSex("女"); dao.updateBySelective(user); } } list = dao.queryByList(nullBean); if(list != null) { for(Users user : list) { System.out.println(user); } } //查詢並更新 bean = new Users(); bean.setName("ding"); List<Users> queList2 = dao.queryByList(bean); if(queList != null) { for(Users user : queList2) { user.setSex("男"); user.setMessage(""); dao.update(user); } } list = dao.queryByList(nullBean); if(list != null) { for(Users user : list) { System.out.println(user); } } int num = dao.queryByCount(nullBean); System.out.println("num=" + num); } }