Corda节点扩展适配非H2数据库及PostgreSQL后扩其他库技术咨询

1. 如何对Corda节点进行扩展，使其能够适配H2以外的数据库？ #

我之前帮团队配置过PostgreSQL和MySQL的适配，核心就是依赖配置+节点配置+数据库环境准备这几步，操作起来不算复杂：

• 添加数据库驱动依赖：在节点的build.gradle文件里，加入对应数据库的runtime依赖。比如配置PostgreSQL的话，就加：

  runtimeOnly 'org.postgresql:postgresql:42.6.0'
  

  版本号可以根据你用的Corda版本调整，尽量选兼容的稳定版。

• 修改节点配置文件：找到节点的node.conf，替换掉原来H2的数据库配置块。以PostgreSQL为例，改成这样：

  dataSourceProperties = {
      dataSourceClassName = "org.postgresql.ds.PGSimpleDataSource"
      dataSource.url = "jdbc:postgresql://localhost:5432/corda_node_db"
      dataSource.user = "corda_admin"
      dataSource.password = "your_secure_password"
  }
  database = {
      transactionIsolationLevel = "READ_COMMITTED"
      schema = "public"
  }
  

  这里要注意dataSourceClassName必须是对应数据库官方提供的数据源类，别填错了。

• 准备数据库环境：提前启动目标数据库服务，创建好指定的数据库（比如上面的corda_node_db），给用户分配足够的权限（比如创建表、读写数据的权限）。漏了这一步的话，节点启动会直接报连接失败。

• 验证配置：重启Corda节点，查看节点日志，如果没有Database connection failed之类的报错，并且能正常启动、处理交易，就说明配置成功了。

2. 已基于PostgreSQL运行Corda，如何扩展使其支持其他数据库？仅添加Gradle依赖的数据库驱动并尝试连接是否足够？ #

肯定不够！只加驱动远远达不到要求，驱动只是基础，还需要做这些关键操作：

• 第一步：添加目标数据库驱动依赖：和第一个问题一样，先在build.gradle里加对应驱动，比如MySQL的：

  runtimeOnly 'mysql:mysql-connector-java:8.0.33'
  

• 第二步：修改节点数据库配置：把node.conf里的PostgreSQL配置换成目标数据库的参数。比如MySQL的配置：

  dataSourceProperties = {
      dataSourceClassName = "com.mysql.cj.jdbc.MysqlDataSource"
      dataSource.url = "jdbc:mysql://localhost:3306/corda_node_db?serverTimezone=UTC&useSSL=false"
      dataSource.user = "corda_admin"
      dataSource.password = "your_secure_password"
  }
  database = {
      transactionIsolationLevel = "READ_COMMITTED"
      schema = "corda_schema"
  }
  

  这里MySQL需要额外指定时区参数，不然会因为时区不兼容报错，这点要特别注意。

• 第三步：数据库环境适配：创建目标数据库、用户，设置好字符集（比如UTF-8）、时区，给用户赋权。不同数据库的权限逻辑不一样，比如MySQL要确保用户能访问指定schema，PostgreSQL是给数据库赋权，别搞混了。

• 第四步：数据迁移（如果需要保留数据）：如果你想把PostgreSQL里的现有数据迁移到新数据库，不能直接复制文件。得用工具导出PostgreSQL的数据（比如pg_dump），然后转换成目标数据库兼容的SQL格式（注意语法差异，比如PostgreSQL的SERIAL对应MySQL的AUTO_INCREMENT），再导入到新数据库里。还要确保Corda的表结构、约束完全一致，不然节点启动会报错。

• 第五步：测试验证：重启节点后，先检查日志里的数据库连接状态，然后跑几个测试交易，看看能不能正常读写数据，有没有异常日志。比如发起一笔转账，查看数据库里的交易记录是否正常生成。

内容的提问来源于stack exchange，提问作者Joel