// 創(chuàng)建數(shù)據(jù)源
DataSource dataSource = DsUtils.dsMySql();
// 創(chuàng)建 LambdaTemplate 對(duì)象和創(chuàng)建 JdbcTemplate 一樣
LambdaTemplate lambdaTemplate = new LambdaTemplate(dataSource);
// 初始化一些數(shù)據(jù)
lambdaTemplate.loadSQL("CreateDB.sql");

// 查詢(xún)，所有數(shù)據(jù)
List<TestUser> dtoList = lambdaTemplate.lambdaQuery(TestUser.class)
                .queryForList();
PrintUtils.printObjectList(dtoList);

// 插入新數(shù)據(jù)
TestUser newUser = new TestUser();
newUser.setName("new User");
newUser.setAge(33);
newUser.setCreateTime(new Date());
int result = lambdaTemplate.lambdaInsert(TestUser.class)
                .applyEntity(newUser)
                .executeSumResult();

// 更新，將name 從 mali 更新為 mala
TestUser sample = new TestUser();
sample.setName("mala");
int result = lambdaTemplate.lambdaUpdate(TestUser.class)
                .eq(TestUser::getId, 1)
                .updateToBySample(sample)
                .doUpdate();

// 刪除，ID 為 2 的數(shù)據(jù)
int result = lambdaTemplate.lambdaUpdate(TestUser.class)
                .eq(TestUser::getId, 1)
                .updateToBySample(sample)
                .doUpdate();

使用 DAO?

使用 DAO 可以繼承 BaseMapper 通用 DAO 接口來(lái)完成一些基本操作，仍然以單表 CRUD 為例。

// DAO 的一些接口需要識(shí)別 ID 屬性，因此有必要在 DTO 對(duì)象上通過(guò) @Column 注解標(biāo)記出它們
@Table(mapUnderscoreToCamelCase = true)
public class TestUser {
    @Column(primary = true)
    private Integer id;
    private String  name;
    private Integer age;
    private Date    createTime;
    
    // getters and setters omitted
}

// 創(chuàng)建數(shù)據(jù)源
DataSource dataSource = DsUtils.dsMySql();
// 創(chuàng)建通用 DAO
DalSession session = new DalSession(dataSource);
BaseMapper<TestUser> baseMapper = session.createBaseMapper(TestUser.class);
// 初始化一些數(shù)據(jù)
baseMapper.template().loadSQL("CreateDB.sql");

// 查詢(xún)數(shù)據(jù)
List<TestUser> dtoList = baseMapper.query().queryForList();
PrintUtils.printObjectList(dtoList);

// 插入新數(shù)據(jù)
TestUser newUser = new TestUser();
newUser.setName("new User");
newUser.setAge(33);
newUser.setCreateTime(new Date());
int result = baseMapper.insert(newUser);

// 更新，將name 從 mali 更新為 mala
TestUser sample = baseMapper.queryById(1);
sample.setName("mala");
int result = baseMapper.updateById(sample);

// 刪除，ID 為 2 的數(shù)據(jù)
int result = baseMapper.deleteById(2);

作為 DAO 可以定義自己的方法，并通過(guò)注解配置具體執(zhí)行的 SQL 語(yǔ)句。

// BaseMapper 是可選的，繼承它相當(dāng)于多了一組單表 CURD 的擴(kuò)展功能。
@SimpleMapper
public interface TestUserDAO extends BaseMapper<TestUser> {
    @Insert("insert into `test_user` (name,age,create_time) values (#{name}, #{age}, now())")
    public int insertUser(@Param("name") String name, 
                          @Param("age") int age);
    
    @Update("update `test_user` set age = #{age} where id = #{id}")
    public int updateAge(@Param("id") int userId, 
                         @Param("age") int newAge);
    
    @Delete("delete from `test_user` where age > #{age}")
    public int deleteByAge(@Param("age") int age);
    
    @Query(value = "select * from `test_user` where  #{beginAge} < age and age < #{endAge}",
           resultType = TestUser.class)
    public List<TestUser> queryByAge(@Param("beginAge") int beginAge, 
                                     @Param("endAge") int endAge);
}

// 創(chuàng)建 DalRegistry 并注冊(cè) TestUserDAO
DalRegistry dalRegistry = new DalRegistry();
dalRegistry.loadMapper(TestUserDAO.class);
// 使用 DalRegistry 創(chuàng)建 Session
DalSession session = new DalSession(dataSource, dalRegistry);
// 創(chuàng)建 DAO 接口
TestUserDAO userDAO = session.createMapper(TestUserDAO.class);

