📣

TiDB Cloud Serverless 现已更名为
Starter
!此页面由 AI 自动翻译,英文原文请见
此处。

使用 Hibernate 连接 TiDB

TiDB 是一个兼容 MySQL 的数据库,Hibernate 是一个流行的开源 Java ORM。从 6.0.0.Beta2 版本开始,Hibernate 支持 TiDB 方言,能够很好地适配 TiDB 的特性。

在本教程中,你可以学习如何使用 TiDB 和 Hibernate 完成以下任务:

  • 搭建你的环境。
  • 使用 Hibernate 连接到你的 TiDB 集群。
  • 构建并运行你的应用程序。你还可以在 示例代码片段 中找到基本 CRUD 操作的示例代码。

前置条件

完成本教程,你需要:

  • Java Development Kit (JDK) 17 或更高版本。你可以根据业务和个人需求选择 OpenJDKOracle JDK
  • Maven 3.8 或更高版本。
  • Git
  • 一个 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 集群。

    1. 进入 Clusters 页面,然后点击目标集群名称进入其概览页面。

    2. 点击右上角的 Connect,弹出连接对话框。

    3. 确保连接对话框中的配置与你的操作环境一致。

      • Connection Type 设置为 Public
      • Branch 设置为 main
      • Connect With 设置为 General
      • Operating System 与你的环境一致
    4. 点击 Generate Password 生成一个随机密码。

    5. 运行以下命令,复制 env.sh.example 并重命名为 env.sh

      cp env.sh.example env.sh
    6. 将对应的连接字符串复制粘贴到 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 Cloud Starter 需要安全连接,因此你需要将 USE_SSL 的值设置为 true

    7. 保存 env.sh 文件。

    1. 进入 Clusters 页面,然后点击目标集群名称进入其概览页面。

    2. 点击右上角的 Connect,弹出连接对话框。

    3. 在连接对话框中,从 Connection Type 下拉列表选择 Public,然后点击 CA cert 下载 CA 证书。

      如果你还没有配置 IP 访问列表,请点击 Configure IP Access List,或参考 Configure an IP Access List 进行配置后再首次连接。

      除了 Public 连接类型,TiDB Cloud Dedicated 还支持 Private EndpointVPC Peering 连接类型。更多信息请参见 Connect to Your TiDB Cloud Dedicated Cluster

    4. 运行以下命令,复制 env.sh.example 并重命名为 env.sh

      cp env.sh.example env.sh
    5. 将对应的连接字符串复制粘贴到 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'

      请务必将 {} 占位符替换为连接对话框中获取的连接参数。

    6. 保存 env.sh 文件。

    1. 运行以下命令,复制 env.sh.example 并重命名为 env.sh

      cp env.sh.example env.sh
    2. 将对应的连接字符串复制粘贴到 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'

      请务必将 {} 占位符替换为连接参数,并将 USE_SSL 设置为 false。如果你在本地运行 TiDB,默认主机地址为 127.0.0.1,密码为空。

    3. 保存 env.sh 文件。

    第 3 步:运行代码并检查结果

    1. 执行以下命令运行示例代码:

      make
    2. 检查 Expected-Output.txt 以确认输出是否一致。

    示例代码片段

    你可以参考以下示例代码片段,完成你自己的应用开发。

    完整示例代码及运行方法请参考 tidb-samples/tidb-java-hibernate-quickstart 仓库。

    连接 TiDB

    编辑 Hibernate 配置文件 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)); }

    更多信息请参考 删除数据

    后续步骤

    需要帮助?

    DiscordSlack 社区提问,或提交支持工单

    文档内容是否有帮助?