maximevw
commented
1 year ago Hello @dzasti,
It should be possible to use Spring Liquibase with Cassandra as I successfully ran it with the example below.
First of all, I used a slightly modified version of liquibase-cassandra using cassandra-jdbc-wrapper (4.9.1 or above). For further details, see here: https://github.com/liquibase/liquibase-cassandra/issues/148#issuecomment-1704090680
But, I guess it should also work with Simba JDBC driver (if you have an appropriate licence).
The dependencies to include in your POM file are:
<!-- Using Spring Boot 3.1.4 and Java 17 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
<groupId>org.liquibase</groupId>
<artifactId>liquibase-core</artifactId>
</dependency>
<!-- Include cassandra-jdbc-wrapper if you don't use Simba JDBC, otherwise include a dependency to Simba driver -->
<dependency>
<groupId>com.ing.data</groupId>
<artifactId>cassandra-jdbc-wrapper</artifactId>
<version>4.10.0</version>
</dependency>
<dependency>
<groupId>org.liquibase.ext</groupId>
<artifactId>liquibase-cassandra</artifactId>
<!-- Use here a version modified to use cassandra-jdbc-wrapper instead of Simba if necessary-->
<version>4.23.2</version>
</dependency>
<!-- Required to avoid runtime exceptions due to a conflict of version between Spring Boot dependencies and cassandra-jdbc-wrapper -->
<dependencyManagement>
<dependencies>
<dependency>
<groupId>com.datastax.oss</groupId>
<artifactId>java-driver-core</artifactId>
<version>4.17.0</version>
</dependency>
</dependencies>
</dependencyManagement>Assuming you have a Cassandra instance running on localhost, port 9042, with a keyspace named test_keyspace.
In your application.properties file, you should have this:
# Liquibase configuration
spring.liquibase.url=jdbc:cassandra://localhost:9042/test_keyspace?localdatacenter=datacenter1&user=cassandra&password=cassandra&compliancemode=Liquibase
spring.liquibase.change-log=classpath:/db/changelog/db.changelog-master.yaml
spring.liquibase.driver-class-name=com.ing.data.cassandra.jdbc.CassandraDriver
# Spring datasource configuration
spring.datasource.name=cassandra_datasource
spring.datasource.url=jdbc:cassandra://localhost:9042/test_keyspace?localdatacenter=datacenter1&user=cassandra&password=cassandra
spring.datasource.driver-class-name=com.ing.data.cassandra.jdbc.CassandraDriver
spring.datasource.hikari.minimum-idle=1In your project resources, you should have the following files:
- db/changelog/db.changelog-master.yaml
databaseChangeLog: - include: file: classpath:/db/changelog/init.sql - db/changelog/init.sql. Note the extension MUST be "sql" otherwise Liquibase will fail to parse the script.
USE test_keyspace; CREATE TABLE IF NOT EXISTS tbl_test ( keyname text PRIMARY KEY, bool_col boolean, int_col int);
INSERT INTO tbl_test(keyname, bool_col, int_col) VALUES ('key1', true, 1) IF NOT EXISTS; INSERT INTO tbl_test(keyname, bool_col, int_col) VALUES ('key2', false, 2) IF NOT EXISTS;
Finally, your Spring Boot application:
```java
@SpringBootApplication
public class SpringLiquibaseCassandraApplication {
@Autowired
JdbcTemplate jdbcTemplate;
@EventListener(ApplicationReadyEvent.class)
public void checkData() throws SQLException {
jdbcTemplate.query("SELECT * FROM tbl_test", rs -> {
System.out.println("------------------------------------");
System.out.println("keyname: " + rs.getString(1));
System.out.println("bool_col: " + rs.getBoolean(2));
System.out.println("int_col: " + rs.getInt(3));
});
}
public static void main(String[] args) {
SpringApplication.run(SpringLiquibaseCassandraApplication.class, args);
}
}Running your application, the output should be the following, proving the Liquibase changes have been executed successfully:
------------------------------------
keyname: key1
bool_col: true
int_col: 1
------------------------------------
keyname: key2
bool_col: false
int_col: 2
shubha11m
nicobte
Danil9966
Hello, is there a possibility to run liquibase cassandra extension via spring boot? Can’t find any example online. Also I’ve done some research: https://github.com/spring-projects/spring-boot/issues/29991#issuecomment-1050240805 , https://github.com/liquibase/liquibase-cassandra/issues/4#issuecomment-689828658. Seems confusing, could someone show me an example, if its possible ?
thanks