MyBatis從入門到放棄一：從SqlSession實現增刪改查

本文轉載自查看原文 2017-03-05 08:55 4173 Java/ 【框架】MyBatis/ MyBatis

前言

開博客這是第一次寫系列文章，從內心上講是有點擔心自己寫不好，寫不全，畢竟是作為java/mybatis學習的過程想把學習的路線和遇到的問題都總結下來，也讓知識點在腦海里能形成一個體系。

開發環境

idea2016、mybatis3、SQLServer2012

pom.xml、mybatis.xml、log4j.properties

先貼上pom.xml是因為他直接和搭建開發環境和測試環境有關系，mybatis.xml則是連接數據庫，log4j.properties在學習階段配置上有助於我們觀察SQL的執行情況。

1、pom.xml

 <dependencies>
    <dependency>
      <groupId>org.mybatis</groupId>
      <artifactId>mybatis</artifactId>
      <version>3.4.2</version>
    </dependency>
    <dependency>
      <groupId>com.microsoft.sqlserver</groupId>
      <artifactId>sqljdbc4</artifactId>
      <version>4.0</version>
    </dependency>
    <dependency>
      <groupId>commons-dbcp</groupId>
      <artifactId>commons-dbcp</artifactId>
      <version>1.4</version>
    </dependency>
    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
      <version>4.10</version>
    </dependency>
    <dependency>
      <groupId>log4j</groupId>
      <artifactId>log4j</artifactId>
      <version>1.2.17</version>
    </dependency>
  </dependencies>

View Code

2、mybatis.xml

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <!DOCTYPE configuration
 3         PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
 4         "http://mybatis.org/dtd/mybatis-3-config.dtd">
 5 <configuration>
 6 
 7     <!-- MyBatis針對SqlServer進行的配置  -->
 8     <typeAliases>
 9         <typeAlias alias="User" type="com.autohome.model.User"/>
10         <typeAlias alias="Teacher" type="com.autohome.model.Teacher" />
11         <typeAlias alias="Student" type="com.autohome.model.Student" />
12     </typeAliases>
13     <environments default="development">
14         <environment id="development">
15             <transactionManager type="JDBC"/>
16             <dataSource type="POOLED">
17                 <property name="driver" value="com.microsoft.sqlserver.jdbc.SQLServerDriver"/>
18                 <property name="url" value="jdbc:sqlserver://localhost:1433;DatabaseName=test"/>
19                 <property name="username" value="sa"/>
20                 <property name="password" value="0"/>
21             </dataSource>
22         </environment>
23     </environments>
24 
25 
26     <mappers>
27         <mapper resource="mapper/User.xml"/>
28         <mapper resource="mapper/Student.xml"/>
29     </mappers>
30 </configuration>

View Code

3、log4j.properties

 1 ### Log4j配置 ###
 2 ### 與Spring結合需要在web.xml中指定此文件位置，並添加監聽器 ###
 3 #定義log4j的輸出級別和輸出目的地（目的地可以自定義名稱，和后面的對應）
 4 #[ level ] , appenderName1 , appenderName2
 5 log4j.rootLogger=DEBUG,console,file
 6 
 7 #-----------------------------------#
 8 #1 定義日志輸出目的地為控制台
 9 log4j.appender.console = org.apache.log4j.ConsoleAppender
10 log4j.appender.console.Target = System.out
11 log4j.appender.console.Threshold=DEBUG
12 ####可以靈活地指定日志輸出格式，下面一行是指定具體的格式 ###
13 #%c: 輸出日志信息所屬的類目，通常就是所在類的全名
14 #%m: 輸出代碼中指定的消息,產生的日志具體信息
15 #%n: 輸出一個回車換行符，Windows平台為"/r/n"，Unix平台為"/n"輸出日志信息換行
16 log4j.appender.console.layout = org.apache.log4j.PatternLayout
17 log4j.appender.console.layout.ConversionPattern=[%c]-%m%n
18 
19 #-----------------------------------#
20 #2 文件大小到達指定尺寸的時候產生一個新的文件
21 log4j.appender.file = org.apache.log4j.RollingFileAppender
22 #日志文件輸出目錄
23 log4j.appender.file.File=log/tibet.log
24 #定義文件最大大小
25 log4j.appender.file.MaxFileSize=10mb
26 ###輸出日志信息###
27 #最低級別
28 log4j.appender.file.Threshold=ERROR
29 log4j.appender.file.layout=org.apache.log4j.PatternLayout
30 log4j.appender.file.layout.ConversionPattern=[%p][%d{yy-MM-dd}][%c]%m%n
31 
32 #-----------------------------------#
33 #3 druid
34 log4j.logger.druid.sql=INFO
35 log4j.logger.druid.sql.DataSource=info
36 log4j.logger.druid.sql.Connection=info
37 log4j.logger.druid.sql.Statement=info
38 log4j.logger.druid.sql.ResultSet=info
39 
40 #4 mybatis 顯示SQL語句部分
41 log4j.logger.org.mybatis=DEBUG
42 #log4j.logger.cn.tibet.cas.dao=DEBUG
43 #log4j.logger.org.mybatis.common.jdbc.SimpleDataSource=DEBUG#
44 #log4j.logger.org.mybatis.common.jdbc.ScriptRunner=DEBUG#
45 #log4j.logger.org.mybatis.sqlmap.engine.impl.SqlMapClientDelegate=DEBUG#
46 #log4j.logger.java.sql.Connection=DEBUG
47 log4j.logger.java.sql=DEBUG
48 log4j.logger.java.sql.Statement=DEBUG
49 log4j.logger.java.sql.ResultSet=DEBUG
50 log4j.logger.java.sql.PreparedStatement=DEBUG

