使用Scala集成Liquibase操作ScyllaDB时的DATABASECHANGELOG异常问题

核心问题定位 #

终端执行liquibase update正常，但Scala代码调用异常，说明Liquibase与ScyllaDB的适配本身无问题，问题出在代码调用逻辑、依赖配置或资源管理上。以下是针对性排查和解决步骤：

1. 检查Liquibase依赖与版本一致性 #

终端使用的是liquibase-4.1.1，Scala项目必须保证依赖版本完全匹配，尤其是要引入Liquibase的Cassandra/Scylla扩展（cli默认包含，但代码需手动引入）：

// 核心依赖，版本必须和cli一致
libraryDependencies += "org.liquibase" % "liquibase-core" % "4.1.1"
// ScyllaDB适配扩展，版本同步
libraryDependencies += "org.liquibase.ext" % "liquibase-cassandra" % "4.1.1"
// Scylla官方JDBC驱动，避免用Cassandra驱动
libraryDependencies += "com.scylladb" % "scylla-jdbc-driver" % "1.0.5" // 适配你的Scylla版本

2. 修正Liquibase代码初始化逻辑 #

2.1 确保正确加载Changelog文件

代码中必须指定正确的ResourceAccessor，否则Liquibase找不到changelog文件：

import liquibase.Liquibase
import liquibase.resource.ClassLoaderResourceAccessor
import liquibase.database.DatabaseFactory
import liquibase.database.jvm.JdbcConnection

// 初始化资源访问器，从类路径加载changelog
val resourceAccessor = new ClassLoaderResourceAccessor(getClass.getClassLoader)
// 确保JDBC连接已指向test01 keyspace（URL需包含keyspace：jdbc:cassandra://localhost:9042/test01?localdatacenter=datacenter1）
val conn = ... // 你的JDBC连接逻辑
val database = DatabaseFactory.getInstance().findCorrectDatabaseImplementation(new JdbcConnection(conn))
val liquibase = new Liquibase("db/changelog.xml", resourceAccessor, database)

2.2 强制资源自动释放，避免锁残留

代码执行完update后必须关闭资源，否则DATABASECHANGELOGLOCK会一直被持有。用Scala的Using语法自动管理资源：

import scala.util.Using

Using.Manager { use =>
  val conn = use(...) // 你的JDBC连接（需实现AutoCloseable）
  val database = use(DatabaseFactory.getInstance().findCorrectDatabaseImplementation(new JdbcConnection(conn)))
  val liquibase = use(new Liquibase("db/changelog.xml", resourceAccessor, database))
  // 执行变更
  liquibase.update(new liquibase.Contexts(), new liquibase.LabelExpression())
} match {
  case Left(ex) => ex.printStackTrace()
  case Right(_) => println("Schema更新完成")
}

3. 排查SQL语法错误 #

终端执行正常但代码报错，需对比两者执行的SQL差异：

1. 在代码中开启Liquibase debug日志，查看生成的SQL：

   System.setProperty("liquibase.logLevel", "debug")
   

2. 对比终端执行时的SQL（可通过liquibase update --logLevel debug查看），重点看第一个变更集的SQL差异。通常是代码中Liquibase未正确使用Scylla扩展，导致生成了Scylla不兼容的SQL。

4. 手动处理残留锁 #

如果已经出现锁无法释放的情况，先手动清除锁：

• 连接ScyllaDB，执行CQL：

  DELETE FROM test01.DATABASECHANGELOGLOCK;
  

• 或者用终端执行：

  liquibase releaseLocks
  

5. 首次运行未生成DATABASECHANGELOG的排查 #

1. 检查代码是否真正执行了liquibase.update()方法，是否有未捕获的异常（比如changelog文件找不到、连接失败）。
2. 确认JDBC URL已指定test01 keyspace，或者代码在连接后切换到了该keyspace：

   conn.createStatement().execute("USE test01;")
   

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