#706 Fix PR suggestions.

Author: yruslan

pramen/core/src/main/scala/za/co/absa/pramen/core/bookkeeper/BookkeeperJdbc.scala

@@ -178,10 +178,13 @@ class BookkeeperJdbc(db: Database, profile: JdbcProfile, batchId: Long) extends
 
   override def deleteTable(tableName: String): Seq[String] = {
     val hasWildcard = tableName.contains("*")
-    val tableNameEscaped = if (hasWildcard)
-      tableName.trim.replace("%", "\\%").replace('*', '%')
-    else
-      tableName.trim.replace("%", "\\%")
+
+    val escape = '\\'
+    val baseEscaped = tableName.trim
+      .replace("\\", "\\\\")
+      .replace("%", "\\%")
+
+    val tableNameEscaped = if (hasWildcard) baseEscaped.replace("*", "%") else baseEscaped
 
     val likePattern = if (!hasWildcard)
       tableNameEscaped + "->%"
@@ -194,7 +197,7 @@ class BookkeeperJdbc(db: Database, profile: JdbcProfile, batchId: Long) extends
       s"'$tableNameEscaped' or '$likePattern'"
 
     val listQuery = BookkeepingRecords.records
-      .filter(r => r.pramenTableName === tableNameEscaped || r.pramenTableName.like(likePattern))
+      .filter(r => r.pramenTableName === tableNameEscaped || r.pramenTableName.like(likePattern, escape))
       .map(_.pramenTableName)
       .distinct
 
@@ -212,19 +215,19 @@ class BookkeeperJdbc(db: Database, profile: JdbcProfile, batchId: Long) extends
       log.info(s"Deleted $deletedBkCount records from the bookkeeping table for tables matching $patternForLogging: ${tablesToDelete.mkString(", ")}")
 
       val deletedSchemaCount = SlickUtils.executeAction(db, SchemaRecords.records
-        .filter(r => r.pramenTableName === tableNameEscaped || r.pramenTableName.like(likePattern))
+        .filter(r => r.pramenTableName === tableNameEscaped || r.pramenTableName.like(likePattern, escape))
         .delete
       )
       log.info(s"Deleted $deletedSchemaCount records from the schemas table.")
 
       val deletedOffsetsCount = SlickUtils.executeAction(db, OffsetRecords.records
-        .filter(r => r.pramenTableName === tableNameEscaped || r.pramenTableName.like(likePattern))
+        .filter(r => r.pramenTableName === tableNameEscaped || r.pramenTableName.like(likePattern, escape))
         .delete
       )
       log.info(s"Deleted $deletedOffsetsCount records from the offsets table.")
 
       val deletedMetadataCount = SlickUtils.executeAction(db, MetadataRecords.records
-        .filter(r => r.pramenTableName === tableNameEscaped || r.pramenTableName.like(likePattern))
+        .filter(r => r.pramenTableName === tableNameEscaped || r.pramenTableName.like(likePattern, escape))
         .delete
       )
       log.info(s"Deleted $deletedMetadataCount records from the metadata table.")

pramen/core/src/test/scala/za/co/absa/pramen/core/mocks/bookkeeper/SyncBookkeeperMock.scala

@@ -164,7 +164,7 @@ class SyncBookkeeperMock(batchId: Long = 123L) extends Bookkeeper {
       tableName.trim.replace(".", "\\.").replace("%", "\\%").replace("*", "\\*")
 
     val likePattern = if (!hasWildcard)
-      tableNameEscaped + "->%"
+      tableNameEscaped + "->*."
     else
       tableNameEscaped