Java通過(guò)MyBatis框架對(duì)MySQL數(shù)據(jù)進(jìn)行增刪查改的基本方法

更新時(shí)間：2016年06月01日 14:53:12 作者：czj4451

MyBatis框架由Java的JDBC API進(jìn)一步封裝而來(lái),在操作數(shù)據(jù)庫(kù)方面效果拔群,接下來(lái)我們就一起來(lái)看看Java通過(guò)MyBatis框架對(duì)MySQL數(shù)據(jù)進(jìn)行增刪查改的基本方法:

1. 查詢

除了單條記錄的查詢，這里我們來(lái)嘗試查詢一組記錄。

IUserMapper接口添加下面方法：

List<User> getUsers(String name);

在User.xml中添加：

<resultMap type="User" id="userList"><!-- type為返回列表元素的類全名或別名 --> 
  <id column="id" property="id" /> 
  <result column="name" property="name" /> 
  <result column="age" property="age" /> 
  <result column="address" property="address" /> 
</resultMap> 
 
<select id="getUsers" parameterType="string" resultMap="userList"><!-- resultMap為上面定義的User列表 --> 
  select * from `user` where name like #{name} 
</select>

測(cè)試方法：

@Test 
public void queryListTest() { 
  SqlSession session = sqlSessionFactory.openSession(); 
  try { 
    IUserMapper mapper = session.getMapper(IUserMapper.class); 
    List<User> users = mapper.getUsers("%a%"); // %在sql里代表任意個(gè)字符。 
    for (User user : users) { 
      log.info("{}: {}", user.getName(), user.getAddress()); 
    } 
  } finally { 
    session.close(); 
  } 
}

如果聯(lián)表查詢，返回的是復(fù)合對(duì)象，需要用association關(guān)鍵字來(lái)處理。
如User發(fā)表Article，每個(gè)用戶可以發(fā)表多個(gè)Article，他們之間是一對(duì)多的關(guān)系。

（1）創(chuàng)建Article表，并插入測(cè)試數(shù)據(jù)：

-- Drop the table if exists 
DROP TABLE IF EXISTS `Article`; 
 
-- Create a table named 'Article' 
CREATE TABLE `Article` ( 
  `id` int NOT NULL AUTO_INCREMENT, 
  `user_id` int NOT NULL, 
  `title` varchar(100) NOT NULL, 
  `content` text NOT NULL, 
  PRIMARY KEY (`id`) 
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8; 
 
-- Add several test records 
INSERT INTO `article` 
VALUES 
('1', '1', 'title1', 'content1'), 
('2', '1', 'title2', 'content2'), 
('3', '1', 'title3', 'content3'), 
('4', '1', 'title4', 'content4');

（2） com.john.hbatis.model.Article類：

public class Article { 
  private int id; 
  private User user; 
  private String title; 
  private String content; 
  // Getters and setters are omitted 
}

（3）在IUserMapper中添加：

List<Article> getArticlesByUserId(int id);

（4）在User.xml中添加：

<resultMap type="com.john.hbatis.model.Article" id="articleList"> 
  <id column="a_id" property="id" /> 
  <result column="title" property="title" /> 
  <result column="content" property="content" /> 
   
  <association property="user" javaType="User"><!-- user屬性映射到User類 --> 
    <id column="id" property="id" /> 
    <result column="name" property="name" /> 
    <result column="address" property="address" /> 
  </association> 
</resultMap> 
 
<select id="getArticlesByUserId" parameterType="int" resultMap="articleList"> 
  select u.id, u.name, u.age, u.address, a.id a_id, a.title, a.content 
  from article a 
  inner join user u 
  on a.user_id=u.id and u.id=#{id} 
</select>

（5）測(cè)試方法：

@Test 
public void getArticlesByUserIdTest() { 
  SqlSession session = sqlSessionFactory.openSession(); 
  try { 
    IUserMapper mapper = session.getMapper(IUserMapper.class); 
    List<Article> articles = mapper.getArticlesByUserId(1); 
    for (Article article : articles) { 
      log.info("{} - {}, author: {}", article.getTitle(), article.getContent(), article.getUser().getName()); 
    } 
  } finally { 
    session.close(); 
  } 
}

附：
除了在association標(biāo)簽內(nèi)定義字段和屬性的映射外，還可以重用User的resultMap:

<association property="user" javaType="User" resultMap="userList" />

2. 新增

IUserMapper接口添加下面方法：

int addUser(User user);

User.xml添加：

<insert id="addUser" parameterType="User" useGeneratedKeys="true" keyProperty="id"><!-- useGeneratedKeys指定myBatis使用數(shù)據(jù)庫(kù)自動(dòng)生成的主鍵，并填充到keyProperty指定的屬性上。如果未指定，返回對(duì)象拿不到生成的值 --> 
  insert into user(name,age,address) values(#{name},#{age},#{address}) 
</insert>

測(cè)試方法：

@Test 
public void addUserTest() { 
  User user = new User("Lucy", 102, "Happy District"); 
  SqlSession session = sqlSessionFactory.openSession(); 
  try { 
    IUserMapper mapper = session.getMapper(IUserMapper.class); 
    int affectedCount = mapper.addUser(user); 
    session.commit(); // 默認(rèn)為不自動(dòng)提交。調(diào)用session.getConnection().getAutoCommit()查看 
    log.info("{} new record was inserted successfully whose id: {}", affectedCount, user.getId()); 
  } finally { 
    session.close(); 
  } 
}

3. 更新

接口添加方法：

int updateUser(User user);

User.xml添加：

<update id="updateUser" parameterType="User"> 
  update `user` set name=#{name}, age=#{age}, address=#{address} 
  where id=#{id} 
</update>

測(cè)試方法：

@Test 
public void updateUserTest() { 
  SqlSession session = sqlSessionFactory.openSession(); 
  try { 
    IUserMapper mapper = session.getMapper(IUserMapper.class); 
    User user = mapper.getUserById(8); 
    user.setAddress("Satisfied District"); 
    int affectedCount = mapper.updateUser(user); // 除了要修改的屬性外，user的其它屬性也要賦值，否則這些屬性會(huì)被數(shù)據(jù)庫(kù)更新為初始值（null或0等），可以先查詢一次，但這樣會(huì)增加和數(shù)據(jù)庫(kù)不必要的交互。后面的條件判斷能避免此問題。 
    log.info("Affected count: {}", affectedCount); 
    session.commit(); 
  } finally { 
    session.close(); 
  } 
}

4. 刪除

接口添加方法：

int deleteUser(int id);

User.xml添加：

<delete id="deleteUser" parameterType="int"> 
  delete from `user` where id=#{id} 
</delete>

測(cè)試方法：

@Test 
public void deleteUserTest() { 
  SqlSession session = sqlSessionFactory.openSession(); 
  try { 
    IUserMapper mapper = session.getMapper(IUserMapper.class); 
    int affectedCount = mapper.deleteUser(8); 
    log.info("Affected count: {}", affectedCount); 
    session.commit(); 
  } finally { 
    session.close(); 
  } 
}

您可能感興趣的文章: