servlet+mybatis 實現mysql的增刪改查實例

古人雲：溫故而知新。趁周末，重新來學習了一遍servlet + mybatis 實現mysql的增刪改查，算是對自己學習的一個總結和記錄。

開門見山，首先我們來看一下項目目錄結構：

 

不難發現這是一個maven的項目結構。既然是maven項目，我們來看看使用servlet + mybatis 需要使用到哪些jar包，pom.xml文件代碼如下：

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.sunshine</groupId>
    <artifactId>ssm</artifactId>
    <packaging>war</packaging>
    <version>1.0-SNAPSHOT</version>
    <name>ssm</name>
    <url>http://maven.apache.org</url>
    <!--設置版本信息-->
    <properties>
        <jdk.version>1.8</jdk.version>
        <slf4j.version>1.7.12</slf4j.version>
        <log4j.version>1.2.14</log4j.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
        </dependency>

        <!--log4j日志支持-->
        <!-- 日志文件管理包 -->
        <dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
            <version>${log4j.version}</version>
        </dependency>


        <!-- 格式化對象，方便輸出日志 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.1.41</version>
        </dependency>


        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-api</artifactId>
            <version>${slf4j.version}</version>
        </dependency>

        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
            <version>${slf4j.version}</version>
        </dependency>
        <!-- log end -->

        <!--mybatis-->
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis</artifactId>
            <version>3.4.1</version>
        </dependency>

        <!--mysql 使用5.X版本-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.6</version>
        </dependency>
        <!--servlet-->
        <dependency>
            <groupId>javax.servlet</groupId>
            <artifactId>javax.servlet-api</artifactId>
            <version>3.1.0</version>
        </dependency>



    </dependencies>
    <build>
        <finalName>ssm</finalName>
        <!--配置編譯jdk版本-->
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.2</version>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>

其中servlet使用到了一個包，連接mysql數據庫需要用一個包，注意是使用5.X版本，mybatis也是使用到了一個包，除了這三個還導入到了log4j日志管理的相關包，以方便日志的輸出和管理，log4j需要用到哪些包上面代碼已標出。使用了log4j除了需要導入以上所示的jar包之外還需要在項目的支援文件夾（resources）中加入log4j.properties文件。代碼如下：

log4j.rootLogger=DEBUG,Console,File

#定義日志輸出目的地為控制台  
log4j.appender.Console=org.apache.log4j.ConsoleAppender
log4j.appender.Console.Target=System.out
#可以靈活地指定日志輸出格式，下面一行是指定具體的格式  
log4j.appender.Console.layout = org.apache.log4j.PatternLayout
#log4j.appender.Console.layout.ConversionPattern=[%c] - %m%n
log4j.appender.Console.layout.ConversionPattern=[%p] [%d{yyyy-MM-dd HH\:mm\:ss}][%c] - %m%n

#文件大小到達指定尺寸的時候產生一個新的文件  
log4j.appender.File = org.apache.log4j.RollingFileAppender
#指定輸出目錄  
log4j.appender.File.File = logs/ssm.log
#定義文件最大大小  
log4j.appender.File.MaxFileSize = 10MB
# 輸出所以日志，如果換成DEBUG表示輸出DEBUG以上級別日志  
log4j.appender.File.Threshold = ALL
log4j.appender.File.layout = org.apache.log4j.PatternLayout
log4j.appender.File.layout.ConversionPattern =[%p] [%d{yyyy-MM-dd HH\:mm\:ss}][%c]%m%n

log4j.properties文件內容可以根據自己需要來進行不同的配置。配置完log4j文件后，開始進入本次的主題。

在資源文件夾下面配置mybatis-config.xml配置文件，配置文件內容如下：

<?xml version="1.0" encoding="utf-8" ?>
<!DOCTYPE configuration
        PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
        "mybatis-3-config.dtd">
<configuration>
    <environments default="development">
        <environment id="development">
            <transactionManager type="JDBC"></transactionManager>
            <dataSource type="POOLED">
                <property name="driver" value="com.mysql.jdbc.Driver" />
                <property name="url" value="jdbc:mysql://localhost:3306/shiro" />
                <property name="username" value="root" />
                <property name="password" value="1111" />
            </dataSource>
        </environment>
    </environments>
    <mappers>
        <mapper resource="usersMapping.xml" />
    </mappers>
</configuration>

 

 特別是要注意的是property的幾個屬性deriver,url,username,password。driver就是連接數據庫的驅動，這里要注意的是，導入的mysql驅動包版本是6.0之前的后面的value都是填寫com.mysql.jdbc.Driver，與6.0及以上填寫的value會不同。剩下的url,username,password就是連接數據庫的地址，用戶名和密碼，根據自己連接的數據庫正確填寫即可。mybatis-config.xml配置文件中還有一段代碼：

<mappers>
        <mapper resource="usersMapping.xml" />
