mybatis如何实现了对数据库的操作:
1.通过Resources.getResourceAsReader()或者 Resources.getResourceAsStream()加载mybatis.cfg.xml文件为InputStream 或者reader。
2.通过new SqlSessionFactoryBuilder.build()方法来创建一个SQLSessionFactory实例----工作过程是:通过调用build(InputStream or reader)方法---------此时,会通过一个XMLConfigBuilder的类中的parse()方法来获得一个Configuration的对象传递给build--------------build方法变成build(Configration)-----创建出一个sqlSessionFactory对象
3.再通过SQLSessionFactory.open()方法来创建一个SqlSession对象,这个SqlSession就类似于我们JDBC中的Connection,通过这个才能跟数据库交互。
下面来演示整个myBatis项目的创建过程(链接的是mysql数据库):
创建maven项目,引入mybatis、mysql-Connector、log4j
为了提高代码的可读性,作者通常会分别建立beans(存放 成员与我们的数据库字段一致的类),mapper(存放 接口方法和映射关系文件),tools(对外提供获得SqlSession的方法)和service包(存放我们的测试类),下面是项目结构图。
下面是作者的数据库表结构:
准备工作完成,下面正式开始:
第一步:先创建一个与该数据库字段对应的java对象:
package com.cj.mybatis.beans;
public class UserBean {
private int id;
private String username;
private String password;
private double account;
//构造函数
public UserBean( String username, String password, double account) {
super();
this.username = username;
this.password = password;
this.account = account;
}
public UserBean() {
}
//getter setter
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 String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public double getAccount() {
return account;
}
public void setAccount(double account) {
this.account = account;
}
//toString
@Override
public String toString() {
return "UserBean [id=" + id + ", username=" + username + ", password=" + password + ", account=" + account
+ "]";
}
}
第二步:创建我们的接口方法和映射配关系文件
下面是接口:
package com.cj.mybatis.mapper;
import java.security.PublicKey;
import java.util.List;
import org.apache.ibatis.annotations.Param;
import com.cj.mybatis.beans.UserBean;
public interface UserMapper {
/**
*增加用户
* @param user
* @return
* @throws Exception
*/
public int insertUser(UserBean user) throws Exception;
/**
* 根据id来更新某用户信息
* @param user
* @return
* @throws Exception
*/
public int updateUser(UserBean user) throws Exception;
/**
* 根据id来删除数据
* @param id
* @return
* @throws Exception
*/
public int deleteUser(int id) throws Exception;
/**
* 根据id查询用户信息
* @param id
* @return
* @throws Exception
*/
public UserBean selectUserById(int id) throws Exception;
/**
* 查询所有用户信息
* @return
* @throws Exception
*/
public List<UserBean> selectAllUser() throws Exception;
}
下面是映射关系文件:
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org/DTD Mapper 3.0" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.cj.mybatis.mapper.UserMapper">
<!-- 自定义结果集,自定义结果集是select语句返回时用的,下面的select语句 中必须指明对应的结果集id-->
<resultMap id="userMap1" type="UserBean">
<!-- 这里的id对应表的主键字段 -->
<!-- <id property="id" column="id" javaType="java.lang.Integer"></id> -->
<!-- 下面是对应表的其他字段-->
<!-- <result property="username" column="username"
javaType="java.lang.String"></result>
<result property="password" column="password"
javaType="java.lang.String"></result>
<result property="account" column="account"
javaType="java.lang.Double"></result> -->
</resultMap>
<!-- 在各种标签中的id属性必须和接口中的方法名相对应 , id属性值必须是唯一的,不能够重复使用。parameterType属性指明查询时使用的参数类型,resultType属性指明查询返回的结果集类型 -->
<!-- useGeneratedKeys:( 仅 对 insert 有 用 ) 这 会 告 诉 MyBatis 使 用 JDBC 的getGeneratedKeys
方法来取出由数据(比如:像 MySQL 和 SQLServer 这样的数据库管理系统的自动递增字段)内部生成的主键。默认值: false。 -->
<!--keyProperty: (仅对 insert有用)标记一个属性, MyBatis 会通过 getGeneratedKeys或者通过 insert
语句的 selectKey 子元素设置它的值。默认:不设置。 -->
<!--#{}中的内容,为占位符,当参数为某个JavaBean时,表示放置该Bean对象的属性值 -->
<insert id="insertUser" useGeneratedKeys="true" keyProperty="id">
insert into user (username,password,account) values
(#{username},#{password},#{account})
</insert><!--下面使用的是动态sql,判断字段是否为null,不为空才去赋值-->
<update id="updateUser"
parameterType="com.cj.mybatis.beans.UserBean">
update user set
<if test="username != null">
username=#{username}
</if>
<if test="password != null">
,password=#{password}
</if>
<if test="account != 0.0">
,account=#{account}
</if>
where
id=#{id}
</update>
<delete id="deleteUser" parameterType="int">
delete from user where
id=#{id}
</delete>
<select id="selectUserById" parameterType="int"
resultMap="userMap1">
select * from user where id=#{id}
</select>
<select id="selectAllUser" resultMap="userMap1">
select * from user
</select>
</mapper>
第三步:将我们的映射文件告知到mybatis的配置文件中,并给类取个全名:
<?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>
<!-- 引入外部配置文件 -->
<properties resource="mysql.properties"></properties>
<!-- 为JAVA Bean起类别名 -->
<typeAliases>
<!-- 别名方式1,一个一个的配置 type中放置的是类的全路径,alias中放置的是类别名 <typeAliase type="com.cy.mybatis.beans.UserBean"
alias="UserBean"/> -->
<!-- 别名方式2,自动扫描,将JAVA类的类名作为类的类别名 -->
<package name="com.cj.mybatis.beans" />
</typeAliases>
<!-- 配置mybatis运行环境 -->
<environments default="cjbatis-claire2">
<environment id="cjbatis-claire2">
<!-- type=jdbc 代表使用JDBC的提交和回滚来管理事物 -->
<transactionManager type="JDBC" />
<!-- mybatis提供了3种数据源类型,分别是:POOLED,UNPOOLED,JNDI -->
<!-- POOLED 表示支持JDBC数据源连接池 -->
<!-- UNPOOLED 表示不支持数据 源连接池 -->
<!-- JNDI表示支持外部数据源连接池 -->
<dataSource type="POOLED">
<property name="driver" value="${jdbc.driver}" />
<property name="url" value="${jdbc.url}" />
<property name="username" value="${jdbc.username}" />
<property name="password" value="${jdbc.password}" />
</dataSource>
</environment>
</environments>
<mappers>
<!-- 当自己使用的是接口方法和Mapper.xml的方式时 ,这里是告知的是.xml的映射文件 -->
<!-- 告知映射文件方式1,一个一个的配置 -->
<!-- <mapper resource="com/cj/mybatis/mapper/UserMapper.xml"/> -->
<mapper class="com.cj.mybatis2.mapper.UserInterfaceFunction"/>
<!-- 告知映射文件方式2,直接将包地址写上,会自动去包里找 。如果要使用这种方式,必须要求接口名称和映射文件名称必须完全一样才可以,否则报Invalid bound statement-->
<package name="com/cj/mybatis/mapper"/>
</mappers>
</configuration>
上面配置文件中引入了mysql的配置文件,将mysql的配置文件准备好:
jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://XXX.XXX.XXX.XXX:3306/game?autoReconnect=true&failOverReadOnly=false
jdbc.username=yourusername
jdbc.password=youpassword
为了方便打印日志信息,还需要配置log4j.properties
###根logger设置###
log4j.rootLogger = INFO,console,file
### 输出信息到控制台###
log4j.appender.console = org.apache.log4j.ConsoleAppender
log4j.appender.console.Target = System.out
log4j.appender.console.layout = org.apache.log4j.PatternLayout
log4j.appender.console.Threshold = warn
log4j.appender.console.layout.ConversionPattern = [%p] %d{yyyy-MM-dd HH:mm:ss} method: %l----%m%n
###输出INFO 级别以上的日志文件设置###
log4j.appender.file = org.apache.log4j.DailyRollingFileAppender
log4j.appender.file.File = E:/log/web.log
log4j.appender.file.Append = true
log4j.appender.file.Threshold = warn
log4j.appender.file.layout = org.apache.log4j.PatternLayout
log4j.appender.file.layout.ConversionPattern = %d{yyyy-MM-dd HH:mm:ss} method: %l - [ %p ]----%m%n
第四步:准备一个DBtools类,来对外提供一个获取SqlSession的方法:
package com.cj.mybatis.tools;
import java.io.IOException;
import java.io.Reader;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
public class DBTools {
public static SqlSessionFactory SessionFactory;
static {
try {
//加载mybatis的配置文件
Reader reader = Resources.getResourceAsReader("mybatis.cfg.xml");
//构建sqlSession的工厂
SessionFactory = new SqlSessionFactoryBuilder().build(reader);
} catch (IOException e) {
e.printStackTrace();
}
}
//对外提供可以获得sqlSession的方法
public static SqlSession getSqlSession() {
return SessionFactory.openSession();
}
}
第五步:提供测试类,去执行增删改查:
package com.cj.mybatis.service;
import java.util.Date;
import java.util.List;
import org.apache.ibatis.session.SqlSession;
import com.cj.mybatis.beans.ProductBean;
import com.cj.mybatis.beans.UserBean;
import com.cj.mybatis.mapper.ProductMapper;
import com.cj.mybatis.mapper.UserMapper;
import com.cj.mybatis.tools.DBTools;
public class UserService {
public static void main(String[] args) throws Exception {
SqlSession session = DBTools.getSqlSession();
UserMapper usermapper = session.getMapper(UserMapper.class);
System.out.println("----------------");
UserBean user3 = new UserBean();
user3.setUsername("Claire6");//修改name字段
//user3.setPassword("iiiiii");
user3.setAccount(20.9);
user3.setId(36);
usermapper.updateUser(user3);// 修改的某条id值为36的数据
session.commit();
UserBean userBean = usermapper.selectUserById(36);
System.out.println(userBean);
}
}
总结:
上面使用的是依赖映射实现的,在映射文件中修改sql来完成自己的测试。
其中的updateUser的sql使用 if实现了动态生成。在平时的测试当中,大多数时候并不会更新整条数据库信息,所以建议掌握这一种。
下面介绍通过注解的方式,来使用mybatis(不需要映射文件的方式):
其他都是一样的,只是不需要创建映射文件,接口方法中直接使用注解即可:
package com.cj.mybatis2.mapper;
import java.util.List;
import org.apache.ibatis.annotations.Delete;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Select;
import org.apache.ibatis.annotations.Update;
import com.cj.mybatis.beans.UserBean;
public interface UserInterfaceFunction {
@Insert("INSERT INTO t_user(username,`password`,account) VALUES(#{username},#{password},#{account})")
public int add(UserBean user);
@Delete("DELETE from t_user where id = #{id}")
public int delete(int id);
@Update("UPDATE t_user SET username=#{username},password=#{password},account=#{account} WHERE id =#{id}")
public int update(UserBean user);
@Select("SELECT * FROM t_user")
public List<UserBean> select();
@Select("SELECT * FROM t_user WHERE id=#{id}")
public UserBean selectOne(int id);
}
注意:这种方式需要在mybatis的配置文件添加下面的语句:
<!-- 接口类的类全名 -->
<mapper class="com.cj.mybatis2.mapper.UserInterfaceFunction"/>