走進(jìn)JavaWeb技術(shù)世界14：通過項(xiàng)目逐步深入了解Mybatis（一）

39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80

package cn.zhisheng.mybatis.jdbc;
/**
 * Created by 10412 on 2016/11/27.
 */
import java.sql.*;
/**
 *通過單獨(dú)的jdbc程序來總結(jié)問題
 */
public class JdbcTest
{
    public static void main(String[] args)
    {
        //數(shù)據(jù)庫連接
        Connection connection = null;
        //預(yù)編譯的Statement，使用預(yù)編譯的Statement可以提高數(shù)據(jù)庫性能
        PreparedStatement preparedStatement = null;
        //結(jié)果集
        ResultSet resultSet = null;
        try
        {
            //加載數(shù)據(jù)庫驅(qū)動
            Class.forName("com.mysql.jdbc.Driver");
            //通過驅(qū)動管理類獲取數(shù)據(jù)庫鏈接
            connection =  DriverManager.getConnection("jdbc:mysql://localhost:3306/mybatis_test?characterEncoding=utf-8", "root", "root");
            //定義sql語句 ?表示占位符（在這里表示username）
            String sql = "select * from user where username = ?";
            //獲取預(yù)處理statement
            preparedStatement = connection.prepareStatement(sql);
            //設(shè)置參數(shù)，第一個(gè)參數(shù)為sql語句中參數(shù)的序號（從1開始），第二個(gè)參數(shù)為設(shè)置的參數(shù)值
            preparedStatement.setString(1, "王五");
            //向數(shù)據(jù)庫發(fā)出sql執(zhí)行查詢，查詢出結(jié)果集
            resultSet =  preparedStatement.executeQuery();
            //遍歷查詢結(jié)果集
            while(resultSet.next())
            {
                System.out.println(resultSet.getString("id")+"  "+resultSet.getString("username"));
            }
        } catch (Exception e) {
            e.printStackTrace();
        }finally{
            //釋放資源
            if(resultSet!=null)
            {
                try {
                    resultSet.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
            if(preparedStatement!=null)
            {
                try {
                    preparedStatement.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
            if(connection!=null)
            {
                try {
                    connection.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }
    }
}

1
2
3
4
5
6
7

# Global logging configuration
#在開發(fā)環(huán)境日志級別要設(shè)置為DEBUG、生產(chǎn)環(huán)境要設(shè)置為INFO或者ERROR
log4j.rootLogger=DEBUG, stdout
# Console output...
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%5p [%t] - %m%n

10
11
12
13
14
15
16
17
18
19
20

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
        PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
    <!-- 和spring整合后 environments配置將廢除-->
    <environments default="development">
        <environment id="development">
            <!-- 使用jdbc事務(wù)管理,事務(wù)由 Mybatis 控制-->
            <transactionManager type="JDBC" />
            <!-- 數(shù)據(jù)庫連接池,由Mybatis管理，數(shù)據(jù)庫名是mybatis_test，Mysql用戶名root，密碼root -->
            <dataSource type="POOLED">
                <property name="driver" value="com.mysql.jdbc.Driver" />
                <property name="url" value="jdbc:mysql://localhost:3306/mybatis_test?characterEncoding=utf-8" />
                <property name="username" value="root" />
                <property name="password" value="root" />
            </dataSource>
        </environment>
    </environments>
</configuration>

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57

package cn.zhisheng.mybatis.po;
import java.util.Date;
/**
 * Created by 10412 on 2016/11/28.
 */
public class User
{
    private int id;
    private String username;            // 用戶姓名
    private String sex;                 // 性別
    private Date birthday;              // 生日
    private String address;             // 地址
    //getter and setter
    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 Date getBirthday() {
        return birthday;
    }
    public void setBirthday(Date birthday) {
        this.birthday = birthday;
    }
    public String getSex() {
        return sex;
    }
    public void setSex(String sex) {
        this.sex = sex;
    }
    public String getAddress() {
        return address;
    }
    public void setAddress(String address) {
        this.address = address;
    }
}

2
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

package cn.zhisheng.mybatis.first;
import cn.zhisheng.mybatis.po.User;
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.Test;
import java.io.IOException;
import java.io.InputStream;
    /**
* Created by 10412 on 2016/11/28.
*/
public class MybatisFirst
{
   //根據(jù)id查詢用戶信息，得到用戶的一條記錄
   @Test
   public void findUserByIdTest() throws IOException
   {
       //Mybatis 配置文件
       String resource = "SqlMapConfig.xml";
       //得到配置文件流
       InputStream inputStream = Resources.getResourceAsStream(resource);
       //創(chuàng)建會話工廠,傳入Mybatis的配置文件信息
       SqlSessionFactory  sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
     //通過工廠得到SqlSession
      SqlSession sqlSession = sqlSessionFactory.openSession();
      //通過SqlSession操作數(shù)據(jù)庫
      //第一個(gè)參數(shù)：映射文件中Statement的id，等于 = namespace + "." + Statement的id
      //第二個(gè)參數(shù)：指定和映射文件中所匹配的parameterType類型的參數(shù)
      //sqlSession.selectOne 結(jié)果與映射文件中所匹配的resultType類型的對象
      User user = sqlSession.selectOne("test.findUserById", 1);
      System.out.println(user);
      //釋放資源
      sqlSession.close();
  }
}

1
2
3
4
5
6
7

public void createSqlSessionFactory() throws IOException {
		// 配置文件
		String resource = "SqlMapConfig.xml";
		InputStream inputStream = Resources.getResourceAsStream(resource);
		// 使用SqlSessionFactoryBuilder從xml配置文件中創(chuàng)建SqlSessionFactory
		sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
	}

11
12
13
14
15
16
17
18
19
20
21

@Test
    public void insetrUser() throws IOException, ParseException {
        //Mybatis 配置文件
        String resource = "SqlMapConfig.xml";
        //得到配置文件流
        InputStream inputStream = Resources.getResourceAsStream(resource);
        //創(chuàng)建會話工廠,傳入Mybatis的配置文件信息
        SqlSessionFactory  sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
        //通過工廠得到SqlSession
        SqlSession sqlSession = sqlSessionFactory.openSession();
        User user = new User();
        SimpleDateFormat sdf = new SimpleDateFormat ("yyyy-MM-dd");
        user.setUsername("田志聲");
        user.setSex("男");
        user.setBirthday(sdf.parse("2016-11-29"));
        user.setAddress("江西南昌");
        sqlSession.insert("test.insetrUser", user);
        sqlSession.commit();
        //釋放資源
        sqlSession.close();
    }

1
2
3
4

<!--刪除用戶-->
    <delete id="deleteUserById" parameterType="int">
        delete from user where user.id = #{id}
    </delete>

4
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

//刪除用戶
    @Test
    public void deleteUserByIdTest() throws IOException
    {
        //Mybatis 配置文件
        String resource = "SqlMapConfig.xml";
        //得到配置文件流
        InputStream inputStream = Resources.getResourceAsStream(resource);
        //創(chuàng)建會話工廠,傳入Mybatis的配置文件信息
        SqlSessionFactory  sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
        //通過工廠得到SqlSession
        SqlSession sqlSession = sqlSessionFactory.openSession();
        //通過SqlSession操作數(shù)據(jù)庫
        //第一個(gè)參數(shù)：映射文件中Statement的id，等于 = namespace + "." + Statement的id
        //第二個(gè)參數(shù)：指定和映射文件中所匹配的parameterType類型的參數(shù)
        sqlSession.delete("test.deleteUserById", 26);
        //提交事務(wù)
        sqlSession.commit();
        //釋放資源
        sqlSession.close();
    }

1
2
3
4
5
6
7
8
9

<!--根據(jù)id更新用戶
        需要輸入用戶的id
        傳入用戶要更新的信息
        parameterType指定user對象，包括id和更新信息，id必須存在
        #{id}：從輸入對象中獲取id屬性值
-->
<update id="updateUserById" parameterType="cn.zhisheng.mybatis.po.User">
        update user set username = #{username}, birthday = #{birthday}, sex = #{sex}, address = #{address} where user.id = #{id}
    </update>

8
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

//根據(jù)id更新用戶信息
    @Test
    public void updateUserByIdTest() throws IOException, ParseException {
        //Mybatis 配置文件
        String resource = "SqlMapConfig.xml";
        //得到配置文件流
        InputStream inputStream = Resources.getResourceAsStream(resource);
        //創(chuàng)建會話工廠,傳入Mybatis的配置文件信息
        SqlSessionFactory  sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
        //通過工廠得到SqlSession
        SqlSession sqlSession = sqlSessionFactory.openSession();
        //為了設(shè)置生日的日期輸入
        SimpleDateFormat sdf = new SimpleDateFormat ("yyyy-MM-dd");
        User user = new User();
        //根據(jù)id更新用戶信息
        user.setId(24);
        user.setUsername("張四風(fēng)");
        user.setBirthday(sdf.parse("2015-01-12"));
        user.setSex("女");
        user.setAddress("上海黃埔");
        //通過SqlSession操作數(shù)據(jù)庫
        //第一個(gè)參數(shù)：映射文件中Statement的id，等于 = namespace + "." + Statement的id
        //第二個(gè)參數(shù)：指定和映射文件中所匹配的parameterType類型的參數(shù)
        sqlSession.update("test.updateUserById", user);
        //提交事務(wù)
        sqlSession.commit();
        //釋放資源
        sqlSession.close();
    }