您的位置:首页 > 其它

初识Mybatis

2017-10-09 19:25 246 查看
先来回顾一下jdbc的编程步骤:

加载数据库驱动

创建并获取数据库连接

创建jdbc statement 对象

设置sql语句

设置sql语句中的参数

通过statement执行sql并获取结果

对sql执行结果进行解析处理

释放资源(result,preparedstatement,connection)

MyBatis是一个优秀的持久层框架,对jdbc的操作数据库过程进行封装,使开发者只需要关注sql本身,而不需要花费精力去处理例如注册驱动,创建connection,创建statement,手动设置参数,结果集检索等jdbc繁杂的过程代码.

Mybatis是通过xml或者注解的方式将要执行的各种statement配置起来,并且通过java对象和statement中的sql进行映射生成最后执行的sql语句,最后由mybatis框架执行sql并将结果映射称java对象并返回.



Mybatis入门程序

需要实现以下功能

根据用户id查询一个用户信息

根据用户名称模糊查询用户信息列表

添加用户

更新用户

删除用户

Mybits sqlmapconfig 全局配置文件:建立数据库连接 然后要进行编写sql语句 Mapper.xml 编写sql语句

然后在算起来mapconfig加载映射文件,建立联系 Sqlsessionfactory 会话工厂 创建session会话用来执行sql语句

Mapperstatement:包含一个statementId:标识 parameterType:输入参数类型

resultType:输出结果类型

第一步:创建java工程



第二步:加入jar包



第三步:log4j.properties

在classpath下创建log4j.properties

这里说一句:mybatis默认使用log4j作为输出日志信息

# Global logging configuration
log4j.rootLogger=DEBUG, stdout
# Console output...
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%5p [%t] - %m%n


第四步:SqlMapConfig.xml

在classpath下创建SqlMapConfig.xml

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
<!-- 和spring整合后 environments配置将废除-->
<environments default="development">
<environment id="development">
<!-- 使用jdbc事务管理-->
<transactionManager type="JDBC" />
<!-- 数据库连接池-->
<dataSource type="POOLED">
<property name="driver"
value="com.mysql.jdbc.Driver" />
<property name="url"
value="jdbc:mysql://localhost:3306/mybatis?characterEncoding=u
tf-8" />
<property name="username" value="root" />
<property name="password" value="mysql" />
</dataSource>
</environment>
</environments>
</configuration>


SqlMapConfig.xml是mybatis核心配置文件

第五步:po类

一、PO:persistant object 持久对象,可以看成是与数据库中的表相映射的java对象。最简单的PO就是对应数据库中某个表中的一条记录,多个记录可以用PO的集合。PO中应该不包含任何对数据库的操作。

二、VO:value

object值对象。通常用于业务层之间的数据传递,和PO一样也是仅仅包含数据而已。但应是抽象出的业务对象,可以和表对应,也可以不,这根据业务的需要.个人觉得同DTO(数据传输对象),在web上传递。

三、DAO:data access object

数据访问对象,此对象用于访问数据库。通常和PO结合使用,DAO中包含了各种数据库的操作方法。通过它的方法,结合PO对数据库进行相关的操作。

四、BO:business object 业务对象,封装业务逻辑的java对象,通过调用DAO方法,结合PO,VO进行业务操作。

五、POJO:plain ordinary java object

简单无规则java对象,我个人觉得它和其他不是一个层面上的东西,VO和PO应该都属于它。

O/R Mapping 是 Object Relational

Mapping(对象关系映射)的缩写。通俗点讲,就是将对象与关系数据库绑定,用对象来表示关系数据。在O/R

Mapping的世界里,有两个基本的也是重要的东东需要了解,即VO,PO。   VO,值对象(Value

Object),PO,持久对象(Persisent

Object),它们是由一组属性和属性的get和set方法组成。从结构上看,它们并没有什么不同的地方。但从其意义和本质上来看是完全不同的。

1.VO是用new关键字创建,由GC回收的。

  PO则是向数据库中添加新数据时创建,删除数据库中数据时削除的。并且它只能存活在一个数据库连接中,断开连接即被销毁。

2.VO是值对象,精确点讲它是业务对象,是存活在业务层的,是业务逻辑使用的,它存活的目的就是为数据提供一个生存的地方。

  PO则是有状态的,每个属性代表其当前的状态。它是物理数据的对象表示。使用它,可以使我们的程序与物理数据解耦,并且可以简化对象数据与物理数据之间的转换。

3.VO的属性是根据当前业务的不同而不同的,也就是说,它的每一个属性都一一对应当前业务逻辑所需要的数据的名称。

  PO的属性是跟数据库表的字段一一对应的。

PO对象需要实现序列化接口。

package com.hpe.mybatis.po;

import java.util.Date;

