使用 Hibernate 连接到 TiDB
TiDB 是一个兼容 MySQL 的数据库。Hibernate 是当前比较流行的开源 Java 应用持久层框架,且 Hibernate 在版本 6.0.0.Beta2
及以上支持了 TiDB 方言,完美适配了 TiDB 的特性。
本文档将展示如何使用 TiDB 和 Hibernate 来完成以下任务:
- 配置你的环境。
- 使用 Hibernate 连接到 TiDB 集群。
- 构建并运行你的应用程序。你也可以参考示例代码片段,完成基本的 CRUD 操作。
前置需求
- 推荐 Java Development Kit (JDK) 17 及以上版本。你可以根据公司及个人需求,自行选择 OpenJDK 或 Oracle JDK。
- Maven 3.8 及以上版本。
- Git。
- TiDB 集群。如果你还没有 TiDB 集群,可以按照以下方式创建:
- (推荐方式)参考创建 TiDB Serverless 集群,创建你自己的 TiDB Cloud 集群。
- 参考部署本地测试 TiDB 集群或部署正式 TiDB 集群,创建本地集群。
运行代码并连接到 TiDB
本小节演示如何运行示例应用程序的代码,并连接到 TiDB。
第 1 步:克隆示例代码仓库到本地
运行以下命令,将示例代码仓库克隆到本地:
git clone https://github.com/tidb-samples/tidb-java-hibernate-quickstart.git
cd tidb-java-hibernate-quickstart
第 2 步:配置连接信息
根据不同的 TiDB 部署方式,使用不同的方法连接到 TiDB 集群。
- TiDB Serverless
- TiDB Dedicated
- 本地部署 TiDB
在 TiDB Cloud 的 Clusters 页面中,选择你的 TiDB Serverless 集群,进入集群的 Overview 页面。
点击右上角的 Connect 按钮,将会弹出连接对话框。
确认对话框中的配置和你的运行环境一致。
- Endpoint Type 为
Public
。 - Branch 选择
main
。 - Connect With 选择
General
。 - Operating System 为你的运行环境。
- Endpoint Type 为
如果你还没有设置密码,点击 Generate Password 生成一个随机密码。
运行以下命令,将
env.sh.example
复制并重命名为env.sh
:cp env.sh.example env.sh复制并粘贴对应连接字符串至
env.sh
中。需更改部分示例结果如下:export TIDB_HOST='{host}' # e.g. gateway01.ap-northeast-1.prod.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. tidb.xxxx.clusters.tidb-cloud.com export TIDB_PORT='4000' export TIDB_USER='{user}' # e.g. 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}' export TIDB_PORT='4000' export TIDB_USER='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
文件。
第 3 步:运行代码并查看结果
运行下述命令,执行示例代码:
make查看
Expected-Output.txt
,并与你的程序输出进行比较。结果近似即为连接成功。
示例代码片段
你可参考以下关键代码片段,完成自己的应用开发。
完整代码及其运行方式,见代码仓库 tidb-java-hibernate-quickstart。
连接到 TiDB
编写配置文件 hibernate.cfg.xml
:
<?xml version='1.0' encoding='utf-8'?>
<!DOCTYPE hibernate-configuration PUBLIC
"-//Hibernate/Hibernate Configuration DTD 3.0//EN"
"http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd">
<hibernate-configuration>
<session-factory>
<!-- Database connection settings -->
<property name="hibernate.connection.driver_class">com.mysql.cj.jdbc.Driver</property>
<property name="hibernate.dialect">org.hibernate.dialect.TiDBDialect</property>
<property name="hibernate.connection.url">${tidb_jdbc_url}</property>
<property name="hibernate.connection.username">${tidb_user}</property>
<property name="hibernate.connection.password">${tidb_password}</property>
<property name="hibernate.connection.autocommit">false</property>
<!-- Required so a table can be created from the 'PlayerDAO' class -->
<property name="hibernate.hbm2ddl.auto">create-drop</property>
<!-- Optional: Show SQL output for debugging -->
<property name="hibernate.show_sql">true</property>
<property name="hibernate.format_sql">true</property>
</session-factory>
</hibernate-configuration>
请将 ${tidb_jdbc_url}
、${tidb_user}
、${tidb_password}
等替换为你的 TiDB 集群的实际值。随后编写以下函数:
public SessionFactory getSessionFactory() {
return new Configuration()
.configure("hibernate.cfg.xml")
.addAnnotatedClass(${your_entity_class})
.buildSessionFactory();
}
在使用该函数时,你需要替换 ${your_entity_class}
为自己的数据实体类。如果你有多个实体类,需要添加多个 .addAnnotatedClass(${your_entity_class})
语句。此外,这仅是 Hibernate 的其中一种配置方式。在配置中遇到任何问题,或想了解更多关于 Hibernate 的信息,你可参考 Hibernate 官方文档。
插入或更新数据
try (Session session = sessionFactory.openSession()) {
session.persist(new PlayerBean("id", 1, 1));
}
查询数据
try (Session session = sessionFactory.openSession()) {
PlayerBean player = session.get(PlayerBean.class, "id");
System.out.println(player);
}
更多信息参考查询数据。
删除数据
try (Session session = sessionFactory.openSession()) {
session.remove(new PlayerBean("id", 1, 1));
}
更多信息参考删除数据。
下一步
- 关于 Hibernate 的更多使用方法,可以参考 Hibernate 官方文档。
- 你可以继续阅读开发者文档,以获取更多关于 TiDB 应用开发的最佳实践。例如:插入数据、更新数据、删除数据、单表读取、事务、SQL 性能优化等。
- 如果你更倾向于参与课程进行学习,我们也提供专业的 TiDB 开发者课程支持,并在考试后提供相应的资格认证。
- 我们还额外提供针对 Java 开发者的课程:使用 Connector/J - TiDB v6 及在 TiDB 上开发应用的最佳实践 - TiDB v6。
需要帮助?
如果在开发的过程中遇到问题,可以在 AskTUG 上进行提问,寻求帮助。