1414import org .junit .jupiter .api .AfterEach ;
1515import org .junit .jupiter .api .BeforeAll ;
1616import org .junit .jupiter .api .extension .RegisterExtension ;
17+
1718import tech .ydb .test .junit5 .YdbHelperExtension ;
1819
1920public 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