您的位置:

使用MyBatis设置数据访问层(DAO)持久化与查询

一、MyBatis简介

MyBatis是一种基于Java的持久化框架,可以将Java对象映射到数据库中的表中。MyBatis可以与多种关系型数据库协作,包括MySQL、Oracle、SQL Server等等。MyBatis相对于其他ORM框架的优点在于,它非常灵活,可以使用原生SQL来进行数据操作,也支持存储过程和高级映射技术。

二、MyBatis与DAO的集成

DAO(Data Access Object)是一种用于访问数据库的模式,它可以提供一种简单易用的接口来隐藏底层数据访问细节。将MyBatis与DAO结合,可以实现更加灵活和易于维护的数据访问层。

首先需要创建一个接口,来定义DAO中的操作。例如,我们可以创建一个UserDao接口:

public interface UserDao {
    void addUser(User user); //添加用户
    User getUserById(int id); //通过ID查询用户
    void updateUser(User user); //更新用户
    void deleteUser(int id); //删除用户
}

接下来需要创建一个映射文件。映射文件可以将Java方法和SQL语句联系起来,以便实现数据访问。例如,我们可以创建一个user.xml映射文件:

<mapper namespace="UserDao">
    <insert id="addUser" parameterType="User">
        insert into users(id, name, age) values(#{id}, #{name}, #{age})
    </insert>

    <select id="getUserById" parameterType="int" resultType="User">
        select * from users where id = #{id}
    </select>

    <update id="updateUser" parameterType="User">
        update users set name=#{name}, age=#{age} where id=#{id}
    </update>

    <delete id="deleteUser" parameterType="int">
        delete from users where id=#{id}
    </delete>
</mapper>

在这个映射文件中定义了addUser、getUserById、updateUser、deleteUser四个SQL语句,分别对应了UserDao接口中的四个方法。例如,addUser方法对应的SQL语句是insert into users(id, name, age) values(#{id}, #{name}, #{age}),其中#{id}、#{name}、#{age}是占位符,用来接收传递给addUser方法的User对象中的id、name、age属性值。

最后需要将UserDao接口和user.xml映射文件进行绑定,在配置文件中加入以下配置:

<!-- 配置UserDao接口 -->
<bean id="userDao" class="org.mybatis.spring.mapper.MapperFactoryBean">
    <property name="mapperInterface" value="com.example.dao.UserDao" />
    <property name="sqlSessionFactory" ref="sqlSessionFactory" />
</bean>

这样,就完成了MyBatis与DAO的集成,可以使用UserDao接口中定义的方法来对数据库进行增删改查操作。

三、MyBatis与Spring的集成

Spring是一种轻量级的Java开发框架,可以提供依赖注入、面向切面编程等特性。将MyBatis与Spring结合,可以实现更加简单和有效的数据访问。

首先需要在Spring配置文件中配置MyBatis连接池和SqlSessionFactory:

<!-- 配置MyBatis连接池 -->
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
    <property name="driverClass" value="com.mysql.jdbc.Driver" />
    <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/test" />
    <property name="user" value="root" />
    <property name="password" value="password" />
</bean>

<!-- 配置SqlSessionFactory -->
<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
    <property name="dataSource" ref="dataSource" />
    <property name="mapperLocations" value="classpath*:com/example/dao/*.xml" />
</bean>

接下来需要配置Spring和MyBatis的集成,在Spring配置文件中添加以下配置:

<!-- 配置MyBatis与Spring的集成 -->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
    <property name="basePackage" value="com.example.dao" />
    <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory" />
</bean>

这样就完成了MyBatis与Spring的集成,可以直接使用Autowired注解来注入UserDao接口,并调用其方法来进行数据访问。

四、示例代码

下面是一个简单的示例代码,演示了如何使用MyBatis设置数据访问层(DAO)持久化与查询:

1、User实体类

public class User {
    private int id;
    private String name;
    private int age;

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

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

    public int getAge() {
        return age;
    }

    public void setAge(int age) {
        this.age = age;
    }
}

2、UserDao接口

public interface UserDao {
    void addUser(User user);
    User getUserById(int id);
    void updateUser(User user);
    void deleteUser(int id);
}

3、user.xml映射文件

<mapper namespace="UserDao">
    <insert id="addUser" parameterType="User">
        insert into users(id, name, age) values(#{id}, #{name}, #{age})
    </insert>

    <select id="getUserById" parameterType="int" resultType="User">
        select * from users where id = #{id}
    </select>

    <update id="updateUser" parameterType="User">
        update users set name=#{name}, age=#{age} where id=#{id}
    </update>

    <delete id="deleteUser" parameterType="int">
        delete from users where id=#{id}
    </delete>
</mapper>

4、UserDao实现类

@Repository
public class UserDaoImpl implements UserDao {
    @Autowired
    private SqlSessionTemplate sqlSessionTemplate;

    @Override
    public void addUser(User user) {
        sqlSessionTemplate.insert("UserDao.addUser", user);
    }

    @Override
    public User getUserById(int id) {
        return sqlSessionTemplate.selectOne("UserDao.getUserById", id);
    }

    @Override
    public void updateUser(User user) {
        sqlSessionTemplate.update("UserDao.updateUser", user);
    }

    @Override
    public void deleteUser(int id) {
        sqlSessionTemplate.delete("UserDao.deleteUser", id);
    }
}

5、Spring配置文件

<!-- 配置MyBatis连接池 -->
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
    <property name="driverClass" value="com.mysql.jdbc.Driver" />
    <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/test" />
    <property name="user" value="root" />
    <property name="password" value="password" />
</bean>

<!-- 配置SqlSessionFactory -->
<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
    <property name="dataSource" ref="dataSource" />
    <property name="mapperLocations" value="classpath*:com/example/dao/*.xml" />
</bean>

<!-- 配置MyBatis与Spring的集成 -->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
    <property name="basePackage" value="com.example.dao" />
    <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory" />
</bean>

<!-- 配置UserDao -->
<bean id="userDao" class="com.example.dao.UserDaoImpl">
    <property name="sqlSessionTemplate" ref="sqlSessionTemplate" />
</bean>

<!-- 配置SqlSessionTemplate -->
<bean id="sqlSessionTemplate" class="org.mybatis.spring.SqlSessionTemplate">
    <constructor-arg index="0" ref="sqlSessionFactory" />
</bean>