added logging functionality

Author: scmacdon

kotlin/services/athena/build.gradle.kts

@@ -35,6 +35,8 @@ dependencies {
     implementation("com.google.code.gson:gson:2.10")
     testImplementation("org.junit.jupiter:junit-jupiter:5.9.2")
     implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.6.4")
+    implementation("org.slf4j:slf4j-api:2.0.15")
+    implementation("org.slf4j:slf4j-simple:2.0.15")
 }
 tasks.withType<KotlinCompile> {
     kotlinOptions.jvmTarget = "17"

kotlin/services/athena/src/test/kotlin/AthenaTest.kt

@@ -23,10 +23,13 @@ import org.junit.jupiter.api.Order
 import org.junit.jupiter.api.Test
 import org.junit.jupiter.api.TestInstance
 import org.junit.jupiter.api.TestMethodOrder
+import org.slf4j.Logger
+import org.slf4j.LoggerFactory
 
 @TestInstance(TestInstance.Lifecycle.PER_CLASS)
 @TestMethodOrder(OrderAnnotation::class)
 class AthenaTest {
+    private val logger: Logger = LoggerFactory.getLogger(AthenaTest::class.java)
     private var nameQuery: String? = null
     private var queryString: String? = null
     private var database: String? = null
@@ -43,39 +46,28 @@ class AthenaTest {
         queryString = values.queryString.toString()
         database = values.database.toString()
         outputLocation = values.outputLocation.toString()
-
-        // Uncomment this code block if you prefer using a config.properties file to retrieve AWS values required for these tests.
-        /*
-        val input: InputStream = this.javaClass.getClassLoader().getResourceAsStream("config.properties")
-        val prop = Properties()
-        prop.load(input)
-        nameQuery = prop.getProperty("nameQuery")
-        queryString = prop.getProperty("queryString")
-        database = prop.getProperty("database")
-        outputLocation = prop.getProperty("outputLocation")
-         */
     }
 
     @Test
     @Order(1)
     fun createNamedQueryTest() = runBlocking {
         queryId = createNamedQuery(queryString.toString(), nameQuery.toString(), database.toString())
         queryId?.let { assertTrue(it.isNotEmpty()) }
-        println("Test 1 passed")
+        logger.info("Test 1 passed")
     }
 
     @Test
     @Order(2)
     fun listNamedQueryTest() = runBlocking {
         listNamedQueries()
-        println("Test 2 passed")
+        logger.info("Test 2 passed")
     }
 
     @Test
     @Order(3)
     fun listQueryExecutionsTest() = runBlocking {
         listQueryIds()
-        println("Test 3 passed")
+        logger.info("Test 3 passed")
     }
 
     @Test
@@ -84,14 +76,14 @@ class AthenaTest {
         val queryExecutionId = submitAthenaQuery(queryString.toString(), database.toString(), outputLocation.toString())
         waitForQueryToComplete(queryExecutionId)
         processResultRows(queryExecutionId)
-        println("Test 4 passed")
+        logger.info("Test 4 passed")
     }
 
     @Test
     @Order(5)
     fun deleteNamedQueryTest() = runBlocking {
         deleteQueryName(queryId)
-        println("Test 5 passed")
+        logger.info("Test 5 passed")
     }
 
     private suspend fun getSecretValues(): String {
@@ -101,7 +93,6 @@ class AthenaTest {
         }
         SecretsManagerClient {
             region = "us-east-1"
-            credentialsProvider = EnvironmentCredentialsProvider()
         }.use { secretClient ->
             val valueResponse = secretClient.getSecretValue(valueRequest)
             return valueResponse.secretString.toString()

kotlin/services/athena/src/test/resources/logback.xml

@@ -0,0 +1,11 @@
+<configuration>
+    <appender name="Console" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder>
+            <pattern>%level %logger{36} - %msg%n</pattern>
+        </encoder>
+    </appender>
+
+    <root level="info">
+        <appender-ref ref="Console"/>
+    </root>
+</configuration>