Skip to content

Commit fd24c86

Browse files
author
JoonWon Choi
committed
fix(logging): Fix unexpected behvior of bulkDelete action (#2772)
1 parent e85e3bb commit fd24c86

File tree

1 file changed

+11
-6
lines changed

1 file changed

+11
-6
lines changed

aws-logging-cloudwatch/src/main/java/com/amplifyframework/logging/cloudwatch/db/CloudWatchLoggingDatabase.kt

+11-6
Original file line numberDiff line numberDiff line change
@@ -82,12 +82,17 @@ internal class CloudWatchLoggingDatabase(
8282

8383
internal suspend fun bulkDelete(eventIds: List<Long>) = withContext(coroutineDispatcher) {
8484
contentUri
85-
val whereClause = "${LogEventTable.COLUMN_ID} in (?)"
86-
database.delete(
87-
LogEventTable.TABLE_LOG_EVENT,
88-
whereClause,
89-
arrayOf(eventIds.joinToString(","))
90-
)
85+
if (eventIds.isNotEmpty()) {
86+
val params = List(eventIds.size) { "?" }.joinToString(",")
87+
val whereClause = "${LogEventTable.COLUMN_ID} in ($params)}"
88+
database.delete(
89+
LogEventTable.TABLE_LOG_EVENT,
90+
whereClause,
91+
eventIds.toTypedArray()
92+
)
93+
} else {
94+
95+
}
9196
}
9297

9398
internal fun isCacheFull(cacheSizeInMB: Int): Boolean {

0 commit comments

Comments
 (0)