使用 Mapper?

統(tǒng)一管理 SQL 的最佳場(chǎng)所仍然是 Mapper 文件，而且 dbVisitor?的 Mapper 文件高度兼容 MyBatis 學(xué)習(xí)成本極低。

// 利用 @RefMapper 注解將 Mapper 文件和 接口類(lèi)聯(lián)系起來(lái)（繼承 BaseMapper 是可選的）
@RefMapper("/mapper/quick_dao3/TestUserMapper.xml")
public interface TestUserDAO extends BaseMapper<TestUser> {
    public int insertUser(@Param("name") String name, 
                          @Param("age") int age);
    
    public int updateAge(@Param("id") int userId, 
                         @Param("age") int newAge);
    
    public int deleteByAge(@Param("age") int age);
    
    public List<TestUser> queryByAge(@Param("beginAge") int beginAge, 
                                     @Param("endAge") int endAge);
}

為了更好了解和使用 dbVisitor?的 Mapper 文件建議增加 DTD加以驗(yàn)證。另外 HasorDB 兼容 MyBatis3 的 DTD 對(duì)于絕大部分 MyBatis 工程都可以正常兼容。

DOCTYPE mapper PUBLIC "-//dbvisitor.net//DTD Mapper 1.0//EN" 
                        "https://www.dbvisitor.net/schema/dbvisitor-mapper.dtd">
<mapper namespace="net.hasor.db.example.quick.dao3.TestUserDAO">
    <resultMap id="testuser_resultMap" type="net.hasor.db.example.quick.dao3.TestUser">
        <id column="id" property="id"/>
        <result column="name" property="name"/>
        <result column="age" property="age"/>
        <result column="create_time" property="createTime"/>
    resultMap>
    
    <sql id="testuser_columns">
        name,age,create_time
    sql>
    
    <insert id="insertUser">
        insert into `test_user` (
            <include refid="testuser_columns"/>
        ) values (
            #{name}, #{age}, now()
        )
    insert>
    
    <update id="updateAge">
        update `test_user` set age = #{age} where id = #{id}
    update>
    
    <delete id="deleteByAge">
        delete from `test_user` where age > #{age}
    ]]>delete>
    
    <select id="queryByAge" resultMap="testuser_resultMap">
        select id,<include refid="testuser_columns"/>
        from `test_user`
        where  #{beginAge} < age and age < #{endAge}
    select>
mapper>

快速條件拼接?

快速條件拼接包含 快速'與'條件 和 快速'或'條件 它們是兩個(gè)規(guī)則用于取代簡(jiǎn)單的 if 標(biāo)簽和簡(jiǎn)單的 foreach 標(biāo)簽。如下語(yǔ)句，當(dāng)參數(shù)不為空時(shí)候才拼接 sql

<select id="queryUser">
    select * from `test_user`
    where 1=1
    <if test="age != null">
        and age = #{age}
    if>
select>

<select id="queryUser">
    select * from `test_user`
    @{and, age = :age}
select>

<select id="queryUser">
    select * from `test_user`
    where
    id in <foreach item="item" index="index" collection="list"
             open="(" separator="," close=")">
        #{item}
    foreach>
select>

<select id="queryUser">
    select * from `test_user`
    @{and, id in (:list)}
select>

<select id="queryByNameAndAge">
    select * from `test_user`
    @{and, age = :age}
    @{and, name = :name}
    @{and, id in (:ids)}
select>

// 構(gòu)造 LambdaTemplate 和初始化一些數(shù)據(jù)
DataSource dataSource = DsUtils.dsMySql();
LambdaTemplate lambdaTemplate = new LambdaTemplate(dataSource);
lambdaTemplate.loadSQL("CreateDB.sql");

// 構(gòu)建分頁(yè)對(duì)象，每頁(yè) 3 條數(shù)據(jù)(默認(rèn)第一頁(yè)的頁(yè)碼為 0)
Page pageInfo = new PageObject();
pageInfo.setPageSize(3);

// 分頁(yè)查詢(xún)數(shù)據(jù)
List<TestUser> pageData1 = lambdaTemplate.lambdaQuery(TestUser.class)
    .usePage(pageInfo)
    .queryForList();

