码迷,mamicode.com
首页 > 数据库 > 详细

Mybatis实现简单的数据库增删改查操作

时间:2019-10-23 09:51:31      阅读:83      评论:0      收藏:0      [点我收藏+]

标签:cte   oca   man   保存   配置数据源   upd   classpath   expand   rri   

Mybatis实现简单的数据库增删改查操作

框架:mybatis(3.5.2)

数据库:mysql

工具:idea

 

1.新建一个maven项目,在pom文件中添加mybatis依赖及MySQL依赖

 1 <!-- mybatis核心依赖 -->
 2     <!-- https://mvnrepository.com/artifact/org.mybatis/mybatis -->
 3     <dependency>
 4         <groupId>org.mybatis</groupId>
 5         <artifactId>mybatis</artifactId>
 6         <version>${mybatis.version}</version>
 7     </dependency>
 8     
 9     <!-- mysql驱动 -->
10     <dependency>
11         <groupId>mysql</groupId>
12         <artifactId>mysql-connector-java</artifactId>
13         <version>${mysql.version}</version>
14     </dependency>

2、新建实体类User、工具类MybatisUtils、数据访问接口UserDao及它的实现类UserDaoImpl

Users类:

 1 private Integer uid;
 2 private String userName;
 3 
 4 public Integer getUid() {
 5     return uid;
 6 }
 7 
 8 public void setUid(Integer uid) {
 9     this.uid = uid;
10 }
11 
12 public String getUserName() {
13     return userName;
14 }
15 
16 public void setUserName(String userName) {
17     this.userName = userName;
18 }

MybatisUtils类:

 1 private static SqlSessionFactory sqlSessionFactory;
 2 
 3 /**
 4 * 在静态代码块中初始化工厂
 5 */
 6 static{
 7     //先查找mybatis的核心配置文件来初始化数据源,
 8     //默认从classpath下查找核心配置文件
 9     try {
10         //注意:import org.apache.ibatis.io.Resources;
11         InputStream is = Resources.getResourceAsStream("mybatis.xml");
12         //创建一个SqlSessionFactoryBuilder来解析配置文件的信息,
13         // 然后创建出SqlSessionFactory实例
14         SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
15         //build方法传入一个输入流,通过解析后返回一个SqlSessionFactory实例
16         sqlSessionFactory = builder.build(is);
17 
18     } catch (IOException e) {
19         e.printStackTrace();
20     }
21 }
22 
23 /**
24 * 提供一个获取SqlSession的方法
25 * @param autoCommit 在获取SQL Session时可以传递一个boolean类型的参数值,
26 *             这个参数的作用似乎用于设置是否手动提交事务还是自动提交事务,
27 *             false为手动提交,true为自动提交
28 * @return
29 */
30 public static SqlSession getSqlSession(boolean autoCommit){
31     //通过openSession方法来创建一个sqlSession实例,
32     //有了SqlSession,就可以来访问数据库
33     return sqlSessionFactory.openSession(autoCommit);
34 }

UserDao接口:

 1 /**
 2      * 通过传递一个对象形式保存用户
 3      * @param user
 4      */
 5 void save(Users user);
 6 
 7     /**
 8      * 通过传递一个map集合保存用户
 9      * @param map
10      */
11 void save2(Map<String, Object> map);
12 
13     /**
14      * 通过传递一个对象修改用户
15      * @param user
16      */
17 void update(Users user);
18 
19     /**
20      * 通过id删除用户
21      * @param id
22      */
23 void delete(int id);
24 
25     /**
26      * 通过传递多个参数修改用户
27      * @param userName
28      * @param uid
29      */
30 void update2(String userName, int uid);
31 
32 /**
33      * 根据id查询一条结果集,返回一个实体对象
34      * @param uid
35      * @return
36      */
37 Users getUserById(String uid);
38 
39 /**
40      * 根据id查询一条结果集,返回一个map集合
41      * @param id
42      * @return
43      */
44 Map<String, Object> getUserById2(String id);
45 
46 /**
47      * 查询所有,返回多个Users对象
48      * @return
49      */
50 List<Users> listUser();
51 
52 /**
53      * 根据所有结果集,返回多个map集合
54      * @return
55      */
56 List<Map<String, Object>> listUser2();

