博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
MyBatis从入门到放弃一:从SqlSession实现增删改查
阅读量:6277 次
发布时间:2019-06-22

本文共 7480 字,大约阅读时间需要 24 分钟。

前言

     开博客这是第一次写系列文章,从内心上讲是有点担心自己写不好,写不全,毕竟是作为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
View Code

2、mybatis.xml

1 
2 5
6 7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24 25 26
27
28
29
30
View Code

3、log4j.properties

1 ### Log4j配置 ### 2 ### 与Spring结合需要在web.xml中指定此文件位置,并添加监听器 ### 3 #定义log4j的输出级别和输出目的地(目的地可以自定义名称,和后面的对应) 4 #[ level ] , appenderName1 , appenderName2 5 log4j.rootLogger=DEBUG,console,file 6  7 #-----------------------------------# 8 #1 定义日志输出目的地为控制台 9 log4j.appender.console = org.apache.log4j.ConsoleAppender10 log4j.appender.console.Target = System.out11 log4j.appender.console.Threshold=DEBUG12 ####可以灵活地指定日志输出格式,下面一行是指定具体的格式 ###13 #%c: 输出日志信息所属的类目,通常就是所在类的全名14 #%m: 输出代码中指定的消息,产生的日志具体信息15 #%n: 输出一个回车换行符,Windows平台为"/r/n",Unix平台为"/n"输出日志信息换行16 log4j.appender.console.layout = org.apache.log4j.PatternLayout17 log4j.appender.console.layout.ConversionPattern=[%c]-%m%n18 19 #-----------------------------------#20 #2 文件大小到达指定尺寸的时候产生一个新的文件21 log4j.appender.file = org.apache.log4j.RollingFileAppender22 #日志文件输出目录23 log4j.appender.file.File=log/tibet.log24 #定义文件最大大小25 log4j.appender.file.MaxFileSize=10mb26 ###输出日志信息###27 #最低级别28 log4j.appender.file.Threshold=ERROR29 log4j.appender.file.layout=org.apache.log4j.PatternLayout30 log4j.appender.file.layout.ConversionPattern=[%p][%d{yy-MM-dd}][%c]%m%n31 32 #-----------------------------------#33 #3 druid34 log4j.logger.druid.sql=INFO35 log4j.logger.druid.sql.DataSource=info36 log4j.logger.druid.sql.Connection=info37 log4j.logger.druid.sql.Statement=info38 log4j.logger.druid.sql.ResultSet=info39 40 #4 mybatis 显示SQL语句部分41 log4j.logger.org.mybatis=DEBUG42 #log4j.logger.cn.tibet.cas.dao=DEBUG43 #log4j.logger.org.mybatis.common.jdbc.SimpleDataSource=DEBUG#44 #log4j.logger.org.mybatis.common.jdbc.ScriptRunner=DEBUG#45 #log4j.logger.org.mybatis.sqlmap.engine.impl.SqlMapClientDelegate=DEBUG#46 #log4j.logger.java.sql.Connection=DEBUG47 log4j.logger.java.sql=DEBUG48 log4j.logger.java.sql.Statement=DEBUG49 log4j.logger.java.sql.ResultSet=DEBUG50 log4j.logger.java.sql.PreparedStatement=DEBUG
View Code

 

配置mapper.xml

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

insert into t_userinfo (name,address) values(#{name},#{address})
update t_userinfo set name=#{name},address=#{address} where id=#{id}
delete t_userinfo where id=#{id}

  

建立单元测试

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

SqlSessionFactory sqlSessionFactory=null;    @Before    public void BeforeClass(){        try {            InputStream is=Resources.getResourceAsStream("log4j.properties");            PropertyConfigurator.configure(is);            Reader reader = Resources.getResourceAsReader("mybatis.xml");            sqlSessionFactory= new SqlSessionFactoryBuilder().build(reader);        } catch (IOException e) {            e.printStackTrace();        }    }

2、queryUsers

@Test    public void queryUsers() throws Exception {        //线程不安全类型,放在方法体内        SqlSession sqlSession=null;        try {            sqlSession=sqlSessionFactory.openSession();            List
list = sqlSession.selectList("com.autohome.mapper.User.queryUsers"); System.out.println("size:"+list.size()); } catch (Exception e) { e.printStackTrace(); }finally { sqlSession.close(); } }

3、queryUserById

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

4、insertUser

@Test    public void insertUser(){        SqlSession sqlSession=null;        try{            sqlSession=sqlSessionFactory.openSession();            User user =new User();            user.setName("kobe");            user.setAddress("usa");            int result = sqlSession.insert("com.autohome.mapper.User.insertUsers",user);            sqlSession.commit();            if(result>0){                System.out.println("insert success....");            }else{                System.out.println("insert error....");            }        }catch(Exception e){            e.printStackTrace();        }finally {            sqlSession.close();        }    }

5、updateUser

@Test    public void updateUser(){        SqlSession sqlSession=null;        try{            sqlSession=sqlSessionFactory.openSession();            User user =new User();            user.setId(36);            user.setName("kobe");            user.setAddress("usa");            int result = sqlSession.update("com.autohome.mapper.User.updateUsers",user);            sqlSession.commit();            if(result>0){                System.out.println("update success....");            }else{                System.out.println("update error....");            }        }catch(Exception e){            e.printStackTrace();        }finally {            sqlSession.close();        }    }

  

6、deleteUser

@Test    public void deleteUser(){        SqlSession sqlSession=null;        try{            sqlSession=sqlSessionFactory.openSession();            int result = sqlSession.delete("com.autohome.mapper.User.deleteUsers",49);            sqlSession.commit();            if(result>0){                System.out.println("delete success....");            }else{                System.out.println("delete error....");            }        }catch(Exception e){            e.printStackTrace();        }finally {            sqlSession.close();        }    }

  

总结

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

 

转载地址:http://pzfva.baihongyu.com/

你可能感兴趣的文章
(总结)Nginx配置文件nginx.conf中文详解
查看>>
openssl用法详解
查看>>
[Java web]Spring+Struts2+Hibernate整合过程(2)
查看>>
基于ThinkPHP与阿里大于的PHP短信验证功能
查看>>
ASP.NET Core 2 学习笔记(十二)REST-Like API
查看>>
react 调用 function 的写法 及 解决 react onClick 方法自动执行
查看>>
adb 切换android输入法
查看>>
OSAL工作机制分析
查看>>
Spring Cloud入门教程(二):客户端负载均衡(Ribbon)
查看>>
BZOJ2681 : 玩游戏2
查看>>
Solr DocValues详解
查看>>
java file
查看>>
sed替换换行符“\n”
查看>>
linux 系统下使用socket进行本地进程间通信
查看>>
OpenStack的八年之痒
查看>>
大数据脱敏
查看>>
Hyper-V~双网卡设置
查看>>
环绕声5.1ch
查看>>
openJDK之如何下载各个版本的openJDK源码
查看>>
[原][粒子特效][spark]深入浅出osgSpark
查看>>