</mappers>
這段代碼就是設置了一個映射文件usersMapping.xml，這個映射文件我們在后面會講到。我們先來看看這次需要進行增刪改查的數據庫：

使用了數據庫shiro下的users表，其他的可以忽略。users表下有id,username,password,password_salt四個字段，這里要注意的是建表的時候，id要設置為自曾，如果是使用可視化工具，設置可參考如下圖：

數據庫創建完后，我們來創建users表對應的實體Users.java,代碼如下：

package com.sunshine.bean;

import java.io.Serializable;

/**
 * Created by WH on 2016/12/3.
 */
public class Users implements Serializable {

    private static final long serialVersionUID = -8209492142737702621L;

    private int id;

    private String username;

    private String password;

    private String password_salt;

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

    public String getPassword_salt() {
        return password_salt;
    }

    public void setPassword_salt(String password_salt) {
        this.password_salt = password_salt;
    }

    @Override
    public String toString() {
        return "Users{" +
                "id=" + id +
                ", username='" + username + '\'' +
                ", password='" + password + '\'' +
                ", password_salt='" + password_salt + '\'' +
                '}';
    }
}

創建好實體后，開始創建myatis的sqlSession工廠類，用於獲得SqlSessionFactory，GetSqlSessionFactory.java類代碼如下：

package com.sunshine.util;

import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.IOException;
import java.io.InputStream;

/**
 * Created by WH on 2016/12/3.
 *
 * 使用單例模式獲取SqlSessionFactory
 */
public class GetSqlSessionFactory {

    private static final Logger LOGGER = LoggerFactory.getLogger(GetSqlSessionFactory.class);

    private static SqlSessionFactory sqlSessionFactory;

    /**
     * 私有構造方法，使該類不可創建新對象
     */
    private GetSqlSessionFactory(){

    }

    /**
     * 使用同步鎖
     * @return sql session 工廠
     */
    synchronized public static SqlSessionFactory getSqlSessionFactory(){
        if (sqlSessionFactory == null){
            //獲取資源文件流
            String resorce = "mybatis-config.xml";
            InputStream inputStream = null;
            try {
                inputStream = Resources.getResourceAsStream(resorce);
            } catch (IOException e) {
                LOGGER.error("Get Resource Error:", e);
            }
            sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
        }
        return sqlSessionFactory;
    }

}

獲取sqlSessionFactory使用單例模式。因為一旦創建SqlSessionFactory對象后，該對象應該在應用的整個執行中都需要存在，不必要每次獲取一次sqlSession都需要創建一次session工廠對象，所以這里最佳的方式就是寫一個單利模式。創建SqlSessionFactory對象后，我們來通過該對象獲得SqlSession。獲得SqlSession我們寫在另外一個類中GetSqlSession.java，代碼如下：

package com.sunshine.util;

import org.apache.ibatis.session.SqlSession;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * Created by WH on 2016/12/3.
 */
public class GetSqlSession {

    private static final Logger LOGGER = LoggerFactory.getLogger(GetSqlSession.class);

    private static ThreadLocal<SqlSession> tl = new ThreadLocal<SqlSession>();

    /**
     * 獲取SqlSession
     * @return sqlSession
     */
    public static SqlSession getSqlSession(){
        SqlSession sqlSession = tl.get();
        if (sqlSession == null){
            sqlSession = GetSqlSessionFactory.getSqlSessionFactory().openSession();
            tl.set(sqlSession);
        }
        LOGGER.info("Get SqlSession hashCode : {}." , sqlSession.hashCode());
        return sqlSession;
    }

    /**
     *  提交事物
     */
    public static void commit(){
        if (tl.get() != null){
            tl.get().commit();
            tl.get().close();
            tl.set(null);
            LOGGER.info("SqlSession commit.");
        }
    }

    /**
     *  回滾事務
     */
    public static void rollback(){
        if (tl.get() != null){
            tl.get().rollback();
            tl.get().close();
            tl.set(null);
            LOGGER.info("SqlSession rollback.");
        }
    }

}

這個類中主要有三個方法，一個是獲取SqlSession，一個是用於增刪改查完成后提交事務，一個是用於增刪改查錯誤后回滾事務，以免數據庫產生臟數據。以上的這一切都准備好后我們開始來寫servlet類，先來一個查詢類GetUsersServlet.java代碼如下：

package com.sunshine.servlet;

import com.sunshine.bean.Users;
import com.sunshine.util.GetSqlSession;
import org.apache.ibatis.session.SqlSession;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;

/**
 * Created by WH on 2016/12/3.
 */
@WebServlet(name = "GetUsersServlet", value = "/getUsersById")
public class GetUsersServlet extends javax.servlet.http.HttpServlet {

