1. 查询
除了单条记录的查询，这里我们来尝试查询一组记录。
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>
测试方法：
@test
public void querylisttest() {
sqlsession session = sqlsessionfactory.opensession();
try {
iusermapper mapper = session.getmapper(iusermapper.class);
list<user> users = mapper.getusers("%a%"); // %在sql里代表任意个字符。
for (user user : users) {
log.info("{}: {}", user.getname(), user.getaddress());
}
} finally {
session.close();
}
}
如果联表查询，返回的是复合对象，需要用association关键字来处理。
如user发表article，每个用户可以发表多个article，他们之间是一对多的关系。
（1） 创建article表，并插入测试数据：
-- 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）测试方法：
@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标签内定义字段和属性的映射外，还可以重用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使用数据库自动生成的主键，并填充到keyproperty指定的属性上。如果未指定，返回对象拿不到生成的值 -->
insert into user(name,age,address) values(#{name},#{age},#{address})
</insert>
测试方法：
@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(); // 默认为不自动提交。调用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>
测试方法：
@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的其它属性也要赋值，否则这些属性会被数据库更新为初始值（null或0等），可以先查询一次，但这样会增加和数据库不必要的交互。后面的条件判断能避免此问题。
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>
测试方法：
@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();
}
}
如对本文有疑问， 点击进行留言回复！！
springboot利用profile配置文件进行多环境切换
如何使用MyBatis-Plus代码生成器(逆向工程)一键生成代码
网友评论