在UserDaoImpl类实现UserDao接口并重写抽象方法:

 1 @Override
 2 public void save(Users user) {
 3     //获取SqlSession实例,true表示自动提交事务
 4     try(SqlSession session = MybatisUtils.getSqlSession(true)){
 5         //getMapper方法返回一个代理对象,这个代理对象也是实现了UserDao接口
 6         //底层使用JDK动态代理技术
 7         UserDao dao = session.getMapper(UserDao.class);
 8         //当执行save方法时,其实调用的时代理对象的save,
 9         //它会解析mapper映射配置文件,找到id为save的元素
10         //并执行其中的sql语句
11         dao.save(user);
12     }catch (RuntimeException e){
13 
14         throw e;
15     }
16 }
17 
18 @Override
19 public void save2(Map<String, Object> map) {
20     try(SqlSession sqlSession = MybatisUtils.getSqlSession(true)){
21         sqlSession.getMapper(UserDao.class).save2(map);
22     }catch(RuntimeException e){
23         throw e;
24     }
25 }
26 
27 @Override
28 public void update(Users user) {
29     try(SqlSession sqlSession = MybatisUtils.getSqlSession(true)){
30         sqlSession.getMapper(UserDao.class).update(user);
31     }catch (RuntimeException e){
32         throw e;
33     }
34 }
35 
36 @Override
37 public void delete(int id) {
38     try(SqlSession sqlSession = MybatisUtils.getSqlSession(true)){
39         sqlSession.getMapper(UserDao.class).delete(id);
40     }catch (RuntimeException e){
41         throw e;
42     }
43 }
44 
45 @Override
46 public void update2(String userName, int uid) {
47     try(SqlSession sqlSession = MybatisUtils.getSqlSession(true)) {
48         sqlSession.getMapper(UserDao.class).update2(userName, uid);
49     }catch (RuntimeException e){
50         throw e;
51     }
52 }
53 
54 @Override
55 public Users getUserById(String uid) {
56     try(SqlSession sqlSession = MybatisUtils.getSqlSession(true)) {
57         return sqlSession.getMapper(UserDao.class).getUserById(uid);
58     }catch (RuntimeException e){
59         throw e;
60     }
61 }
62 
63 @Override
64 public Map<String, Object> getUserById2(String id) {
65     try(SqlSession sqlSession = MybatisUtils.getSqlSession(true)) {
66         return sqlSession.getMapper(UserDao.class).getUserById2(id);
67     }catch (RuntimeException e){
68         throw e;
69     }
70 }
71 
72 @Override
73 public List<Users> listUser() {
74     try(SqlSession sqlSession = MybatisUtils.getSqlSession(true)) {
75         return sqlSession.getMapper(UserDao.class).listUser();
76     }catch (RuntimeException e){
77         throw e;
78     }
79 }
80 
81 @Override
82 public List<Map<String, Object>> listUser2() {
83     try(SqlSession sqlSession = MybatisUtils.getSqlSession(true)) {
84         return sqlSession.getMapper(UserDao.class).listUser2();
85     }catch (RuntimeException e){
86         throw e;
87     }
88 }

上述这些类的结构如图所示:

技术图片

 

 

 

 3、在main目录下的resources目录中新建一个mybatis.xml文件,以及mapper文件夹下新建一个UsersMapper.xml(此文件命名规范是实体类名+Mapper)如图所示:

技术图片

 

 

  mybatis.xml:

 1 <?xml version="1.0" encoding="utf-8"?>
 2 <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
 3         "http://mybatis.org/dtd/mybatis-3-config.dtd">
 4 <!-- mybatis核心配置,用于配置相关数据源以及连接池等信息,以及实体类的别称映射,插件配置等等 -->
 5 <configuration>
 6     <!-- 指定实体类的别名,方便在mapper配置中进行引用 -->
 7     <typeAliases>
 8         <!-- 方法1、定义一个alias别名,缺点在于需要一个实体类分别指定
 9         <typeAlias type="edu.nf.ch01.entity.Users" alias="user" />-->
