Replace println with proper SLF4J logging in test fixtures

- Added Logging trait to ClickHouseSingleMixIn
- Replaced all println statements with log.info() calls
- Provides structured, filterable logging for test execution
- Maintains test output visibility while enabling proper log management

Author: ShimonSte

clickhouse-core/src/testFixtures/scala/com/clickhouse/spark/base/ClickHouseSingleMixIn.scala

@@ -19,13 +19,16 @@ import com.clickhouse.data.ClickHouseVersion
 import com.dimafeng.testcontainers.{ForAllTestContainer, JdbcDatabaseContainer, SingleContainer}
 import org.scalatest.BeforeAndAfterAll
 import org.scalatest.funsuite.AnyFunSuite
+import org.slf4j.LoggerFactory
 import org.testcontainers.containers.ClickHouseContainer
 import org.testcontainers.utility.{DockerImageName, MountableFile}
 import java.nio.file.{Path, Paths}
 import scala.collection.JavaConverters._
 
 trait ClickHouseSingleMixIn extends AnyFunSuite with BeforeAndAfterAll with ForAllTestContainer
     with ClickHouseProvider {
+  
+  private val logger = LoggerFactory.getLogger(getClass)
   // format: off
   private val CLICKHOUSE_IMAGE:    String = Utils.load("CLICKHOUSE_IMAGE", "clickhouse/clickhouse-server:23.8")
   private val CLICKHOUSE_USER:     String = Utils.load("CLICKHOUSE_USER", "default")
@@ -36,7 +39,7 @@ trait ClickHouseSingleMixIn extends AnyFunSuite with BeforeAndAfterAll with ForA
   private val CLICKHOUSE_TPC_PORT  = 9000
   // format: on
 
-  println(s"[ClickHouseSingleMixIn] Initializing with ClickHouse image: $CLICKHOUSE_IMAGE")
+  logger.info(s"Initializing with ClickHouse image: $CLICKHOUSE_IMAGE")
 
   override val clickhouseVersion: ClickHouseVersion = ClickHouseVersion.of(CLICKHOUSE_IMAGE.split(":").last)
 
@@ -87,17 +90,17 @@ trait ClickHouseSingleMixIn extends AnyFunSuite with BeforeAndAfterAll with ForA
 
   override def beforeAll(): Unit = {
     val startTime = System.currentTimeMillis()
-    println(s"[ClickHouseSingleMixIn] Starting ClickHouse container: $CLICKHOUSE_IMAGE")
+    logger.info(s"Starting ClickHouse container: $CLICKHOUSE_IMAGE")
     super.beforeAll() // This starts the container and makes mappedPort available
     val duration = System.currentTimeMillis() - startTime
-    println(
-      s"[ClickHouseSingleMixIn] ClickHouse container started in ${duration}ms at ${container.host}:${container.mappedPort(CLICKHOUSE_HTTP_PORT)}"
+    logger.info(
+      s"ClickHouse container started in ${duration}ms at ${container.host}:${container.mappedPort(CLICKHOUSE_HTTP_PORT)}"
     )
   }
 
   override def afterAll(): Unit = {
-    println(s"[ClickHouseSingleMixIn] Stopping ClickHouse container")
+    logger.info("Stopping ClickHouse container")
     super.afterAll()
-    println(s"[ClickHouseSingleMixIn] ClickHouse container stopped")
+    logger.info("ClickHouse container stopped")
   }
 }

spark-4.0/clickhouse-spark/src/main/scala/com/clickhouse/spark/ClickHouseCatalog.scala

@@ -109,7 +109,7 @@ class ClickHouseCatalog extends TableCatalog
     case Array(database) =>
       nodeClient.syncQueryOutputJSONEachRow(s"SHOW TABLES IN ${quoted(database)}") match {
         case Left(exception) if exception.code == UNKNOWN_DATABASE.code =>
-          throw new NoSuchNamespaceException(namespace.mkString("."))
+          throw new NoSuchNamespaceException(namespace)
         case Left(rethrow) =>
           throw rethrow
         case Right(output) =>
@@ -118,7 +118,7 @@ class ClickHouseCatalog extends TableCatalog
             .map(table => Identifier.of(namespace, table))
             .toArray
       }
-    case _ => throw new NoSuchNamespaceException(namespace.mkString("."))
+    case _ => throw new NoSuchNamespaceException(namespace)
   }
 
   @throws[NoSuchTableException]
@@ -131,7 +131,7 @@ class ClickHouseCatalog extends TableCatalog
             throw new NoSuchTableException(ident)
           // not sure if this check is necessary
           case Left(exception) if exception.code == UNKNOWN_DATABASE.code =>
-            throw new NoSuchTableException(s"Database $db does not exist")
+            throw new NoSuchTableException(Array(db))
           case Left(rethrow) =>
             throw rethrow
           case Right(_) => (db, tbl)
@@ -323,7 +323,11 @@ class ClickHouseCatalog extends TableCatalog
     (unwrap(oldIdent), unwrap(newIdent)) match {
       case (Some((oldDb, oldTbl)), Some((newDb, newTbl))) =>
         nodeClient.syncQueryOutputJSONEachRow(s"RENAME TABLE `$oldDb`.`$oldTbl` to `$newDb`.`$newTbl`") match {
-          case Left(exception) => throw new NoSuchTableException(exception.getMessage, Some(exception))
+          case Left(exception) => throw new NoSuchTableException(
+              errorClass = "TABLE_OR_VIEW_NOT_FOUND",
+              messageParameters = Map("relationName" -> oldIdent.toString),
+              cause = Some(exception)
+            )
           case Right(_) =>
         }
       case _ => throw CHClientException("Invalid table identifier")
@@ -343,13 +347,13 @@ class ClickHouseCatalog extends TableCatalog
     case Array(_) =>
       loadNamespaceMetadata(namespace)
       Array()
-    case _ => throw new NoSuchNamespaceException(namespace.map(quoted).mkString("."))
+    case _ => throw new NoSuchNamespaceException(namespace)
   }
 
   @throws[NoSuchNamespaceException]
   override def loadNamespaceMetadata(namespace: Array[String]): util.Map[String, String] = namespace match {
     case Array(database) => queryDatabaseSpec(database).toJavaMap
-    case _ => throw new NoSuchNamespaceException(namespace.map(quoted).mkString("."))
+    case _ => throw new NoSuchNamespaceException(namespace)
   }
 
   @throws[NamespaceAlreadyExistsException]

spark-4.0/clickhouse-spark/src/main/scala/com/clickhouse/spark/ClickHouseHelper.scala

@@ -45,10 +45,10 @@ import scala.collection.JavaConverters._
 trait ClickHouseHelper extends Logging {
 
   @volatile lazy val DEFAULT_ACTION_IF_NO_SUCH_DATABASE: String => Unit =
-    (db: String) => throw new NoSuchNamespaceException(db)
+    (db: String) => throw new NoSuchNamespaceException(Array(db))
 
   @volatile lazy val DEFAULT_ACTION_IF_NO_SUCH_TABLE: (String, String) => Unit =
-    (database, table) => throw new NoSuchTableException(s"$database.$table")
+    (database, table) => throw new NoSuchTableException(database, table)
 
   def unwrap(ident: Identifier): Option[(String, String)] = ident.namespace() match {
     case Array(database) => Some((database, ident.name()))