1
1
package com .datastax .astra .test .integration .prod ;
2
2
3
- import com .datastax .astra .client .DataAPIClient ;
4
- import com .datastax .astra .client .Database ;
5
- import com .datastax .astra .client .admin .AstraDBDatabaseAdmin ;
6
- import com .datastax .astra .client .admin .DatabaseAdmin ;
7
- import com .datastax .astra .client .model .DatabaseInfo ;
8
3
import com .datastax .astra .test .integration .AbstractAstraDBAdminTest ;
9
4
import com .dtsx .astra .sdk .db .domain .CloudProviderType ;
10
5
import com .dtsx .astra .sdk .utils .AstraEnvironment ;
11
- import com .dtsx .astra .sdk .utils .Utils ;
12
- import org .junit .jupiter .api .Assertions ;
13
6
import org .junit .jupiter .api .MethodOrderer ;
14
- import org .junit .jupiter .api .Order ;
15
- import org .junit .jupiter .api .Test ;
16
7
import org .junit .jupiter .api .TestMethodOrder ;
17
8
import org .junit .jupiter .api .condition .EnabledIfEnvironmentVariable ;
18
9
19
- import java .util .Optional ;
20
- import java .util .UUID ;
21
-
22
- import static org .assertj .core .api .Assertions .assertThat ;
23
-
24
10
@ EnabledIfEnvironmentVariable (named = "ASTRA_DB_APPLICATION_TOKEN" , matches = "Astra.*" )
11
+ @ EnabledIfEnvironmentVariable (named = "ASTRA_CLOUD_PROVIDER" , matches = ".*" )
12
+ @ EnabledIfEnvironmentVariable (named = "ASTRA_CLOUD_REGION" , matches = ".*" )
25
13
@ TestMethodOrder (MethodOrderer .OrderAnnotation .class )
26
14
class AstraProdDevopsITTest extends AbstractAstraDBAdminTest {
27
15
28
- private static final String TMP_VECTOR_DB = "astra_db_admin_test" ;
29
- private static final String TMP_VECTOR_DB2 = "astra_db_admin_test2" ;
30
-
31
16
@ Override
32
17
protected AstraEnvironment getAstraEnvironment () {
33
18
return AstraEnvironment .PROD ;
34
19
}
35
20
36
21
@ Override
37
22
protected CloudProviderType getCloudProvider () {
38
- return null ;
23
+ return CloudProviderType . valueOf ( System . getenv ( "ASTRA_CLOUD_PROVIDER" )) ;
39
24
}
40
25
41
26
@ Override
42
27
protected String getRegion () {
43
- return "" ;
44
- }
45
-
46
- @ Test
47
- @ Order (1 )
48
- void shouldConnectToDatabase () {
49
- // Given
50
- Assertions .assertNotNull (getAstraDbAdmin ());
51
-
52
- // Create a DB
53
- Assertions .assertFalse (getAstraDbAdmin ().databaseExists (TMP_VECTOR_DB ));
54
- DatabaseAdmin dbAdmin = getAstraDbAdmin ()
55
- .createDatabase (TMP_VECTOR_DB , CloudProviderType .GCP , "us-east1" );
56
-
57
- // List DBs
58
- assertThat (getAstraDbAdmin ().listDatabaseNames ()).contains (TMP_VECTOR_DB );
59
- assertThat (getAstraDbAdmin ().databaseExists (TMP_VECTOR_DB )).isTrue ();
60
-
61
- Optional <DatabaseInfo > info = getAstraDbAdmin ().listDatabases ()
62
- .stream ().filter (db -> db .getName ().equals (TMP_VECTOR_DB )).findFirst ();
63
-
64
- // Access DB
65
- assertThat (info ).isPresent ();
66
- assertThat (info .get ().getName ()).isEqualTo (TMP_VECTOR_DB );
67
- UUID databaseId = info .get ().getId ();
68
- Database db = getAstraDbAdmin ().getDatabase (databaseId );
69
- Assertions .assertNotNull (db );
70
- assertThat (getAstraDbAdmin ().databaseExists (databaseId )).isTrue ();
71
-
72
- // Delete DB
73
- getAstraDbAdmin ().dropDatabase (databaseId );
74
- }
75
-
76
- @ Test
77
- @ Order (2 )
78
- void shouldCreateOtherDatabase () {
79
- Assertions .assertFalse (getAstraDbAdmin ().databaseExists (TMP_VECTOR_DB2 ));
80
- DatabaseAdmin dbAdmin = getAstraDbAdmin ().createDatabase (TMP_VECTOR_DB2 );
81
- AstraDBDatabaseAdmin dbAmin2 = (AstraDBDatabaseAdmin ) dbAdmin ;
82
- UUID databaseId = UUID .fromString (dbAmin2 .getDatabaseInformations ().getId ());
83
-
84
- Optional <String > oToken = Utils .readEnvVariable ("ASTRA_DB_APPLICATION_TOKEN" );
85
- assertThat (oToken ).isPresent ();
86
- DataAPIClient client = new DataAPIClient (oToken .get ());
87
- assertThat (client .getDatabase (databaseId )).isNotNull ();
88
- assertThat (client .getDatabase (databaseId , "default_keyspace" )).isNotNull ();
89
-
90
- Assertions .assertTrue (getAstraDbAdmin ().databaseExists (TMP_VECTOR_DB2 ));
91
- getAstraDbAdmin ().dropDatabase (TMP_VECTOR_DB2 );
28
+ return System .getenv ("ASTRA_CLOUD_REGION" );
92
29
}
93
30
94
-
95
-
96
31
}
0 commit comments