Skip to content

feat(databend): support minio enable param #9997

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
hantmac wants to merge 1 commit into from
Closed

feat(databend): support minio enable param #9997

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 12 additions & 0 deletions modules/databend/src/main/java/org/testcontainers/databend/DatabendContainer.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -37,6 +37,8 @@ public class DatabendContainer extends JdbcDatabaseContainer<DatabendContainer>

private String password = "databend";

private boolean minioEnabled = true;

public DatabendContainer(String dockerImageName) {
this(DockerImageName.parse(dockerImageName));
}
Expand All @@ -53,6 +55,7 @@ public DatabendContainer(final DockerImageName dockerImageName) {
protected void configure() {
withEnv("QUERY_DEFAULT_USER", this.username);
withEnv("QUERY_DEFAULT_PASSWORD", this.password);
withEnv("MINIO_ENABLED", this.minioEnabled);
}

@Override
Expand Down Expand Up @@ -93,6 +96,10 @@ public String getDatabaseName() {
return this.databaseName;
}

public boolean isMinioEnabled() {
return this.minioEnabled;
}

@Override
public String getTestQueryString() {
return TEST_QUERY;
Expand All @@ -109,4 +116,9 @@ public DatabendContainer withPassword(String password) {
this.password = password;
return this;
}

public DatabendContainer withMinioEnabled(boolean minioEnabled) {
this.minioEnabled = minioEnabled;
return this;
}
}
21 changes: 21 additions & 0 deletions modules/databend/src/test/java/org/testcontainers/databend/DatabendContainerTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -38,4 +38,25 @@ public void customCredentialsWithUrlParams() throws SQLException {
assertThat(resultSetInt).isEqualTo(1);
}
}

@Test
public void testInsertIntoWithMinioEnabled() throws SQLException {
try (DatabendContainer databend = new DatabendContainer("datafuselabs/databend:v1.2.615")
.withMinioEnabled(true)
.withUsername("test")
.withPassword("test")
.withUrlParam("ssl", "false")
) {
databend.start();

performQuery(databend, "CREATE TABLE test_table (a int, b int);");
performQuery(databend, "INSERT INTO test_table VALUES (1, 2);");

ResultSet resultSet = performQuery(databend, "SELECT * FROM test_table;");

resultSet.next();
assertThat(resultSet.getInt(1)).isEqualTo(1);
assertThat(resultSet.getInt(2)).isEqualTo(2);
}
}
}
Loading