一、封装SqlSession
public class SqlSessionUtil {
? ?private static SqlSessionFactory factory;
? ?//MyBatis作者认为,在应用程序运行过程中,SessionFactory对象有且只应该有一个
? ?static {
? ? ? ?try {
? ? ? ? ? ?InputStream in = Resources.getResourceAsStream("mybatis.xml");
? ? ? ? ? ?factory = new SqlSessionFactoryBuilder().build(in);
? ? ? } catch (IOException e) {
? ? ? ? ? ?e.printStackTrace();
? ? ? }
? }
?
? ?public static SqlSession openSession(boolean autoCommit){
? ? ? ?return factory.openSession(autoCommit);
? }
}
<update id="update">
? ? ? ? update dept set dname='人事部门',loc='地点' where deptno=50
</update>
@Test
public void test()throws Exception{
? ? ?SqlSession sqlSession = SqlSessionUtil.openSession(true);
? ? ?int result = sqlSession.update("dept.update");
? ? ?sqlSession.close();
? ? ? ?System.out.println("更新了"+result+"部门");
? }
二、mybatis框架服务---查询结果映射服务
-
前提:使用jdbc技术推送查询时,会得到一个临时表的引用(resultset) 此时需要手动将临时表中的数据行转换成Java中相关类型对象 List deptList = new ArrayList(); resultset rs = ps.executeQuery(select * from Dept) while(rs.next()){ int deptNo = rs.getInt("deptNo"); ......... deptList.add(dept); } 随着表中字段个数的增加,rs.getXXX方法调用次数也会逐渐增加,最终会影响开发效率,增加开发难度。
? ? ? <select id="deptCount" resultType="Integer">
? ? ? ? ? ? select count(*) from dept
? ? ? </select>
? ?@Test
? ?public void test1()throws Exception{
? ? ? ?SqlSession sqlSession = SqlSessionUtil.openSession(true);
? ? ? ?int deptNo =sqlSession.selectOne("dept.deptCount");//只有确信查询语句返回的临时表只有一行数据时,才可以使用selectOne
? ? ? ?sqlSession.close();
? ? ? ?System.out.println("部门的个数是 "+deptNo);
? }
<!--自定义映射关系-->
? ?<resultMap id="mapper_1" type="com.bjpowernode.entity.Dept">
? ? ? ?<result column="departNum" property="deptNo"/>
? ? ? ?<result column="departName" property="dname"/>
? ? ? ?<result column="departLoc" ?property="loc"/>
? ?</resultMap>
?
<select id="findByDeptNo" resultMap="mapper_1">
? ? ? select deptNo as departNum , dname as departName, loc as departLoc
? ? ? from dept where deptno=30
</select>
@Test
? ?public void test1()throws Exception{
? ? ?SqlSession sqlSession = SqlSessionUtil.openSession(true);
? ? ?Dept dept =sqlSession.selectOne("dept.findByDeptNo");
? ? ?sqlSession.close();
? ? ?System.out.println(dept.toString());
? }
三、占位符自动赋值服务
-
前提:jdbc规范中提供了预编译的SQL命令格式,降低动态SQL书写难度,同时也可以防止SQL注入攻击 insert into dept values (?,?,?)。 但是在jdbc规范中,需要开发人员手动完成占位符的赋值操作,如下: ps.setInt(2,10) ps.setString(2,"BeiJing")
? ? <!--
? ? SQL映射文件中要求使用 #{}来描述?
? ? 同时开发人员需要在#{}内部设置形参名
?
? ? parameterType的值是基本数据类型,此时#{}中形参名称可以随意设置
? ? 但是最好要符合'见名知义'
? ? -->
<!--根据部门编号删除部门-->
? ?<delete id="deleteByDeptNo" parameterType="int">
? ? ? delete from dept where deptNo=#{deptNo}
? ?</delete>
?
?
<!--
? ? ? parameterType的值是实体类,此时SQL语句中#{}的值必须是
? ? ? 实体类的"属性名"
? ?-->
? ?<insert id="insertDept" parameterType="com.bjpowernode.entity.Dept">
? ? ? insert into dept values(#{deptNo},#{dname},#{loc})
? ?</insert>
? ?@Test
? ?public void test1()throws Exception{
? ? ?SqlSession sqlSession = SqlSessionUtil.openSession(true);
? ? ?int result = sqlSession.delete("dept.deleteByDeptNo",40);
? ? ?sqlSession.close();
? ? ?System.out.println("本次删除了"+result+"个部门");
? }
?
? ?@Test
? ?public void test2()throws Exception{
? ? ? ?SqlSession sqlSession = SqlSessionUtil.openSession(true);
? ? ? ?Dept dept = new Dept(40,"综合部","北京");
? ? ? ?int result = sqlSession.insert("dept.insertDept",dept);
? ? ? ?sqlSession.close();
? ? ? ?System.out.println("本次注册了"+result+"个部门");
? }
|