10         <!-- 方法2、也可以使用package来给某个包下面的所有实体类自动创建别名,
11         自动创建的别名规则是类的类名并将首字母改为小写 -->
12         <package name="edu.nf.ch01.entity"/>
13     </typeAliases>
14     <!-- 配置数据源环境,default指定默认的数据源 -->
15     <environments default="mysql">
16         <!-- 创建一个MySQL的数据源环境,id就叫mysql -->
17         <environment id="mysql">
18             <!-- 配置事务管理,这里有JDBC和MANAGED两个值
19              JDBC:使用本地jdbc的事务
20              MANAGED:mybatis不参与事务管理,由运行容器来管理事务-->
21             <transactionManager type="JDBC"/>
22             <!-- 配置数据源,type指定获取连接的方式,有以下几个值:
23              POOLED:使用mybatis自带的数据库连接池(方便连接的复用)
24              UNPOOLRF:不使用连接池,而是每次请求都从数据库去获取连接
25               JMDI:通过查找JNDI树去获取数据源对象,通常结合web容器或者EJB容器来配置 -->
26             <dataSource type="POOLED">
27                 <!-- 配置数据源信息,驱动,url,连接的账号密码等 -->
28                 <property name="driver" value="com.mysql.jdbc.Driver"/>
29                 <property name="url" value="jdbc:mysql://localhost:3306/mybatis?useUnicode=true&amp;characterEncoding=utf-8"/>
30                 <property name="username" value="root"/>
31                 <property name="password" value="root"/>
32             </dataSource>
33         </environment>
34     </environments>
35 
36     <!-- 指定mapper配置文件 -->
37     <mappers>
38         <mapper resource="mapper/UsersMapper.xml" />
39     </mappers>
40 </configuration>

UsersMapper.xml:

 1 <?xml version="1.0" encoding="utf-8"?>
 2 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 3         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 4 <!-- mapper根节点的namespace指定Dao接口的完整类名,
 5 因为mybatis在解析的时候要根据这个类名找到相应dao方法执行 -->
 6 <mapper namespace="edu.nf.ch01.dao.UserDao">
 7     <!-- 映射SQL语句,比如<insert>标签用于映射insert语句,
 8      id属性对应Dao接口中的方法名
 9      parameterType表示Dao接口方法参数的类型,可以指定完整类名,
10      这里指定实体类的别名,也就是在mybatis.xml中定义的别名
11      在sql语句中使用#{}表达式来指定要插入的列,{}中指定实体的字段名-->
12     <insert id="save" parameterType="edu.nf.ch01.entity.Users">
13         insert into user_info(u_name) values(#{userName})
14     </insert>
15 
16     <!-- 如果参数类型时Map集合,那么#{}表达式对应的就是Map的kek,parameterType中也可以为map -->
17     <insert id="save2" parameterType="java.util.Map">
18         insert into user_info(u_name) values(#{uname})
19     </insert>
20 
21     <update id="update" parameterType="edu.nf.ch01.entity.Users">
22         update user_info set u_name = #{userName} where u_id = #{uid};
23     </update>
24 
25     <delete id="delete" parameterType="int">
26         delete from user_info where u_id = #{id}
27     </delete>
28     <!-- 当有多个参数时,不需要指定parameterType属性,
29     而是使用#{param1}#{param2}...的方式映射参数,对应方法参数的顺序 -->
30     <update id="update2">
31         update user_info set u_name = #{param1} where u_id = #{param2}
32     </update>
33     
34     <!-- 查询当个用户,将结果集封装成一个实体对象
35      resultType属性指定查询结果集的返回类型,
36      如果返回一个实体,则返回引用mybatis.xml文件中Alias设置的别名
37      需要注意的是,查询sql语句中,查询column必须要和实体的字段名称相同-->
38     <select id="getUserById" parameterType="java.lang.String" resultType="users">
39         select u_id as uid, u_name as userName from user_info2 where u_id = #{id}
40     </select>
41 
42     <!-- 查询单个用户,将结果集封装成一个map集合
43      此时只需要将resultType设置为map即可-->
44     <select id="getUserById2" parameterType="java.lang.String" resultType="map">
45         select u_id, u_name from user_info2 where u_id = #{id}
46     </select>
47 
48     <!-- 查询用户列表,返回list集合,集合中封装了多个实体对象 -->
49     <select id="listUser" resultType="users">
50         select u_id as uid, u_name as userName from user_info2
51     </select>
52 
53     <!-- 查询用户列表,返回list集合,集合中存放多个map对象 -->
54     <select id="listUser2" resultType="map">
55         select u_id, u_name from user_info2
56     </select>
57 </mapper>

4、数据库代码:

数据库:mybatis

数据表:user_info

1 create table user_info(
2     u_id int primary key auto_increment,
3     u_name varchar(50) not null
4 );

 

 

 

 

 

 

 

Mybatis实现简单的数据库增删改查操作

标签:cte   oca   man   保存   配置数据源   upd   classpath   expand   rri   

原文地址:https://www.cnblogs.com/drxwyq/p/11723908.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!