MyBatis 单表CRUD

 

 

 

 

 

 

项目当中用到了MyBatis，所以为了快速上手，先来个单表CRUD

 

还是不习惯用maven构建项目，不下载jar包就没有doc也没有example，mybatis下载地址，

https://github.com/mybatis/mybatis-3

 建立web项目，导入包，创建数据表，创建pojo对象

 

mybatis核心位置文件时sqlMapConfig.xml，配置了数据的链接和事物

<configuration>
	<environments default="development">
		<environment id="development">
			<transactionManager type="JDBC" />
			<dataSource type="POOLED">
				<property name="driver" value="com.mysql.jdbc.Driver" />
				<property name="url" value="jdbc:mysql://localhost:3306/test?characterEncoding=utf-8" />
				<property name="username" value="root" />
				<property name="password" value="root" />
			</dataSource>
		</environment>
	</environments>
</configuration>

 创建数据库表所对应的pojo对象，这点跟Hibernate无差别

public class User {
	private String id;
	private String name;
	private Integer age;
}

所有的查询语句都需要编写在xml文件中，在User类的同级目录下建立User.xml文件，该文件就是编写CRUD的配置文件

查询所有数据

<select id="findAll" resultType="entity.User">
		select * from user
	</select>

 根据id查询一条数据

<!--
		parameterType：指定输入的参数类型
		#{}：表示占位符 
		#{id}：简单类型时，参数名称任意
		resultType：指定sql输出结果所映射的java对象类型
	 -->
	<select id="findUserById" parameterType="int" resultType="entity.User">
		select * from user where id=#{id}
	</select>

 模糊查询

<!-- ${}：中的参数只能是value ，这种方式不使用占位符，拼接字符串，有注入的危险-->
	<select id="searchUserLikeNama" parameterType="java.lang.String" resultType="entity.User">
		select * from user where name like '%${value}%'
	</select>

 新增数据，新增时返回主键有两种情况，第一种是数据库自增，第二种是手动生成，比如uuid，这两种方式不能同时使用

	<insert id="insertUser" parameterType="entity.User">
		<!--
		将插入数据的主键返回，适用于主键自增 
		order：语句执行顺序
		keyProperty：将查询到的主键值映射到parameterType中配置的pojo中的属性上	
		-->
		<selectKey keyProperty="id" order="AFTER" resultType="java.lang.String">
			select last_insert_id()
		</selectKey>
		手动设置主键的返回方式
		<selectKey keyProperty="id" order="BEFORE" resultType="java.lang.String">
		         select uuid()
		</selectKey>
		insert into user (id,name,age) value (#{id},#{name},#{age}) 
	</insert>

还有一种获取主键的方式

<!--执行增加操作的SQL语句。id和parameterType分别与StudentMapper接口中的add方法的名字和参数类型一致。以#{name}的形式引用Student参数的name属性，MyBatis将使用反射读取Student参数的此属性。#{name}中name大小写敏感。引用其他的gender等属性与此一致。seGeneratedKeys设置为"true"表明要MyBatis获取由数据库自动生成的主键；keyProperty="id"指定把获取到的主键值注入到Student的id属性-->
<insert id="add" parameterType="Student"useGeneratedKeys="true" keyProperty="id">
insert into student(name,gender,major,grade) values(#{name},#{gender},#{major},#{grade})
</insert>

 根据id删除

<delete id="deleteUserById" parameterType="java.lang.String">
		delete from user where id=#{id}
	</delete>

 根据id更新，pojo对象中id一定不能为空

<update id="updateUserById" parameterType="entity.User">
		update user set name=#{name} where id=#{id}
	</update>

 完整的User.xml

<?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有特殊的作用 -->
<mapper namespace="entity.User">
	<!-- 查询所有记录 -->
	<select id="findAll" resultType="entity.User">
		select * from user
	</select>
	
	<!--
		parameterType：指定输入的参数类型
		#{}：表示占位符 
		#{id}：简单类型时，参数名称任意
		resultType：指定sql输出结果所映射的java对象类型
	 -->
	<select id="findUserById" parameterType="int" resultType="entity.User">
		select * from user where id=#{id}
	</select>
	
	<!-- ${}：中的参数只能是value ，这种方式不使用占位符，拼接字符串，有注入的危险-->
	<select id="searchUserLikeNama" parameterType="java.lang.String" resultType="entity.User">
		select * from user where name like '%${value}%'
	</select>
	
	<insert id="insertUser" parameterType="entity.User">
		<!--
		将插入数据的主键返回，适用于主键自增 
		order：语句执行顺序
		keyProperty：将查询到的主键值映射到parameterType中配置的pojo中的属性上	
		-->
		<selectKey keyProperty="id" order="AFTER" resultType="java.lang.String">
			select last_insert_id()
		</selectKey>
		手动设置主键的返回方式
		<selectKey keyProperty="id" order="BEFORE" resultType="java.lang.String">
		select uuid()
		</selectKey>
		insert into user (id,name,age) value (#{id},#{name},#{age}) 
	</insert>
	
	<delete id="deleteUserById" parameterType="java.lang.String">
		delete from user where id=#{id}
	</delete>
	
	<update id="updateUserById" parameterType="entity.User">
		update user set name=#{name} where id=#{id}
	</update>
</mapper>

然后sqlMapConfig.xml中引入该配置文件

	<mappers>
		<mapper resource="entity/User.xml" />
	</mappers>

 通过程序调用配置文件中的CRUD语句，获取sqlMapConfig.xml配置文件，创建SqlSessionFactory工厂，所有的SQL查询都是通过SqlSession对象完成的

public class T {
	public static final String RESOURCE = "sqlMapConfig.xml"; // 配置文件
	SqlSessionFactory sqlSessionFactory;// Session工厂

	@Before
	public void initFactory() throws IOException {
		InputStream in = Resources.getResourceAsStream(RESOURCE);// 配置文件的输入流
		sqlSessionFactory = new SqlSessionFactoryBuilder().build(in); // 获得sqlSessionFactory
	}

	@Test
	public void testFindAll() {
		SqlSession session = sqlSessionFactory.openSession(); // 获得SqlSession
		List<User> users = session.selectList("entity.User.findAll"); // 命名空间+方法名
		System.out.println("总记录个数：" + users.size());
		session.close();
	}

	@Test
	public void testFindUserById() {
		SqlSession session = sqlSessionFactory.openSession(); // 获得SqlSession
		User u = session.selectOne("entity.User.findUserById", 1); // 命名空间+方法名
		List<User> users = session.selectList("entity.User.findUserById", 1); // 命名空间+方法名
		System.out.println(u);
		System.out.println(users);
		session.close();
	}

	@Test
	public void testSearchUserByName() {
		SqlSession session = sqlSessionFactory.openSession(); // 获得SqlSession
		List<User> users = session.selectList("searchUserLikeNama", "l"); // 命名空间+方法名
		System.out.println("总记录个数：" + users);
		session.close();
	}

	@Test
	public void testInsertUser() {
		SqlSession session = sqlSessionFactory.openSession(); // 获得SqlSession
		User u = new User("4", "cls", 18);
		session.insert("insertUser", u);
		session.commit();
		session.close();
	}
	
	@Test
	public void testDeleteUser() {
		SqlSession session = sqlSessionFactory.openSession(); // 获得SqlSession
		session.delete("deleteUserById", "4");
		session.commit();
		session.close();
	}
	@Test
	public void testUpdateUser() {
		SqlSession session = sqlSessionFactory.openSession(); // 获得SqlSession
		User u = new User("4", "LY", 18);
		session.update("updateUserById", u);
		session.commit();
		session.close();
	}
}