View Code

配置mapper.xml

mapper.xml在mybatis.xml是專職處理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.autohome.mapper.User">

    <!-- 查詢全部用戶 -->
    <select id="queryUsers" resultType="com.autohome.model.User">
        select * from t_userinfo
    </select>
    <!-- 按照ID查詢 -->
    <select id="queryUserById" parameterType="int" resultType="com.autohome.model.User">
        select * from t_userinfo where id=#{id}
    </select>

    <select id="queryUserByAddress" resultType="com.autohome.model.User">
        select * from t_userinfo where name=#{name,javaType=String,jdbcType=VARCHAR} and address=#{address}
    </select>

    <!-- 添加用戶 -->
    <insert id="insertUsers"  parameterType="com.autohome.model.User">
        insert into t_userinfo (name,address) values(#{name},#{address})
    </insert>
    <!-- 修改用戶 -->
    <update id="updateUsers" parameterType="com.autohome.model.User">
        update t_userinfo set name=#{name},address=#{address} where id=#{id}
    </update>
    <!-- 刪除用戶 -->
    <delete id="deleteUsers" parameterType="int">
        delete  t_userinfo where id=#{id}
    </delete>
</mapper>

建立單元測試

1、准備工作，我建立的是控制台程序，所以在使用sqlsession前先創建sqlsessionfactory。當然，還要加載log4j.properties

SqlSessionFactory sqlSessionFactory=null;
    @Before
    public void BeforeClass(){

        try {
            InputStream is=Resources.getResourceAsStream("log4j.properties");
            PropertyConfigurator.configure(is);
            Reader reader = Resources.getResourceAsReader("mybatis.xml");
            sqlSessionFactory= new SqlSessionFactoryBuilder().build(reader);
        } catch (IOException e) {
            e.printStackTrace();
        }

    }

2、queryUsers

@Test
    public void queryUsers() throws Exception {

        //線程不安全類型，放在方法體內
        SqlSession sqlSession=null;

        try {

            sqlSession=sqlSessionFactory.openSession();

            List<User> list = sqlSession.selectList("com.autohome.mapper.User.queryUsers");
            System.out.println("size:"+list.size());

        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            sqlSession.close();
        }

    }

3、queryUserById

 @Test
    public void queryUserById() {
        SqlSession sqlSession=null;
        try{
            sqlSession=sqlSessionFactory.openSession();

            User user = sqlSession.selectOne("com.autohome.mapper.User.queryUserById",2);
            System.out.println("id:"+user.getId()+",name:"+user.getName()+","+user.getAddress());
        }catch(Exception e){
            e.printStackTrace();
        }finally {
            sqlSession.close();
        }
    }

4、insertUser

 @Test
    public void insertUser(){

        SqlSession sqlSession=null;
        try{

            sqlSession=sqlSessionFactory.openSession();

            User user =new User();
            user.setName("kobe");
            user.setAddress("usa");

            int result = sqlSession.insert("com.autohome.mapper.User.insertUsers",user);
            sqlSession.commit();
            if(result>0){
                System.out.println("insert success....");
            }else{
                System.out.println("insert error....");
            }

        }catch(Exception e){
            e.printStackTrace();
        }finally {
            sqlSession.close();
        }

    }

5、updateUser

  @Test
    public void updateUser(){
        SqlSession sqlSession=null;
        try{

            sqlSession=sqlSessionFactory.openSession();

            User user =new User();
            user.setId(36);
            user.setName("kobe");
            user.setAddress("usa");

            int result = sqlSession.update("com.autohome.mapper.User.updateUsers",user);
            sqlSession.commit();
            if(result>0){
                System.out.println("update success....");
            }else{
                System.out.println("update error....");
            }

        }catch(Exception e){
            e.printStackTrace();
        }finally {
            sqlSession.close();
        }
    }

6、deleteUser

 @Test
    public void deleteUser(){
        SqlSession sqlSession=null;
        try{

            sqlSession=sqlSessionFactory.openSession();

            int result = sqlSession.delete("com.autohome.mapper.User.deleteUsers",49);
            sqlSession.commit();
            if(result>0){
                System.out.println("delete success....");
            }else{
                System.out.println("delete error....");
            }

        }catch(Exception e){
            e.printStackTrace();
        }finally {
            sqlSession.close();
        }
    }

總結

添加、修改、刪除的操作要調用sqlsession.commit(),不然數據無法入庫的，我剛開始就忘記了這個。

免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。

猜您在找 Mybatis入門案例之增刪改查 springmvc+mybatis的增刪改查入門 mybatis基於注解實現增刪改查 MyBatis單表增刪改查--XML實現 Mybatis實現數據的增刪改查（CRUD） Mybatis通過接口的方式實現增刪改查 mybatis實現最簡單的增刪改查 Mybatis(一）實現單表的增刪改查 Mybatis實現單表增刪改查操作 mybatis的增刪改查