[Feat]: Add a demo of MyBatis working with OceanBase.

.github/workflows/ci.yml

@@ -37,6 +37,9 @@ jobs:
           - name: 'mybatis-plus'
             language: 'java'
             with_oceanbase_container: false
+          - name: 'mybatis'
+            language: 'java'
+            with_oceanbase_container: true
     uses: ./.github/workflows/basic-ci.yml
     with:
       module: ${{ matrix.module.name }}

java/mybatis/README-CN.md

@@ -0,0 +1,251 @@
+# Spring Boot 连接 OceanBase 指南（使用 Spring Data JPA）
+
+[English](README.md) | 简体中文
+
+本文介绍如何通过 MyBatis 连接 OceanBase 数据库。
+由于 OceanBase 支持 MySQL 模式与 Oracle 模式，因此可以使用 MySQL 驱动连接 OceanBase。
+## 快速开始
+
+1.在 pom.xml 中首先加入 MySQL 以及 MyBatis 驱动，pom.xml 参考[OceanBase MyBatis 连接示例](https://www.oceanbase.com/docs/community-observer-cn-10000000000900919) 示例。
+
+```xml
+  <dependencies>
+  <dependency>
+    <groupId>mysql</groupId>
+    <artifactId>mysql-connector-java</artifactId>
+    <version>8.0.25</version>
+  </dependency>
+  <dependency>
+    <groupId>org.mybatis</groupId>
+    <artifactId>mybatis</artifactId>
+    <version>3.5.4</version>
+  </dependency>
+  <dependency>
+    <groupId>junit</groupId>
+    <artifactId>junit</artifactId>
+    <version>4.13.2</version>
+    <scope>test</scope>
+  </dependency>
+</dependencies>
+```
+
+ 2.在 src/main/resources 文件夹新建 mybatis-config.xml ，并修改数据库连接信息,指定 mapper.xml 路径。
+
+ mybatis-config.xml
+```xml
+<?xml version="1.0" encoding="UTF8"?>
+<!DOCTYPE configuration
+  PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
+  "http://mybatis.org/dtd/mybatis-3-config.dtd">
+<configuration>
+  <environments default="development">
+    <environment id="development">
+      <transactionManager type="JDBC"/>
+      <dataSource type="POOLED">
+        <property name="driver" value="com.mysql.cj.jdbc.Driver"/>
+        <property name="url" value="jdbc:mysql://localhost:2881/test?useUnicode=true&amp;characterEncoding=utf-8&amp;useServerPrepStmts=false&amp;useCursorFetch=true"/>
+        <property name="username" value="username=root@test"/>
+        <property name="password" value=""/>
+      </dataSource>
+    </environment>
+  </environments>
+
+  <!--注册mapper（mapper.xml所在地址）-->
+  <mappers>
+    <mapper resource="UserMapper.xml"></mapper>
+  </mappers>
+</configuration>
+```
+3.新建 实体类，以及对应的 Mapper.xml 文件。 本次示例中，我们创建一个 User 实体类。
+```java
+package com.oceanbase.samples.entity;
+
+import java.util.Objects;
+
+public class User {
+    private Integer id;
+    private String name;
+
+    public User() {
+    }
+
+    public User(Integer id, String name) {
+        this.id = id;
+        this.name = name;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+        User user = (User) o;
+        return Objects.equals(id, user.id) && Objects.equals(name, user.name);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(id, name);
+    }
+
+    @Override
+    public String toString() {
+        return "User{" +
+            "id=" + id +
+            ", name='" + name + '\'' +
+            '}';
+    }
+}
+```
+4.新建 UserMapper 接口，用于与 UserMapper关联相应的增删改查操作
+```java
+package com.oceanbase.samples.mapper;
+
+public interface UserMapper {
+}
+```
+
+5.新建 UserMapper.xml ，并绑定 UserMapper 接口， 添加相应的增删改查操作。
+```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="com.oceanbase.samples.mapper.UserMapper">
+  <select id="selectUser" resultType="com.oceanbase.samples.entity.User" fetchSize="40000">
+    select * from user;
+  </select>
+
+  <select id="selectWithPagination" parameterType="map" resultType="com.oceanbase.samples.entity.User">
+    SELECT * FROM User LIMIT #{offset}, #{pageSize}
+  </select>
+
+  <delete id="delete" >
+    delete from user where id = #{id};
+  </delete>
+
+  <insert id="insert" parameterType="com.oceanbase.samples.entity.User">
+    insert into user (name) values (#{name});
+  </insert>
+
+  <update id="update" parameterType="com.oceanbase.samples.entity.User">
+    update user set name = #{name} where id = #{id};
+  </update>
+</mapper>
+```
+
+6.测试用例,用于测试 UserMapper.xml 中的增删改查操作。
+```java
+package com.oceanbase.samples;
+
+
+import com.oceanbase.samples.entity.User;
+import com.oceanbase.samples.util.SqlSessionUtil;
+import org.apache.ibatis.io.Resources;
+import org.apache.ibatis.jdbc.ScriptRunner;
+import org.apache.ibatis.session.SqlSession;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+import java.io.InputStreamReader;
+import java.sql.Connection;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+
+
+public class OceanBaseMyBatisTest
+{
+
+
+  @Before
+  public void setUp() throws Exception {
+    // 执行SQL脚本
+    try  {
+      Connection connection = SqlSessionUtil.openSession().getConnection();
+      ScriptRunner runner = new ScriptRunner(connection);
+      runner.runScript(new InputStreamReader(Resources.getResourceAsStream("init.sql")));
+      SqlSessionUtil.openSession().commit();
+    } catch (Exception e) {
+      e.printStackTrace();
+    }
+  }
+
+  @Test
+  public void test() {
+    insertTest(SqlSessionUtil.openSession());
+    updateTest(SqlSessionUtil.openSession());
+    selectTest(SqlSessionUtil.openSession());
+    selectWithPagination(SqlSessionUtil.openSession(), 0, 2);
+    deleteTest(SqlSessionUtil.openSession());
+  }
+
+
+
+  public static void insertTest(SqlSession sqlSession) {
+    // Insert data
+    User user = new User();
+    user.setName("Tom");
+    int count = sqlSession.insert("com.oceanbase.samples.mapper.UserMapper.insert", user);
+    System.out.println("Insert count: " + count);
+
+  }
+
+  public static void updateTest(SqlSession sqlSession) {
+    // Update data
+    User user = new User();
+    user.setId(1);
+    user.setName("Jerry");
+    int count = sqlSession.update("com.oceanbase.samples.mapper.UserMapper.update", user);
+    System.out.println("Update count: " + count);
+  }
+
+  public static void selectTest(SqlSession sqlSession) {
+    // Select data
+    List<User> user = sqlSession.selectList("com.oceanbase.samples.mapper.UserMapper.selectUser", 1);
+    user.stream().filter(Objects::nonNull).forEach(System.out::println);
+  }
+
+
+  public static void selectWithPagination(SqlSession sqlSession, int offset, int pageSize) {
+    Map<String, Object> params = new HashMap<>();
+    params.put("offset", offset);
+    params.put("pageSize", pageSize);
+    List<User> users = sqlSession.selectList("com.oceanbase.samples.mapper.UserMapper.selectWithPagination", params);
+    users.stream().filter(Objects::nonNull).forEach(System.out::println);
+  }
+
+  public static void deleteTest(SqlSession sqlSession) {
+    // Delete data
+    int count = sqlSession.delete("com.oceanbase.samples.mapper.UserMapper.delete", 3);
+    System.out.println("Delete count: " + count);
+  }
+
+  @After
+  public void closeSession() {
+    SqlSessionUtil.openSession().close();
+  }
+}
+
+```
+
+
+修改代码中的连接信息，之后你就可以直接使用 run.sh 运行示例代码。
+
+```bash
+sh run.sh
+```