Java数据库编程-MyBatis

Java数据库编程-MyBatis

• • 1. MyBatis入门
  • • 1.1 简介
    • 1.2 安装
    • 1.3 与JDBC进行对比
    • 1.4 入门案例：搭建环境
    • • 1.4.1 构建项目
      • 1.4.2 数据库和表：User
    • 1.5 入门案例：查询所有
    • • 1.5.1 JavaBean:User
      • 1.5.2 编写Dao:UserMapper
      • 1.5.3 编写核心配置文件：SqlMapConfig.xml
      • 1.5.4 测试类
    • 1.6 总结
  • 2. 基本操作：增删改查
  • • 2.1 模糊查询
    • 2.2 插入数据
    • 2.3 更新数据
    • 2.4 删除数据
  • 3. 日志与工具类
  • • • 3.1.1 什么是日志
      • 3.1.2 整合日志
    • 3.2 工具类
    • • 3.2.1 拷贝工具类
      • 3.2.2 工具类原理分析
      • 3.2.3 测试类

1. MyBatis入门 1.1 简介

      MyBatis 是一个开源、轻量级的数据持久化框架，支持自定义 SQL、存储程序和高级映射，是 JDBC和 Hibernate的替代方案。它对JDBC的操作数据库的过程进行封装，使开发者只需要关注 SQL 本身，而不需要花费精力去处理注册驱动、创建 Connection、创建 Statement、手动设置参数、结果集检索及映射等繁杂的过程代码。
      MyBatis 本是apache的一个开源项目iBatis, 2010年这个项目由apache software foundation迁移到了google code，并且改名为MyBatis，实质上Mybatis对iBatis进行一些改进。

1.2 安装

MyBaits的代码由github.com管理，地址：https://github.com/mybatis/mybatis-3/releases
如果您使用的是Maven，只需在 pom 中添加以下依赖。

  org.mybatis
  mybatis
  x.x.x

1.3 与JDBC进行对比

• JDBC 编写DAO 的步骤
  

• MyBatis 编写DAO 的步骤
  

1.4 入门案例：搭建环境 1.4.1 构建项目

1. 新建项目：Java/Java Enterprise ==> Java EE ==> Web Application
   Java Enterprise 主要是针对Java EE 项目的开发设计的“帮助我们开发和部署可移植、健壮、可伸缩且安全的服务器端 Java应用程序”。
   
2. 选择路径并输入项目名后构建项目
   
3. 添加jar包至web/WEB-INF/lib目录下(lib目录不存在，需手动创建)
   
4. 添加jar包(导包)
   

1.4.2 数据库和表：User

# 创建数据库
CREATE DATAbase ssm_db1;
# 使用数据库
USE ssm_db1;
# 1.1 创建用户表
CREATE TABLE `user` (
  `uid` VARCHAR(32) NOT NULL,
  `username` VARCHAR(20) DEFAULT NULL,	#用户名
  `password` VARCHAR(32) DEFAULT NULL,	#密码
  `name` VARCHAR(20) DEFAULT NULL,		#昵称
  `email` VARCHAR(30) DEFAULT NULL,		#电子邮箱
  `telephone` VARCHAR(20) DEFAULT NULL,	#电话
  `birthday` DATE DEFAULT NULL,			#生日
  `sex` VARCHAR(10) DEFAULT NULL,		#性别
  `state` INT(11) DEFAULT 0,			#状态：0=未激活，1=已激活
  `code` VARCHAR(64) DEFAULT NULL,		#激活码
  PRIMARY KEY (`uid`)
) ;
# 1.2 初始化用户默认数据
INSERT INTO `user` VALUES ('u001','jack','1234','杰克','jack@czxy.com','13612345678','2015-11-04','男',0,NULL);
INSERT INTO `user` VALUES ('u002','rose','1234','肉丝','rose@czxy.com','13612345679','2015-11-05','女',0,NULL);
INSERT INTO `user` VALUES ('373eb242933b4f5ca3bd43503c34668b','ccc','ccc','aaa','bbb@store.com','15723689921','2015-11-04','男',0,'9782f3e837ff422b9aee8b6381ccf927bdd9d2ced10d48f4ba4b9f187edf7738'),('3ca76a75e4f64db2bacd0974acc7c897','bb','bb','张三','bbb@store.com','15723689921','1990-02-01','男',0,'1258e96181a9457987928954825189000bae305094a042d6bd9d2d35674684e6'),('62145f6e66ea4f5cbe7b6f6b954917d3','cc','cc','张三','bbb@store.com','15723689921','2015-11-03','男',0,'19f100aa81184c03951c4b840a725b6a98097aa1106a4a38ba1c29f1a496c231'),('c95b15a864334adab3d5bb6604c6e1fc','bbb','bbb','老王','bbb@store.com','15712344823','2000-02-01','男',0,'71a3a933353347a4bcacff699e6baa9c950a02f6b84e4f6fb8404ca06febfd6f'),('f55b7d3a352a4f0782c910b2c70f1ea4','aaa','aaa','小王','aaa@store.com','15712344823','2000-02-01','男',1,NULL);