public class User {
private int id;//编号
private String username;//姓名
private Date birthday;//生日
private String sex;//性别
private String address;//地址
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
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 String getAddress() {
return address;
}
public void setAddress(String address) {
this.address = address;
}
@Override
public String toString() {
return "User [id=" + id + ", username=" + username + ", birthday=" + birthday + ", sex=" + sex + ", address="
+ address + "]";
}

}


第六步:程序编写



在classpath 下的sqlmap 目录下创建sql 映射文件Users.xml:

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="test">
<!--namespace就是一个命名空间,用来隔离sql语句,相当于一个容器,可以有多个 -->

<!-- 功能: 通过用户id查询用户信息 属性: id就是标识映射文件的sql 将sql语句封装到mappedStatement对象中,所以id成为statement的id
parameterType:输入映射参数类型 resultType:输出结果所映射的java对象的类型(指定sql输入结果映射的对象类型,就是返回类型是user) -->
<select id="findUserById" parameterType="int"
resultType="com.hpe.mybatis.po.User">
SELECT * FROM `user` WHERE id = #{id}
</select>
<!--根据用户名模糊查询用户信息 -->
<!--${}表示拼接sql语句,如果传入的数据参数类型是简单类型,那么参数必须为value ${value} -->
<select id="findUserByName" parameterType="java.lang.String"
resultType="com.hpe.mybatis.po.User">
SELECT * FROM `user` WHERE username LIKE '%${value}%'
</select>

<!--新增用户 -->
<insert id="insertUser" parameterType="com.hpe.mybatis.po.User">
<!-- 返回主键值 -->
<selectKey keyProperty="id" order="AFTER" resultType="java.lang.Integer">
select LAST_INSERT_ID()
</selectKey>
INSERT INTO user(id,username,birthday,sex,address)
VALUES(#{id},#{username},#{birthday},#{sex},#{address})
</insert>
<!-- 删除用户 -->
<delete id="deleteUser" parameterType="int">
DELETE FROM user WHERE id = #{id}
</delete>

<!--更新用户 -->
<update id="updateUser">
UPDATE user SET username=#{username},birthday=#{birthday},
sex=#{sex},address=#{address} where id = #{id}
</update>
</mapper>


package com.hpe.mybatis.first;

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

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 org.junit.Before;
import org.junit.Test;

import com.hpe.mybatis.po.User;

public class MybatisDemo {
//会话工厂
private SqlSessionFactory sqlSessionFactory;

@Before
public void setUp() throws IOException {
// mybatis配置文件
String resource = "SqlMapConfig.xml";

// 读取配置文件
InputStream inputStream = Resources.getResourceAsStream(resource);

// 创建会话工厂,传入参数是MyBatis配置文件
sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);

}

// 根据用户id查询一个用户信息
@Test
public void findUserByIdTest() throws IOException {
// System.out.println("这是一个测试方法");

// 创建会话,用来操作数据库(增删改查)
SqlSession sqlSession = sqlSessionFactory.openSession();

// statement:namespace.statementID 即test.findUserById
// parameter:输入映射参数 指定和映射文件中所匹配的parameterType类型的参数
User user = sqlSession.selectOne("test.findUserById", 1);
System.out.println(user);

// 关闭会话
sqlSession.close();
}

// 根据用户名称模糊查询用户信息列表(可能返回多条结果-->用list集合存储结果)
@Test
public void findUserByNameTest() throws IOException {
// 创建会话,用来操作数据库
SqlSession sqlSession = sqlSessionFactory.openSession();

List<User> list = sqlSession.selectList("test.findUserByName", "三丰");

System.out.println(list);

sqlSession.close();
}

//添加用户信息
@Test
public void insertUserTest() throws IOException{
SqlSession sqlSession = sqlSessionFactory.openSession();
User user = new User();
user.setUsername("鹿晗");
user.setBirthday(new Date());
user.setSex("1");
user.setAddress("山东济宁");
sqlSession.insert("test.insertUser", user);
//提交事务(默认autocommit==false 我们要将其改成手动提交)
sqlSession.commit();
System.out.println(user.getId());//输出新添加的id号
//关闭会话
sqlSession.close();
}

//删除用户信息
@Test
public void deleteUserTest() throws IOException{
SqlSession sqlSession = sqlSessionFactory.openSession();
sqlSession.delete("test.deleteUser", 28);
//提交事务(默认autocommit==false 我们要将其改成手动提交)
sqlSession.commit();
//关闭会话
sqlSession.close();
}

@Test
public void updateUserTest() throws IOException{
SqlSession sqlSession = sqlSessionFactory.openSession();
User user = new User();
user.setUsername("鹿晗");
user.setBirthday(new Date());
user.setSex("1");
user.setAddress("山东济南");
user.setId(27);
sqlSession.update("test.updateUser", user);
//提交事务(默认autocommit==false 我们要将其改成手动提交)
sqlSession.commit();
//关闭会话
sqlSession.close();
}
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  开发人员 mybatis