MYBATIS的使用（一【xml方式实现】）

自MYBATIS从BATIS奔向Google后&＃xff0c;一直在蜕化&＃xff0c;大方向实现分xml和注解Annation。接下来分别为初学者推出xml和注解Annation两种Demo。

一、第一种实现方式&＃xff1a;xml

1、Demo结构。

2、配置文件

&＃xff08;1&＃xff09;数据源&＃xff1a;jdbc.properties

#******************** 数据库连接属性 *****************************
driver&＃61;com.mysql.jdbc.Driver
username&＃61;root
password&＃61;123
url&＃61;jdbc\:mysql\://localhost\:3306/solrdb?characterEncoding\&＃61;utf8

&＃xff08;2&＃xff09;mybatis-config.xml配置


PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-config.dtd">
&＃xff08;3&＃xff09;日志文件&＃xff1a;log4j.xml

(4)sysUser.xml配置


PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
insert into sys_user(id,user_name) values (#{id},#{user_name})delete from sys_user where id &＃61; #{id}update sys_user set user_name &＃61; #{user_name} where id &＃61; #{id}select * from sys_user where id &＃61; #{id}

&＃xff08;1&＃xff09;LogHelper.java

package com.wrs.common;import java.net.URL;import org.apache.log4j.Logger;
import org.apache.log4j.PropertyConfigurator;/*** &＃64;function 项目日志 * &＃64;author WRS* &＃64;remark 项目日志打印&＃xff1a;常用日志、sql日志 exception异常日志* &＃64;version 1.0* &＃64;since jdk1.8* &＃64;datetime 2015年7月9日 下午4:10:39* &＃64;copyright {xx.com (c) 2018}*/
public class LogHelper {static{URL configFileResource &＃61; LogHelper.class.getResource("/log4j.xml");PropertyConfigurator.configure(configFileResource);}/*** 普通日志打印* &＃64;return 返回普通日志对象*/public static Logger printLog() {return Logger.getLogger("log");}/*** sql日志打印* &＃64;return 返回sql日志对象*/public static Logger printSql() {return Logger.getLogger("sql");}/*** 异常日志打印* &＃64;return 返回exception日志对象*/public static Logger printException() {return Logger.getLogger("exception");}public static void main(String[] args) {}}


SessionFactory.java

package com.wrs.common;import java.io.IOException;
import java.io.InputStream;import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;/*** &＃64;function session工厂 * &＃64;author {作者}* &＃64;remark {描述}* &＃64;version {版本}* &＃64;since jdk1.6* &＃64;datetime 2015年7月28日 上午9:57:58* &＃64;copyright {wrs.com (c) 2013}*/
public class SessionFactory {/*** 获取session对象* &＃64;return*/public static SqlSession getSession(){LogHelper.printLog().info("SessionFactory getSession()");SqlSession session &＃61; null;try {String resource &＃61; "mybatis-config.xml";InputStream inputStream &＃61; Resources.getResourceAsStream(resource);SqlSessionFactory sqlSessionFactory &＃61; new SqlSessionFactoryBuilder().build(inputStream);if(sqlSessionFactory!&＃61;null){session &＃61; sqlSessionFactory.openSession();}else{LogHelper.printLog().info("Session对象创建失败,请检查mybatis-config.xml配置是否正确&＃xff01;");}} catch (IOException e) {e.printStackTrace();}return session;}/*** 释放没用的资源* &＃64;param sqlSession*/public static void close(SqlSession session) {LogHelper.printLog().info("SessionFactory close(SqlSession session)");if (session!&＃61;null) {//释放session资源session.clearCache();session.close();session &＃61; null;}LogHelper.printLog().info("释放资源完毕!");}public static void main(String[] args) {getSession();}
}


数据分层》

SysUserDao.java

package com.wrs.dao;import java.util.List;import com.wrs.model.SysUser;/*** &＃64;function {功能} * &＃64;author {作者}* &＃64;remark {描述}* &＃64;version {版本}* &＃64;since jdk1.6* &＃64;datetime 2015年7月30日 下午1:53:32* &＃64;copyright {wrs.com (c) 2013}*/
public interface SysUserDao{/*** 增加用户* &＃64;param sysUser* &＃64;return*/public int insert(SysUser sysUser);/*** 删除用户* &＃64;param id* &＃64;return*/public int delete(Integer id);/*** 更新用户* &＃64;param sysUser* &＃64;return*/public int update(SysUser sysUser);/*** 查询用户* &＃64;param id* &＃64;return*/public SysUser query(Integer id);/*** 获取所有用户信息* &＃64;return*/public List querySysUserList();
}


SysUserDaoImpl.java

package com.wrs.dao.impl;import java.util.List;import org.apache.ibatis.session.SqlSession;import com.wrs.common.SessionFactory;
import com.wrs.dao.SysUserDao;
import com.wrs.model.SysUser;/*** &＃64;function 用户数据访问接口实现 * &＃64;author WRS* &＃64;remark 增、删、改、查* &＃64;version 1.0* &＃64;since jdk1.6* &＃64;datetime 2015年7月30日 下午1:58:09* &＃64;copyright {wrs.com (c) 2013}*/
public class SysUserDaoImpl implements SysUserDao {private SqlSession session &＃61; null;public SysUserDaoImpl() {if (session&＃61;&＃61;null) {session &＃61; SessionFactory.getSession();}}/** 新增用户* 【注意&＃xff1a;增加时应该将session的自动提交改为手动提交&＃xff0c;不执行改操作会导致无法增加数据】* (non-Javadoc)* &＃64;see com.wrs.dao.SysUserDao#insert(com.wrs.model.SysUser)*/&＃64;Overridepublic int insert(SysUser sysUser) {session.commit(false);//1、先取消自动提交int insertRslt &＃61; session.insert("com.wrs.model.SysUserMapper.insertSysUser", sysUser);//2、执行增加操作session.commit();//3、手动提交return insertRslt;}/** 删除用户* 【注意&＃xff1a;删除时应该将session的自动提交改为手动提交&＃xff0c;不执行改操作会导致无法删除数据】* (non-Javadoc)* &＃64;see com.wrs.dao.SysUserDao#delete(java.lang.Integer)*/&＃64;Overridepublic int delete(Integer Id) {session.commit(false);int deleteRslt &＃61; session.delete("com.wrs.model.SysUserMapper.deleteSysUser", Id);session.commit();System.out.println("删除用户结果&＃xff1a;"&＃43;(deleteRslt&＃61;&＃61;1?"成功":"失败")&＃43;"!");return deleteRslt;}/** 修改用户* 【注意&＃xff1a;修改时应该将session的自动提交改为手动提交&＃xff0c;不执行改操作会导致无法修改数据】* (non-Javadoc)* &＃64;see com.wrs.dao.SysUserDao#update(com.wrs.model.SysUser)*/&＃64;Overridepublic int update(SysUser sysUser) {session.commit(false);int deleteRslt &＃61; session.update("com.wrs.model.SysUserMapper.updateSysUser", sysUser);session.commit();return deleteRslt;}/** 查询单个用户* (non-Javadoc)* &＃64;see com.wrs.dao.SysUserDao#query(java.lang.Integer)*/&＃64;Overridepublic SysUser query(Integer Id) {return session.selectOne("com.wrs.model.SysUserMapper.selectSysUser", Id);}/** 查询所有用户* (non-Javadoc)* &＃64;see com.wrs.dao.SysUserDao#querySysUserList()*/&＃64;Overridepublic List querySysUserList() {return session.selectList("com.wrs.model.SysUserMapper.selectSysUserList");}}


业务逻辑层》

SysUserService.java

package com.wrs.service;import java.util.List;import com.wrs.model.SysUser;/*** &＃64;function {功能} * &＃64;author {作者}* &＃64;remark {描述}* &＃64;version {版本}* &＃64;since jdk1.6* &＃64;datetime 2015年7月30日 下午1:53:32* &＃64;copyright {wrs.com (c) 2013}*/
public interface SysUserService {/*** 增加用户* &＃64;param sysUser* &＃64;return*/public int insert(SysUser sysUser);/*** 删除用户* &＃64;param id* &＃64;return*/public int delete(Integer id);/*** 更新用户* &＃64;param sysUser* &＃64;return*/public int update(SysUser sysUser);/*** 查询用户* &＃64;param id* &＃64;return*/public SysUser query(Integer id);/*** 获取所有用户信息* &＃64;return*/public List querySysUserList();
}

SysUserServiceImpl.java

package com.wrs.service.impl;import java.util.List;import com.wrs.dao.SysUserDao;
import com.wrs.dao.impl.SysUserDaoImpl;
import com.wrs.model.SysUser;
import com.wrs.service.SysUserService;/*** &＃64;function {功能} * &＃64;author {作者}* &＃64;remark {描述}* &＃64;version {版本}* &＃64;since jdk1.6* &＃64;datetime 2015年7月30日 下午1:58:09* &＃64;copyright {wrs.com (c) 2013}*/
public class SysUserServiceImpl implements SysUserService {private SysUserDao sysUserDao &＃61; null;public SysUserServiceImpl() {if (sysUserDao&＃61;&＃61;null) {sysUserDao &＃61; new SysUserDaoImpl();}}&＃64;Overridepublic int insert(SysUser sysUser) {return sysUserDao.insert(sysUser);}&＃64;Overridepublic int delete(Integer Id) {return sysUserDao.delete(Id);}&＃64;Overridepublic int update(SysUser sysUser) {return sysUserDao.update(sysUser);}&＃64;Overridepublic SysUser query(Integer Id) {return sysUserDao.query(Id);}&＃64;Overridepublic List querySysUserList() {return sysUserDao.querySysUserList();}}


调用Action》

SysUserAction.java

package com.wrs.action;import java.util.List;import com.wrs.common.LogHelper;
import com.wrs.model.SysUser;
import com.wrs.service.SysUserService;
import com.wrs.service.impl.SysUserServiceImpl;/*** &＃64;function {功能} * &＃64;author {作者}* &＃64;remark {描述}* &＃64;version {版本}* &＃64;since jdk1.6* &＃64;datetime 2015年7月30日 上午11:47:31* &＃64;copyright {wrs.com (c) 2013}*/
public class SysUserAction {private SysUserService sysUserService &＃61; null;public SysUserAction() {if(sysUserService&＃61;&＃61;null){sysUserService &＃61; new SysUserServiceImpl();}}/*** 新增用户* 【注意&＃xff1a;增加时应该将session的自动提交改为手动提交&＃xff0c;不执行改操作会导致无法增加数据】*/public void insert(){LogHelper.printLog().info("SysUserAction insert()");SysUser sysUser &＃61; new SysUser(3,"生哥");//如数据库支持Id主键自增&＃xff0c;则Id可以为null值,如"mysql数据库"int insertRslt &＃61; sysUserService.insert(sysUser);LogHelper.printLog().info("新增用户结果&＃xff1a;"&＃43;(insertRslt&＃61;&＃61;1?"成功":"失败")&＃43;"!");}/*** 删除用户* 【注意&＃xff1a;删除时应该将session的自动提交改为手动提交&＃xff0c;不执行改操作会导致无法删除数据】*/public void delete(){LogHelper.printLog().info("SysUserAction delete()");int deleteRslt &＃61; sysUserService.delete(3);LogHelper.printLog().info("删除用户结果&＃xff1a;"&＃43;(deleteRslt&＃61;&＃61;1?"成功":"失败")&＃43;"!");}/*** 修改用户* 【注意&＃xff1a;删除时应该将session的自动提交改为手动提交&＃xff0c;不执行改操作会导致无法修改数据】*/public void update(){LogHelper.printLog().info("SysUserAction delete()");SysUser sysUser &＃61; new SysUser(3,"生哥别名");int deleteRslt &＃61; sysUserService.update(sysUser);LogHelper.printLog().info("修改用户结果&＃xff1a;"&＃43;(deleteRslt&＃61;&＃61;1?"成功":"失败")&＃43;"!");}/*** 查询用户*/public void query(){LogHelper.printLog().info("SysUserAction query()");SysUser sysUser &＃61; sysUserService.query(1);LogHelper.printLog().info("用户ID:"&＃43;sysUser.getId()&＃43;",用户名:"&＃43;sysUser.getUser_name());}/*** 查询所有用户数量*/public void querySysUserList(){LogHelper.printLog().info("SysUserAction query()");List sysUserList &＃61; sysUserService.querySysUserList();LogHelper.printLog().info("用户数量&＃xff1a;"&＃43;sysUserList.size());}public static void main(String[] args) {SysUserAction sysUserAction &＃61; new SysUserAction();//sysUserAction.insert();//sysUserAction.delete();//sysUserAction.update();//sysUserAction.query();sysUserAction.querySysUserList();}
}


友情提示&＃xff1a;本人提供相关IT技术开发和支持&＃xff0c;与其相关技术交流。

如需请加微信号&＃xff1a;