    private static final Logger LOGGER = LoggerFactory.getLogger(GetUsersServlet.class);

    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        this.doGet(request, response);
    }

    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        Users users = null;
        try {
            SqlSession sqlSession = GetSqlSession.getSqlSession();
            users = sqlSession.selectOne("users.sql.getUsersById", 3);
        } catch (Exception e) {
            LOGGER.error("select error", e);
            GetSqlSession.rollback();
        } finally {
            GetSqlSession.commit();
        }
        System.out.println(users.toString());
    }
}

這里需要注意的是@WebServlet(name = "GetUsersServlet", value = "/getUsersById")一定要寫上value並給value賦值，這是通過瀏覽器訪問這個類的路徑，所以千萬別忘記了。寫到這里似乎少了些什么，代碼中也出現了一段讓人難以理解的代碼：

users = sqlSession.selectOne("users.sql.getUsersById", 3);

嗯，對。"users.sql.getUsersById"這就是前面提到的在mybatis-config.xml配置文件中的映射文件usersMapping.xml，我們來看看這映射文件寫了什么：

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "mybatis-3-mapper.dtd">
<mapper namespace="users.sql">
    
    <!--查詢Sql-->
    <select id="getUsersById" parameterType="int" resultType="com.sunshine.bean.Users">
        select * from
        users where id = #{id}
    </select>

    <!--新增-->
    <insert id="insertUsers" parameterType="com.sunshine.bean.Users"
            useGeneratedKeys="true" keyProperty="id">
        insert into
        users(username, password, password_salt)
        values(#{username}, #{password}, #{password_salt})
    </insert>

    <!--刪除-->
    <delete id="deleteUsersById" parameterType="int">
        delete from
        users where id=#{id}
    </delete>

    <!--更新-->
    <update id="updateUsersById" parameterType="com.sunshine.bean.Users">
        update users
        set
        username=#{username},password=#{password},password_salt=#{password_salt}
        where id=#{id}
    </update>
</mapper>

這里我們要注意的是映射文件中的<mapper namespace="users.sql">這段代碼和各查詢、新增、刪除和更新Sql的id。看了這些我們就不難理解剛剛讓我們難以理解的句代碼users = sqlSession.selectOne("users.sql.getUsersById", 3);了，表示的就是使用了namespace="users.sql"中的查詢sql。

到這里，前期的所有工作也基本完成，我們開始啟動程序，啟動好程序后在瀏覽器輸入http://localhost:8082/ssm/getUsersById請求我們剛剛的寫的servlet類GetUsersServlet.java。看看控制台發生了什么：

 

數據庫數據：

 

 查詢結果正確。

數據查詢出來，我們來新增個數據，新增數據的servlet類InsertUsersServlet.java代碼如下：

package com.sunshine.servlet;

import com.sunshine.bean.Users;
import com.sunshine.util.GetSqlSession;
import com.sunshine.util.GetSqlSessionFactory;
import org.apache.ibatis.session.SqlSession;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;

/**
 * Created by WH on 2016/12/3.
 */
@WebServlet(name = "InsertUsersServlet", value = "/insertUsers")
public class InsertUsersServlet extends HttpServlet {

    private static final Logger LOGGER = LoggerFactory.getLogger(GetSqlSessionFactory.class);

    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        this.doGet(request, response);
    }

    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        Users users = new Users();
        users.setUsername("liu");
        users.setPassword("123456");
        try {
            SqlSession sqlSession = GetSqlSession.getSqlSession();
            sqlSession.insert("users.sql.insertUsers", users);
            System.out.println("新增成功！新增id為：" + users.getId());
        } catch (Exception e){
            GetSqlSession.rollback();
            LOGGER.error("insert error", e);
        } finally {
            GetSqlSession.commit();
        }
    }
}

 

 寫好后，重啟服務，輸入地址：http://localhost:8082/ssm/insertUsers，運行結果如下：

看數據庫是否真插入成功：

至此已完成了查詢和新增，修改刪除讀者可自己驗證。修改片段代碼如下：

protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        Users users = new Users();
        SqlSession sqlSession = GetSqlSession.getSqlSession();
        try {
            users = sqlSession.selectOne("users.sql.getUsersById", 3);
        } catch (Exception e) {
            LOGGER.error("select error", e);
            GetSqlSession.rollback();
        }

        System.out.println(users.toString());

        users.setUsername("WeiHong");

        try {
            sqlSession.update("users.sql.updateUsersById", users);
        } catch (Exception e) {
            LOGGER.error("updateUsersById error", e);
            GetSqlSession.rollback();
        } finally {
            GetSqlSession.commit();
        }

    }

刪除部分代碼如下：

protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        SqlSession sqlSession = GetSqlSession.getSqlSession();
        try {
            sqlSession.delete("users.sql.deleteUsersById", 4);
        } catch (Exception e) {
            LOGGER.error("delete error", e);
            GetSqlSession.rollback();
        } finally {
            GetSqlSession.commit();
        }
    }

至此，servlet+mybatis 實現mysql的增刪改查實例已經完成。