title | summary |
---|---|
使用 MyBatis 连接到 TiDB |
了解如何使用 MyBatis 连接到 TiDB。本文提供了使用 MyBatis 与 TiDB 交互的 Java 示例代码片段。 |
TiDB 是一个兼容 MySQL 的数据库。MyBatis 是当前比较流行的开源 Java 应用持久层框架。
本文档将展示如何使用 TiDB 和 MyBatis 来完成以下任务:
- 配置你的环境。
- 使用 MyBatis 连接到 TiDB 集群。
- 构建并运行你的应用程序。你也可以参考示例代码片段,完成基本的 CRUD 操作。
注意
本文档适用于 TiDB Serverless、TiDB Dedicated 和本地部署的 TiDB。
- 推荐 Java Development Kit (JDK) 17 及以上版本。你可以根据公司及个人需求,自行选择 OpenJDK 或 Oracle JDK。
- Maven 3.8 及以上版本。
- Git。
- TiDB 集群。如果你还没有 TiDB 集群,可以按照以下方式创建:
- (推荐方式)参考创建 TiDB Serverless 集群,创建你自己的 TiDB Cloud 集群。
- 参考部署本地测试 TiDB 集群或部署正式 TiDB 集群,创建本地集群。
本小节演示如何运行示例应用程序的代码,并连接到 TiDB。
运行以下命令,将示例代码仓库克隆到本地:
git clone https://github.com/tidb-samples/tidb-java-mybatis-quickstart.git
cd tidb-java-mybatis-quickstart
根据不同的 TiDB 部署方式,使用不同的方法连接到 TiDB 集群。
-
在 TiDB Cloud 的 Clusters 页面中,选择你的 TiDB Serverless 集群,进入集群的 Overview 页面。
-
点击右上角的 Connect 按钮,将会弹出连接对话框。
-
确认对话框中的配置和你的运行环境一致。
- Endpoint Type 为
Public
。 - Branch 选择
main
。 - Connect With 选择
General
。 - Operating System 为你的运行环境。
Tip:
如果你在 Windows Subsystem for Linux (WSL) 中运行,请切换为对应的 Linux 发行版。
- Endpoint Type 为
-
如果你还没有设置密码,点击 Generate Password 生成一个随机密码。
Tip:
如果你之前已经生成过密码,可以直接使用原密码,或点击 Reset Password 重新生成密码。
-
运行以下命令,将
env.sh.example
复制并重命名为env.sh
:cp env.sh.example env.sh
-
复制并粘贴对应连接字符串至
env.sh
中。需更改部分示例结果如下:export TIDB_HOST='{host}' # e.g. xxxxxx.aws.tidbcloud.com export TIDB_PORT='4000' export TIDB_USER='{user}' # e.g. xxxxxx.root export TIDB_PASSWORD='{password}' export TIDB_DB_NAME='test' export USE_SSL='true'
注意替换
{}
中的占位符为连接对话框中获得的值。TiDB Serverless 要求使用 TLS (SSL) connection,因此
USE_SSL
的值应为true
。 -
保存
env.sh
文件。
-
在 TiDB Cloud 的 Clusters 页面中,选择你的 TiDB Dedicated 集群,进入集群的 Overview 页面。
-
点击右上角的 Connect 按钮,将会出现连接对话框。
-
在对话框中点击 Allow Access from Anywhere。
更多配置细节,可参考 TiDB Dedicated 标准连接教程(英文)。
-
运行以下命令,将
env.sh.example
复制并重命名为env.sh
:cp env.sh.example env.sh
-
复制并粘贴对应的连接字符串至
env.sh
中。需更改部分示例结果如下:export TIDB_HOST='{host}' # e.g. xxxxxx.aws.tidbcloud.com export TIDB_PORT='4000' export TIDB_USER='{user}' # e.g. xxxxxx.root export TIDB_PASSWORD='{password}' export TIDB_DB_NAME='test' export USE_SSL='false'
注意替换
{}
中的占位符为连接对话框中获得的值。 -
保存
env.sh
文件。
-
运行以下命令,将
env.sh.example
复制并重命名为env.sh
:cp env.sh.example env.sh
-
复制并粘贴对应 TiDB 的连接字符串至
env.sh
中。需更改部分示例结果如下:export TIDB_HOST='{host}' # e.g. xxxxxx.aws.tidbcloud.com export TIDB_PORT='4000' export TIDB_USER='root' # e.g. xxxxxx.root export TIDB_PASSWORD='{password}' export TIDB_DB_NAME='test' export USE_SSL='false'
注意替换
{}
中的占位符为你的 TiDB 对应的值,并设置USE_SSL
为false
。如果你在本机运行 TiDB,默认 Host 地址为127.0.0.1
,密码为空。 -
保存
env.sh
文件。
-
运行下述命令,执行示例代码:
make
-
查看
Expected-Output.txt
,并与你的程序输出进行比较。结果近似即为连接成功。
你可参考以下关键代码片段,完成自己的应用开发。
完整代码及其运行方式,见代码仓库 tidb-java-mybatis-quickstart。
编写配置文件 mybatis-config.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>
<settings>
<setting name="cacheEnabled" value="true"/>
<setting name="lazyLoadingEnabled" value="false"/>
<setting name="aggressiveLazyLoading" value="true"/>
<setting name="logImpl" value="LOG4J"/>
</settings>
<environments default="development">
<environment id="development">
<!-- JDBC transaction manager -->
<transactionManager type="JDBC"/>
<!-- Database pool -->
<dataSource type="POOLED">
<property name="driver" value="com.mysql.cj.jdbc.Driver"/>
<property name="url" value="${TIDB_JDBC_URL}"/>
<property name="username" value="${TIDB_USER}"/>
<property name="password" value="${TIDB_PASSWORD}"/>
</dataSource>
</environment>
</environments>
<mappers>
<mapper resource="${MAPPER_LOCATION}.xml"/>
</mappers>
</configuration>
请将 ${TIDB_JDBC_URL}
、${TIDB_USER}
、${TIDB_PASSWORD}
等替换为你的 TiDB 集群的实际值。并替换 ${MAPPER_LOCATION}
的值为你的 mapper XML 配置文件的位置。如果你有多个 mapper XML 配置文件,需要添加多个 <mapper/>
标签。随后编写以下函数:
public SqlSessionFactory getSessionFactory() {
InputStream inputStream = Resources.getResourceAsStream("mybatis-config.xml");
SqlSessionFactory sessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
}
在 mapper XML 中添加节点,并在 XML 配置文件的 mapper.namespace
属性中配置的接口类中添加同名函数:
<?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.pingcap.model.PlayerMapper">
<insert id="insert" parameterType="com.pingcap.model.Player">
INSERT INTO player (id, coins, goods)
VALUES (#{id, jdbcType=VARCHAR}, #{coins, jdbcType=INTEGER}, #{goods, jdbcType=INTEGER})
</insert>
</mapper>
更多信息参考插入数据。
在 mapper XML 中添加节点,并在 XML 配置文件的 mapper.namespace
属性中配置的接口类中添加同名函数。特别地,如果你在 MyBatis 的查询函数中使用 resultMap
作为返回类型,需要额外注意配置文件的 <resultMap/>
节点配置是否正确。
<?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.pingcap.model.PlayerMapper">
<resultMap id="BaseResultMap" type="com.pingcap.model.Player">
<constructor>
<idArg column="id" javaType="java.lang.String" jdbcType="VARCHAR" />
<arg column="coins" javaType="java.lang.Integer" jdbcType="INTEGER" />
<arg column="goods" javaType="java.lang.Integer" jdbcType="INTEGER" />
</constructor>
</resultMap>
<select id="selectByPrimaryKey" parameterType="java.lang.String" resultMap="BaseResultMap">
SELECT id, coins, goods
FROM player
WHERE id = #{id, jdbcType=VARCHAR}
</select>
</mapper>
更多信息参考查询数据。
在 mapper XML 中添加节点,并在 XML 配置文件的 mapper.namespace
属性中配置的接口类中添加同名函数:
<?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.pingcap.model.PlayerMapper">
<update id="updateByPrimaryKey" parameterType="com.pingcap.model.Player">
UPDATE player
SET coins = #{coins, jdbcType=INTEGER},
goods = #{goods, jdbcType=INTEGER}
WHERE id = #{id, jdbcType=VARCHAR}
</update>
</mapper>
更多信息参考更新数据。
在 mapper XML 中添加节点,并在 XML 配置文件的 mapper.namespace
属性中配置的接口类中添加同名函数:
<?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.pingcap.model.PlayerMapper">
<delete id="deleteByPrimaryKey" parameterType="java.lang.String">
DELETE FROM player
WHERE id = #{id, jdbcType=VARCHAR}
</delete>
</mapper>
更多信息参考删除数据。
- 关于 MyBatis 的更多使用方法,可以参考 MyBatis 官方文档。
- 你可以继续阅读开发者文档,以获取更多关于 TiDB 应用开发的最佳实践。例如:插入数据、更新数据、删除数据、单表读取、事务、SQL 性能优化等。
- 如果你更倾向于参与课程进行学习,我们也提供专业的 TiDB 开发者课程支持,并在考试后提供相应的资格认证。
- 我们还额外提供针对 Java 开发者的课程:使用 Connector/J - TiDB v6 及在 TiDB 上开发应用的最佳实践 - TiDB v6。
如果在开发的过程中遇到问题,可以在 AskTUG 上进行提问,寻求帮助。