Skip to content

Commit ca9ce2b

Browse files
committed
Fixed tests
1 parent 7c3ac6f commit ca9ce2b

File tree

1 file changed

+7
-6
lines changed

1 file changed

+7
-6
lines changed

jooq-dialect/src/test/java/tech/ydb/jooq/BaseTest.java

+7-6
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@
1414
import org.junit.jupiter.api.AfterEach;
1515
import org.junit.jupiter.api.BeforeAll;
1616
import org.junit.jupiter.api.extension.RegisterExtension;
17+
1718
import tech.ydb.test.junit5.YdbHelperExtension;
1819

1920
public abstract class BaseTest {
@@ -66,15 +67,15 @@ protected static List<DateTableRecord> getExampleDateRecords() {
6667
public static void beforeAll() {
6768
dsl = YDB.using(jdbcUrl());
6869

69-
dsl.createTable("series")
70+
dsl.createTableIfNotExists("series")
7071
.column("series_id", YdbTypes.UINT64)
7172
.column("title", YdbTypes.UTF8)
7273
.column("series_info", YdbTypes.UTF8)
7374
.column("release_date", YdbTypes.UINT64)
7475
.primaryKey("series_id")
7576
.execute();
7677

77-
dsl.createTable("seasons")
78+
dsl.createTableIfNotExists("seasons")
7879
.column("series_id", YdbTypes.UINT64)
7980
.column("season_id", YdbTypes.UINT64)
8081
.column("title", YdbTypes.UTF8)
@@ -83,7 +84,7 @@ public static void beforeAll() {
8384
.primaryKey("series_id", "season_id")
8485
.execute();
8586

86-
dsl.createTable("episodes")
87+
dsl.createTableIfNotExists("episodes")
8788
.column("series_id", YdbTypes.UINT64)
8889
.column("season_id", YdbTypes.UINT64)
8990
.column("episode_id", YdbTypes.UINT64)
@@ -92,15 +93,15 @@ public static void beforeAll() {
9293
.primaryKey("series_id", "season_id", "episode_id")
9394
.execute();
9495

95-
dsl.createTable("hard_table")
96+
dsl.createTableIfNotExists("hard_table")
9697
.column("id", YdbTypes.STRING)
9798
.column("first", YdbTypes.JSON)
9899
.column("second", YdbTypes.JSONDOCUMENT)
99100
.column("third", YdbTypes.YSON)
100101
.primaryKey("id")
101102
.execute();
102103

103-
dsl.createTable("date_table")
104+
dsl.createTableIfNotExists("date_table")
104105
.column("id", YdbTypes.UINT64)
105106
.column("int_col", YdbTypes.INT32)
106107
.column("percent", YdbTypes.DOUBLE)
@@ -112,7 +113,7 @@ public static void beforeAll() {
112113
.primaryKey("id")
113114
.execute();
114115

115-
CreateTableElementListStep createQuery = dsl.createTable("numeric").column("id", YdbTypes.INT32);
116+
CreateTableElementListStep createQuery = dsl.createTableIfNotExists("numeric").column("id", YdbTypes.INT32);
116117

117118
for (int i = 1; i <= 23; i++) {
118119
createQuery.column(Integer.toString(i), YdbTypes.INT32);

0 commit comments

Comments
 (0)