FIR-32836: log is simplified now - no lombok in log

build.gradle

@@ -69,6 +69,7 @@ dependencies {
     implementation 'net.jodah:expiringmap:0.5.11'
     implementation 'org.apache.commons:commons-text:1.12.0'
     implementation 'org.lz4:lz4-java:1.8.0'
+    implementation 'org.slf4j:jul-to-slf4j:2.0.13'
 
     implementation fileTree(dir: 'libs', includes: ['*.jar'])
 

lombok.config

@@ -1,4 +1,3 @@
 lombok.anyConstructor.addConstructorProperties = true
 config.stopBubbling = true
 lombok.addLombokGeneratedAnnotation = true
-lombok.log.custom.declaration = com.firebolt.jdbc.log.FireboltLogger com.firebolt.jdbc.util.LoggerUtil.getLogger(NAME)

src/integrationTest/java/integration/IntegrationTest.java

@@ -1,7 +1,6 @@
 package integration;
 
 import com.firebolt.jdbc.client.HttpClientConfig;
-import lombok.CustomLog;
 import lombok.SneakyThrows;
 import org.junit.jupiter.api.Tag;
 import org.junit.jupiter.api.TestInstance;
@@ -17,7 +16,6 @@
 import static com.firebolt.jdbc.connection.FireboltConnectionUserPassword.SYSTEM_ENGINE_NAME;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
 
-@CustomLog
 @TestInstance(TestInstance.Lifecycle.PER_CLASS)
 @Tag("common")
 public abstract class IntegrationTest {

src/integrationTest/java/integration/tests/PreparedStatementArrayTest.java

@@ -3,7 +3,6 @@
 import com.firebolt.jdbc.type.FireboltDataType;
 import com.firebolt.jdbc.type.array.FireboltArray;
 import integration.IntegrationTest;
-import lombok.CustomLog;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
@@ -27,7 +26,6 @@
 import static org.junit.jupiter.api.Assertions.assertFalse;
 import static org.junit.jupiter.api.Assertions.assertNull;
 
-@CustomLog
 class PreparedStatementArrayTest extends IntegrationTest {
 	enum PreparedStatementValueSetter {
 		ARRAY {

src/integrationTest/java/integration/tests/PreparedStatementTest.java

@@ -9,7 +9,6 @@
 import integration.ConnectionInfo;
 import integration.IntegrationTest;
 import lombok.Builder;
-import lombok.CustomLog;
 import lombok.EqualsAndHashCode;
 import lombok.Value;
 import org.junit.jupiter.api.AfterEach;
@@ -33,7 +32,6 @@
 import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.sql.Statement;
-import java.sql.Time;
 import java.sql.Timestamp;
 import java.util.ArrayList;
 import java.util.Arrays;
@@ -51,7 +49,6 @@
 import static org.junit.jupiter.api.Assertions.assertNull;
 import static org.junit.jupiter.api.Assertions.assertTrue;
 
-@CustomLog
 class PreparedStatementTest extends IntegrationTest {
 
 	@BeforeEach

src/integrationTest/java/integration/tests/StatementCancelTest.java

@@ -5,7 +5,6 @@
 import com.firebolt.jdbc.statement.FireboltStatement;
 import integration.EnvironmentCondition;
 import integration.IntegrationTest;
-import lombok.CustomLog;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Tag;
@@ -17,13 +16,15 @@
 import java.sql.SQLException;
 import java.sql.Statement;
 import java.util.concurrent.TimeUnit;
+import java.util.logging.Level;
+import java.util.logging.Logger;
 
 import static integration.EnvironmentCondition.Attribute.databaseVersion;
 import static integration.EnvironmentCondition.Comparison.GE;
 import static org.junit.jupiter.api.Assertions.assertEquals;
 
-@CustomLog
 class StatementCancelTest extends IntegrationTest {
+	private static final Logger log = Logger.getLogger(StatementCancelTest.class.getName());
 
 	@BeforeEach
 	void beforeEach() {
@@ -91,11 +92,11 @@ private void verifyThatNoMoreRecordsAreAdded(Connection connection, String table
 		// data is available.
 		long waitForResultTime = insertTime / 2;
 		long waitForResultDelay = waitForResultTime / 10;
-		log.info("verifyThatNoMoreRecordsAreAdded insertTime={}, waitForResultTime={}", insertTime, waitForResultTime);
+		log.log(Level.INFO, "verifyThatNoMoreRecordsAreAdded insertTime={0}, waitForResultTime={0}", new Object[] {insertTime, waitForResultTime});
 		int count0;
 		int i = 0;
 		for (count0 = count(connection, tableName); i < 10; count0 = count(connection, tableName), i++) {
-			log.info("verifyThatNoMoreRecordsAreAdded count0={}", count0);
+			log.log(Level.INFO, "verifyThatNoMoreRecordsAreAdded count0={0}", count0);
 			if (count0 > 0) {
 				break;
 			}
@@ -108,7 +109,7 @@ private void verifyThatNoMoreRecordsAreAdded(Connection connection, String table
 		int count1 = count(connection, tableName);
 		Thread.sleep(insertTime); // waiting to see if more records are being added
 		int count2 = count(connection, tableName);
-		log.info("verifyThatNoMoreRecordsAreAdded count1={}, count2={}", count1, count2);
+		log.log(Level.INFO, "verifyThatNoMoreRecordsAreAdded count1={0}, count2={1}", new Object[] {count1, count2});
 		assertEquals(count1, count2);
 	}
 

src/integrationTest/java/integration/tests/StatementTest.java

@@ -5,7 +5,6 @@
 import integration.ConnectionInfo;
 import integration.IntegrationTest;
 import kotlin.collections.ArrayDeque;
-import lombok.CustomLog;
 import org.hamcrest.Matchers;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
@@ -42,7 +41,6 @@
 import static org.junit.jupiter.api.Assertions.assertThrows;
 import static org.junit.jupiter.api.Assertions.assertTrue;
 
-@CustomLog
 class StatementTest extends IntegrationTest {
 
 	@BeforeEach

src/integrationTest/java/integration/tests/SystemEngineTest.java

@@ -6,7 +6,6 @@
 import integration.ConnectionInfo;
 import integration.EnvironmentCondition;
 import integration.IntegrationTest;
-import lombok.CustomLog;
 import org.junit.Assert;
 import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.BeforeAll;
@@ -33,6 +32,8 @@
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
+import java.util.logging.Level;
+import java.util.logging.Logger;
 import java.util.stream.Stream;
 
 import static java.lang.String.format;
@@ -45,7 +46,6 @@
 import static org.junit.jupiter.api.Assertions.assertThrows;
 import static org.junit.jupiter.api.Assertions.assertTrue;
 
-@CustomLog
 @TestMethodOrder(MethodOrderer.OrderAnnotation.class)
 public class SystemEngineTest extends IntegrationTest {
 
@@ -59,12 +59,14 @@ public class SystemEngineTest extends IntegrationTest {
 	private static final String TABLE1 = TABLE + "_1";
 	private static final String TABLE2 = TABLE + "_2";
 
+	private static final Logger log = Logger.getLogger(SystemEngineTest.class.getName());
+
 	@BeforeAll
 	void beforeAll() {
 		try {
 			executeStatementFromFile("/statements/system/ddl.sql", getSystemEngineName());
 		} catch (Exception e) {
-			log.warn("Could not execute statement", e);
+			log.log(Level.WARNING, "Could not execute statement", e);
 		}
 	}
 
@@ -73,7 +75,7 @@ void afterAll() {
 		try {
 			executeStatementFromFile("/statements/system/cleanup.sql", getSystemEngineName());
 		} catch (Exception e) {
-			log.warn("Could not execute statement", e);
+			log.log(Level.WARNING, "Could not execute statement", e);
 		}
 	}
 
@@ -153,7 +155,7 @@ void useDatabase(String entityType) throws SQLException {
 					try (Statement statement = connection.createStatement()) {
 						statement.executeUpdate(query);
 					} catch (SQLException e) { // catch just in case to do our best to clean everything even if test has failed
-						log.warn("Cannot perform query {}",  query, e);
+						log.log(Level.WARNING, "Cannot perform query " + query, e);
 					}
 				}
 			}
@@ -273,9 +275,8 @@ void shouldExecuteEngineManagementQueries() throws SQLException {
 						format("DROP DATABASE %s", SECOND_DATABASE_NAME)}) {
 					try (Statement statement = connection.createStatement()) {
 						statement.executeUpdate(query);
-					} catch (
-							SQLException e) { // catch just in case to do our best to clean everything even if test has failed
-						log.warn("Cannot perform query {}", query, e);
+					} catch (SQLException e) { // catch just in case to do our best to clean everything even if test has failed
+						log.log(Level.WARNING, "Cannot perform query " + query, e);
 					}
 				}
 			}

src/integrationTest/java/integration/tests/TimeoutTest.java

@@ -2,9 +2,7 @@
 
 import com.firebolt.jdbc.connection.FireboltConnection;
 import integration.EnvironmentCondition;
-import integration.EnvironmentCondition.Comparison;
 import integration.IntegrationTest;
-import lombok.CustomLog;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Tag;
@@ -16,16 +14,18 @@
 import java.sql.Statement;
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
+import java.util.logging.Level;
+import java.util.logging.Logger;
 
 import static integration.EnvironmentCondition.Attribute.databaseVersion;
 import static integration.EnvironmentCondition.Comparison.GE;
 import static java.lang.String.format;
 import static org.junit.jupiter.api.Assertions.assertTrue;
 
-@CustomLog
 class TimeoutTest extends IntegrationTest {
 	private static final int MIN_TIME_SECONDS = 350;
 	private static final Map<Integer, Long> SERIES_SIZE = Map.of(1, 80000000000L, 2, 180000000000L);
+	private static final Logger log = Logger.getLogger(TimeoutTest.class.getName());
 	private long startTime;
 
 	@BeforeEach
@@ -37,7 +37,7 @@ void before() {
 	void after() {
 		long endTime = System.nanoTime();
 		long elapsedTimeSeconds = (endTime - startTime) / 1_000_000_000;
-		log.info("Time elapsed: {} seconds", elapsedTimeSeconds);
+		log.log(Level.INFO, "Time elapsed: {0} seconds", elapsedTimeSeconds);
 		assertTrue(elapsedTimeSeconds > MIN_TIME_SECONDS, format("Test is too short. It took %d but should take at least %d seconds", elapsedTimeSeconds, MIN_TIME_SECONDS));
 	}
 

src/integrationTest/java/integration/tests/TimestampTest.java

@@ -3,7 +3,6 @@
 import com.firebolt.jdbc.testutils.AssertionUtil;
 import integration.IntegrationTest;
 import io.zonky.test.db.postgres.embedded.EmbeddedPostgres;
-import lombok.CustomLog;
 import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.Test;
@@ -37,7 +36,6 @@
 import static java.sql.Types.TIMESTAMP_WITH_TIMEZONE;
 import static org.junit.jupiter.api.Assertions.assertEquals;
 
-@CustomLog
 @DefaultTimeZone("UTC")
 class TimestampTest extends IntegrationTest {
 	private static final TimeZone UTC_TZ = TimeZone.getTimeZone("UTC");

src/main/java/com/firebolt/FireboltDriver.java

@@ -1,27 +1,28 @@
 package com.firebolt;
 
 import com.firebolt.jdbc.connection.FireboltConnection;
-import com.firebolt.jdbc.exception.FireboltSQLFeatureNotSupportedException;
+import com.firebolt.jdbc.util.LoggerUtil;
 import com.firebolt.jdbc.util.PropertyUtil;
 import com.firebolt.jdbc.util.VersionUtil;
-import lombok.CustomLog;
 
 import java.sql.Connection;
 import java.sql.Driver;
 import java.sql.DriverPropertyInfo;
 import java.sql.SQLException;
-import java.sql.SQLFeatureNotSupportedException;
 import java.util.Properties;
 import java.util.logging.Logger;
 
-@CustomLog
 public class FireboltDriver implements Driver {
 
 	public static final String JDBC_FIREBOLT = "jdbc:firebolt:";
+	private static Logger root;
+	private static final Logger log;
 
 	static {
 		try {
 			java.sql.DriverManager.registerDriver(new FireboltDriver());
+			root = LoggerUtil.getRootLogger();
+			log = Logger.getLogger(FireboltDriver.class.getName());
 			log.info("Firebolt Driver registered");
 		} catch (SQLException ex) {
 			throw new RuntimeException("Cannot register the driver");
@@ -59,7 +60,7 @@ public boolean jdbcCompliant() {
 	}
 
 	@Override
-	public Logger getParentLogger() throws SQLFeatureNotSupportedException {
-		throw new FireboltSQLFeatureNotSupportedException();
+	public Logger getParentLogger() {
+		return root;
 	}
 }

src/main/java/com/firebolt/jdbc/client/FireboltClient.java

@@ -4,7 +4,6 @@
 import com.firebolt.jdbc.exception.FireboltException;
 import com.firebolt.jdbc.resultset.compress.LZ4InputStream;
 import com.firebolt.jdbc.util.CloseableUtil;
-import lombok.CustomLog;
 import lombok.Getter;
 import lombok.NonNull;
 import okhttp3.Call;
@@ -28,6 +27,8 @@
 import java.util.Map.Entry;
 import java.util.Optional;
 import java.util.concurrent.TimeUnit;
+import java.util.logging.Level;
+import java.util.logging.Logger;
 import java.util.stream.Collectors;
 
 import static java.lang.String.format;
@@ -36,13 +37,13 @@
 import static java.util.Optional.ofNullable;
 
 @Getter
-@CustomLog
 public abstract class FireboltClient {
 
 	private static final String HEADER_AUTHORIZATION = "Authorization";
 	private static final String HEADER_AUTHORIZATION_BEARER_PREFIX_VALUE = "Bearer ";
 	private static final String HEADER_USER_AGENT = "User-Agent";
 	private static final String HEADER_PROTOCOL_VERSION = "Firebolt-Protocol-Version";
+	private static final Logger log = Logger.getLogger(FireboltClient.class.getName());
 	private final OkHttpClient httpClient;
 	private final String headerUserAgentValue;
 	protected final FireboltConnection connection;
@@ -169,7 +170,7 @@ private String extractErrorMessage(Response response, boolean isCompress) throws
 		try {
 			entityBytes = response.body() !=  null ? response.body().bytes() : null;
 		} catch (IOException e) {
-			log.warn("Could not parse response containing the error message from Firebolt", e);
+			log.log(Level.WARNING, "Could not parse response containing the error message from Firebolt", e);
 			String errorResponseMessage = format("Server failed to execute query%ninternal error:%n%s",
 					getInternalErrorWithHeadersText(response));
 			throw new FireboltException(errorResponseMessage, response.code(), e);
@@ -184,7 +185,7 @@ private String extractErrorMessage(Response response, boolean isCompress) throws
 				return new BufferedReader(new InputStreamReader(is, StandardCharsets.UTF_8)).lines()
 						.collect(Collectors.joining("\n")) + "\n";
 			} catch (Exception e) {
-				log.warn("Could not decompress error from server");
+				log.log(Level.WARNING, "Could not decompress error from server");
 			}
 		}
 		return new String(entityBytes, StandardCharsets.UTF_8);

src/main/java/com/firebolt/jdbc/client/HttpClientConfig.java

@@ -1,20 +1,18 @@
 package com.firebolt.jdbc.client;
 
+import com.firebolt.jdbc.client.config.OkHttpClientCreator;
+import com.firebolt.jdbc.connection.settings.FireboltProperties;
+import okhttp3.OkHttpClient;
+
 import java.io.IOException;
 import java.security.KeyManagementException;
 import java.security.KeyStoreException;
 import java.security.NoSuchAlgorithmException;
 import java.security.cert.CertificateException;
+import java.util.logging.Logger;
 
-import com.firebolt.jdbc.client.config.OkHttpClientCreator;
-import com.firebolt.jdbc.connection.settings.FireboltProperties;
-
-import lombok.CustomLog;
-import okhttp3.OkHttpClient;
-
-@CustomLog
 public class HttpClientConfig {
-
+	private static final Logger log = Logger.getLogger(HttpClientConfig.class.getName());
 	private static OkHttpClient instance;
 
 	private HttpClientConfig() {