MyBatis中SqlSession实现增删改查案例

2024-02-28 07:26:37 359

前言

开博客这是第一次写系列文章，从内心上讲是有点担心自己写不好，写不全，毕竟是作为java/mybatis学习的过程想把学习的路线和遇到的问题都总结下来，也让知识点在脑海里能形成一个体系。

开发环境

idea2016、mybatis3、SQLServer2012

pom.xml、mybatis.xml、log4j.properties

先贴上pom.xml是因为他直接和搭建开发环境和测试环境有关系，mybatis.xml则是连接数据库，log4j.properties在学习阶段配置上有助于我们观察SQL的执行情况。

1、pom.xml



org.mybatis
mybatis
3.4.2


com.microsoft.sqlserver
sqljdbc4
4.0


commons-dbcp
commons-dbcp
1.4


junit
junit
4.10


log4j
log4j
1.2.17

2、mybatis.xml

3、log4j.properties

###Log4j配置###
###与Spring结合需要在web.xml中指定此文件位置，并添加监听器###
#定义log4j的输出级别和输出目的地（目的地可以自定义名称，和后面的对应）
#[level],appenderName1,appenderName2
log4j.rootLogger=DEBUG,console,file

#-----------------------------------#
#1定义日志输出目的地为控制台
log4j.appender.console=org.apache.log4j.ConsoleAppender
log4j.appender.console.Target=System.out
log4j.appender.console.Threshold=DEBUG
####可以灵活地指定日志输出格式，下面一行是指定具体的格式###
#%c:输出日志信息所属的类目，通常就是所在类的全名
#%m:输出代码中指定的消息,产生的日志具体信息
#%n:输出一个回车换行符，Windows平台为"/r/n"，Unix平台为"/n"输出日志信息换行
log4j.appender.console.layout=org.apache.log4j.PatternLayout
log4j.appender.console.layout.ConversionPattern=[%c]-%m%n

#-----------------------------------#
#2文件大小到达指定尺寸的时候产生一个新的文件
log4j.appender.file=org.apache.log4j.RollingFileAppender
#日志文件输出目录
log4j.appender.file.File=log/tibet.log
#定义文件最大大小
log4j.appender.file.MaxFileSize=10mb
###输出日志信息###
#最低级别
log4j.appender.file.Threshold=ERROR
log4j.appender.file.layout=org.apache.log4j.PatternLayout
log4j.appender.file.layout.ConversionPattern=[%p][%d{yy-MM-dd}][%c]%m%n

#-----------------------------------#
#3druid
log4j.logger.druid.sql=INFO
log4j.logger.druid.sql.DataSource=info
log4j.logger.druid.sql.Connection=info
log4j.logger.druid.sql.Statement=info
log4j.logger.druid.sql.ResultSet=info

#4mybatis显示SQL语句部分
log4j.logger.org.mybatis=DEBUG
#log4j.logger.cn.tibet.cas.dao=DEBUG
#log4j.logger.org.mybatis.common.jdbc.SimpleDataSource=DEBUG#
#log4j.logger.org.mybatis.common.jdbc.ScriptRunner=DEBUG#
#log4j.logger.org.mybatis.sqlmap.engine.impl.SqlMapClientDelegate=DEBUG#
#log4j.logger.java.sql.Connection=DEBUG
log4j.logger.java.sql=DEBUG
log4j.logger.java.sql.Statement=DEBUG
log4j.logger.java.sql.ResultSet=DEBUG
log4j.logger.java.sql.PreparedStatement=DEBUG

配置mapper.xml

mapper.xml在mybatis.xml是专职处理sql的一个环节，各种映射和实现都在这里处理






select*fromt_userinfo



select*fromt_userinfowhereid=#{id}


select*fromt_userinfowherename=#{name,javaType=String,jdbcType=VARCHAR}andaddress=#{address}



insertintot_userinfo(name,address)values(#{name},#{address})



updatet_userinfosetname=#{name},address=#{address}whereid=#{id}



deletet_userinfowhereid=#{id}

建立单元测试

1、准备工作，我建立的是控制台程序，所以在使用sqlsession前先创建sqlsessionfactory。当然，还要加载log4j.properties

SqlSessionFactorysqlSessionFactory=null;
@Before
publicvoidBeforeClass(){
try{
InputStreamis=Resources.getResourceAsStream("log4j.properties");
PropertyConfigurator.configure(is);
Readerreader=Resources.getResourceAsReader("mybatis.xml");
sqlSessionFactory=newSqlSessionFactoryBuilder().build(reader);
}catch(IOExceptione){
e.printStackTrace();
}
}

2、queryUsers

@Test
publicvoidqueryUsers()throwsException{
//线程不安全类型，放在方法体内
SqlSessionsqlSession=null;
try{
sqlSession=sqlSessionFactory.openSession();
Listlist=sqlSession.selectList("com.autohome.mapper.User.queryUsers");
System.out.println("size:"+list.size());
}catch(Exceptione){
e.printStackTrace();
}finally{
sqlSession.close();
}
}

3、queryUserById

@Test
publicvoidqueryUserById(){
SqlSessionsqlSession=null;
try{
sqlSession=sqlSessionFactory.openSession();
Useruser=sqlSession.selectOne("com.autohome.mapper.User.queryUserById",2);
System.out.println("id:"+user.getId()+",name:"+user.getName()+","+user.getAddress());
}catch(Exceptione){
e.printStackTrace();
}finally{
sqlSession.close();
}
}

4、insertUser

@Test
publicvoidinsertUser(){
SqlSessionsqlSession=null;
try{
sqlSession=sqlSessionFactory.openSession();
Useruser=newUser();
user.setName("kobe");
user.setAddress("usa");
intresult=sqlSession.insert("com.autohome.mapper.User.insertUsers",user);
sqlSession.commit();
if(result>0){
System.out.println("insertsuccess....");
}else{
System.out.println("inserterror....");
}
}catch(Exceptione){
e.printStackTrace();
}finally{
sqlSession.close();
}
}

5、updateUser

@Test
publicvoidupdateUser(){
SqlSessionsqlSession=null;
try{
sqlSession=sqlSessionFactory.openSession();
Useruser=newUser();
user.setId(36);
user.setName("kobe");
user.setAddress("usa");
intresult=sqlSession.update("com.autohome.mapper.User.updateUsers",user);
sqlSession.commit();
if(result>0){
System.out.println("updatesuccess....");
}else{
System.out.println("updateerror....");
}
}catch(Exceptione){
e.printStackTrace();
}finally{
sqlSession.close();
}
}

6、deleteUser

@Test
publicvoiddeleteUser(){
SqlSessionsqlSession=null;
try{
sqlSession=sqlSessionFactory.openSession();
intresult=sqlSession.delete("com.autohome.mapper.User.deleteUsers",49);
sqlSession.commit();
if(result>0){
System.out.println("deletesuccess....");
}else{
System.out.println("deleteerror....");
}
}catch(Exceptione){
e.printStackTrace();
}finally{
sqlSession.close();
}
}

总结

添加、修改、删除的操作要调用sqlsession.commit(),不然数据无法入库的，我刚开始就忘记了这个。

以上所述是小编给大家介绍的MyBatis中SqlSession实现增删改查案例，希望对大家有所帮助，如果大家有任何疑问欢迎给我留言，小编会及时回复大家的！

MyBatis中SqlSession实现增删改查案例

热门推荐

随机推荐