MyBatis基本CRUD与动态SQL(带log4j.properties).zip

package com.hehe.mybatis.test; import java.io.InputStream; import java.util.HashMap; import java.util.List; import java.util.Map; import org.apache.ibatis.io.Resources; import org.apache.ibatis.session.SqlSession; import org.apache.ibatis.session.SqlSessionFactory; import org.apache.ibatis.session.SqlSessionFactoryBuilder; import org.junit.Before; import org.junit.Test; import com.hehe.mybatis.domain.User; public class UserTest { SqlSessionFactory sqlSessionFactory = null; @Test @Before public void testInitMyBatis() throws Exception { // 装载总配置文件 String resource = "sqlMapConfig.xml"; InputStream inputStream = Resources.getResourceAsStream(resource); sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream); System.out.println(sqlSessionFactory); } /* <select id="selectUserById" parameterType="string" resultType="com.hehe.mybatis.domain.User"> select * from user where id = #{id} </select> */ @Test public void testSelectUserById() throws Exception { SqlSession session = sqlSessionFactory.openSession(); // namespace + SQL-id 唯一标识一条SQL // namespace : com.hehe.mybatis.domain.User // SQL-id : selectUserById User user = session.selectOne("com.hehe.mybatis.domain.User.selectUserById", "0001"); System.out.println(user); session.close(); } /* <select id="selectAllUsers" resultType="com.hehe.mybatis.domain.User"> select * from user </select> */ @Test public void testSelectAllUsers() throws Exception { SqlSession session = sqlSessionFactory.openSession(); List<User> users = session.selectList("com.hehe.mybatis.domain.User.selectAllUsers"); for (User user : users) { System.out.println(user); } session.close(); } /* <select id="selectUserByIdForMap" parameterType="string" resultType="java.util.HashMap"> select * from user where id = #{id} </select> */ @Test public void testSelectUserByIdForMap() throws Exception { SqlSession session = sqlSessionFactory.openSession(); Map<String, Object> usermap= session.selectMap("com.hehe.mybatis.domain.User.selectUserByIdForMap", "0001", "id"); System.out.println(usermap.get("0001")); session.close(); } /* <!-- dynamic SQL --> <select id="selectUserByCondition" parameterType="com.hehe.mybatis.domain.User" resultType="com.hehe.mybatis.domain.User"> select * from user where 1 = 1 <if test="id != null"> and id = #{id} </if> <if test="name != null"> and name = #{name} </if> <if test="address != null"> and address = #{address} </if> </select> */ @Test public void testSelectUserByCondition() throws Exception { SqlSession session = sqlSessionFactory.openSession(); User user = new User(); // user.setId("0001"); user.setName("lisi"); List<User> users = session.selectList("com.hehe.mybatis.domain.User.selectUserByCondition", user); for (User u : users) { System.out.println(u); } session.close(); } /* <!-- dynamic SQL --> <select id="selectUserByCondition2" parameterType="com.hehe.mybatis.domain.User" resultType="com.hehe.mybatis.domain.User"> select * from user <where> <if test="id != null"> id = #{id} </if> <if test="name != null"> and name = #{name} </if> <if test="address != null"> and address = #{address} </if> </where> </select> */ @Test public void testSelectUserByCondition2() throws Exception { SqlSession session = sqlSessionFactory.openSession(); User user = new User(); // user.setId("0001"); user.setName("lisi"); List<User> users = session.selectList("com.hehe.mybatis.domain.User.selectUserByCondition2", user); for (User u : users) { System.out.println(u); } session.close(); } /* <insert id="insertUser" parameterType="com.hehe.mybatis.domain.User"> insert into user(id, name, address) values(#{id}, #{name}, #{address}) </insert> */ @Test public void testInsertUser() throws Exception { SqlSession session = sqlSessionFactory.openSession(); User user = new User(); user.setId("0003"); user.setName("wangwu"); user.setAddress("Guangdong"); int affectedRows = session.insert("com.hehe.mybatis.domain.User.insertUser", user); System.out.println(affectedRows); // 注意要提交事务 session.commit(); session.close(); } /* <insert id="insertUserForMap" parameterType="java.util.HashMap"> insert into user(id, name, address) values(#{id}, #{name}, #{address}) </insert> */ @Test public void testInsertUserForMap() throws Exception { SqlSession session = sqlSessionFactory.openSession(); Map<String, Object> usermap = new HashMap<String, Object>(); usermap.put("id", "0004"); usermap.put("name", "zhaoliu"); usermap.put("address", "Shenzhen"); int affectedRows = session.insert("com.hehe.mybatis.domain.User.insertUserForMap", usermap); System.out.println(affectedRows); // 注意要提交事务 session.commit(); session.close(); } /* <delete id="deleteUsreById" parameterType="java.util.String"> delete from user where id = #{id} </delete> */ @Test public void testDeleteUsreById() throws Exception { SqlSession session = sqlSessionFactory.openSession(); int affectedRows = session.delete("com.hehe.mybatis.domain.User.deleteUsreById", "0004"); System.out.println(affectedRows); // 注意要提交事务 session.commit(); session.close(); } /* <update id="updateUserById" parameterType="com.hehe.mybatis.domain.User"> update user set name =#{name} address = #{address} where id = #{id} </update> */ @Test public void testUpdateUserById() throws Exception { SqlSession session = sqlSessionFactory.openSession(); User user = session.selectOne("com.hehe.mybatis.domain.User.selectUserById", "0001"); user.setName("zhangsan00"); int affectedRows = session.update("com.hehe.mybatis.domain.User.updateUserById", user); System.out.println(affectedRows); // 注意要提交事务 session.commit(); session.close(); } }