// 分頁(yè)查詢(xún)下一頁(yè)數(shù)據(jù)
pageInfo.nextPage();
List<TestUser> pageData2 = lambdaTemplate.lambdaQuery(TestUser.class)
    .usePage(pageInfo)
    .queryForList();

// 構(gòu)造 BaseMapper 和初始化一些數(shù)據(jù)
DataSource dataSource = DsUtils.dsMySql();
DalSession session = new DalSession(dataSource);
BaseMapper<TestUser> baseMapper = session.createBaseMapper(TestUser.class);
baseMapper.template().loadSQL("CreateDB.sql");

// 構(gòu)建分頁(yè)對(duì)象，每頁(yè) 3 條數(shù)據(jù)(默認(rèn)第一頁(yè)的頁(yè)碼為 0)
Page pageInfo = new PageObject();
pageInfo.setPageSize(3);

// 分頁(yè)查詢(xún)數(shù)據(jù)
PageResult<TestUser> pageData1 = baseMapper.pageBySample(null, pageInfo);

// 分頁(yè)查詢(xún)下一頁(yè)數(shù)據(jù)
pageInfo.nextPage();
PageResult<TestUser> pageData2 = baseMapper.pageBySample(null, pageInfo);

@RefMapper("/mapper/quick_page3/TestUserMapper.xml")
public interface TestUserDAO extends BaseMapper<TestUser> {
    // 可以直接返回分頁(yè)之后的數(shù)據(jù)結(jié)果
    public List<TestUser> queryByAge(@Param("beginAge") int beginAge, 
                                     @Param("endAge") int endAge, 
                                     Page pageInfo);
    
    // 也可以返回包含分頁(yè)信息的分頁(yè)結(jié)果
    public List<TestUser> queryByAge(@Param("beginAge") int beginAge, 
                                     @Param("endAge") int endAge, 
                                     Page pageInfo);
}

// 構(gòu)建分頁(yè)條件
Page pageInfo = new PageObject();
pageInfo.setPageSize(3);

// 分頁(yè)方式查詢(xún) mapper 中的查詢(xún)
List<TestUser> data1 = userDAO.queryByAge(25, 100, pageInfo);
PageResult<TestUser> page1 = userDAO.queryByAge2(25, 100, pageInfo);

// 分頁(yè)方式查詢(xún) mapper 中的查詢(xún)
pageInfo.nextPage();
List<TestUser> data2 = userDAO.queryByAge(25, 100, pageInfo);
PageResult<TestUser> page2 = userDAO.queryByAge2(25, 100, pageInfo);

DataSource dataSource = DsUtils.dsMySql();
TransactionManager manager = DataSourceManager.getManager(dataSource);

TransactionStatus tranA = manager.begin();

...

manager.commit(tranA);

DataSource dataSource = DsUtils.dsMySql();
TransactionManager manager = DataSourceManager.getManager(dataSource);

manager.begin(); // 開(kāi)啟一個(gè)事務(wù)

...

manager.commit(); //遞交最近的一個(gè)事務(wù)

DataSource dataSource = DsUtils.dsMySql();
TransactionManager manager = DataSourceManager.getManager(dataSource);

TransactionStatus tranA = manager.begin();
TransactionStatus tranB = manager.begin();
TransactionStatus tranC = manager.begin();

...

manager.commit(tranC);
manager.commit(tranB);
manager.commit(tranA);

TransactionStatus tranA = manager.begin(
        Propagation.REQUIRES_NEW, // 傳播屬性
        Isolation.READ_COMMITTED  // 隔離級(jí)別
);

Object result = template.execute(new TransactionCallback<Object>() {
    @Override
    public Object doTransaction(TransactionStatus tranStatus) throws Throwable {
        ...
        return null;
    }
});

// 使用 Java8 Lambda 語(yǔ)法可以簡(jiǎn)化為下面這種
Object result = template.execute(tranStatus -> {
    return ...;
});

try {
    Object result = template.execute(new TransactionCallback<Object>() {
        public Object doTransaction(TransactionStatus tranStatus) throws Throwable {
            throw new Exception("...");
        }
    });
} catch (Throwable e) {
    ... run here
}

Object result = template.execute(new TransactionCallback<Object>() {
    public Object doTransaction(TransactionStatus tranStatus) throws Throwable {
        tranStatus.setReadOnly();
        // 或
        tranStatus.setRollback();

        return ...;
    }
});

template.execute((TransactionCallbackWithoutResult) tranStatus -> {
    ...
});