1.5 入门案例：查询所有 1.5.1 JavaBean:User

import java.util.Date;



public class User {

	private String uid;
	private String username;
	private String password;
	private String name;
	private String email;
	private Date birthday;
	private String sex;
	private Integer state;
	private String code;

	@Override
	public String toString() {
		return "User{" +
				"uid='" + uid + ''' +
				", username='" + username + ''' +
				", password='" + password + ''' +
				", name='" + name + ''' +
				", email='" + email + ''' +
				", birthday=" + birthday +
				", sex='" + sex + ''' +
				", state=" + state +
				", code='" + code + ''' +
				'}';
	}

	public String getUid() {
		return uid;
	}

	public void setUid(String uid) {
		this.uid = uid;
	}

	public String getUsername() {
		return username;
	}

	public void setUsername(String username) {
		this.username = username;
	}

	public String getPassword() {
		return password;
	}

	public void setPassword(String password) {
		this.password = password;
	}

	public String getName() {
		return name;
	}

	public void setName(String name) {
		this.name = name;
	}

	public String getEmail() {
		return email;
	}

	public void setEmail(String email) {
		this.email = email;
	}

	public Date getBirthday() {
		return birthday;
	}

	public void setBirthday(Date birthday) {
		this.birthday = birthday;
	}

	public String getSex() {
		return sex;
	}

	public void setSex(String sex) {
		this.sex = sex;
	}

	public Integer getState() {
		return state;
	}

	public void setState(Integer state) {
		this.state = state;
	}

	public String getCode() {
		return code;
	}

	public void setCode(String code) {
		this.code = code;
	}

	public User(String uid, String username, String password, String name, String email, Date birthday, String sex, Integer state, String code) {

		this.uid = uid;
		this.username = username;
		this.password = password;
		this.name = name;
		this.email = email;
		this.birthday = birthday;
		this.sex = sex;
		this.state = state;
		this.code = code;
	}

	public User() {

	}
}

1.5.2 编写Dao:UserMapper

之前的开发中我们编写的都是UserDao，在MyBatis将Dao称为Mapper。。
在MyBatis只需要编写接口即可，实现类由MyBatis自动生成，并在测试程序时自动执行。

import org.apache.ibatis.annotations.Select;
import java.util.List;

public interface UserMapper {
    
    @Select("select * from user")
    public List selectAll();
}

1.5.3 编写核心配置文件：SqlMapConfig.xml

• 配置文件名称：SqlMapConfig.xml
• 配置文件位置：src
• 配置文件内容：

1.5.4 测试类

import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

import java.io.IOException;
import java.io.InputStream;
import java.util.List;


 
public class Test01_SelectAll {
    public static void main(String[] args) throws IOException {
        //1 加载配置文件
        // 1.1 获得资源流
        InputStream is = Resources.getResourceAsStream("SqlMapConfig.xml");
        // 1.2 获得工厂
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(is);
        //2 获得会话(连接)
        SqlSession session = factory.openSession();
        //3获得功能接口
        UserMapper userMapper = session.getMapper(UserMapper.class);
        //4 调用功能
        List userList = userMapper.selectAll();
        //5 打印查询结果
        for (User user : userList) {
            System.out.println(user);
        }
    }
}

1.6 总结

到这里MyBatis的入门案例已经完成。我们总结一下：

• 编写SqlMapConfig.xml，用于配置数据源和需要加载的Mapper。
• 编写UserMapper.java接口，用于执行方法与SQL语句的绑定。
• 基本API使用，流程是：加载资源、获得工厂、获得会话、获得Mapper。

2. 基本操作：增删改查 2.1 模糊查询

功能接口中的方法

• 如果参数简单类型，sql语句需要使用value [不推荐]

@Select("select * from user where name like '%${value}%'")
public List selectByName(String name);

• 如果使用@Param，可以进行相应的命名 [推荐]

@Select("select * from user where name like '%${name}%'")
public List selectByName(@Param("name") String name);

• 参数替换总结

#{} ，全部替换，例如：where uid = #{uid}
${} ，部分替换，例如：where name like ‘%${name}%’

tips:#{}替换的数据有''包裹，${}替换的数据没有 ''包裹。

测试类

public class Test02_Like {
    public static void main(String[] args) throws IOException {
        //1 加载配置文件
        // 1.1 获得资源流
        InputStream is = Resources.getResourceAsStream("SqlMapConfig.xml");
        // 1.2 获得工厂
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(is);
        //2 获得会话(连接)
        SqlSession session = factory.openSession();
        //3获得功能接口
        UserMapper userMapper = session.getMapper(UserMapper.class);
        //4 调用功能
        List userList = userMapper.selectByName("王");
        //5 打印查询结果
        for (User user : userList) {
            System.out.println(user);
        }
    }
}

2.2 插入数据

功能接口中的方法

    
    @Insert("insert into user(uid, username, password, name, email, birthday, sex, state) values(#{uid},#{username},#{password},#{name},#{email},#{birthday},#{sex},#{state})")
    public Integer insert(User user);

测试类

public class Test03_Insert {
    public static void main(String[] args) throws IOException {
        //1 加载配置文件
        // 1.1 获得资源流
        InputStream is = Resources.getResourceAsStream("SqlMapConfig.xml");
        // 1.2 获得工厂
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(is);
        //2 获得会话(连接)
        SqlSession session = factory.openSession();
        //3获得功能接口
        UserMapper userMapper = session.getMapper(UserMapper.class);
        //4 调用功能
        User user = new User();
        user.setUid("1");
        user.setUsername("jack");
        user.setPassword("1234");
        user.setName("杰克");
        user.setEmail("itcast_lt@163.com");
        user.setBirthday(new Date());
        user.setSex("男");
        user.setSex("0");
        Integer result = userMapper.insert(user);
        System.out.println(result);
        //5 提交资源
        session.commit();
        //6 释放资源
        session.close();
    }
}

2.3 更新数据

功能接口中的方法

      
    @Insert("update user set username=#{username}, password=#{password}, name=#{name}, email=#{email},birthday=#{birthday},sex=#{sex}, state=#{state} where uid=#{uid}")
    public Integer update(User user);

测试类

public class Test04_Update {
    public static void main(String[] args) throws IOException {
        //1 加载配置文件
        // 1.1 获得资源流
        InputStream is = Resources.getResourceAsStream("SqlMapConfig.xml");
        // 1.2 获得工厂
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(is);
        //2 获得会话(连接)
        SqlSession session = factory.openSession();
        //3获得功能接口
        UserMapper userMapper = session.getMapper(UserMapper.class);
        //4 调用功能
        User user = new User();
        user.setUid("1");
        user.setUsername("jack1");
        user.setPassword("12341");
        user.setName("杰克");
        user.setEmail("itcast_lt@163.com");
        user.setBirthday(new Date());
        user.setSex("男");
        user.setSex("0");
        Integer result = userMapper.update(user);
        System.out.println(result);
        //5 提交资源
        session.commit();
        //6 释放资源
        session.close();
    }
}

2.4 删除数据

功能接口中的方法

  	
    @Delete("delete from user where uid = #{uid}")
    public Integer deleteByPrimaryKey(@Param("uid") Integer uid);

测试类

public class Test05_Delete {
    public static void main(String[] args) throws IOException {
        //1 加载配置文件
        // 1.1 获得资源流
        InputStream is = Resources.getResourceAsStream("SqlMapConfig.xml");
        // 1.2 获得工厂
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(is);
        //2 获得会话(连接)
        SqlSession session = factory.openSession();
        //3获得功能接口
        UserMapper userMapper = session.getMapper(UserMapper.class);
        //4 调用功能
        Integer result = userMapper.deleteByPrimaryKey(1);
        System.out.println(result);
        //5 提交资源
        session.commit();
        //6 释放资源
        session.close();
    }
}

3. 日志与工具类 3.1.1 什么是日志

• 记录程序运行的过程细节。例如：
  

3.1.2 整合日志

1. 添加jar包
   

2. 添加配置文件
   

# 2. 输出格式
## log4j.appender.stdout=输出位置（固定值，由log4j提供）
## log4j.appender.stdout.Target=方式
## log4j.appender.stdout.layout=布局（固定值）
## log4j.appender.stdout.layout.ConversionPattern=格式

# 2.1 将日志输出到控制台
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.Target=System.out
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%d{ABSOLUTE} %5p %c:%L - %m%n

# 2.2 将日志输出到文件
log4j.appender.file=org.apache.log4j.FileAppender
log4j.appender.file.File=d:/file.log
log4j.appender.file.Append=false
log4j.appender.file.layout=org.apache.log4j.PatternLayout
log4j.appender.file.layout.ConversionPattern=%d{ABSOLUTE} %5p %c:%L - %m%n

#1.log4j.rootLogger=日志级别, 输出方式1, 输出方式2, ...
## 日志级别：debug、info、warn、error
log4j.rootLogger=debug, stdout, file

# 3 自定义日志级别
## log4j.logger.包=日志级别

#log4j.logger.com.ibatis = debug    
#log4j.logger.com.ibatis.common.jdbc.SimpleDataSource = debug    
#log4j.logger.com.ibatis.common.jdbc.scriptRunner = debug    
#log4j.logger.com.ibatis.sqlmap.engine.impl.SqlMapClientDelegate = debug    
#log4j.logger.java.sql.Connection = debug    

#log4j.logger.java.sql.Statement = debug    
#log4j.logger.java.sql.PreparedStatement = debug    
#log4j.logger.java.sql.ResultSet =debug

log4j.logger.org.apache.ibatis.transaction = info
log4j.logger.org.apache.ibatis.io = info
log4j.logger.org.apache.ibatis.datasource = info
log4j.logger.org.apache.ibatis.logging = info

3.2 工具类 3.2.1 拷贝工具类

我们将封装工具类以便提高代码的复用性并且降低冗余度。

public class MyBatisUtils {
    // 会话工厂
    private static SqlSessionFactory factory;
    static{
        try {
            // 1.1 加载核心配置文件
            InputStream is = Resources.getResourceAsStream("SqlMapConfig.xml");
            // 1.2 获得工厂
            factory = new SqlSessionFactoryBuilder().build(is);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    private static ThreadLocal local = new ThreadLocal<>();

    
    private static SqlSession openSession(){
        SqlSession sqlSession = local.get();
        if(sqlSession == null){
            sqlSession = factory.openSession();
            local.set(sqlSession);
        }
        return sqlSession;
    }

    
    public static  T getMapper(Class clazz){
        return openSession().getMapper(clazz);
    }

    
    public static void close() {
        SqlSession sqlSession = openSession();
        if(sqlSession != null){
            sqlSession.close();
        }
    }

    
    public static void commitAndClose() {
        SqlSession sqlSession = openSession();
        if(sqlSession != null){
            sqlSession.commit();
            close();
        }
    }

    
    public static void rollbackAndClose() {
        SqlSession sqlSession = openSession();
        if(sqlSession != null){
            sqlSession.rollback();
            close();
        }
    }
}

3.2.2 工具类原理分析

• 工具类实现原理分析
  

3.2.3 测试类

public class Test06_Utils {
    public static void main(String[] args) {
        UserMapper userMapper = MyBatisUtils.getMapper(UserMapper.class);
        User user = new User();
        user.setUid("1");
        user.setUsername("Ryan");
        user.setPassword("1234");
        user.setName("RYAN");
        user.setEmail("itcast_lt@163.com");
        user.setBirthday(new Date());
        user.setSex("男");
        user.setSex("0");
        Integer result = userMapper.insert(user);
        System.out.println(result);
        MyBatisUtils.commitAndClose();
    }
}